From d0d220f9de6c990fecebbe4e4575074020208085 Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Tue, 23 Dec 2014 06:57:13 -0500 Subject: [PATCH] fix(bitswap) always dial --- exchange/bitswap/bitswap.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index 0dcbc0649..8d75e10b7 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -19,9 +19,10 @@ import ( wantlist "github.com/jbenet/go-ipfs/exchange/bitswap/wantlist" peer "github.com/jbenet/go-ipfs/peer" u "github.com/jbenet/go-ipfs/util" + errors "github.com/jbenet/go-ipfs/util/debugerror" "github.com/jbenet/go-ipfs/util/delay" 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") @@ -352,8 +353,13 @@ func (bs *bitswap) ReceiveError(err error) { // send strives to ensure that accounting is always performed when a message is // sent 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 { - return err + return errors.Wrap(err) } return bs.engine.MessageSent(p, m) }