@@ -521,12 +521,10 @@ func (s *Ethereum) setupDiscovery() error {
521
521
if s .p2pServer .DiscoveryV4 () != nil {
522
522
fairmix := enode .NewFairMix (0 )
523
523
for i := 0 ; i < discoveryParallelLookups ; i ++ {
524
- asyncFilter := s .p2pServer .DiscoveryV4 ().RequestENR
525
- filter := eth .NewNodeFilter (s .blockchain )
526
- iter := enode .AsyncFilter (
527
- enode .NewBufferIter (s .p2pServer .DiscoveryV4 ().RandomNodes (), discoveryPrefetchBuffer ),
528
- asyncFilter , maxParallelENRRequests )
529
- iter = enode .Filter (iter , filter )
524
+ iter := s .p2pServer .DiscoveryV4 ().RandomNodes ()
525
+ iter = enode .NewBufferIter (iter , discoveryPrefetchBuffer )
526
+ iter = enode .AsyncFilter (iter , s .p2pServer .DiscoveryV4 ().RequestENR , maxParallelENRRequests )
527
+ iter = enode .Filter (iter , eth .NewNodeFilter (s .blockchain ))
530
528
fairmix .AddSource (iter , fmt .Sprintf ("DiscoveryV4-%d" , i ))
531
529
}
532
530
s .discmix .AddSource (fairmix , "DiscoveryV4" )
@@ -536,10 +534,10 @@ func (s *Ethereum) setupDiscovery() error {
536
534
if s .p2pServer .DiscoveryV5 () != nil {
537
535
fairmix := enode .NewFairMix (0 )
538
536
for i := 0 ; i < discoveryParallelLookups ; i ++ {
539
- iter := enode . NewBufferIter ( s .p2pServer .DiscoveryV5 ().RandomNodes (), discoveryPrefetchBuffer )
540
- filter := eth . NewNodeFilter ( s . blockchain )
541
- filterIter : = enode .Filter (iter , filter )
542
- fairmix .AddSource (filterIter , fmt .Sprintf ("DiscoveryV5-%d" , i ))
537
+ iter := s .p2pServer .DiscoveryV5 ().RandomNodes ()
538
+ iter = enode . NewBufferIter ( iter , discoveryPrefetchBuffer )
539
+ iter = enode .Filter (iter , eth . NewNodeFilter ( s . blockchain ) )
540
+ fairmix .AddSource (iter , fmt .Sprintf ("DiscoveryV5-%d" , i ))
543
541
}
544
542
s .discmix .AddSource (fairmix , "DiscoveryV5" )
545
543
}
0 commit comments