fix(chain): add ticker stop method

stop the ticker to release associated resources.

Author: ksco

blockchain/blocksyn.go

@@ -131,14 +131,15 @@ func (chain *BlockChain) OnChainTimeout(height int64) bool {
 func (chain *BlockChain) SynRoutine() {
 	//获取peerlist的定时器，默认1分钟
 	fetchPeerListTicker := time.NewTicker(time.Duration(fetchPeerListSeconds) * time.Second)
+	defer fetchPeerListTicker.Stop()
 
 	//向peer请求同步block的定时器，默认2s
 	blockSynTicker := time.NewTicker(chain.blockSynInterVal * time.Second)
-
+	defer blockSynTicker.Stop()
 	//5分钟检测一次bestchain主链高度是否有增长，如果没有增长可能是目前主链在侧链上，
 	//需要从最高peer向后同步指定的headers用来获取分叉点，再后从指定peer获取分叉点以后的blocks
 	checkHeightNoIncreaseTicker := time.NewTicker(time.Duration(checkHeightNoIncSeconds) * time.Second)
-
+	defer checkHeightNoIncreaseTicker.Stop()
 	//目前暂定1分钟检测一次本bestchain的tiphash和最高peer的对应高度的blockshash是否一致。
 	//如果不一致可能两个节点在各自的链上挖矿，需要从peer的对应高度向后获取指定数量的headers寻找分叉点
 	//考虑叉后的第一个block没有广播到本节点，导致接下来广播过来的blocks都是孤儿节点，无法进行主侧链总难度对比
@@ -152,13 +153,13 @@ func (chain *BlockChain) SynRoutine() {
 	}
 	//3分钟尝试检测一次故障peer是否已经恢复
 	recoveryFaultPeerTicker := time.NewTicker(180 * time.Second)
-
+	defer recoveryFaultPeerTicker.Stop()
 	//2分钟尝试检测一次最优链，确保本节点在最优链
 	checkBestChainTicker := time.NewTicker(120 * time.Second)
-
+	defer checkBestChainTicker.Stop()
 	//30s尝试从peer节点请求ChunkRecord
 	chunkRecordSynTicker := time.NewTicker(30 * time.Second)
-
+	defer chunkRecordSynTicker.Stop()
 	//节点下载模式
 	go chain.DownLoadBlocks()
 

blockchain/chain.go

@@ -582,6 +582,7 @@ func (chain *BlockChain) InitIndexAndBestView() {
 func (chain *BlockChain) UpdateRoutine() {
 	//1秒尝试检测一次futureblock，futureblock的time小于当前系统时间就广播此block
 	futureblockTicker := time.NewTicker(1 * time.Second)
+	defer futureblockTicker.Stop()
 
 	for {
 		select {

blockchain/chunkshard.go

@@ -35,6 +35,8 @@ func (chain *BlockChain) chunkDeleteRoutine() {
 	defer chain.tickerwg.Done()
 	// 60s检测一次是否可以删除本地的body数据
 	checkDelTicker := time.NewTicker(time.Minute)
+	defer checkDelTicker.Stop()
+
 	for {
 		select {
 		case <-chain.quit:
@@ -49,6 +51,8 @@ func (chain *BlockChain) chunkGenerateRoutine() {
 	defer chain.tickerwg.Done()
 	// 10s检测一次是否可以触发归档操作
 	checkGenChunkTicker := time.NewTicker(10 * time.Second)
+	defer checkGenChunkTicker.Stop()
+
 	for {
 		select {
 		case <-chain.quit:

blockchain/reduce.go

@@ -160,6 +160,8 @@ func (chain *BlockChain) ReduceLocalDB() {
 	}
 	// 10s检测一次是否可以进行reduce localdb
 	checkTicker := time.NewTicker(10 * time.Second)
+	defer checkTicker.Stop()
+
 	for {
 		select {
 		case <-chain.quit:

cmd/miner_accounts/accounts/block.go

@@ -144,6 +144,8 @@ func SyncBlock(host string) {
 	syncHeaders(host)
 
 	timeout := time.NewTicker(time.Minute)
+	defer timeout.Stop()
+
 	for {
 		<-timeout.C
 		syncHeaders(host)

system/p2p/dht/manage/connectionGater.go

@@ -194,6 +194,8 @@ func (tc *TimeCache) Add(s string, lifetime time.Duration) {
 
 func (tc *TimeCache) sweep() {
 	ticker := time.NewTicker(time.Second)
+	defer ticker.Stop()
+
 	for {
 		select {
 		case <-ticker.C:

system/p2p/dht/manage/conns.go

@@ -101,7 +101,10 @@ func (s *ConnManager) BandTrackerByProtocol() *types.NetProtocolInfos {
 // MonitorAllPeers monitory all peers
 func (s *ConnManager) MonitorAllPeers() {
 	ticker1 := time.NewTicker(time.Minute)
+	defer ticker1.Stop()
 	ticker2 := time.NewTicker(time.Minute * 2)
+	defer ticker2.Stop()
+
 	for {
 		select {
 		case <-s.ctx.Done():

system/p2p/dht/protocol/p2pstore/p2pstore.go

@@ -109,8 +109,11 @@ func InitProtocol(env *protocol.P2PEnv) {
 	go p.syncRoutine()
 	go func() {
 		ticker1 := time.NewTicker(time.Minute)
+		defer ticker1.Stop()
 		ticker2 := time.NewTicker(types2.RefreshInterval)
+		defer ticker2.Stop()
 		ticker4 := time.NewTicker(time.Hour)
+		defer ticker4.Stop()
 
 		for {
 			select {
@@ -246,6 +249,8 @@ func (p *Protocol) updateShardHealthyRoutingTableRoutine() {
 		time.Sleep(time.Second)
 	}
 	ticker := time.NewTicker(time.Minute * 5)
+	defer ticker.Stop()
+
 	for {
 		select {
 		case <-p.Ctx.Done():

system/p2p/dht/protocol/peer/peer.go

@@ -87,7 +87,10 @@ func InitProtocol(env *protocol.P2PEnv) {
 	go p.detectNodeAddr()
 	go func() {
 		ticker := time.NewTicker(time.Second / 2)
+		defer ticker.Stop()
 		ticker2 := time.NewTicker(time.Minute * 5)
+		defer ticker2.Stop()
+
 		for {
 			select {
 			case <-p.Ctx.Done():
@@ -104,6 +107,8 @@ func InitProtocol(env *protocol.P2PEnv) {
 		if p.ChainCfg.IsTestNet() {
 			ticker1 = time.NewTicker(time.Second)
 		}
+		defer ticker1.Stop()
+
 		for {
 			select {
 			case <-p.Ctx.Done():

util/cli/chain33.go

@@ -280,6 +280,8 @@ func fixtimeRoutine(hosts []string) {
 	}
 	//时间请求频繁一点:
 	ticket := time.NewTicker(time.Minute * 1)
+	defer ticket.Stop()
+
 	for range ticket.C {
 		t = common.GetRealTimeRetry(hosts, 10)
 		if !t.IsZero() {