forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 09:53:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/network: Wait in processDeliveries until hash is ready

Browse source
This commit is contained in:
Balint Gabor 2018-01-12 20:04:37 +01:00
parent 2efb994c19
commit 1c7805bde4
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
swarm/network/requests.go
View file

@ -72,11 +72,13 @@ func NewRetrieveRequestStreamer(db *DbAccess) *RetrieveRequestStreamer {
// processDeliveries handles delivered chunk hashes // processDeliveries handles delivered chunk hashes
func (s *RetrieveRequestStreamer) processDeliveries() { func (s *RetrieveRequestStreamer) processDeliveries() {
var hashes []byte var hashes []byte
var batchC chan []byte
for { for {
select { select {
case delivery := <-s.deliveryC: case delivery := <-s.deliveryC:
hashes = append(hashes, delivery.Key[:]...) hashes = append(hashes, delivery.Key[:]...)
case s.batchC <- hashes: batchC = s.batchC
case batchC <- hashes:
hashes = nil hashes = nil
} }
} }