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

swarm/network: Add missing RetrieveRequestMsg in spec in and handler

Browse source
This commit is contained in:
Balint Gabor 2018-01-12 20:10:38 +01:00
parent bab67a45be
commit 2f703edd12
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

@ -643,6 +643,7 @@ var StreamerSpec = &protocols.Spec{
WantedHashesMsg{}, WantedHashesMsg{},
TakeoverProofMsg{}, TakeoverProofMsg{},
SubscribeMsg{}, SubscribeMsg{},
RetrieveRequestMsg{},
}, },
} }
@ -685,6 +686,9 @@ func (self *StreamerPeer) HandleMsg(msg interface{}) error {
case *ChunkDeliveryMsg: case *ChunkDeliveryMsg:
return self.handleChunkDeliveryMsg(msg) return self.handleChunkDeliveryMsg(msg)
case *RetrieveRequestMsg:
return self.handleRetrieveRequestMsg(msg)
default: default:
return fmt.Errorf("unknown message type: %T", msg) return fmt.Errorf("unknown message type: %T", msg)
} }