fix(bitswap): handling of network notification

044f3b38 · Brian Tiger Chow · 0c9f60a7 · 044f3b38
Commit 044f3b38 authored Jan 24, 2015 by Brian Tiger Chow
Hide whitespace changes
Inline Side-by-side

Showing with 7 additions and 0 deletions

bitswap.go bitswap.go +7 -0

No files found.
--- a/bitswap.go
+++ b/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