Commit 0c9f60a7 authored by Brian Tiger Chow's avatar Brian Tiger Chow

revert bitswap network notification

@jbenet @whyrusleeping
parent a6794230
...@@ -342,14 +342,6 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg ...@@ -342,14 +342,6 @@ func (bs *bitswap) ReceiveMessage(ctx context.Context, p peer.ID, incoming bsmsg
// Connected/Disconnected warns bitswap about peer connections // Connected/Disconnected warns bitswap about peer connections
func (bs *bitswap) PeerConnected(p peer.ID) { func (bs *bitswap) PeerConnected(p peer.ID) {
// TODO: add to clientWorker?? // TODO: add to clientWorker??
peers := make(chan peer.ID)
err := bs.sendWantlistToPeers(context.TODO(), peers)
if err != nil {
log.Errorf("error sending wantlist: %s", err)
}
peers <- p
close(peers)
} }
// Connected/Disconnected warns bitswap about peer connections // Connected/Disconnected warns bitswap about peer connections
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment