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

swarm/network: Fix comments

Browse source
This commit is contained in:
Balint Gabor 2018-01-12 20:15:00 +01:00
parent 646d46614c
commit b2f0655c57
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
swarm/network/streamer.go
View file

@ -415,7 +415,7 @@ func (self *StreamerPeer) setIncomingStreamer(s string, i IncomingStreamer, prio
priority: priority, priority: priority,
next: next, next: next,
} }
next <- struct{}{} // this is to allow wantedHashesMsg before first batch arrives next <- struct{}{} // this is to allow wantedKeysMsg before first batch arrives
return nil return nil
} }
@ -534,7 +534,7 @@ func (self *StreamerPeer) handleOfferedHashesMsg(req *OfferedHashesMsg) error {
} }
s.next <- struct{}{} s.next <- struct{}{}
}() }()
// only send wantedHashesMsg if all missing chunks of the previous batch arrived // only send wantedKeysMsg if all missing chunks of the previous batch arrived
// except // except
if s.live { if s.live {
s.sessionAt = req.From s.sessionAt = req.From