remove pre commit

dotbitHQ · Oct 19, 2021 · 029e725 · 029e725
1 parent 7fe9dab
commit 029e725
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 15 deletions.
diff --git a/bin/mac/rpc_server b/bin/mac/rpc_server
diff --git a/cmd/main.go b/cmd/main.go
@@ -143,14 +143,12 @@ func runServer(ctx *cli.Context) error {
 			}
 		}
 		log.Info("rpc server need to wait for block info finish sync, stopping ...")
-		ticker := time.NewTicker(time.Second)
-		defer ticker.Stop()
 		go func() {
 			for {
 				select {
 				case <-rpcWait:
 					return
-				case <-ticker.C:
+				default:
 					if txParser.BlockSyncFinish() {
 						if rpcWait != nil {
 							close(rpcWait)
@@ -161,6 +159,7 @@ func runServer(ctx *cli.Context) error {
 						}
 					}
 				}
+				time.Sleep(time.Second)
 			}
 		}()
 	} else {

diff --git a/parser/parser.go b/parser/parser.go
@@ -74,20 +74,16 @@ func (p *TxParser) BlockSyncFinish() bool {
 }
 
 func (p *TxParser) getChainLatestBlockNumber(blockFontNumber uint64) {
-	ticker := time.NewTicker(time.Second)
-	defer ticker.Stop()
 	for {
-		select {
-		case <-ticker.C:
-			if p.context != nil && p.context.Err() != nil {
-				return
-			}
-			if blockNumber, err := p.rpcClient.GetTipBlockNumber(context.TODO()); err != nil {
-				log.Error(fmt.Sprintf("getChainLatestBlockNumber err: %s", err.Error()))
-			} else {
-				p.latestBlockNumber = blockNumber - blockFontNumber
-			}
+		if p.context != nil && p.context.Err() != nil {
+			return
+		}
+		if blockNumber, err := p.rpcClient.GetTipBlockNumber(context.TODO()); err != nil {
+			log.Error(fmt.Sprintf("getChainLatestBlockNumber err: %s", err.Error()))
+		} else {
+			p.latestBlockNumber = blockNumber - blockFontNumber
 		}
+		time.Sleep(time.Second)
 	}
 }