Skip to content

Commit 8616367

Browse files
committed
last number store in exception
1 parent d7cb215 commit 8616367

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

monitor.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -801,7 +801,7 @@ func (m *Monitor) syncLastBlock() uint64 {
801801
for _, rpcBlock := range blocks {
802802
//if err := m.solve(rpcBlock); err != nil {
803803
if err := m.taskQueue(rpcBlock); err != nil {
804-
//m.lastNumber.Store(i - m.scope)
804+
m.lastNumber.Store(i - 1)
805805
log.Error("solve err", "err", err, "last", m.lastNumber.Load())
806806
return 0
807807
}
@@ -812,10 +812,12 @@ func (m *Monitor) syncLastBlock() uint64 {
812812
select {
813813
case err := <-m.errCh:
814814
if err != nil {
815+
m.lastNumber.Store(i - 1)
815816
log.Error("solve err", "err", err, "last", m.lastNumber.Load(), "i", i, "scope", m.scope, "min", minNumber, "max", maxNumber, "cur", currentNumber)
816817
return 0
817818
}
818819
case <-m.exitCh:
820+
m.lastNumber.Store(i - 1)
819821
log.Info("Task checker quit")
820822
return 0
821823
}

0 commit comments

Comments
 (0)