cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

break error

Browse Source
This commit is contained in:
zgfzgf 2020-09-22 15:21:35 +08:00
parent 46ed0142db
commit 001ba17d37
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
miner/miner.go
View File

@ -151,6 +151,7 @@ func (m *Miner) mine(ctx context.Context) {
var lastBase MiningBase var lastBase MiningBase
for { for {
minerStop:
select { select {
case <-m.stop: case <-m.stop:
stopping := m.stopping stopping := m.stopping
@ -171,7 +172,7 @@ func (m *Miner) mine(ctx context.Context) {
if err != nil { if err != nil {
log.Errorf("failed to get best mining candidate: %s", err) log.Errorf("failed to get best mining candidate: %s", err)
if !m.niceSleep(time.Second * 5) { if !m.niceSleep(time.Second * 5) {
break goto minerStop
} }
continue continue
} }
@ -203,7 +204,7 @@ func (m *Miner) mine(ctx context.Context) {
if err != nil { if err != nil {
log.Errorf("failed getting beacon entry: %s", err) log.Errorf("failed getting beacon entry: %s", err)
if !m.niceSleep(time.Second) { if !m.niceSleep(time.Second) {
break goto minerStop
} }
continue continue
} }
@ -214,7 +215,7 @@ func (m *Miner) mine(ctx context.Context) {
if base.TipSet.Equals(lastBase.TipSet) && lastBase.NullRounds == base.NullRounds { if base.TipSet.Equals(lastBase.TipSet) && lastBase.NullRounds == base.NullRounds {
log.Warnf("BestMiningCandidate from the previous round: %s (nulls:%d)", lastBase.TipSet.Cids(), lastBase.NullRounds) log.Warnf("BestMiningCandidate from the previous round: %s (nulls:%d)", lastBase.TipSet.Cids(), lastBase.NullRounds)
if !m.niceSleep(time.Duration(build.BlockDelaySecs) * time.Second) { if !m.niceSleep(time.Duration(build.BlockDelaySecs) * time.Second) {
break goto minerStop
} }
continue continue
} }
@ -225,7 +226,7 @@ func (m *Miner) mine(ctx context.Context) {
if err != nil { if err != nil {
log.Errorf("mining block failed: %+v", err) log.Errorf("mining block failed: %+v", err)
if !m.niceSleep(time.Second) { if !m.niceSleep(time.Second) {
break goto minerStop
} }
onDone(false, 0, err) onDone(false, 0, err)
continue continue