fix(bitswap) always use prvivate `send` method to send
cc @whyrusleeping
Brian Tiger Chow committed
Dec 23, 2014 at 06:59 UTC
fb75184c359fa7995f990ba027174f9ad70b1311
1 file changed
+2
-15
exchange/bitswap/bitswap.go
+2
-15
@@ -182,23 +182,10 @@ func (bs *bitswap) sendWantListTo(ctx context.Context, peers <-chan peer.PeerInf
182
wg.Add(1)
183
go func(p peer.ID) {
184
defer wg.Done()
185
-
186
- log.Event(ctx, "DialPeer", p)
187
- err := bs.sender.DialPeer(ctx, p)
188
- if err != nil {
189
- log.Errorf("Error sender.DialPeer(%s): %s", p, err)
190
- return
191
- }
192
-
193
- err = bs.sender.SendMessage(ctx, p, message)
194
- if err != nil {
195
- log.Errorf("Error sender.SendMessage(%s) = %s", p, err)
185
+ if err := bs.send(ctx, p, message); err != nil {
186
+ log.Error(err)
187
return
188
}
198
- // FIXME ensure accounting is handled correctly when
199
- // communication fails. May require slightly different API to
200
- // get better guarantees. May need shared sequence numbers.
201
- bs.engine.MessageSent(p, message)
189
}(peerToQuery.ID)
190
}
191
wg.Wait()