forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-18 10:50:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

network/stream: remove cast for msg type (#1449)

Browse source
This commit is contained in:
Anton Evangelatov 2019-06-12 08:55:15 +02:00 committed by acud
parent de220b8323
commit e865445f17
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
network/stream/stream.go
View file

@ -423,7 +423,7 @@ func (p *Peer) HandleMsg(ctx context.Context, msg interface{}) error {
case *ChunkDeliveryMsgRetrieval: case *ChunkDeliveryMsgRetrieval:
// handling chunk delivery is the same for retrieval and syncing, so let's cast the msg // handling chunk delivery is the same for retrieval and syncing, so let's cast the msg
go func() { go func() {
err := p.streamer.delivery.handleChunkDeliveryMsg(ctx, p, ((*ChunkDeliveryMsg)(msg))) err := p.streamer.delivery.handleChunkDeliveryMsg(ctx, p, msg)
if err != nil { if err != nil {
log.Error(err.Error()) log.Error(err.Error())
p.Drop() p.Drop()
@ -434,7 +434,7 @@ func (p *Peer) HandleMsg(ctx context.Context, msg interface{}) error {
case *ChunkDeliveryMsgSyncing: case *ChunkDeliveryMsgSyncing:
// handling chunk delivery is the same for retrieval and syncing, so let's cast the msg // handling chunk delivery is the same for retrieval and syncing, so let's cast the msg
go func() { go func() {
err := p.streamer.delivery.handleChunkDeliveryMsg(ctx, p, ((*ChunkDeliveryMsg)(msg))) err := p.streamer.delivery.handleChunkDeliveryMsg(ctx, p, msg)
if err != nil { if err != nil {
log.Error(err.Error()) log.Error(err.Error())
p.Drop() p.Drop()