diff --git a/blocksync/reactor.go b/blocksync/reactor.go index 5e3082d12..9bac4229b 100644 --- a/blocksync/reactor.go +++ b/blocksync/reactor.go @@ -239,7 +239,7 @@ func (bcR *Reactor) Receive(e p2p.Envelope) { bcR.Logger.Error("Block content is invalid", "err", err) return } - bcR.pool.AddBlock(e.Src.ID(), bi, 0) // TODO: fix block size calculation + bcR.pool.AddBlock(e.Src.ID(), bi, msg.Block.Size()) case *bcproto.StatusRequest: // Send peer our state. wm, err := wrapMsg(&bcproto.StatusResponse{