@@ -521,12 +521,14 @@ 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 := enode .Filter (
525
+ enode .AsyncFilter (
526
+ enode .NewBufferIter (
527
+ s .p2pServer .DiscoveryV4 ().RandomNodes (),
528
+ discoveryPrefetchBuffer ,
529
+ ), s .p2pServer .DiscoveryV4 ().RequestENR , maxParallelENRRequests ,
530
+ ), eth .NewNodeFilter (s .blockchain ),
531
+ )
530
532
fairmix .AddSource (iter , fmt .Sprintf ("DiscoveryV4-%d" , i ))
531
533
}
532
534
s .discmix .AddSource (fairmix , "DiscoveryV4" )
@@ -536,10 +538,12 @@ func (s *Ethereum) setupDiscovery() error {
536
538
if s .p2pServer .DiscoveryV5 () != nil {
537
539
fairmix := enode .NewFairMix (0 )
538
540
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 ))
541
+ iter := enode .Filter (
542
+ enode .NewBufferIter (
543
+ s .p2pServer .DiscoveryV5 ().RandomNodes (), discoveryPrefetchBuffer ,
544
+ ), eth .NewNodeFilter (s .blockchain ),
545
+ )
546
+ fairmix .AddSource (iter , fmt .Sprintf ("DiscoveryV5-%d" , i ))
543
547
}
544
548
s .discmix .AddSource (fairmix , "DiscoveryV5" )
545
549
}
0 commit comments