@@ -471,17 +471,6 @@ impl MempoolSync {
471
471
match Self :: mempool_sync_resolve_data_url ( url_str, dns_request, dns_client_opt)
472
472
{
473
473
Ok ( ( false , Some ( addr) ) ) => {
474
- // address must be resolvable
475
- if PeerAddress :: from_socketaddr ( & addr) . is_in_private_range ( ) {
476
- debug ! (
477
- "{:?}: Mempool sync skips {}, which has private IP {}" ,
478
- network. get_local_peer( ) ,
479
- & url_str,
480
- & addr
481
- ) ;
482
- self . mempool_sync_reset ( ) ;
483
- return ( true , None ) ;
484
- }
485
474
// success! advance
486
475
self . mempool_state =
487
476
MempoolSyncState :: SendQuery ( url_str. clone ( ) , addr, page_id. clone ( ) ) ;
@@ -508,6 +497,18 @@ impl MempoolSync {
508
497
}
509
498
MempoolSyncState :: SendQuery ( ref url, ref addr, ref page_id) => {
510
499
// 3. ask for the remote peer's mempool's novel txs
500
+ // address must be resolvable
501
+ if !network. get_connection_opts ( ) . private_neighbors
502
+ && PeerAddress :: from_socketaddr ( & addr) . is_in_private_range ( )
503
+ {
504
+ debug ! (
505
+ "{:?}: Mempool sync skips {}, which has private IP" ,
506
+ network. get_local_peer( ) ,
507
+ & addr
508
+ ) ;
509
+ self . mempool_sync_reset ( ) ;
510
+ return ( true , None ) ;
511
+ }
511
512
debug ! (
512
513
"{:?}: Mempool sync will query {} for mempool transactions at {}" ,
513
514
& network. get_local_peer( ) ,
0 commit comments