tiny fix

Author: ucwong

monitor.go

@@ -799,13 +799,7 @@ func (m *Monitor) syncLastBlock() uint64 {
 
 			// batch blocks operation according service category
 			for _, rpcBlock := range blocks {
-				//if err := m.solve(rpcBlock); err != nil {
-				if err := m.taskQueue(rpcBlock); err != nil {
-					m.lastNumber.Store(i - 1)
-					log.Error("solve err", "err", err, "last", m.lastNumber.Load())
-					return 0
-				}
-				//i++
+				m.taskCh <- rpcBlock
 			}
 
 			for n := 0; n < len(blocks); n++ {
@@ -835,7 +829,6 @@ func (m *Monitor) syncLastBlock() uint64 {
 				m.lastNumber.Store(i - 1)
 				return 0
 			}
-			//m.taskQueue(rpcBlock)
 			i++
 		}
 	}
@@ -848,16 +841,6 @@ func (m *Monitor) syncLastBlock() uint64 {
 	return uint64(maxNumber - minNumber)
 }
 
-func (m *Monitor) taskQueue(task *types.Block) error {
-	select {
-	case m.taskCh <- task:
-	case <-m.exitCh:
-		return nil
-	}
-
-	return nil
-}
-
 // solve block from node
 func (m *Monitor) solve(block *types.Block) error {
 	switch m.srv.Load() {