Ph ddlZddlZddlmZddlmZddlmZee Z dZ dZ dZ dZ dded ed ed ed ed ef dZdZdZdejfdZy)N)closing) get_loggerzAddress already in usezSocket Timeoutz_tcp_store/num_membersz_tcp_store/last_member is_server server_addr server_port world_sizetimeoutwait_for_workersc D|dk(r|dkDrtd|d||dk7rtjd||dk(r|nd} |dk7r|}n t}tjd||||| t j ||||t j||} |r t| |tjd | S#t$rS} t| tk(r6||krtjd ||||dz }ntd |d |d | Yd} ~ nd} ~ wwxYw)NzCserver_port must be specified when world_size > 1, got server_port=z , world_size=z+sever_port: %s, specified, ignoring retrieszVCreating c10d store on %s:%s world_size : %s is_server : %s timeout(sec): %s )seconds) host_nameportr is_masterr r zSuccessfully created c10d storez)port: %s already in use, attempt: [%s/%s]zon z, port: z already in use) ValueErrorloginfo get_free_portdistTCPStoredatetime timedelta_check_full_rank RuntimeErrorstr_ADDRESS_IN_USEwarning) rrrrr r retriesattemptrstorees vC:\Users\daisl\Desktop\realtime-object-detection\venv\Lib\site-packages\torch/distributed/elastic/utils/distributed.pycreate_c10d_storer$s[bZ!^QR]Q^^klvkw x  b > L%*gG  " D ?D  # z9g   MM%%# **7;!1 E   3 HH6 7L  1v(W$KKCT7T[qLG&k](4&H  9 s.AC D A DDc|jtd}||k(r|jtd |j ty#t $r(}t |tk(rtd|d|d}~wwxYw)Nr z ztimed out waiting for all z members to join) add_MEMBER_CHECKINset_LAST_MEMBER_CHECKINgetrr_SOCKET_TIMEOUT TimeoutError)r!ridxr"s r#rr\sy ))OQ 'C j &8 &'  q6_ $,ZL8HI   sA A:#A55A:c~t}t|5|jdcdddS#1swYyxYw)Nr )get_socket_with_portr getsockname)socks r#rrls,  !D !!$ s3<returnctjddtjtj}|D]G}|\}}}}}tj|||} |j d|j d|cStd#t $r1}|jtjd|Yd}~d}~wwxYw) 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)hostrfamilytype)r4rrzSocket creation attempt failed.)exc_infozFailed to create a socket) socket getaddrinfo AF_UNSPEC SOCK_STREAMbindlistenOSErrorcloserrr)addrsaddrr6r7proto_sr"s r#r/r/rs"    tF,<,<6CUCU E$(!eQ MM&$ . D FF# $ HHQKH  2 33 D GGI HH6H C C Ds#B  C'CC)r r iXT)rr9 contextlibrtorch.distributed distributedr'torch.distributed.elastic.utils.loggingr__name__rrr+r'r)boolrintfloatr$rrr/r#rQs  >*"*/ ! @@@@ @  @  @F  % 4fmm4rP