From 1c7805bde450bb32579b0bdd67f54a7af91b988e Mon Sep 17 00:00:00 2001 From: Balint Gabor Date: Fri, 12 Jan 2018 20:04:37 +0100 Subject: [PATCH] swarm/network: Wait in processDeliveries until hash is ready --- swarm/network/requests.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/swarm/network/requests.go b/swarm/network/requests.go index bea5ff09de..ce68afd35d 100644 --- a/swarm/network/requests.go +++ b/swarm/network/requests.go @@ -72,11 +72,13 @@ func NewRetrieveRequestStreamer(db *DbAccess) *RetrieveRequestStreamer { // processDeliveries handles delivered chunk hashes func (s *RetrieveRequestStreamer) processDeliveries() { var hashes []byte + var batchC chan []byte for { select { case delivery := <-s.deliveryC: hashes = append(hashes, delivery.Key[:]...) - case s.batchC <- hashes: + batchC = s.batchC + case batchC <- hashes: hashes = nil } }