+ j^RIt^RIt^RIt^RIHt^RIHt^RIH t ^RI H t .ROt ] !] 4tRtRtRtRRR lltR tR tR R ltR#)N)closing) get_logger)barrierzaddress already in usezSocket Timeoutz_tcp_store/num_membersczV^8dQhR\R\R\R\R\R\R\R,/#)  is_server server_addr server_port world_sizetimeoutwait_for_workers use_libuvN)boolstrintfloat)formats"l/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/distributed/elastic/utils/distributed.py __annotate__rs[PPPPP P  P  Pd{Pc <Ve\PR4\PP RR4R8HpVR8XdV^8d\ RV RV 24hVR8wd\P RV4VR8XdTM^pVR8wdTp M \4p \P RVV VVVV4\P!VV VV\P!VR7VVR 7p V'd\WVR 7\P R 4V # \Pdtp \\T 4P!49dLY8d(\PR T TT4T^, pRp ? K\P!R T RT R24T hhRp ? ii;i)Nzargument use_libuv is deprecated and ignored. Set USE_LIBUV environment variable to "0" to disable libuv, or "1" to enable it. If the env var is not set, libuv will be used by default. USE_LIBUV1zCserver_port must be specified when world_size > 1, got server_port=z , world_size=z+sever_port: %s, specified, ignoring retriesziCreating c10d store on %s:%s world_size : %s is_server : %s timeout(sec): %s use_libuv : %s )seconds) host_nameportr is_masterr r r)r zSuccessfully created c10d storez)port: %s already in use, attempt: [%s/%s]zon z, port: z already in use)loggerwarningosenvironget ValueErrorinfo get_free_portdistTCPStoredatetime timedelta_check_full_rankDistNetworkError_ADDRESS_IN_USErlower) rr r r r r retriesrattemptrstorees &&&&&&&& rcreate_c10d_storer3s 9  {C0C7IbZ!^QR]Q^^klvkw x  b A;O%*gG  " D ?D  #        MM%%# **7;!1#E  GD KK9 :L$$ #a&,,.0$NNC  qLG//k](4&H s%59D/#DF(A F7FFc\W\VR7R# \d+p\T4\8Xd\ RT R24ThhRp?ii;i)) key_prefixbarrier_timeoutztimed out waiting for all z members to joinN)r_TCP_STORE_INIT RuntimeErrorr_SOCKET_TIMEOUT TimeoutError)r1r r r2s&&& rr+r+psQowW  q6_ $,ZL8HI   s A %AA c\4p\V4;_uu_4VP4^,uuRRR4# +'giR#;i)a Returns an unused port on localhost. This function finds an unused port on localhost by opening to socket to bind to a port and then closing it. Returns: int: an unused port on localhost Example: >>> # xdoctest: +SKIP("Nondeterministic") >>> get_free_port() 63976 .. note:: The port returned by :func:`get_free_port` is not reserved and may be taken by another process after this function returns. N)get_socket_with_portr getsockname)socks rr&r&|s2& !D !!$ s A A c8V^8dQhR\P/#)rreturn)socket)rs"rrrs44fmm4rc\P!RR\P\PR7pVFFpVwr#pp\P!W#V4pVP R4VP ^4Vu# \R4h \ d3pTP4\PRTR7Rp?KRp?ii;i)a Returns a free port on localhost that is "reserved" by binding a temporary socket on it. Close the socket before passing the port to the entity that requires it. Usage example :: sock = _get_socket_with_port() with closing(sock): port = sock.getsockname()[1] sock.close() # there is still a race-condition that some other process # may grab this port before func() runs func(port) localhostN)hostrfamilytypezSocket creation attempt failed.)exc_infozFailed to create a socket)rCr) rA getaddrinfo AF_UNSPEC SOCK_STREAMbindlistenOSErrorcloserr r8)addrsaddrrErFproto_sr2s rr<r<s"    tF,<,<6CUCU E$(!eQ MM& . J FF# $ HHQKH  2 33 J GGI NNr^sS  >9 I H *"*Pf %04r