Add logs to the routing system
Signed-off-by: Antonio Navarro Perez <antnavper@gmail.com>
Antonio Navarro Perez committed
Dec 1, 2022 at 16:15 UTC
a3913d9f909edf5c1611130e445a6facc2c0624f
1 file changed
+56
-9
routing/composer.go
+56
-9
@@ -23,52 +23,99 @@ type Composer struct {
23
}
24
25
func (c *Composer) Provide(ctx context.Context, cid cid.Cid, provide bool) error {
26
- return c.ProvideRouter.Provide(ctx, cid, provide)
26
+ log.Debug("composer: calling provide: ", cid)
27
+ err := c.ProvideRouter.Provide(ctx, cid, provide)
28
+ if err != nil {
29
+ log.Debug("composer: calling provide: ", cid, " error: ", err)
30
+
31
+ }
32
+
33
+ return err
34
}
35
36
func (c *Composer) ProvideMany(ctx context.Context, keys []multihash.Multihash) error {
37
+ log.Debug("composer: calling provide many: ", len(keys))
38
pmr, ok := c.ProvideRouter.(routinghelpers.ProvideManyRouter)
39
if !ok {
40
+ log.Debug("composer: provide many is not implemented on the actual router")
41
return nil
42
}
43
35
- return pmr.ProvideMany(ctx, keys)
44
+ err := pmr.ProvideMany(ctx, keys)
45
+ if err != nil {
46
+ log.Debug("composer: calling provide many error: ", err)
47
+ }
48
+
49
+ return err
50
}
51
52
func (c *Composer) Ready() bool {
53
+ log.Debug("composer: calling ready")
54
pmr, ok := c.ProvideRouter.(routinghelpers.ProvideManyRouter)
55
if !ok {
41
- return false
56
+ return true
57
}
58
44
- return pmr.Ready()
59
+ ready := pmr.Ready()
60
+
61
+ log.Debug("composer: calling ready result: ", ready)
62
+
63
+ return ready
64
}
65
66
func (c *Composer) FindProvidersAsync(ctx context.Context, cid cid.Cid, count int) <-chan peer.AddrInfo {
67
+ log.Debug("composer: calling findProvidersAsync: ", cid)
68
return c.FindProvidersRouter.FindProvidersAsync(ctx, cid, count)
69
}
70
71
func (c *Composer) FindPeer(ctx context.Context, pid peer.ID) (peer.AddrInfo, error) {
52
- return c.FindPeersRouter.FindPeer(ctx, pid)
72
+ log.Debug("composer: calling findPeer: ", pid)
73
+ addr, err := c.FindPeersRouter.FindPeer(ctx, pid)
74
+ if err != nil {
75
+ log.Debug("composer: calling findPeer error: ", pid, addr.String(), err)
76
+ }
77
+ return addr, err
78
}
79
80
func (c *Composer) PutValue(ctx context.Context, key string, val []byte, opts ...routing.Option) error {
56
- return c.PutValueRouter.PutValue(ctx, key, val, opts...)
81
+ log.Debug("composer: calling putValue: ", key, len(val))
82
+ err := c.PutValueRouter.PutValue(ctx, key, val, opts...)
83
+ if err != nil {
84
+ log.Debug("composer: calling putValue error: ", key, len(val), err)
85
+ }
86
+
87
+ return err
88
}
89
90
func (c *Composer) GetValue(ctx context.Context, key string, opts ...routing.Option) ([]byte, error) {
60
- return c.GetValueRouter.GetValue(ctx, key, opts...)
91
+ log.Debug("composer: calling getValue: ", key)
92
+ val, err := c.GetValueRouter.GetValue(ctx, key, opts...)
93
+ if err != nil {
94
+ log.Debug("composer: calling getValue error: ", key, len(val), err)
95
+ }
96
+
97
+ return val, err
98
}
99
100
func (c *Composer) SearchValue(ctx context.Context, key string, opts ...routing.Option) (<-chan []byte, error) {
64
- return c.GetValueRouter.SearchValue(ctx, key, opts...)
101
+ log.Debug("composer: calling searchValue: ", key)
102
+ ch, err := c.GetValueRouter.SearchValue(ctx, key, opts...)
103
+ if err != nil {
104
+ log.Debug("composer: calling searchValue error: ", key, err)
105
+ }
106
+ return ch, err
107
}
108
109
func (c *Composer) Bootstrap(ctx context.Context) error {
110
+ log.Debug("composer: calling bootstrap")
111
errfp := c.FindPeersRouter.Bootstrap(ctx)
112
errfps := c.FindProvidersRouter.Bootstrap(ctx)
113
errgv := c.GetValueRouter.Bootstrap(ctx)
114
errpv := c.PutValueRouter.Bootstrap(ctx)
115
errp := c.ProvideRouter.Bootstrap(ctx)
73
- return multierror.Append(errfp, errfps, errgv, errpv, errp)
116
+ err := multierror.Append(errfp, errfps, errgv, errpv, errp)
117
+ if err != nil {
118
+ log.Debug("composer: calling bootstrap error: ", err)
119
+ }
120
+ return err
121
}