@@ -522,9 +522,9 @@ func (s *Ethereum) setupDiscovery() error {
522
522
fairmix := enode .NewFairMix (0 )
523
523
for i := 0 ; i < discoveryParallelLookups ; i ++ {
524
524
iter := s .p2pServer .DiscoveryV4 ().RandomNodes ()
525
- iter = enode .NewBufferIter (iter , discoveryPrefetchBuffer )
526
525
iter = enode .AsyncFilter (iter , s .p2pServer .DiscoveryV4 ().RequestENR , maxParallelENRRequests )
527
526
iter = enode .Filter (iter , eth .NewNodeFilter (s .blockchain ))
527
+ iter = enode .NewBufferIter (iter , discoveryPrefetchBuffer )
528
528
fairmix .AddSource (iter , fmt .Sprintf ("DiscoveryV4-%d" , i ))
529
529
}
530
530
s .discmix .AddSource (fairmix , "DiscoveryV4" )
@@ -535,8 +535,8 @@ func (s *Ethereum) setupDiscovery() error {
535
535
fairmix := enode .NewFairMix (0 )
536
536
for i := 0 ; i < discoveryParallelLookups ; i ++ {
537
537
iter := s .p2pServer .DiscoveryV5 ().RandomNodes ()
538
- iter = enode .NewBufferIter (iter , discoveryPrefetchBuffer )
539
538
iter = enode .Filter (iter , eth .NewNodeFilter (s .blockchain ))
539
+ iter = enode .NewBufferIter (iter , discoveryPrefetchBuffer )
540
540
fairmix .AddSource (iter , fmt .Sprintf ("DiscoveryV5-%d" , i ))
541
541
}
542
542
s .discmix .AddSource (fairmix , "DiscoveryV5" )
0 commit comments