Optimize status message process (#66)

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

diff --git a/netsync/block_keeper.go b/netsync/block_keeper.go
index 62a4025..9b61081 100644 (file)
--- a/netsync/block_keeper.go
+++ b/netsync/block_keeper.go
@@ -379,11 +379,6 @@ func (bk *blockKeeper) startSync() bool {
 }
 
 func (bk *blockKeeper) syncWorker() {
-       genesisBlock, err := bk.chain.GetBlockByHeight(0)
-       if err != nil {
-               log.WithFields(log.Fields{"module": logModule, "err": err}).Error("fail on handleStatusRequestMsg get genesis")
-               return
-       }
        syncTicker := time.NewTicker(syncCycle)
        defer syncTicker.Stop()
 
@@ -398,11 +393,7 @@ func (bk *blockKeeper) syncWorker() {
                        log.WithFields(log.Fields{"module": logModule, "err": err}).Error("fail on syncWorker get best block")
                }
 
-               if err := bk.peers.broadcastMinedBlock(block); err != nil {
-                       log.WithFields(log.Fields{"module": logModule, "err": err}).Error("fail on syncWorker broadcast new block")
-               }
-
-               if err = bk.peers.broadcastNewStatus(block, genesisBlock); err != nil {
+               if err = bk.peers.broadcastNewStatus(block); err != nil {
                        log.WithFields(log.Fields{"module": logModule, "err": err}).Error("fail on syncWorker broadcast new status")
                }
        }