opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-01 10:49:24 +08:00
Code Issues Projects Releases Wiki Activity

fix(bitswap) always dial

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-12-23 06:57:13 -05:00
committed by Juan Batiz-Benet
parent 55c8f8f505
commit d0d220f9de
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
exchange/bitswap/bitswap.go
View File

@ -19,9 +19,10 @@ import (
wantlist "github.com/jbenet/go-ipfs/exchange/bitswap/wantlist" wantlist "github.com/jbenet/go-ipfs/exchange/bitswap/wantlist"
peer "github.com/jbenet/go-ipfs/peer" peer "github.com/jbenet/go-ipfs/peer"
u "github.com/jbenet/go-ipfs/util" u "github.com/jbenet/go-ipfs/util"
errors "github.com/jbenet/go-ipfs/util/debugerror"
"github.com/jbenet/go-ipfs/util/delay" "github.com/jbenet/go-ipfs/util/delay"
eventlog "github.com/jbenet/go-ipfs/util/eventlog" eventlog "github.com/jbenet/go-ipfs/util/eventlog"
pset "github.com/jbenet/go-ipfs/util/peerset" pset "github.com/jbenet/go-ipfs/util/peerset" // TODO move this to peerstore
) )
var log = eventlog.Logger("bitswap") var log = eventlog.Logger("bitswap")
@ -352,8 +353,13 @@ func (bs *bitswap) ReceiveError(err error) {
// send strives to ensure that accounting is always performed when a message is // send strives to ensure that accounting is always performed when a message is
// sent // sent
func (bs *bitswap) send(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) error { func (bs *bitswap) send(ctx context.Context, p peer.ID, m bsmsg.BitSwapMessage) error {
log.Event(ctx, "DialPeer", p)
err := bs.sender.DialPeer(ctx, p)
if err != nil {
return errors.Wrap(err)
}
if err := bs.sender.SendMessage(ctx, p, m); err != nil { if err := bs.sender.SendMessage(ctx, p, m); err != nil {
return err return errors.Wrap(err)
} }
return bs.engine.MessageSent(p, m) return bs.engine.MessageSent(p, m)
} }