From faded108701cce17ca45b47d3acb304357fa2eb9 Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Sat, 24 Jan 2015 11:33:16 -0800 Subject: [PATCH] fix(bitswap): handling of network notification --- exchange/bitswap/bitswap.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index 81da2e61b..b698146ba 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -342,6 +342,13 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg // Connected/Disconnected warns bitswap about peer connections func (bs *bitswap) PeerConnected(p peer.ID) { // TODO: add to clientWorker?? + peers := make(chan peer.ID, 1) + peers <- p + close(peers) + err := bs.sendWantlistToPeers(context.TODO(), peers) + if err != nil { + log.Errorf("error sending wantlist: %s", err) + } } // Connected/Disconnected warns bitswap about peer connections