ethmonitor: timer stop

0xsequence · Apr 16, 2024 · c6a8a08 · c6a8a08
1 parent b69b303
commit c6a8a08
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/ethmonitor/ethmonitor.go b/ethmonitor/ethmonitor.go
@@ -307,6 +307,12 @@ func (m *Monitor) listenNewHead() <-chan uint64 {
 		var streamingErrorCount int
 		var streamingErrorLastTime time.Time
 
+		blockTimer := time.NewTimer(3 * m.options.ExpectedBlockInterval)
+		defer blockTimer.Stop()
+
+		retryStreamingTimer := time.NewTimer(m.options.StreamingRetryAfter)
+		defer retryStreamingTimer.Stop()
+
 	reconnect:
 		// reset the latest head block
 		latestHeadBlock.Store(0)
@@ -334,7 +340,6 @@ func (m *Monitor) listenNewHead() <-chan uint64 {
 				goto reconnect
 			}
 
-			blockTimer := time.NewTimer(3 * m.options.ExpectedBlockInterval)
 			for {
 				select {
 				case <-m.ctx.Done():
@@ -375,7 +380,6 @@ func (m *Monitor) listenNewHead() <-chan uint64 {
 			// We default to polling if streaming is not enabled
 			m.log.Info("ethmonitor: starting poll head listener")
 
-			retryStreamingTimer := time.NewTimer(m.options.StreamingRetryAfter)
 			for {
 				// if streaming is enabled, we'll retry streaming
 				if m.provider.IsStreamingEnabled() {