forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-19 18:32:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

adjust timeout for m1

Browse source
This commit is contained in:
Tuna 2018-09-26 11:05:34 +07:00
parent ce1f6d589e
commit c9e13e2def
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
miner/worker.go
View file

@ -52,8 +52,8 @@ const (
chainHeadChanSize = 10 chainHeadChanSize = 10
// chainSideChanSize is the size of channel listening to ChainSideEvent. // chainSideChanSize is the size of channel listening to ChainSideEvent.
chainSideChanSize = 10 chainSideChanSize = 10
// Timeout waiting for M1 // timeout waiting for M1
m1Timeout = 10 waitPeriod = 10
) )
// Agent can register themself with the worker // Agent can register themself with the worker
@ -477,7 +477,7 @@ func (self *worker) commitNewWork() {
return return
} }
h := hop(len(masternodes), preIndex, curIndex) 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) log.Info("Distance from the parent block", "seconds", gap, "hops", h)
L: L:
select { select {
@ -487,9 +487,9 @@ func (self *worker) commitNewWork() {
self.chainHeadCh <- newBlock self.chainHeadCh <- newBlock
return return
} }
case <-time.After(time.Duration(gap+m1Timeout) * time.Second): case <-time.After(time.Duration(gap) * time.Second):
// wait enough. It's my turn // 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 break L
} }
} }