,hBIddlmZddlZddlmZmZddlmZmZddl Z ddl m Z m Z m Z mZerddlmZmZddlmZmZddlmZej,d krdd lmZmZd Zedd Z dd ZddZedd ddZy)) annotationsN)contextmanagersuppress) TYPE_CHECKINGAny) SOCK_STREAM SocketType getaddrinfosocket) GeneratorMutableSequence) AddressFamily SocketKind) AddressFormat) )BaseExceptionGroupExceptionGroupg?c#Kt} |g}|D]} |jt |dk(r|d|r t d|y#t$r}|j|Yd}~Wd}~wwxYw#g}|D]:} |j#t$r}|j|Yd}~4d}~wwxYwt |dk(r|d|r t d|wxYww)Nr)setclose BaseExceptionappendlenr)sockets_to_closeerrssockexcs a/var/www/html/Resume-Scraper/venv/lib/python3.12/site-packages/trio/_highlevel_open_tcp_stream.py close_allr"ws(+ /$ !D !  ! t9>q'M $R. . ! ! C   ! $ !D !   ! C   ! ! t9>q'M $R. .sm CA5CA$C A2A-(C-A22C5C>BC B3 B. )C.B3 3&CCctdt|D];}||d|ddk7s|dk7r!|jd|j|yy)Nrr)rangerinsertpop)targetsis r! reorder_for_rfc_6555_section_5_4r)sX1c'l # 1:a=GAJqM )Avq'++a.1  cnt|tr|jdn|}d|vrd|d|S|d|S)Nascii:[z]:) isinstancebytesdecode)hostports r!format_host_portr4sF#-dE#:4;;w D d{4&4&!!qr*)happy_eyeballs_delay local_addressc 0Kt|ttfstd|t|tst d||t }t||td{}|sdt||}t|t|gd d fd }t5tj4d{|D]\}}} } } tj} t r|||| f| | d{j#|||| f| | tj$|5| j'd{ddddddd{?t)t)|k(sJdt||d}t|t+|tj,} j/| cdddS7u777#1swYxYw7#1d{7swYxYw#1swYyxYww) a Connect to the given host and port over TCP. If the given ``host`` has multiple IP addresses associated with it, then we have a problem: which one do we use? One approach would be to attempt to connect to the first one, and then if that fails, attempt to connect to the second one ... until we've tried all of them. But the problem with this is that if the first IP address is unreachable (for example, because it's an IPv6 address and our network discards IPv6 packets), then we might end up waiting tens of seconds for the first connection attempt to timeout before we try the second address. Another approach would be to attempt to connect to all of the addresses at the same time, in parallel, and then use whichever connection succeeds first, abandoning the others. This would be fast, but create a lot of unnecessary load on the network and the remote server. This function strikes a balance between these two extremes: it works its way through the available addresses one at a time, like the first approach; but, if ``happy_eyeballs_delay`` seconds have passed and it's still waiting for an attempt to succeed or fail, then it gets impatient and starts the next connection attempt in parallel. As soon as any one connection attempt succeeds, all the other attempts are cancelled. This avoids unnecessary load because most connections will succeed after just one or two attempts, but if one of the addresses is unreachable then it doesn't slow us down too much. This is known as a "happy eyeballs" algorithm, and our particular variant is modelled after how Chrome connects to webservers; see `RFC 6555 `__ for more details. Args: host (str or bytes): The host to connect to. Can be an IPv4 address, IPv6 address, or a hostname. port (int): The port to connect to. happy_eyeballs_delay (float or None): How many seconds to wait for each connection attempt to succeed or fail before getting impatient and starting another one in parallel. Set to `None` if you want to limit to only one connection attempt at a time (like :func:`socket.create_connection`). Default: 0.25 (250 ms). local_address (None or str): The local IP address or hostname to use as the source for outgoing connections. If ``None``, we let the OS pick the source IP. This is useful in some exotic networking configurations where your host has multiple IP addresses, and you want to force the use of a specific one. Note that if you pass an IPv4 ``local_address``, then you won't be able to connect to IPv6 hosts, and vice-versa. If you want to take advantage of this to force the use of IPv4 or IPv6 without specifying an exact source address, you can use the IPv4 wildcard address ``local_address="0.0.0.0"``, or the IPv6 wildcard address ``local_address="::"``. Returns: SocketStream: a :class:`~trio.abc.Stream` connected to the given server. Raises: OSError: if the connection fails. See also: open_ssl_over_tcp_stream zhost must be str or bytes, not zport must be int, not N)typez&no results found for hostname lookup: ctK t|}j||ttt5|j t jjt jjdddd |jdfd{|j|d{| jjy#1swY[xYw7F#t$rtdd|dwxYw7N#t$r+}j||jYd}~yd}~wwxYww)Nrrzlocal_address=z% is incompatible with remote address )r addrOSErrorAttributeError setsockopttrio IPPROTO_IPIP_BIND_ADDRESS_NO_PORTbindconnect cancel_scopecancelrr) socket_argssockaddrattempt_failedrr r6nursery open_socketsoserrorswinning_sockets r!attempt_connectz(open_tcp_stream..attempt_connect)s.? !;'D   T "(Bg~6OO .. ;;  ))]A$6777,,x( ( ("N  ' ' )'8 !((9://7l<   )  ! OOC     !s|D8/DAC8DC CC D0C?1 DD8CDC C<<D D5 !D0+D80D55D8zall attempts to connect to z failed)rEz%tuple[AddressFamily, SocketKind, int]rFrrGz trio.EventreturnNone)r/strr0 ValueErrorint TypeError DEFAULT_DELAYr rr4r;r)r"r> open_nurseryEventr start_soon move_on_afterwaitrr SocketStreamremove)r2r3r5r6r'msgrLaddress_family socket_typeproto_addrrGstreamrHrIrJrKs ` @@@@r!open_tcp_streamrbs_^ dS%L ):4(CDD dC 09::#,d==G 67Gd7S6TUcl$W-!H)-NF!:F!F!#F!  F!F!P $ $$& 0 0'?F 0; UAt"&!)'e<& ""##[%8" ''(<=0(--///00+ 0 0 04  !x=CL0 0/0@t0L/MWUC#,N3$A A&&~6F    /I$$C>H 0000- 0 0 0 0$$sA H'G(A H3H  G H 6G5G" 0G57G& G$ G&  G5 H %G3&A,H  HH "G5$G& &G0 +G53H 5H ;G><H H  HH)rMz&Generator[set[SocketType], None, None])r'z@MutableSequence[tuple[AddressFamily, SocketKind, int, str, Any]]rMrN)r2 str | bytesr3z int | strrMrO) r2rcr3rQr5z float | Noner6z str | NonerMztrio.SocketStream) __future__rsys contextlibrrtypingrrr> trio.socketrr r r collections.abcr r rr trio._socketr version_infoexceptiongrouprrrSr"r)r4rbr*r!rns" /% DD:0*gAx T//" M ( @*7 $ \ \ \' \  \  \r*