From 351631a580059653f74faaf91cd8b56d65bc7416 Mon Sep 17 00:00:00 2001 From: Brian Tiger Chow Date: Tue, 20 Jan 2015 02:43:01 -0800 Subject: [PATCH] pass as param --- exchange/bitswap/bitswap.go | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/exchange/bitswap/bitswap.go b/exchange/bitswap/bitswap.go index 7387a98bd..10b7befd8 100644 --- a/exchange/bitswap/bitswap.go +++ b/exchange/bitswap/bitswap.go @@ -199,12 +199,7 @@ func (bs *bitswap) sendWantlistToPeers(ctx context.Context, peers <-chan peer.ID return bs.sendWantlistMsgToPeers(ctx, message, peers) } -func (bs *bitswap) sendWantlistToProviders(ctx context.Context) { - entries := bs.wantlist.Entries() - if len(entries) == 0 { - log.Debug("No entries in wantlist, skipping send routine.") - return - } +func (bs *bitswap) sendWantlistToProviders(ctx context.Context, entries []wantlist.Entry) { ctx, cancel := context.WithCancel(ctx) defer cancel() @@ -268,7 +263,10 @@ func (bs *bitswap) clientWorker(parent context.Context) { for { select { case <-broadcastSignal: // resend unfulfilled wantlist keys - bs.sendWantlistToProviders(ctx) + entries := bs.wantlist.Entries() + if len(entries) > 0 { + bs.sendWantlistToProviders(ctx, entries) + } broadcastSignal = time.After(rebroadcastDelay.Get()) case keys := <-bs.batchRequests: if len(keys) == 0 {