o "j @s<ddlZddlZddlZddlmZddlZgZddZdS)N)closingc Cs4z tdd}Wnd}Y|rdSt|trJ d}g}|D]U}|d}tttjtj<}| d| tj tj dt tdrP| tj tjd||d t|df}|d krhd}||Wdn1srwYq"|stjd tjd t|d tjtd ndSq)aC Wait until parameter servers are ready, use connext_ex to detect port readiness. Args: endpoints (list|tuple): endpoints string list, like: ["127.0.0.1:8080", "127.0.0.1:8081"] Examples: .. code-block:: python >>> wait_server_ready(["127.0.0.1:8080", "127.0.0.1:8081"]) Z!FLAGS_dynamic_static_unified_commFNT: SO_REUSEPORTrz)server not ready, wait 3 sec to retry... znot ready endpoints: )paddleZ get_flags isinstancestrsplitrsocketAF_INET SOCK_STREAM settimeout setsockopt SOL_SOCKET SO_REUSEADDRhasattrr connect_exintappendsysstderrwriteflushtimesleep)Z endpointsZ use_new_commall_okZnot_ready_endpointsepZip_portsockresultr"v/var/www/html/Deteccion_Ine/venv/lib/python3.10/site-packages/paddle/distributed/fleet/base/private_helper_function.pywait_server_readysL       r$)r rr contextlibrr __all__r$r"r"r"r#s