From c9e13e2def71c481837e8476a6c15f8f42a88268 Mon Sep 17 00:00:00 2001 From: Tuna Date: Wed, 26 Sep 2018 11:05:34 +0700 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 8c6beb8c65..94c2525e2d 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -52,8 +52,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 @@ -477,7 +477,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 { @@ -487,9 +487,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 } }