Optimize status message process (#66)

[bytom/vapor.git] / netsync / block_fetcher.go

diff --git a/netsync/block_fetcher.go b/netsync/block_fetcher.go
index e7fe585..c48cd0b 100644 (file)
--- a/netsync/block_fetcher.go
+++ b/netsync/block_fetcher.go
@@ -92,6 +92,11 @@ func (f *blockFetcher) insert(msg *blockMsg) {
                log.WithFields(log.Fields{"module": logModule, "err": err}).Error("blockFetcher fail on broadcast new block")
                return
        }
+
+       if err := f.peers.broadcastNewStatus(msg.block); err != nil {
+               log.WithFields(log.Fields{"module": logModule, "err": err}).Error("blockFetcher fail on broadcast new status")
+               return
+       }
 }
 
 func (f *blockFetcher) processNewBlock(msg *blockMsg) {