|
@@ -331,8 +331,12 @@ func (f *BlockFetcher) FilterBodies(peer string, transactions [][]*types.Transac
|
|
|
// events.
|
|
// events.
|
|
|
func (f *BlockFetcher) loop() {
|
|
func (f *BlockFetcher) loop() {
|
|
|
// Iterate the block fetching until a quit is requested
|
|
// Iterate the block fetching until a quit is requested
|
|
|
- fetchTimer := time.NewTimer(0)
|
|
|
|
|
- completeTimer := time.NewTimer(0)
|
|
|
|
|
|
|
+ var (
|
|
|
|
|
+ fetchTimer = time.NewTimer(0)
|
|
|
|
|
+ completeTimer = time.NewTimer(0)
|
|
|
|
|
+ )
|
|
|
|
|
+ <-fetchTimer.C // clear out the channel
|
|
|
|
|
+ <-completeTimer.C
|
|
|
defer fetchTimer.Stop()
|
|
defer fetchTimer.Stop()
|
|
|
defer completeTimer.Stop()
|
|
defer completeTimer.Stop()
|
|
|
|
|
|