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: Store stream in outgoingStreamer

Browse source
This commit is contained in:
Balint Gabor 2018-01-12 20:24:45 +01:00
parent 791cac2403
commit dc134e0219
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
swarm/network/streamer.go
View file

@ -203,6 +203,7 @@ type outgoingStreamer struct {
OutgoingStreamer OutgoingStreamer
priority uint8 priority uint8
currentBatch []byte currentBatch []byte
stream string
} }
// OutgoingStreamer interface for outgoing peer Streamer // OutgoingStreamer interface for outgoing peer Streamer
@ -640,6 +641,9 @@ func (self *StreamerPeer) SendOfferedHashes(s *outgoingStreamer, f, t uint64) er
Hashes: hashes, Hashes: hashes,
From: from, From: from,
To: to, To: to,
Stream: s.stream,
// TODO: use real key here
Key: []byte{},
} }
return self.SendPriority(msg, s.priority) return self.SendPriority(msg, s.priority)
} }