Skip to content

Commit 9194dc7

Browse files
authored
Merge 509552e into a7761be
2 parents a7761be + 509552e commit 9194dc7

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

ctxc/fetcher/block_fetcher.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -294,8 +294,13 @@ func (f *Fetcher) FilterBodies(peer string, transactions [][]*types.Transaction,
294294
// events.
295295
func (f *Fetcher) loop() {
296296
// Iterate the block fetching until a quit is requested
297-
fetchTimer := time.NewTimer(0)
298-
completeTimer := time.NewTimer(0)
297+
var (
298+
fetchTimer = time.NewTimer(0)
299+
completeTimer = time.NewTimer(0)
300+
)
301+
<-fetchTimer.C // clear out the channel
302+
<-completeTimer.C
303+
299304
defer fetchTimer.Stop()
300305
defer completeTimer.Stop()
301306

0 commit comments

Comments
 (0)