rm logging statements and inline `send`
Brian Tiger Chow committed
Jan 18, 2015 at 20:34 UTC
2f247f33557df663b85370c8c742c4f1df6ee2d4
1 file changed
+3
-13
exchange/bitswap/bitswap.go
+3
-13
@@ -168,18 +168,6 @@ func (bs *bitswap) HasBlock(ctx context.Context, blk *blocks.Block) error {
168
return bs.network.Provide(ctx, blk.Key())
169
}
170
171
-func (bs *bitswap) sendWantlistMsgToPeer(ctx context.Context, m bsmsg.BitSwapMessage, p peer.ID) error {
172
- log := log.Prefix("bitswap(%s).bitswap.sendWantlistMsgToPeer(%d, %s)", bs.self, len(m.Wantlist()), p)
173
-
174
- log.Debug("sending wantlist")
175
- if err := bs.send(ctx, p, m); err != nil {
176
- log.Errorf("send wantlist error: %s", err)
177
- return err
178
- }
179
- log.Debugf("send wantlist success")
180
- return nil
181
-}
182
-
171
func (bs *bitswap) sendWantlistMsgToPeers(ctx context.Context, m bsmsg.BitSwapMessage, peers <-chan peer.ID) error {
172
if peers == nil {
173
panic("Cant send wantlist to nil peerchan")
@@ -203,7 +191,9 @@ func (bs *bitswap) sendWantlistMsgToPeers(ctx context.Context, m bsmsg.BitSwapMe
191
wg.Add(1)
192
go func(p peer.ID) {
193
defer wg.Done()
206
- bs.sendWantlistMsgToPeer(ctx, m, p)
194
+ if err := bs.send(ctx, p, m); err != nil {
195
+ log.Error(err) // TODO remove if too verbose
196
+ }
197
}(peerToQuery)
198
}
199
wg.Wait()