diff --git a/core/services/networking/httpx/connect.py b/core/services/networking/httpx/connect.py index 79571be..1e2ef1f 100644 --- a/core/services/networking/httpx/connect.py +++ b/core/services/networking/httpx/connect.py @@ -208,7 +208,7 @@ def bulk_async(wanted_list: list, observer: ConnectionObserver, client_observer: ######################################################## if connection_type == ConnectionChoice.SYSTEM: logger.info("We are entering a clearweb async bulk..") - return async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=None) + return async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=None, already_checked=True) ######################################################## @@ -216,15 +216,12 @@ def bulk_async(wanted_list: list, observer: ConnectionObserver, client_observer: ######################################################## if _port_used is None: _port_used = Constants.DEFAULT_TOR_PORT - already_checked = False - else: - already_checked = True # check if that (default) port is even listening: listening = ports.is_port_in_use(_port_used) if listening: - results = async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=_port_used, already_checked=already_checked) + results = async_parallel(desired_endpoints=desired_endpoints, client_observer=client_observer, port=_port_used, already_checked=True) else: new_port = just_only_bootstrap_port(port_used=_port_used, observer=observer) if new_port: