+ j ^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI t ]P!]4tRtRRRllt!RR4tR# ] dL2i;i) N)TextIOc\P!RR\P\PR7pVFFpVwr#pp\P!W#V4pVP R4VP ^4Vu# \R4h \ d*pXP4\RT 24Rp?KRp?ii;i)a} Find a free port and binds a temporary socket to it so that the port can be "reserved" until used. .. note:: the returned socket must be closed before using the port, otherwise an ``address already in use`` error will happen. The socket should be held and closed as close to the consumer of the port as possible since otherwise, there is a greater chance of race-condition where a different process may see the port as being free and take it. Returns: a socket bound to the reserved free port Usage:: sock = find_free_port() port = sock.getsockname()[1] sock.close() use_port(port) localhostN)hostportfamilytypez Socket creation attempt failed: zFailed to create a socket)rr) socket getaddrinfo AF_UNSPEC SOCK_STREAMbindlistenOSErrorcloseprint RuntimeError)addrsaddrrr proto_ses q/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/distributed/elastic/rendezvous/etcd_server.pyfind_free_portrs(    tF,<,<6CUCU E$(!eQ : fE2A FF# $ HHQKH  2 33 : GGI 4QC8 9 9 :s:B CB==Cc2V^8dQhR\R,/#data_dirNstr)formats"r __annotate__r#Cs44C$J4cV'dKVP!4f8\PR4VP!4VP!4V'd1\PRV4\ P !VRR7R#R#)Nzstopping etcd serverzdeleting etcd data dir: %sT ignore_errors)pollloggerinfo terminatewaitshutilrmtree) subprocessrs&&r stop_etcdr0CsYjoo'/ *+ 0(; hd3r$ca]tRt^NtoRtRV3RlRlltV3RlRltV3RlRltV3R lR ltV3R lR lt RV3R lRllt RV3RlRllt Rt RV3RlRllt V3RlRltRtVtR#) EtcdServeraa .. note:: tested on etcd server v3.4.3. Starts and stops a local standalone etcd server on a random free port. Useful for single node, multi-worker launches or testing, where a sidecar etcd server is more convenient than having to separately setup an etcd server. This class registers a termination handler to shutdown the etcd subprocess on exit. This termination handler is NOT a substitute for calling the ``stop()`` method. The following fallback mechanism is used to find the etcd binary: 1. Uses env var TORCHELASTIC_ETCD_BINARY_PATH 2. Uses ``/bin/etcd`` if one exists 3. Uses ``etcd`` from ``PATH`` Usage :: server = EtcdServer("/usr/bin/etcd", 2379, "/tmp/default.etcd") server.start() client = server.get_client() # use client server.stop() Args: etcd_binary_path: path of etcd server binary (see above for fallback path) Nc.<V^8dQhRS[R,/#rr )r" __classdict__s"rr#EtcdServer.__annotate__ns88t8r$cRVnRVn\PP \ 4p\PP VR4p\PPRV4Vn \PPVP4'gRVn V'dTM\P!RR7Vn RVnRVnR#) rzbin/etcdTORCHELASTIC_ETCD_BINARY_PATHetcdtorchelastic_etcd_data)prefixN)_port_hostospathdirname__file__joinenvironget_etcd_binary_pathisfiletempfilemkdtemp_base_data_dir _etcd_cmd _etcd_proc)selfrrootdefault_etcd_bins&& r__init__EtcdServer.__init__ns   wwx(77<<j9!# +-=" ww~~d4455%+D "!Hh&6&6>V&W 37r$c4<V^8dQhRS[P/#rreturn)r/Popen)r"r4s"rr#r5s##**:*:#r$cTVP'g \R4hVP#)z>No etcd server process started. Call etcd_server.start() first)rLrrMs&r_get_etcd_server_process#EtcdServer._get_etcd_server_processs'P ?? "r$c <V^8dQhRS[/#rSint)r"r4s"rr#r5#r$c VP#)z)Return the port the server is running on.)r=rWs&rget_portEtcdServer.get_port zzr$c <V^8dQhRS[/#rSr )r"r4s"rr#r5r]r$c VP#)z)Return the host the server is running on.)r>rWs&rget_hostEtcdServer.get_hostrar$c <V^8dQhRS[/#rSr )r"r4s"rr#r5s,,c,r$c 8VP RVP 2#)z,Return the etcd server endpoint (host:port).:)r>r=rWs&r get_endpointEtcdServer.get_endpoints**Qtzzl++r$cN<V^8dQhRS[RS[RS[S[,R,RR/#)rtimeout num_retriesstderrNrT)r\r)r"r4s"rr#r5sB%I%I%I%If t# %I  %Ir$c ^p\PPVP\ V44p\P !VRR7VP WQV4# \dipT^, p\TP4\PRT4YB8d$\P!TPRR7hRp?KRp?ii;i)a Start the server, and waits for it to be ready. When this function returns the server is ready to take requests. Args: timeout: time (in seconds) to wait for the server to be ready before giving up. num_retries: number of retries to start the server. Each retry will wait for max ``timeout`` before considering it as failed. stderr: the standard error file handle. Valid values are `subprocess.PIPE`, `subprocess.DEVNULL`, an existing file descriptor (a positive integer), an existing file object, and `None`. Raises: TimeoutError: if the server is not ready within the specified timeout T)exist_okz4Failed to start etcd server, got error: %s, retryingr&N)r?r@rCrJr!makedirs_start Exceptionr0rLr)warningr-r.atexitregister)rMrlrmrn curr_retriesrrs&&&& rstartEtcdServer.starts,  77<<(;(;S=NO Ht4{{8f== ! $//*JA .MM$"5"5TJ/  sAA"" C-ACCcN<V^8dQhRS[RS[RS[S[,R,RR/#)rrrlrnNrT)r!r\r)r"r4s"rr#r5s6&&&&)&8;f t8K& &r$cX\4p\4pVP4^,VnVP4^,p\P!RP VP RRVRRVP RVP 2RRVP RVP 2RRVP RV 2. 44p\PR V4VP4VP4\P!VR VR 7Vn VPV4R #) r7 z --enable-v2z --data-dirz--listen-client-urlszhttp://rhz--advertise-client-urlsz--listen-peer-urlszStarting etcd server: [%s]T) close_fdsrnN)r getsocknamer=shlexsplitrCrFr>r)r*rr/rUrL_wait_for_ready)rMrrlrnsock sock_peer peer_portetcd_cmds&&&& rrrEtcdServer._starts"$ %%'* ))+A. ;; HH**! *djj\4::,7-djj\4::,7(djj\9+6   "  0(; $**8tFS W%r$c ^\P!VPVPR^ R7#)zNReturn an etcd client object that can be used to make requests to this server./v2rrversion_prefix read_timeout)r9Clientr>r=rWs&r get_clientEtcdServer.get_clients%{{$**UQS  r$c$<V^8dQhRS[RR/#)rrlrTNr[)r"r4s"rr#r5sMMsMDMr$c\P!VP VPR^R7p\P!4V,p\P!4V8dlVP 4P 4e)VP 4Pp\RV 24h\PRVP4R#\R4h \d\P!^4Ki;i)rrNz*Etcd server process exited with the code: zetcd server ready. version: %sz.Timed out waiting for etcd server to be ready!)r9rr>r=timerXr( returncoderr)r*versionrssleep TimeoutError)rMrlclientmax_timeexitcodes&& rrEtcdServer._wait_for_readysJJr=N)<N)rN)r)__name__ __module__ __qualname____firstlineno____doc__rPrXr_rdrirxrrrrr__static_attributes____classdictcell__)r4s@rr2r2Nso>88$##,,%I%IN&&@ MM(88r$r2r)ruloggingr?rr-r r/rHrtypingrr9ModuleNotFoundError getLoggerrr)rr0r2rr$rrsk      8 $"4J4j8j8o  sAA#"A#