h%SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJ r J r J r J r SSK Jr SSKJrJr SSSSSS.S\ \S \ \ \S \ \S \ \S \ \R(S \ \S\R 4SjjrSS \R(S\\\ \\4S\S \ \ \S\ \ \R S \ \S\R 4SjjrSS\ \S\S\\4Sjjrg)zBase implementation.N)ListOptionalSequenceSetUnion) _staggered) AddrInfoTypeSocketFactoryType)local_addr_infoshappy_eyeballs_delay interleaveloopsocket_factory addr_infosr r rrrreturnc l^^^^^^^# U=m(d[R"5m[U5S:HnUbUcSnU(aU(d [X5nSn/mUbU(a#UHn[ TTUTST5IShvN n O O[5m[R"UUUUU4SjU5U5IShvN un n TH<n XLdM [R"[ 5 U R5 SSS5 M> SmUGc TV V s/sH oHoPM M n n n U Sn[U 5S:XaUe[U5m[U4SjU 55(aUeSRSR!SU 555n[#U[ 5(a3UR$m[U4S jU 55(a [ TU5eO7[#U[ 5(a"[S U 55(a [ U5e[ U5eU$GN![ [ 4a GMf=fGNy!,(df  GM=f!THNn XLdM [R"[ 5 U R5 SSS5 M>!,(df  MM=f Smf=fs sn n f!Sn Smf=f7f) a Connect to a TCP server. Create a socket connection to a specified destination. The destination is specified as a list of AddrInfoType tuples as returned from getaddrinfo(). The arguments are, in order: * ``family``: the address family, e.g. ``socket.AF_INET`` or ``socket.AF_INET6``. * ``type``: the socket type, e.g. ``socket.SOCK_STREAM`` or ``socket.SOCK_DGRAM``. * ``proto``: the protocol, e.g. ``socket.IPPROTO_TCP`` or ``socket.IPPROTO_UDP``. * ``canonname``: the canonical name of the address, e.g. ``"www.python.org"``. * ``sockaddr``: the socket address This method is a coroutine which will try to establish the connection in the background. When successful, the coroutine returns a socket. The expected use case is to use this method in conjunction with loop.create_connection() to establish a connection to a server:: socket = await start_connection(addr_infos) transport, protocol = await loop.create_connection( MyProtocol, sock=socket, ...) rNc 3d># UH%n[R"[TTUTTT5v M' g7fN) functoolspartial _connect_sock).0addrinfo current_loop exceptionsr open_socketsrs G/var/www/html/env/lib/python3.13/site-packages/aiohappyeyeballs/impl.py #start_connection..XsA %/%%%$" ($&%/s-0rc3@># UHn[U5T:Hv M g7frstr)rexcmodels rrr ~sCNSs3x5(NszMultiple exceptions: {}z, c38# UHn[U5v M g7frr"rr$s rrr sA.3c#hh.sc3p># UH+n[U[5=(a URT:Hv M- g7fr) isinstanceOSErrorerrno)rr$ first_errnos rrr s0#1C#30MSYY+5MM#1s36c3B# UHn[U[5v M g7fr)r) RuntimeErrorr's rrr sG=KcJsL11^s)asyncioget_running_looplen_interleave_addrinfosrr.r*setr staggered_race contextlibsuppresscloser#allformatjoinr)r+)rr r rrrsingle_addr_infosockr_ssubr$all_exceptionsfirst_exceptionmsgrrr,r%rs ` ` @@@@@rstart_connectionrCsN! L //1 :!+'J,> **:B $(D;=J#'7"H * $" #,/5  )88  %/ % JD!Q0"=#,,W5 65" L |)3C#s#s#C! ,Q/O>"a'%%O,CNCCC))066IIA.AA ow77"1"7"7K#1&k377   >>3G=KGDD's++cl" Kc!'*   465"=#,,W5 6555" LDB"NJsA!J4+H>H?HJ4(I ;H4<I J4J4)H7:J4J%%J4)C.J+J4HH1,J40H11J44I 7 I  J4 J"J"0J  J" J  J"" J4+J11J4r addr_inforc# /nURU5 Uupxpn Sn Ub U"U5n O[R"XxU S9n UbURU 5 U RS5 UbNUH!un pX:waMU R U5 O) U(aUR5e[ SU<S35eURX5IShvN U S=p$![ a\nSU<SUR =(d SR53n[ URU5nURU5 SnAMSnAff=fNr![[ 4adnURU5 U bJUbURU 5 U R5 e![ anURU5 eSnAff=feSnAf U bJUbURU 5 U R5 e![ anURU5 eSnAff=fe=f!S=pf=f7f) aU Create, bind and connect one socket. If open_sockets is passed, add the socket to the set of open sockets. Any failure caught here will remove the socket from the set and close it. Callers can use this set to close any sockets that are not the winner of all staggered tasks in the result there are runner up sockets aka multiple winners. N)familytypeprotoFz*error while attempting to bind on address z: z&no matching local address with family=z found)appendsocketadd setblockingbindr*strerrorlowerr+pop sock_connectr.remover7)rrrDr rr my_exceptionsrFtype_rHr=addressr<lfamilyladdrr$rBes rrrs4$9;Mm$'0$F5W D5*  %!),D==%HD  #   T "   '+;'Aq$ .IIe$ ,< !'++--!$KF9F"STT....&*) ]K.##()2LL.B5578: "#))S1C!((--. / ' " S!  '##D)    $$Q'     '##D)    $$Q'  %)) ]sH AD?:C ?D? D= D?H  D:AD5/D?5D::D??H(F.8F F. F*F%%F**F..H GH G=&G88G==HHH  H  addrinfosfirst_address_family_countc[R"5nUH$nUSnXB;a/X$'X$RU5 M& [UR 55n/nUS:a%UR USSUS- 5 USSUS- 2 UR S[ RR[ R"U6555 U$)z-Interleave list of addrinfo tuples by family.rrNc30# UH nUcMUv M g7fr)ras rr(_interleave_addrinfos..sWA  Ws ) collections OrderedDictrJlistvaluesextend itertoolschain from_iterable zip_longest)rZr[addrinfos_by_familyaddrrFaddrinfos_lists reordereds rr2r2s !a  ,*,  '#**40  .5578O$&I!A%+,L.H1.LMN A ?!;a!?? @ ..y/D/Do/VW )NNN)r)__doc__r/rar5rrfrKtypingrrrrrrIr typesr r floatintAbstractEventLooprCr*r.rr2r^rnrrusz 772 :>,0 $0426K&Kx 56K#5/ K  K 7,, - K./K ]]Kd:>1526 K*  # #K*T% 5678K*K*x 56 K* 3v}}-. K* ./ K* ]]K*^JK %CF ,rn