hg X U d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm Z m
Z
d dl m Z m
Z
mZmZmZmZmZmZmZ d dlZd dlZd dlmZ ddlm Z e r-d d l m Z d d
l m Z d d l!m"Z"m#Z#m$Z$m%Z%m&Z& dd l'm(Z(m)Z) e$d
Z* ed Z+e
Z,de-d< G d d Z. e j/ d Z0de-d< e j/ d Z1de-d< dbdZ2dcd Z3ej4 ej5 z Z6 ddded(Z7dfd,Z8dgd/Z9dhd3Z: eej; d4d45 ej< ej= d fdid: Z;ej> d;k se s) e?ed< r eej@ d4d45 djd? Z@ej> d;k reAZBde-d@< eAZCde-dA< ej< ZDn+dZDdBe-dC< eeAe df ZBde-d@< eej eAf ZCde-dA< eejE d4d45 eDe
j= d fdkdE ZE eej d4d45 ej< ej= d dfdldH ZdmdKZF eGedLd eGedMd z ZH dndodVZIdpd]ZJ G d^ d2 ZKeKjL M D ]X\ ZNZOeNP d_ seOjQ r"ej ejK fD ]ZR eGeReNd ZSeSr eSjQ r nLeSjQ eO_Q Y G d` daeK ZTdS )q ) annotationsN)index)
AddressFamily
SocketKind)
TYPE_CHECKINGAny AwaitableCallableLiteral
SupportsIndexTypeVarUnionoverload)wraps )_core)Iterable)
TracebackType)Buffer Concatenate ParamSpecSelf TypeAlias)HostnameResolver
SocketFactoryPTr
AddressFormatc 2 e Zd Z dddZdd Zdd ZddZdS ) _try_syncNblocking_exc_override&Callable[[BaseException], bool] | Nonec || _ d S N)_blocking_exc_override)selfr! s E/var/www/fb-scrape/myenv/lib/python3.11/site-packages/trio/_socket.py__init__z_try_sync.__init__@ s '<### exc
BaseExceptionreturnboolc d | j t |t S | | S r$ )r%
isinstanceBlockingIOError)r& r* s r' _is_blocking_io_errorz _try_sync._is_blocking_io_errorF s/ & . c?33 3..s33 3r) Nonec R K t j d {V d S r$ )triolowlevelcheckpoint_if_cancelledr& s r'
__aenter__z_try_sync.__aenter__L s2 m3355555555555r) exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonec K || | rdS t j d {V dS )NTF)r1 r4 r5 cancel_shielded_checkpointr& r9 r; r= s r' __aexit__z_try_sync.__aexit__O sS T%?%? %J%J 4-::<< < < < < < < <5r) r$ )r! r" r* r+ r, r- r, r2 )r9 r: r; r< r= r> r, r- )__name__
__module__ __qualname__r( r1 r8 rB r) r' r r ? sp IM< < < < < 4 4 4 4 6 6 6 6
r) r hostname_resolverz%_core.RunVar[HostnameResolver | None] _resolversocket_factoryz"_core.RunVar[SocketFactory | None]_socket_factoryHostnameResolver | Noner, c n t d }t | |S )a\ Set a custom hostname resolver.
By default, Trio's :func:`getaddrinfo` and :func:`getnameinfo` functions
use the standard system resolver functions. This function allows you to
customize that behavior. The main intended use case is for testing, but it
might also be useful for using third-party resolvers like `c-ares
`__ (though be warned that these rarely make
perfect drop-in replacements for the system resolver). See
:class:`trio.abc.HostnameResolver` for more details.
Setting a custom hostname resolver affects all future calls to
:func:`getaddrinfo` and :func:`getnameinfo` within the enclosing call to
:func:`trio.run`. All other hostname resolution in Trio is implemented in
terms of these functions.
Generally you should call this function just once, right at the beginning
of your program.
Args:
hostname_resolver (trio.abc.HostnameResolver or None): The new custom
hostname resolver, or None to restore the default behavior.
Returns:
The previous hostname resolver (which may be None).
N)rJ getset)rI olds r' set_custom_hostname_resolverrR g s- : --
C
MM#$$$ Jr) SocketFactory | Nonec n t d }t | |S )a Set a custom socket object factory.
This function allows you to replace Trio's normal socket class with a
custom class. This is very useful for testing, and probably a bad idea in
any other circumstance. See :class:`trio.abc.HostnameResolver` for more
details.
Setting a custom socket factory affects all future calls to :func:`socket`
within the enclosing call to :func:`trio.run`.
Generally you should call this function just once, right at the beginning
of your program.
Args:
socket_factory (trio.abc.SocketFactory or None): The new custom
socket factory, or None to restore the default behavior.
Returns:
The previous socket factory (which may be None).
N)rL rO rP )rK rQ s r' set_custom_socket_factoryrU s0 0
d
#
#C''' Jr) hostbytes | str | Noneportbytes | str | int | Nonefamilyinttypeprotoflags]list[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int]]]c
L K d d}t | 4 d{V t j | |||||t z cddd d{V S # 1 d{V swxY w Y t | t
r= | d } n&# t $ r t j | d } Y nw xY wt
d }| | | ||||| d{V S t j
t j | |||||d
d{V S ) aT Look up a numeric address given a name.
Arguments and return values are identical to :func:`socket.getaddrinfo`,
except that this version is async.
Also, :func:`trio.socket.getaddrinfo` correctly uses IDNA 2008 to process
non-ASCII domain names. (:func:`socket.getaddrinfo` uses IDNA 2003, which
can give the wrong result in some cases and cause you to connect to a
different host than the one you intended; see `bpo-17305
`__.)
This function's behavior can be customized using
:func:`set_custom_hostname_resolver`.
r* r+ r, r- c ` t | t j o| j t j k S r$ )r/ _stdlib_socketgaierrorerrno
EAI_NONAME)r* s r' numeric_only_failurez)getaddrinfo..numeric_only_failure s) sN 3 4 4
7 ^ 66
r) NasciiT)uts46abandon_on_cancelrC )r rb getaddrinfo
_NUMERIC_ONLYr/ strencodeUnicodeEncodeError_idnarJ rO r4 to_threadrun_sync)rV rX rZ r\ r] r^ rf hrs r' rk rk s H
-..
) M !
" $ 2 2;;w''DD! 2 2 2 <D111DDD 2
t B ~^^D$eUKKKKKKKKK^,, & " -
s# !A
A A7B
B0/B0sockaddr+tuple[str, int] | tuple[str, int, int, int]tuple[str, str]c K t d }| | | | d{V S t j t j | |d d{V S )a Look up a name given a numeric address.
Arguments and return values are identical to :func:`socket.getnameinfo`,
except that this version is async.
This function's behavior can be customized using
:func:`set_custom_hostname_resolver`.
NTri )rJ rO getnameinfor4 rq rr rb )rt r^ rs s r' rx rx s
t B ~^^He444444444^,, & " -
r) namerm c j K t j t j | d d{V S )zkLook up a protocol number by name. (Rarely used.)
Like :func:`socket.getprotobyname`, but async.
Tri N)r4 rq rr rb getprotobyname)ry s r' r{ r{ sQ ((% ) r) sock_stdlib_socket.socket
SocketTypec t | S )z]Convert a standard library :class:`socket.socket` object into a Trio
socket object.
) _SocketType)r| s r' from_stdlib_socketr / s
t r) rH assignedupdatedfdr AddressFamily | intSocketKind | intc t |||t | \ }}}t t j | ||| S )z=Like :func:`socket.fromfd`, but returns a Trio socket object.)_sniff_sockopts_for_filenor r rb fromfd)r rZ r\ r] type_s r' r r 7 sD 6fdE5QS99UUFE5 n 3Bu M M N NNr) win32 fromshareinfobytesc D t t j | S )z@Like :func:`socket.fromshare`, but returns a Trio socket object.)r rb r )r s r' r r G s ".":4"@"@AAAr) FamilyTTypeTz
Literal[None]
FamilyDefault tuple[SocketType, SocketType]c p t j | || \ }}t | t | fS )zTLike :func:`socket.socketpair`, but returns a pair of Trio socket
objects.
)rb
socketpairr )rZ r\ r] leftrights r' r r W s8 !+FD%@@KD% t $ $&8&?&? @@r) fileno
int | Nonec |4t d }|| | || S nt | ||| \ } }}t j | ||| }t | S )zCreate a new Trio socket, like :class:`socket.socket`.
This function's behavior can be customized using
:func:`set_custom_socket_factory`.
N)rL rO socketr rb r )rZ r\ r] r sf
stdlib_sockets r' r r e s ~
&
&
>99VT511 1 9
e #)&$vFFM m , ,,r) r 1tuple[AddressFamily | int, SocketKind | int, int]c ` t j dk r| ||fS ddlm}m}m}m} t j | ||| } | || } | || }| || }| n# | w xY w| ||fS )zCCorrect SOCKOPTS for given fileno, falling back to provided values.linuxr ) SO_DOMAIN SO_PROTOCOLSO_TYPE
SOL_SOCKET)r )
sysplatformr r r r r rb
getsockoptdetach) rZ r r] r r r r r sockobjs r' r r s |w ue## #FE5HHHG##J ::"":{;;"":w77 5% s AB B(
SOCK_NONBLOCK SOCK_CLOEXECFfn2Callable[Concatenate[_stdlib_socket.socket, P], T]wait_fn2Callable[[_stdlib_socket.socket], Awaitable[None]] maybe_availr- 3Callable[Concatenate[_SocketType, P], Awaitable[T]]c t dd d fd }d
j d|_ |r|xj d j dz
c_ |S )N)rE rH r r& r argsP.argskwargsP.kwargsr, r c 8 K | j g|R i | d {V S r$ )_nonblocking_helper)r& r r r r s r' wrapperz1_make_simple_sock_method_wrapper..wrapper s> -T-grKDKKKFKKKKKKKKKr) zLike :meth:`socket.socket.z`, but async.
z7Only available on platforms where :meth:`socket.socket.z` is available.)r& r r r r r r, r )_wrapsrE __doc__)r r r r s `` r' _make_simple_sock_method_wrapperr s
B 333L L L L L L 43LR[ GO
bk
Nr) r ipv6_v6only
bool | intaddresslocalr c K |t j k r8t |t rt | dk st d n|t j k rAt |t r dt | cxk rdk sn t d ndt t d rM|t j k r=t |t t t j f sJ t j
| S |S |^}}}t |t r1|/ t j || |S # t t" f$ r Y nw xY w|dk rd }|dk rd}d } |r| t j z } |t j k r|s| t j z } t) |||| || d {V }
t |
d
k sJ |
^^ }} }|t j k rot+ | } t | dk sJ t | d k r |d | d< t | dk r |d | d < t | S | S ) N z&address should be a (host, port) tuple z=address should be a (host, port, [flowinfo, [scopeid]]) tupleAF_UNIX z z255.255.255.255r r )rb AF_INETr/ tuplelen
ValueErrorAF_INET6hasattrr rm r osPathLikefspathr[ inet_ptonOSError TypeError
AI_PASSIVE AI_V4MAPPEDrk list)
r rZ r] r r r rV rX _r^ gai_resnormed list_normeds
r' _resolve_address_nocpr s ''''5)) GW 1B1B EFF F 2C >* * *'5)) c'll1G1G1G1Ga1G1G1G1G O
2H
+ + .:P0P0P'C #<=====y!!! ND$ $ !1 $VT 2 2 2 N # D
rzz }
E +
** ((((
++ dFE5%HHHHHHHHG w<<1 La1 (((6ll 6{{a w<<1 $QZKN w<<1 $QZKN[!!! Ms D4 4EEc e Zd Zdl fd ZdmdZdmdZdndZdnd Zedod Z edpd Z dqdrdZ edsd Z
edtd Z
dqdudZ
e e j
d fdvd Zdwd Zdxd!Zej d"k ses ee j d# rdyd%Zdzd'Zd{d.Zed|d0 Zed}d2 Zedmd3 Z edwd4 Z d~d6Z dd7Z dld8Z dd:Z!dd<Z"dwd=Z#dld>Z$dd@Z%ddAZ&dddFZ' dddLZ( dddOZ) dddQZ*ej d"k ses ee j dR r dddUZ+ej d"k ses ee j dV r dddZZ,ddd\Z-edd` Z.edda Z.dddZ.ej d"k ses; ee j de r. e/e j j0 dfdfg dddk Z0 xZ1S xZ1S xZ1S )r~ r, r2 c t t | t u rt d d S )Nz`SocketType is an abstract class; use trio.socket.socket if you want to construct a socket object)superr( r\ r~ r )r& __class__s r' r( zSocketType.__init__" sI
:: # #4
$ #r) r[ c t r$ NotImplementedErrorr7 s r' r zSocketType.detach, !!r) c t r$ r r7 s r' r zSocketType.fileno/ r r) r c t r$ r r7 s r' getpeernamezSocketType.getpeername2 r r) c t r$ r r7 s r' getsocknamezSocketType.getsockname5 r r) leveloptnamec d S r$ rH r& r r s r' r zSocketType.getsockopt8 >Acr) buflenr c d S r$ rH r& r r r s r' r zSocketType.getsockopt; MPSr) Nr int | bytesc t r$ r r s r' r zSocketType.getsockopt> s
"!r) value int | Bufferc d S r$ rH r& r r r s r'
setsockoptzSocketType.setsockoptG TWTWr) optlenc d S r$ rH r& r r r r s r' r zSocketType.setsockoptJ sr) int | Buffer | Nonec t r$ r r s r' r zSocketType.setsockoptT s
"!r) backlogc t r$ r r& r s r' listenzSocketType.listen^ r r) r- c t r$ r r7 s r' get_inheritablezSocketType.get_inheritablea r r) inheritablec t r$ r r& r s r' set_inheritablezSocketType.set_inheritabled r r) r share
process_idc t r$ r r& r s r' r zSocketType.sharek s % %r) r c t r$ r r7 s r' __enter__zSocketType.__enter__n r r) r9 r: r; r< r= r> c t r$ r rA s r' __exit__zSocketType.__exit__q
"!r) r c t r$ r r7 s r' rZ zSocketType.familyy !!r) r c t r$ r r7 s r' r\ zSocketType.type} r r) c t r$ r r7 s r' r] zSocketType.proto r r) c t )zBReturn True if the socket has been shut down with the SHUT_WR flagr r7 s r' did_shutdown_SHUT_WRz SocketType.did_shutdown_SHUT_WR s
"!r) rm c t r$ r r7 s r' __repr__zSocketType.__repr__ r r) c t r$ r r7 s r' dupzSocketType.dup r r) c t r$ r r7 s r' closezSocketType.close r r) r c K t r$ r r& r s r' bindzSocketType.bind !!r) flagc t r$ r r& r$ s r' shutdownzSocketType.shutdown r r) c t )zpReturn True if the socket is readable. This is checked with `select.select` on Windows, otherwise `select.poll`.r r7 s r' is_readablezSocketType.is_readable r r) c K t )zIConvenience method that calls trio.lowlevel.wait_writable for the object.r r7 s r'
wait_writablezSocketType.wait_writable s !!r) tuple[SocketType, AddressFormat]c K t r$ r r7 s r' acceptzSocketType.accept r# r) c K t r$ r r! s r' connectzSocketType.connect r# r) r _SocketType__buflen_SocketType__flagsAwaitable[bytes]c t r$ r _SocketType__selfr1 r2 s r' recvzSocketType.recv r r) bufferr nbytesr^ Awaitable[int]c t r$ r r6 r8 r9 r^ s r' recv_intozSocketType.recv_into r r) _SocketType__bufsize&Awaitable[tuple[bytes, AddressFormat]]c t r$ r r6 r> r2 s r' recvfromzSocketType.recvfrom s
"!r) $Awaitable[tuple[int, AddressFormat]]c t r$ r r< s r'
recvfrom_intozSocketType.recvfrom_into r r) recvmsg_SocketType__ancbufsize?Awaitable[tuple[bytes, list[tuple[int, int, bytes]], int, Any]]c t r$ r r6 r> rG r2 s r' rF zSocketType.recvmsg
& %r) recvmsg_into_SocketType__buffersIterable[Buffer]=Awaitable[tuple[int, list[tuple[int, int, bytes]], int, Any]]c t r$ r r6 rM rG r2 s r' rL zSocketType.recvmsg_into rK r) _SocketType__bytesc t r$ r r6 rR r2 s r' sendzSocketType.send r r) _SocketType__data_SocketType__address!tuple[object, ...] | str | Bufferc
K d S r$ rH r& rV rW s r' sendtozSocketType.sendto
cr) c
K d S r$ rH r& rV r2 rW s r' r[ zSocketType.sendto
cr) r r c K t r$ r )r& r s r' r[ zSocketType.sendto r# r) sendmsgrH r _SocketType__ancdata!Iterable[tuple[int, int, Buffer]]AddressFormat | Nonec K t r$ r r& rM rb r2 rW s r' ra zSocketType.sendmsg s & %r) rD r, r[ r, r r r[ r r[ r, r[ r r[ r r[ r r[ r, r r$ r r[ r r[ r r r, r r r[ r r[ r r r, r2
r r[ r r[ r r2 r r[ r, r2
r r[ r r[ r r r r r, r2 r r[ r, r2 r, r- r r- r, r2 r r[ r, r r, r r9 r: r; r< r= r> r, r2 r, r r, r r, rm r, r~ r r r, r2 r$ r[ r, r2 r, r, r r1 r[ r2 r[ r, r3 r r r8 r r9 r[ r^ r[ r, r: r> r[ r2 r[ r, r? r8 r r9 r[ r^ r[ r, rC r> r[ rG r[ r2 r[ r, rH rM rN rG r[ r2 r[ r, rO rR r r2 r[ r, r: rV r rW rX r, r[ rV r r2 r[ rW rX r, r[ r r r, r[ rH r N
rM rN rb rc r2 r[ rW rd r, r[ )2rE rF rG r( r r r r r r r minrb SOMAXCONNr r r
r r r r r r r r propertyrZ r\ r] r r r r r" r' r) r+ r. r0 r7 r= rB rE rF rL rU r[ r ra
__classcell__)r s @r' r~ r~ ! s5 " " " "" " " "" " " "" " " " AAA XA
PPP XP " " " " " " WWW XW
X "
" " " " " (+s>+CS'I'I " " " " "" " " "" " " " |w %gn&;W E E & & & &" " " "" " " " " " " X" " " " X" " " " X" " " " X"" " " "" " " "" " " "" " " "" " " "" " " "" " " "" " " "" " " "" " " " " " " " " " " " " " " " " " " " |w %gn&;Y G G !" & & & & & |w %gn&;^ L L !" & & & & &" " " " " X X" " " " |w %gn&;Y G G
%-B G G G <> .2 & & & &
H G & & & & & r) __c e Zd Zd|dZd}dZd}dZd~d Zd~d
Zedd
Z edd Z dddZ edd Z
edd Z
ddd Z
e e j
d fdd Zdd!Zdd#Zej d$k ses ee j d% rdd'Zdd)Zdd0Zedd2 Zedd4 Zed}d5 Z edd6 Z dd8Z dd:Z dd;Z dd=Z!dd?Z"dd@Z#ddAZ$ddCZ%ddMZ& e'e j j( e)j* Z+ddOZ(ddPZ,erdddUZ- e'e j j- e)j* Z-er ddd[Z. e'e j j. e)j* Z.er ddd^Z/ e'e j j/ e)j* Z/er ddd`Z0 e'e j j0 e)j* Z0ej d$k ses7 ee j da r&er ddddZ1 e'e j j1 e)j* def Z1ej d$k ses7 ee j dg r&er dddkZ2 e'e j j2 e)j* def Z2erdddmZ3 e'e j j3 e)j$ Z3eddq Z4eddr Z4 e5e j j4 dsdst ddv Z4ej d$k ses9 ee j dw r* e5e j j6 dsdst ddd{ Z6dS dS dS )r r| r} c t | t j ur%t dt | j d || _ | j d d| _ d S )Nz.expected object of type 'socket.socket', not ''F)r\ rb r r rE _sock setblocking_did_shutdown_SHUT_WR)r& r| s r' r( z_SocketType.__init__ sn ::^ 2 2 2 WdATWWW
u%%%%*"""r) r, r[ c 4 | j S r$ )r r r7 s r' r z_SocketType.detach z """r) c 4 | j S r$ )r r r7 s r' r z_SocketType.fileno# r r) r c 4 | j S r$ )r r r7 s r' r z_SocketType.getpeername& z%%'''r) c 4 | j S r$ )r r r7 s r' r z_SocketType.getsockname) r r) r r c d S r$ rH r s r' r z_SocketType.getsockopt, r r) r r c d S r$ rH r s r' r z_SocketType.getsockopt/ r r) Nr r c t || j || S | j ||| S r$ )r r r s r' r z_SocketType.getsockopt2 s; >:((88 8z$$UGV<<} a :((?? ? eueee
z$$UGUFCCCr) r r c 6 | j | S r$ )r r r s r' r z_SocketType.listena s z )))r) r- c 4 | j S r$ )r r r7 s r' r z_SocketType.get_inheritabled s z))+++r) r c 6 | j | S r$ )r r
r s r' r
z_SocketType.set_inheritableg s z))+666r) r r r c 6 | j | S r$ )r r r s r' r z_SocketType.sharen s :##J// /r) r c | S r$ rH r7 s r' r z_SocketType.__enter__q s r) r9 r: r; r< r= r> c : | j ||| S r$ )r r rA s r' r z_SocketType.__exit__t s z""8Y BBBr) r c | j j S r$ )r rZ r7 s r' rZ z_SocketType.family| s
z r) r c | j j S r$ )r r\ r7 s r' r\ z_SocketType.type s z r) c | j j S r$ )r r] r7 s r' r] z_SocketType.proto s
z r) c | j S r$ )r r7 s r' r z _SocketType.did_shutdown_SHUT_WR s ))r) rm c R t | j dd S )Nz
socket.socketztrio.socket.socket)reprr replacer7 s r' r z_SocketType.__repr__ s# DJ ''9MNNNr) r~ c N t | j S )z"Same as :meth:`socket.socket.dup`.)r r r r7 s r' r z_SocketType.dup s 4:>>++,,,r) c | j dk r?t j | j | j d S d S )N)r r r4 r5 notify_closingr r7 s r' r z_SocketType.close sU : " $ $ M ( ( 4 4 4 J % $r) r c K | |d d {V }t t d rM| j t j k r8|d r0t
j | j j | d {V S t
j
d {V | j | S )NTr r r ) r r rb rZ r r4 rq rr r r" r5
checkpointr! s r' r" z_SocketType.bind s 227$2GGGGGGGG NI . . , ~ 555
6
00 'JJJJJJJJ J -**,, , , , , , , ,:??7++ +r) r$ c | j | |t j t j fv r d| _ d S d S )NT)r r' rb SHUT_WR SHUT_RDWRr r& s r' r' z_SocketType.shutdown sE
D!!! N*N,DE E E)-D & & & F Er) c 6 t j dk r0t j | j gg g d \ }}}t | S t j }| | j t j t | d S )Nr r )r r selectr r- pollregisterPOLLIN)r& rreadyr ps r' r) z_SocketType.is_readable ss <7 " "!=$* r2qAALFAq<< KMM
4:v}---AFF1II r) c H K t j | j d {V d S r$ )r r+ r r7 s r' r+ z_SocketType.wait_writable s1 !$*-----------r) r c K | j t j k r0| j t j t j }nd}t | j | j | j ||| d {V S )NF)r r r )
rZ rb r r r IPPROTO_IPV6 IPV6_V6ONLYr r\ r] )r& r r r s r' r z!_SocketType._resolve_address_nocp s ;.1 1 1 *// + * KK
K* I K J#
r) r r r r r r r r r c K t 4 d {V || j g|R i |cd d d d {V S # 1 d {V swxY w Y || j d {V || j g|R i |S # t $ r Y nw xY w9r$ )r r r0 )r& r r r r s r' r z _SocketType._nonblocking_helper sZ 8 ;; 3 3 3 3 3 3 3 32dj24222622 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 '$*%% % % % % % % %
r$*6t666v666"
s! ;
AA$A5 5
BBr, c b K | d{V \ }}t | |fS )z-Like :meth:`socket.socket.accept`, but async.N)_acceptr )r& r| addrs r' r. z_SocketType.accept s< <<>>))))))
d!$''--r) c > K | |d d {V }t 4 d {V | j | cd d d d {V S # 1 d {V swxY w Y t j | j d {V n-# t j $ r | j w xY w| j t j t j }|dk r(t |d|dt j | d S )NFr r zError connecting to z: )r r r r0 r r+ r4 Cancelledr r rb r SO_ERRORr r strerror)r& r errs r' r0 z_SocketType.connect s
; 6 6we 6 L LLLLLLLG {{ 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3` z))'22a0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3 0
3f %dj11 1 1 1 1 1 1 1 1~
J j##N$=~?VWW !88# Ug U U2;sCSCS U UVV V 8s. 1B A"B "
A,,B /A,0"B *B=r r1 r2 r3 c d S r$ rH r5 s r' r7 z_SocketType.recva r) r8 r r9 r^ r: c d S r$ rH r< s r' r= z_SocketType.recv_intoq s
!Sr) r> r? c d S r$ rH rA s r' rB z_SocketType.recvfrom s 69Sr) rC c d S r$ rH r< s r' rE z_SocketType.recvfrom_into s
473r) rF rG rH c d S r$ rH rJ s r' rF z_SocketType.recvmsg s
SVRUr) T)r rL rM rN rO c d S r$ rH rQ s r' rL z_SocketType.recvmsg_into s
QTPSr) rR c d S r$ rH rT s r' rU z_SocketType.send r r) rV rW rX c
K d S r$ rH rZ s r' r[ z_SocketType.sendto r\ r) c
K d S r$ rH r^ s r' r[ z_SocketType.sendto r_ r) rH r r c K t | }| |d d d{V |d< | j t j t
j j g|R d{V S )z3Similar to :meth:`socket.socket.sendto`, but async.r Fr N)r r r r r+ rb r r[ )r& r args_lists r' r[ z_SocketType.sendto s
JJ " 8 8b 8 O OOOOOOO "
.T- ! (
r) ra rb rc rd c K | | |d d{V }| t j t j j |||| d{V S )zSimilar to :meth:`socket.socket.sendmsg`, but async.
Only available on platforms where :meth:`socket.socket.sendmsg` is
available.
NFr )r r r r+ rb r ra rf s r' ra z_SocketType.sendmsg s $"&"<"+CS'I'I * * * * *, , , ,7 7 7 7 |w %gn&;W E E 0 0 0 0 C C C C ! ! ! X! X X * * * X*O O O O- - - -
, , , ,$. . . . . . . .
8$ $ $ $T /. $
G
. . . .DW DW DW DW\ SRRRRR
, + "
D !
! ! ! ! ! 10 '
I 9
9 9 9 9 9 0/ &
H 7
7 7 7 7 7 54 +
M |w %gn&;Y G G V
%&
V
V
V
V
V 32 ! )
|w %gn&;^ L L T
%&
T
T
T
T
T 87 ! .
SRRRRR + + "
D X X VN ! (2rBBB
CB
$ |w %gn&;Y G G
%-B G G G <> .2
H G r) r )rI rM r, rM )rK rS r, rS )r r r r )rV rW rX rY rZ r[ r\ r[ r] r[ r^ r[ r, r_ )rt ru r^ r[ r, rv )ry rm r, r[ )r| r} r, r~ )
r r rZ r r\ r r] r[ r, r~ )r r r, r~ )rZ r r\ r r] r[ r, r )
rZ r r\ r r] r[ r r r, r~ )
rZ r r r r] r[ r r r, r )F)r r r r r r- r, r )r r[ rZ r r] r[ r r r r r r- r, r )U
__future__r r r r rb r operatorr r r typingr r r r
r r r
r r idnarp r4
trio._utilr r r r collections.abcr typesr typing_extensionsr r r r r _abcr r r r r __annotations__r RunVarrJ rL rR rU AI_NUMERICHOSTAI_NUMERICSERVrl rk rx r{ r r r SOCK_STREAMr r r r[ r r r r r getattr_SOCK_TYPE_MASKr r r~ __dict__itemsry obj
startswithr stdlib_type
stdlib_objr rH r) r' r s " " " " " " "
, , , , , , , ,
& & & & & & ((((((######QQQQQQQQQQQQQQ55555555 #A GCLL
H 4@5<@S3T3T T T T T6BelCS6T6T T T T T D B -0MM
P
P
P
P
P
f
2
* B777 #1"8 + 7 O O O O 87O <7 !'.+>> VN $r2>>>B B B ?>B
<7 G E"*MM#'M'''' sM4 78G8888 ^ 2C 78E8888 !B;;;# (
A
A
A
A <;
A B777"0"8 + 7 - - - - 87-6 T GNOQ//
gnna001 NG G G GT\& \& \& \& \& \& \& \&@ $**,, % %ID# t %,n.GG W[$55
*, E $CKKK K K K K* K K K K Kr)