minor fix for chainHeadCh

This commit is contained in:
MestryOmkar 2018-11-05 14:47:35 +05:30
parent dd0f27ebeb
commit c9ad5cedb2

View file

@ -481,9 +481,9 @@ func (self *worker) commitNewWork() {
L: L:
select { select {
case newBlock := <-self.chainHeadCh: case newBlock := <-self.chainHeadCh:
self.chainHeadCh <- newBlock
if newBlock.Block.NumberU64() > parent.NumberU64() { if newBlock.Block.NumberU64() > parent.NumberU64() {
log.Info("New block has came already. Skip this turn", "new block", newBlock.Block.NumberU64(), "current block", parent.NumberU64()) log.Info("New block has came already. Skip this turn", "new block", newBlock.Block.NumberU64(), "current block", parent.NumberU64())
self.chainHeadCh <- newBlock
return return
} }
case <-time.After(time.Duration(gap) * time.Second): case <-time.After(time.Duration(gap) * time.Second):