g T U d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm Z m
Z
d dl m Z m
Z
mZmZmZmZ d dlZd dlZd dlmZ ddlmZ e r1d d lmZm Z 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- ej. d Z/de,d< ej. d Z0de,d< dadZ1dbd Z2ej3 ej4 z Z5 dcddd(Z6ded,Z7dfd/Z8dgd3Z9 eej: d4d45 ej; ej< d fdhd: Z:ej= d;k se s) e>ed< r eej? d4d45 did? Z?ej= d;k re@ZAde,d@< e@ZBde,dA< ej; ZCn+dZCdBe,dC< ee@e df ZAde,d@< eej e@f ZBde,dA< eejD d4d45 eCe
j< d fdjdE ZD eej d4d45 ej; ej< d dfdkdH ZdldKZE eFedLd eFedMd z ZG dmdndVZHdod\ZI G d] d2 ZJeJjK L D ]X\ ZMZNeMO d^ seNjP r"ej ejJ fD ]ZQ eFeQeMd ZReRr eRjP r nLeRjP eN_P Y G d_ d`eJ ZSdS )p ) annotationsN)index)
AddressFamily
SocketKind)
TYPE_CHECKINGAny
SupportsIndexTypeVarUnionoverload)wraps )_core) AwaitableCallableIterable)
TracebackType)Buffer Concatenate ParamSpecSelf TypeAlias)HostnameResolver
SocketFactoryPTr
AddressFormatc 2 e Zd Z dddZdd
Zdd ZddZdS ) _try_syncNblocking_exc_override&Callable[[BaseException], bool] | NonereturnNonec || _ d S N)_blocking_exc_override)selfr s X/var/www/html/nodeJS/PythonScripts/venv3.11/lib/python3.11/site-packages/trio/_socket.py__init__z_try_sync.__init__= s '<### exc
BaseExceptionboolc d | j t |t S | | S r% )r&
isinstanceBlockingIOError)r' r+ s r( _is_blocking_io_errorz _try_sync._is_blocking_io_errorC s/ & . c?33 3..s33 3r* c R K t j d {V d S r% )triolowlevelcheckpoint_if_cancelledr' s r(
__aenter__z_try_sync.__aenter__I s2 m3355555555555r* exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonec K || | rdS t j d {V dS )NTF)r1 r3 r4 cancel_shielded_checkpointr' r8 r: r< s r( __aexit__z_try_sync.__aexit__L sS T%?%? %J%J 4-::<< < < < < < < <5r* r% )r r! r" r# r+ r, r" r- r" r# )r8 r9 r: r; r< r= r" r- )__name__
__module__ __qualname__r) r1 r7 rA 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)rI getset)rH olds r( set_custom_hostname_resolverrQ d 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)rK rN rO )rJ rP s r( set_custom_socket_factoryrT s0 0
d
#
#C''' Jr* hostbytes | str | Noneportbytes | str | int | Nonefamilyinttypeprotoflagsqlist[tuple[AddressFamily, SocketKind, int, str, tuple[str, int] | tuple[str, int, int, int] | tuple[int, bytes]]]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_cancelrB )r ra getaddrinfo
_NUMERIC_ONLYr/ strencodeUnicodeEncodeError_idnarI rN r3 to_threadrun_sync)rU rW rY r[ r\ r] re hrs r( rj rj 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`.
NTrh )rI rN getnameinfor3 rp rq ra )rs r] rr s r( rw rw s
t B ~^^He444444444^,, & " -
r* namerl 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.
Trh N)r3 rp rq ra getprotobyname)rx s r( rz rz 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* rG 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 ra fromfd)r rY r[ r\ type_s r( r r 4 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 ra r )r s r( r r D s ".":4"@"@AAAr* FamilyTTypeTr#
FamilyDefault tuple[SocketType, SocketType]c p t j | || \ }}t | t | fS )zTLike :func:`socket.socketpair`, but returns a pair of Trio socket
objects.
)ra
socketpairr )rY r[ r\ leftrights r( r r T 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)rK rN socketr ra r )rY r[ r\ r sf
stdlib_sockets r( r r b 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 ra
getsockoptdetach) rY 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)rD rG 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 )_wrapsrD __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 | intaddresslocalc 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 )ra AF_INETr/ tuplelen
ValueErrorAF_INET6hasattrr rl r osPathLikefspathrZ inet_ptonOSError TypeError
AI_PASSIVE AI_V4MAPPEDrj list)
r rY r\ r r r rU rW _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 Zdh fd ZdidZdidZdjdZdjd Zedkd Z edld Z dmdndZ edod Z
edpd Z
dmdqdZ
e e j
d fdrd Zdsd Zdtd!Zej d"k ses ee j d# rdud%Zdvd'Zdwd.Zedxd0 Zedyd2 Zedid3 Z edsd4 Z dzd6Z d{d7Z dhd8Z d|d:Z!d}d<Z"dsd=Z#dhd>Z$d~d@Z%d|dAZ&dddEZ' dddJZ( dddMZ) dddOZ*ej d"k ses ee j dP r dddSZ+ej d"k ses ee j dT r dddXZ,dddYZ-edd\ Z.edd] Z.dd`Z.ej d"k ses; ee j da r. e/e j j0 dbdbc dddg Z0 xZ1S xZ1S xZ1S )r} r" r# 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* rZ c t r% NotImplementedErrorr6 s r( r zSocketType.detach) !!r* c t r% r r6 s r( r zSocketType.fileno, r r* r c t r% r r6 s r( getpeernamezSocketType.getpeername/ r r* c t r% r r6 s r( getsocknamezSocketType.getsockname2 r r* leveloptnamec d S r% rG r' r r s r( r zSocketType.getsockopt5 ;>3r* buflenr c d S r% rG r' r r r s r( r zSocketType.getsockopt8 JM#r* Nr int | bytesc t r% r r s r( r zSocketType.getsockopt;
"!r* value int | Bufferc d S r% rG r' r r r s r(
setsockoptzSocketType.setsockoptC QTQTr* optlenc d S r% rG r' r r r r s r( r zSocketType.setsockoptF sr* int | Buffer | Nonec t r% r r s r( r zSocketType.setsockoptO s
"!r* backlogc t r% r r' r s r( listenzSocketType.listenX r r* r- c t r% r r6 s r( get_inheritablezSocketType.get_inheritable[ r r* inheritablec t r% r r' r s r( set_inheritablezSocketType.set_inheritable^ r r* r share
process_idc t r% r r' r s r( r zSocketType.sharee s % %r* r c t r% r r6 s r( __enter__zSocketType.__enter__h r r* r8 r9 r: r; r< r= c t r% r r@ s r( __exit__zSocketType.__exit__k r r* r c t r% r r6 s r( rY zSocketType.familys !!r* r c t r% r r6 s r( r[ zSocketType.typew r r* c t r% r r6 s r( r\ zSocketType.proto{ r r* c t )zBReturn True if the socket has been shut down with the SHUT_WR flagr r6 s r( did_shutdown_SHUT_WRz SocketType.did_shutdown_SHUT_WR s
"!r* rl c t r% r r6 s r( __repr__zSocketType.__repr__ r r* c t r% r r6 s r( dupzSocketType.dup r r* c t r% r r6 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 r6 s r( is_readablezSocketType.is_readable r r* c K t )zIConvenience method that calls trio.lowlevel.wait_writable for the object.r r6 s r(
wait_writablezSocketType.wait_writable s !!r* tuple[SocketType, AddressFormat]c K t r% r r6 s r( acceptzSocketType.accept r" r* c K t r% r r s r( connectzSocketType.connect r" r* r r] Awaitable[bytes]c t r% r r' r r] s r( recvzSocketType.recv r r* bufferr nbytesAwaitable[int]c t r% r r' r4 r5 r] s r( recv_intozSocketType.recv_into r r* bufsize&Awaitable[tuple[bytes, AddressFormat]]c t r% r r' r: r] s r( recvfromzSocketType.recvfrom r r* $Awaitable[tuple[int, AddressFormat]]c t r% r r8 s r(
recvfrom_intozSocketType.recvfrom_into r r* recvmsg
ancbufsizeBAwaitable[tuple[bytes, list[tuple[int, int, bytes]], int, object]]c t r% r r' r: rC r] s r( rB zSocketType.recvmsg
& %r* recvmsg_intobuffersIterable[Buffer]@Awaitable[tuple[int, list[tuple[int, int, bytes]], int, object]]c t r% r r' rI rC r] s r( rH zSocketType.recvmsg_into rG r* c t r% r r' r r] s r( sendzSocketType.send r r* data!tuple[object, ...] | str | Bufferc
K d S r% rG r' rQ r s r( sendtozSocketType.sendto
cr* c
K d S r% rG r' rQ r] r s r( rU zSocketType.sendto
cr* r objectc K t r% r )r' r s r( rU zSocketType.sendto r" r* sendmsgrG r ancdata!Iterable[tuple[int, int, Buffer]]AddressFormat | Nonec K t r% r r' rI r] r] r s r( r\ zSocketType.sendmsg s & %r* rC r" rZ r" r r rZ r rZ r" rZ r rZ r rZ r rZ r" r r% r rZ r rZ r r r" r r rZ r rZ r r r" r#
r rZ r rZ r r# r rZ r" r#
r rZ r rZ r r r r r" r# r rZ r" r# r" r- r r- r" r# r rZ r" r r" r r8 r9 r: r; r< r= r" r# r" r r" r r" rl r" r} r r r" r# r# rZ r" r# r" r+ r r rZ r] rZ r" r0 r r r4 r r5 rZ r] rZ r" r6 r: rZ r] rZ r" r; r4 r r5 rZ r] rZ r" r? r: rZ rC rZ r] rZ r" rD rI rJ rC rZ r] rZ r" rK r r r] rZ r" r6 rQ r r rR r" rZ rQ r r] rZ r rR r" rZ r rZ r" rZ rG r N
rI rJ r] r^ r] rZ r r_ r" rZ )2rD rE rF r) r r r r r r r minra SOMAXCONNr r r
r r r r r r r r propertyrY r[ r\ r r r r r! r& r( r* r- r/ r3 r9 r> rA rB rH rP rU r r\
__classcell__)r s @r( r} r} s5 " " " "" " " "" " " "" " " " >>> X>
MMM XM " " " " " " TTT XT
X " " " " " " %(C(@#$F$F " " " " "" " " "" " " " |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 :<,0 & & & &
H G & & & & & r* __c e Zd ZdxdZdydZdydZdzd
Zdzd Zed{d Z ed|d Z d}d~dZ edd Z
edd Z
d}dd Z
e e j
d fdd Zdd!Zdd#Zej d$k ses ee j d% rdd'Zdd)Zdd0Zedd2 Zedd4 Zedyd5 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,erdddTZ- e'e j j- e)j* Z-er dddYZ. 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 d_ r&er dddbZ1 e'e j j1 e)j* dcd Z1ej d$k ses7 ee j de r&er dddiZ2 e'e j j2 e)j* dcd Z2erdddjZ3 e'e j j3 e)j$ Z3eddm Z4eddn Z4 e5e j j4 dodop ddr Z4ej d$k ses9 ee j ds r* e5e j j6 dodop dddw Z6dS dS dS )r r{ 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[ ra r r rD _sock setblocking_did_shutdown_SHUT_WR)r' r{ s r( r) z_SocketType.__init__ sn ::^ 2 2 2 WdATWWW
u%%%%*"""r* rZ c 4 | j S r% )r r r6 s r( r z_SocketType.detach z """r* c 4 | j S r% )r r r6 s r( r z_SocketType.fileno" r r* r c 4 | j S r% )r r r6 s r( r z_SocketType.getpeername% z%%'''r* c 4 | j S r% )r r r6 s r( r z_SocketType.getsockname( r r* r r c d S r% rG r s r( r z_SocketType.getsockopt+ r r* r r c d S r% rG 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.getsockopt1 s; >:((88 8z$$UGV<< r r* r c |-|t d | j ||| S |t d|d | j |||| S )NzKinvalid value for argument 'value', must not be None when specifying optlenz$invalid value for argument 'value': z%, must be None when specifying optlen)r r r r s r( r z_SocketType.setsockoptG s >} a :((?? ? eueee
z$$UGUFCCCr* r r c 6 | j | S r% )r r r s r( r z_SocketType.listen] s z )))r* r- c 4 | j S r% )r r r6 s r( r z_SocketType.get_inheritable` s z))+++r* r c 6 | j | S r% )r r
r s r( r
z_SocketType.set_inheritablec s z))+666r* r r r c 6 | j | S r% )r r r s r( r z_SocketType.sharej s :##J// /r* r c | S r% rG r6 s r( r z_SocketType.__enter__m s r* r8 r9 r: r; r< r= c : | j ||| S r% )r r r@ s r( r z_SocketType.__exit__p s z""8Y BBBr* r c | j j S r% )r rY r6 s r( rY z_SocketType.familyx s
z r* r c | j j S r% )r r[ r6 s r( r[ z_SocketType.type| s z r* c | j j S r% )r r\ r6 s r( r\ z_SocketType.proto s
z r* c | j S r% )r r6 s r( r z _SocketType.did_shutdown_SHUT_WR s ))r* rl c R t | j dd S )Nz
socket.socketztrio.socket.socket)reprr replacer6 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 r6 s r( r z_SocketType.dup s 4:>>++,,,r* c | j dk r?t j | j | j d S d S )N)r r r3 r4 notify_closingr r6 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 ra rY r r3 rp rq r r! r4
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& ra 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 r6 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 )
rY ra 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 r/ r r* r3 Cancelledr r ra r SO_ERRORr r strerror)r' r errs r( r/ 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 r] r0 c d S r% rG r2 s r( r3 z_SocketType.recv] r* r4 r r5 r6 c d S r% rG r8 s r( r9 z_SocketType.recv_intoj s !Sr* r: r; c d S r% rG r= s r( r> z_SocketType.recvfrom} s
69Sr* r? c d S r% rG r8 s r( rA z_SocketType.recvfrom_into s 473r* rB rC rD c d S r% rG rF s r( rB z_SocketType.recvmsg s VYUXr* T)r rH rI rJ rK c d S r% rG rM s r( rH z_SocketType.recvmsg_into s TWSVr* c d S r% rG rO s r( rP z_SocketType.send r r* rQ rR c
K d S r% rG rT s r( rU z_SocketType.sendto rV r* c
K d S r% rG rX s r( rU z_SocketType.sendto rY r* rG r rZ 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* ra r rU )r' r args_lists r( rU z_SocketType.sendto s
JJ " 8 8b 8 O OOOOOOO "
.T- ! (
r* r\ r] r^ r_ 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* ra r r\ ra s r( r\ z_SocketType.sendmsg s " $ : :7% : P PPPPPPP 11# %-
r* )r{ r| r" r# rb rc rd re r% rf rg rh ri rj rk rl rm rn ro rp rq rr rs rC rt ru )r r r r- r" r )
r r r r r r r r r" r rv rw rx ry rz r{ r| r} r~ r r r r r r )7rD rE rF r) r r r r r r r r ra r r r r
r r r r r r r r r rY r[ r\ r r r r r! r& r( r* r r r r- r
wait_readabler r/ r3 r9 r> rA rB rH rP rU r r\ rG r* r( r r s + + + + # # # ## # # #( ( ( (( ( ( ( >>> X>
MMM XM " = = = = = TTT XT
X " D D D D D, %(C(@#$F$F * * * * *, , , ,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\ POOOOO + + "
D ! ! ! ! ! ! 10 '
I 9
9 9 9 9 9 0/ &
H 7 7 7 7 7 7 54 +
M |w %gn&;Y G G Y
#$
Y
Y
Y
Y
Y 32 ! )
|w %gn&;^ L L W
#$
W
W
W
W
W 87 ! .
POOOOO + + "
D X X VN ! (2rBBB
CB
$ |w %gn&;Y G G
%-B G G G :<,0
H G r* r )rH rL r" rL )rJ rR r" rR )r r r r )rU rV rW rX rY rZ r[ rZ r\ rZ r] rZ r" r^ )rs rt r] rZ r" ru )rx rl r" rZ )r{ r| r" r} )
r r rY r r[ r r\ rZ r" r} )r r r" r} )rY r r[ r r\ rZ r" r )
rY r r[ r r\ rZ r r r" r} )
rY r r r r\ rZ r r r" r )F)r r r r r r- r" r )r rZ rY r r\ rZ r r r r r r- r" r )T
__future__r r r r ra r operatorr r r typingr r r r
r r idnaro r3
trio._utilr
r r r collections.abcr r r typesr typing_extensionsr r r r r _abcr r r r r __annotations__r RunVarrI rK rQ rT AI_NUMERICHOSTAI_NUMERICSERVrk rj rw rz r r r SOCK_STREAMr r r rZ r r r r r getattr_SOCK_TYPE_MASKr r r} __dict__itemsrx obj
startswithr stdlib_type
stdlib_objr rG 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^& ^& ^& ^& ^& ^& ^& ^&D $**,, % %ID# t %,n.GG W[$55
*, E $CKKM M M M M* M M M M Mr*