g^(h  ddlZddlZddlZddlZddlZddlZddlmZddlm Z m Z ddl m Z m Z mZmZdgZdedeeeffdZd edeefd Zd eed edeeeffd ZdedefdZdeeeeeffddfdZGddZy)N) timedelta)EventThread)AnyCallableOptionalUnionparse_rendezvous_endpoint config_strreturnc i}|j}|s|S|jd}|D]a}|jdd^}}|j}|s td|r|dj}nd}|std|d|||<c|S) zExtract key-value pairs from a rendezvous configuration string. Args: config_str: A string in format =,...,=. ,=zZThe rendezvous configuration string must be in format =,...,=.rNz%The rendezvous configuration option 'z' must have a value specified.)stripsplit ValueError)r config key_valueskvkeyvaluesvalues h/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/torch/distributed/elastic/rendezvous/utils.py_parse_rendezvous_configrs F!!#J  !!#&JxxQ' fiik7  1IOO%EE7u[:]. default_port: The port number to use if the endpoint does not include one. Returns: A tuple of hostname and port number. localhostr[]:riz,The port number of the rendezvous endpoint 'z)' must be an integer between 0 and 65536.z ^[\w\.:-]+$z)The hostname of the rendezvous endpoint 'zN' must be a dot-separated list of labels, an IPv4 address, or an IPv6 address.)rrsplitlenr"rrr )r#r$hostrestports rr r Cs>># \**{chrlc1mm tooc1- t 4y1}aCDHOAbz 4yA~tAw' <45=>xjI''   88ND )7zB; ;  :rr-c~|dk(ry tj|}|r |jry t j |dtj tj}|Dcgc] }|dd }}t j}||k(ryt j |dtj tj}|D]5}|dr |d|k(ry|r|ddt|k(ry|dd|vs5yy#t$rd}YwxYw#ttjf$r }g}Yd}~d}~wwxYwcc}w) a<Indicate whether ``host`` matches the hostname of this machine. This function compares ``host`` to the hostname as well as to the IP addresses of this machine. Note that it may return a false negative if this machine has CNAME records beyond its FQDN or IP addresses assigned to secondary NICs. r&TN)protoflagsrF) ipaddress ip_addressr is_loopbacksocket getaddrinfo IPPROTO_TCP AI_CANONNAMEgaierror gethostnamestr) r-addrhost_addr_list_host_addr_info host_ip_list this_host addr_list addr_infos r_matches_machine_hostnamerGtsS {##D)   ++ $f008K8K  @NN^N1%a(NLN""$I y""4v119L9LI  Qrrr_ContextrTs49%%CHoS#Xrrb_name_thread _finalizer_ctxrUrWrVrXrYr Nc>d|_|j|_|j|j_||j_|xsd|j_|xsi|j_t|j_ d|_ d|_ y)Nra) rcrbrf total_secondsrUrWrXrYrrZrdre)selfrUrWrXrYs r__init__z_PeriodicTimer.__init__st MMO %335 %  !|jr|jyy)z'Stop the timer at the next opportunity.N)rerls rcancelz_PeriodicTimer.cancels ?? OO  rc|jj|jsM|j|ji|j |jj|jsLyyN)rZwaitrUrWrXrY)ctxs rrvz_PeriodicTimer._runsK..%%cll3 CLL#(( 1cjj 1..%%cll3rcD|j|jyr)setjoin)threadrZs rryz_PeriodicTimer._stop_threads r)r N)r[r\r]__doc__rbrr>r_rrwrxrrrrjpropertyrmrqr{r} staticmethodrvryrarrrRrRs C= f ))** N9%     &hsm S T 4 22rrR)r5rLrr8rNrwdatetimer threadingrrtypingrrrr __all__r>r`rr!r"rKr boolrGr^rPrRrarrrs #11 ' '##c3h#Lchsm.sm.+.. 38_.b1C1D1h E%ue|!445 $ eer