From a8c2a15886311d621bf90abddd1072653fe7e7a0 Mon Sep 17 00:00:00 2001 From: AnilChinchawale Date: Mon, 5 Nov 2018 17:29:35 +0530 Subject: [PATCH] adjust timeout for m1 --- miner/worker.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/miner/worker.go b/miner/worker.go index 1ec9b9c7e7..dc375b524d 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -51,8 +51,8 @@ const ( chainHeadChanSize = 10 // chainSideChanSize is the size of channel listening to ChainSideEvent. chainSideChanSize = 10 - // Timeout waiting for M1 - m1Timeout = 10 + // timeout waiting for M1 + waitPeriod = 10 ) // Agent can register themself with the worker @@ -476,7 +476,7 @@ func (self *worker) commitNewWork() { return } h := hop(len(masternodes), preIndex, curIndex) - gap := int64(c.GetPeriod()) * int64(h) + gap := waitPeriod * int64(h) log.Info("Distance from the parent block", "seconds", gap, "hops", h) L: select { @@ -486,9 +486,9 @@ func (self *worker) commitNewWork() { self.chainHeadCh <- newBlock return } - case <-time.After(time.Duration(gap+m1Timeout) * time.Second): + case <-time.After(time.Duration(gap) * time.Second): // wait enough. It's my turn - log.Info("Wait enough. It's my turn", "waited seconds", gap+m1Timeout) + log.Info("Wait enough. It's my turn", "waited seconds", gap) break L } }