sh SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r J r J r SSK r \R"\5rSrSS\ \4Sjjr"SS5rg!\a N4f=f) N)OptionalTextIOUnionc[R"SS[R[RS9nUHFnUup#n n[R"X#U5nUR S5 UR S5 Us $ [S5e![ a)nWR5 [SU35 SnAMSnAff=f)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 a ``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 binded to the reserved free port Usage:: sock = find_free_port() port = sock.getsockname()[1] sock.close() use_port(port) localhostN)hostportfamilytype)rrrz Socket creation attempt failed: zFailed to create a socket) socket getaddrinfo AF_UNSPEC SOCK_STREAMbindlistenOSErrorcloseprint RuntimeError)addrsaddrr r proto_ses ڄ/Users/tiagomarins/Projetos/claudeai/copy_bank/venv/lib/python3.13/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  B>B99B>data_dirc U(aIUR"5c7[RS5 UR"5 UR"5 U(a,[RSU5 [ R "USS9 gg)Nzstopping etcd serverzdeleting etcd data dir: %sT ignore_errors)pollloggerinfo terminatewaitshutilrmtree) subprocessrs r stop_etcdr*CsYjoo'/ *+ 0(; hd3c \rSrSrSrSS\\4SjjrS\R4Sjr S\ 4Sjr S\4S jr S\4S jrSS \ S \ S \\ \S4SS4SjjrSS\S \ S \\ \S4SS4SjjrSrSS \ SS4SjjrSSjrSrg) EtcdServerNaa .. 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) NrcSUlSUl[RR [ 5n[RR US5n[RRSU5Ul [RRUR5(dSUl U(aUO[R"SS9Ul SUlSUlg)Nrzbin/etcdTORCHELASTIC_ETCD_BINARY_PATHetcdtorchelastic_etcd_data)prefix)_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 6:r+returncRUR(d [S5eUR$)Nz>No etcd server process started. Call etcd_server.start() first)rDrrEs r_get_etcd_server_process#EtcdServer._get_etcd_server_processs%P ?? "r+cUR$)z)Return the port the server is running on.)r5rLs rget_portEtcdServer.get_port zzr+cUR$)z)Return the host the server is running on.)r6rLs rget_hostEtcdServer.get_hostrRr+c8URSUR3$)z,Return the etcd server endpoint (host:port).:)r6r5rLs r get_endpointEtcdServer.get_endpoints**Qtzzl++r+timeout num_retriesstderrcSn[RRUR[ U55n[R "USS9 UR XQU5$![ahnUS- n[UR5 [RS[ U55 XB:a [R"URSS9 eSnAOSnAff=fM)a Start the server, and waits for it to be ready. When this function returns the sever 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 rT)exist_okz4Failed to start etcd server, got error: %s, retryingr N)r7r8r;rBstrmakedirs_start Exceptionr*rDr#warningr'r(atexitregister)rErZr[r\ curr_retriesrrs rstartEtcdServer.starts,  77<<(;(;S=NO Ht4{{8f== ! $//*JCPQF .MM$"5"5TJ/   sAA C)AC  Cc@[5n[5nUR5SUlUR5Sn[R"SR UR SSUSSURSUR3SSURSUR3S SURSU3/ 55n[RS U5 UR5 UR5 [R"US US 9Ul URU5 g) Nr_ z --enable-v2z --data-dirz--listen-client-urlszhttp://rWz--advertise-client-urlsz--listen-peer-urlszStarting etcd server: [%s]T) close_fdsr\)r getsocknamer5shlexsplitr;r>r6r#r$rr)PopenrD_wait_for_ready)rErrZr\sock sock_peer peer_portetcd_cmds rrbEtcdServer._starts"$ %%'* ))+A. ;; HH**! *djj\4::,7-djj\4::,7(djj\9+6   "  0(; $**8tFS W%r+cX[R"URURSSS9$)zNReturn an etcd client object that can be used to make requests to this server./v2 rr version_prefix read_timeout)r2Clientr6r5rLs r get_clientEtcdServer.get_clients%{{$**UQS  r+c([R"URURSSS9n[R"5U-n[R"5U:aiUR 5R 5b(UR 5Rn[SU35e[RSUR5 g[S5e![a [R"S5 Of=f[R"5U:aMNM)Nrxrzz*Etcd server process exited with the code: zetcd server ready. version: %sr_z.Timed out waiting for etcd server to be ready!)r2r}r6r5timerMr" returncoderr#r$versionrcsleep TimeoutError)rErZclientmax_timeexitcodes rrqEtcdServer._wait_for_readysJJrCrDr6r5N)<N)rN)r)rJN)__name__ __module__ __qualname____firstlineno____doc__rr`rHr)rprMintrPrTrXrrrhrbr~rqr__static_attributes__r+rr-r-Ns>;#;$#**:*:###,c, +/ %I%I%Ic64'( %I  %IPTX&&&)&8=c64>O8P& &@ MsMDM(8r+r-r)reloggingr7rnr'r r)r@rtypingrrrr2ModuleNotFoundError getLoggerrr#rr`r*r-rr+rrsy  **    8 $"4J4HSM4j8j8o  sA A)(A)