h0SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJ r SSK J r SSK J r SSKJr SSKJr SSKJr SS KJrJrJrJrJrJrJrJr \R8(aSS KJr S r"S S 5r"SS5r g)z'A non-blocking TCP connection factory. N)Futurefuture_add_done_callback)IOLoop)IOStream)gen)Resolver) TimeoutError)AnyUnionDictTupleListCallableIteratorOptional)Setg333333?c \rSrSrSrS\\S\\R\/\\ S44SS4Sjr \ S\\S\\\\R\4\\\R\444S j5r \S4S \S \\\\R&4SS 4S jjrS\\\R\4SS4SjrS\\\R\4S\RS\SSSS4 SjrS \SS4SjrSSjrSSjrS \\\R&4SS4SjrSSjrSSjrSSjrSrg) _Connector)atA stateless implementation of the "Happy Eyeballs" algorithm. "Happy Eyeballs" is documented in RFC6555 as the recommended practice for when both IPv4 and IPv6 addresses are available. In this implementation, we partition the addresses by family, and make the first connection attempt to whichever address was returned first by ``getaddrinfo``. If that connection fails or times out, we begin a connection in parallel to the first address of the other family. If there are additional failures we retry with other addresses, keeping one connection attempt per family in flight at a time. http://tools.ietf.org/html/rfc6555 addrinfoconnectFuture[IOStream]returnNc[R"5UlX l[ 5UlSUlSUlSUl[U5Ul URU5uUl Ul [5UlgN)rcurrentio_looprrfuturetimeoutconnect_timeout last_errorlen remainingsplit primary_addrssecondary_addrssetstreams)selfrrs dC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\tornado/tcpclient.py__init___Connector.__init__;sj~~'   H  #X37::h3G0D0u c/n/nUSSnUH0upEXC:XaURXE45 MURXE45 M2 X4$)aTPartition the ``addrinfo`` list by address family. Returns two lists. The first list contains the first entry from ``addrinfo`` and all others with the same family, and the second list contains all other addresses (normally one list will be AF_INET and the other AF_INET6, although non-standard resolvers may return additional families). r)append)rprimary secondary primary_afafaddrs r*r$_Connector.splitOsV a[^  HBz*  ", ! !!r-rr z2Future[Tuple[socket.AddressFamily, Any, IOStream]]cUR[UR55 URU5 UbUR U5 UR $r) try_connectiterr% set_timeoutset_connect_timeoutr)r)rr s r*start_Connector.starthsI d0012 !  &  $ $_ 5{{r-addrsc [U5up#URX#5upEURRU5 [U[R"URXU55 g![ai URS:XaVURR 5(d7URR UR =(d [S55 gf=f)Nrzconnection failed)next StopIterationr#rdone set_exceptionr!IOErrorrr(addr functoolspartialon_connect_done)r)r=r3r4streamrs r*r7_Connector.try_connectss E{HBb/   I%%d&:&:EtL  ~~"4;;+;+;+=+= ))OOCw/B'C  s A**A0CCr3r4rcU=RS-slUR5nUR5 URR 5(aUR5 gURRU5 URRX#U45 UR!5 g![anURR 5(aSnAgX`lUR U5 URb5URRUR5 UR5 SnAgSnAff=f)N)r#result ExceptionrrAr!r7rrremove_timeout on_timeoutclear_timeoutscloser(discard set_result close_streams)r)r=r3r4rrHes r*rG_Connector.on_connect_dones ! ]]_F  ;;     LLN LL  ( KK " "Bf#5 6    ) {{!! O   U #||' ++DLL9!  sB00 E:D<AD<<EcURRURR5U-UR5Ulgr)r add_timeouttimerOr)r)rs r*r9_Connector.set_timeouts3||// LL   ' )4??  r-cSUlURR5(d%UR[ UR 55 ggr)rrrAr7r8r&r)s r*rO_Connector.on_timeouts: {{!!   T$"6"67 8"r-cjURb&URRUR5 ggr)rrrNr\s r* clear_timeout_Connector.clear_timeouts' << # LL ' ' 5 $r-cXURRXR5Ulgr)rrXon_connect_timeoutr )r)r s r*r:_Connector.set_connect_timeouts$ $||77 44 r-cURR5(d#URR[55 UR 5 gr)rrArBr rTr\s r*rb_Connector.on_connect_timeouts5{{!! KK % %ln 5 r-cURb%URRUR5 URb&URRUR5 ggr)rrrNr r\s r*rP_Connector.clear_timeoutssK << # LL ' ' 5    + LL ' '(<(< = ,r-cJURHnUR5 M gr)r(rQ)r)rHs r*rT_Connector.close_streamssllF LLN#r-) rr rrr!r%r#r&r(rrN) __name__ __module__ __qualname____firstlineno____doc__rr rsocket AddressFamilyrr+ staticmethodr$_INITIAL_CONNECT_TIMEOUTfloatrr datetime timedeltar;rr7rGr9rOr_r:rbrPrT__static_attributes__r-r*rr)s"u+  ! !5 )5;M1M+N N   ("u+"  U6''. /0 U6''. /0 2 ""42FJ  "%x/A/A(A"BC  >  %0D0De0K*L!M RV $!f22E9:;!  ! ! # !  !@ 5 T 9 6 $UH,>,>%>?   > r-rc\\rSrSrSrSS\\SS4SjjrSSjr\ RSSSSS4S\ S \ S \ RS \\\\ \4\R$4S \\ S \\ S\\ S\\\\R*4S\4SjjrSS \ S \ RS\S \\ S\\ S\\S44 SjjrSrg) TCPClientzA non-blocking TCP connection factory. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. NresolverrcRUbXlSUlg[5UlSUlg)NFT)r| _own_resolverr)r)r|s r*r+TCPClient.__init__s&  $M!&D $JDM!%D r-c\UR(aURR5 ggr)r~r|rQr\s r*rQTCPClient.closes    MM   ! r-hostportr3 ssl_optionsmax_buffer_size source_ip source_portrc \# Ub[U[R5(a'[R"5R 5U-nOb[U[ R5(a5[R"5R 5UR5-nO[SU-5eUb9[R"XRRXU55IShvN n O$URRXU5IShvN n [U [R "UR"UUUS95n U R%US9IShvN up;n UbJUb/[R"UU R'SXAS95IShvN n U $U R'SXAS9IShvN n U $NNNZN&N7f)a_Connect to the given host and port. Asynchronously returns an `.IOStream` (or `.SSLIOStream` if ``ssl_options`` is not None). Using the ``source_ip`` kwarg, one can specify the source IP address to use when establishing the connection. In case the user needs to resolve and use a specific interface, it has to be handled outside of Tornado as this depends very much on the platform. Raises `TimeoutError` if the input future does not complete before ``timeout``, which may be specified in any form allowed by `.IOLoop.add_timeout` (i.e. a `datetime.timedelta` or an absolute time relative to `.IOLoop.time`) Similarly, when the user requires a certain source port, it can be specified using the ``source_port`` arg. .. versionchanged:: 4.5 Added the ``source_ip`` and ``source_port`` arguments. .. versionchanged:: 5.0 Added the ``timeout`` argument. NzUnsupported timeout %r)rr)r F)rserver_hostname) isinstancenumbersRealrrrYrurv total_seconds TypeErrorr with_timeoutr|resolverrErF_create_streamr; start_tls) r)rrr3rrrrrr connectorr4rHs r*rTCPClient.connectsH  '7<<00 ..*//1G;GX%7%788 ..*//1G4I4I4KK 87 BCC   --..t2>H"]]224rBBH    ###'   "+!II&  """//$$;%   &//{ 0  =CJ s[C"F,$F"%$F, F$ AF, F& 5F,F(F,F*F,$F,&F,(F,*F,r4rc[U[5(aUOSnUnU(aU(dU[R:XaSOSn[R"U5nU(dU(aUR Xv45 [XS9n XRU54$![ a UR 5 ef=f![ a)n [5n U RU 5 W U 4sSn A $Sn A ff=f)Nrz::1z 127.0.0.1)r) rintrpAF_INET6bindOSErrorrQrrrrB) r)rr3r4rrsource_port_bindsource_ip_bind socket_objrHrUfus r*rTCPClient._create_stream)s+5[#*F*F;A" I')FOO&;UN]]2& ~  BC  0jJF >>$// /   "   B   Q 2:  s*'B: B4B14 C'>C"C'"C')r~r|rrj)NN)rkrlrmrnrorrr+rQrp AF_UNSPECstrrrqr r r ssl SSLContextrtrurvrrr rrwrxr-r*rzrzsM &(!3&t&"$*#3#3GK)-#'%)>BJJJ  J eDcNCNN$BCD J "# JC=Jc]J%x'9'9 9:;J Jb$(%) #0#0  #0 #0 C= #0 c] #0 x++ ,#0#0r-rz)!rorErprrurtypingtornado.concurrentrrtornado.iolooprtornado.iostreamrtornadortornado.netutilr tornado.genr r r r r rrrr TYPE_CHECKINGrrsrrzrxr-r*rsd   ?!%$$NNN ^^BB0B0r-