"dz0ddlZddlmZddlmZddlmZmZddlmZddl m Z ddl m Z m Z mZmZmZmZmZmZmZmZmZmZdd lmZmZmZd d lmZmZmZm Z d d l!m"Z"ee#eefZ$ee#e%fZ&ee&e#fZ'ee(e&fZ)ed Z*GddZ+GddeZ,GddeZ-Gddee-Z.Gdde.Z/Gddee.e-Z0Gdde e)e-Z1Gdde e(e-Z2dS)N)abstractmethod)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType) AnyAsyncContextManagerCallable CollectionDictListMappingOptionalTupleTypeTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerT_StreamUnreliableObjectStream) TaskGroupT_Retvalc jeZdZddZdeeedeedeedeefdZ dS) _NullAsyncContextManagerreturnNc KdSNselfs 6D:\api_v1\venv\Lib\site-packages\anyio/abc/_sockets.py __aenter__z#_NullAsyncContextManager.__aenter__&s  exc_typeexc_valexc_tbc KdSr$r%)r'r+r,r-s r( __aexit__z"_NullAsyncContextManager.__aexit__)s tr*)r"N) __name__ __module__ __qualname__r)rr BaseExceptionrboolr/r%r*r(r!r!%sz    4 ./-('  $ r*r!ceZdZUeZeed<eZeed<eZ e ed<eZ e j ed<eZ eed<eZe ed<dS)SocketAttributefamily local_address local_port raw_socketremote_address remote_portN)r0r1r2rr7r__annotations__r8 SockAddrTyper9intr:socketr;r<r%r*r(r6r62s+O--FM---"1/"3"3M<333%o''J''' / 1 1J 111#2?#4#4NL444&((K(((((r*r6ceZdZedeeegefffdZeede j fdZ dS)_SocketProviderr"cddlmtjfdtjfdtjfdi} jn#t$rdYnwxYwfd|tj <jjtj tj fvr.fd|tj <dfd |tj<|S) Nr)convert_ipv6_sockaddrcjjSr$) _raw_socketr7r&sr(z2_SocketProvider.extra_attributes..Gs D,<,Cr*cHjSr$rF getsockname)convertr'sr(rGz2_SocketProvider.extra_attributes..Hs%77 ,,..44r*cjSr$)rFr&sr(rGz2_SocketProvider.extra_attributes..Ks 0@r*cSr$r%)peernamesr(rGz2_SocketProvider.extra_attributes..Vsr*cBjdS)NrrIr&sr(rGz2_SocketProvider.extra_attributes..\s(4466q9r*rcSr$r%)r<sr(rGz2_SocketProvider.extra_attributes.._s+r*)_core._socketsrDr6r7r8r:rF getpeernameOSErrorr;rAF_INETAF_INET6r9r<)r' attributesrKrNr<s` @@@r(extra_attributesz _SocketProvider.extra_attributesBs=EEEEEE  "$C$C$C$C  ),,,,,  &(@(@(@(@ 4  29' ,,..33HH   HHH   9I9I9I9IJ5 6   "}'T&U U U:999 * #&qk :M:M:M:M ?67s"A A.-A.cdSr$r%r&s r(rFz_SocketProvider._raw_socketcs  r*N) r0r1r2propertyrr r rWrr@rFr%r*r(rBrBAs '#xC/@*@"AX@ V]   ^X   r*rBceZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr0r1r2__doc__r%r*r(r[r[ir*r[c eZdZededeeeefddfdZ ededede ee effdZ dS) UNIXSocketStreammessagefdsr"Nc KdS)z Send file descriptors along with a message to the peer. :param message: a non-empty bytestring :param fds: a collection of files (either numeric file descriptors or open file or socket objects) Nr%)r'rarbs r(send_fdszUNIXSocketStream.send_fdsr r*msglenmaxfdsc KdS)a Receive file descriptors along with a message from the peer. :param msglen: length of the message to expect from the peer :param maxfds: maximum number of file descriptors to expect from the peer :return: a tuple of (message, file descriptors) Nr%)r'rfrgs r( receive_fdszUNIXSocketStream.receive_fds~rer*) r0r1r2rbytesr rr?rrdrrrir%r*r(r`r`qs    #-eCK.@#A      ^    S U5$s)CS=T   ^   r*r`cdeZdZdZedefdZ ddeege fde e ddfdZ dS) SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r"c KdS)zAccept an incoming connection.Nr%r&s r(acceptzSocketListener.acceptrer*Nhandler task_groupcKddlm}| |x}}nt}|4d{V |d{V}|||1#1d{VswxYwYdS)Nr)create_task_group)rrr!rn start_soon)r'rorprrcontext_managerstreams r(servezSocketListener.serves )(((((  +<+<+>+> >J788O" 7 7 7 7 7 7 7 7 7#{{}},,,,,,%%gv666 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s3A!! A+.A+r$) r0r1r2r]rr[rnr rr rrrwr%r*r(rlrls -l---^-UY77 C07>Fy>Q7 777777r*rlc*eZdZdZdedededdfdZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datahostportr"NcDK||||ffd{VS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r'rzr{r|s r(sendtozUDPSocket.sendtos3YYtTl3444444444r*)r0r1r2r]rjstrr?rr%r*r(ryrysN 55c55555555r*ryceZdZdZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr\r%r*r(rrr^r*r)3r@abcrior ipaddressrrrtypesrtypingr r r r r rrrrrrr_core._typedattrrrr_streamsrrrr_tasksrr IPAddressTyper?IPSockAddrTyper>rj UDPPacketTyperr!r6rBr[r`rlryrr%r*r(rs$ ........                              MLLLLLLLLLLLc; 34 sCx^S() e^+, 7:           ) ) ) ) )' ) ) )% % % % % ,% % % P:     |   077777Xl+_777: 5 5 5 5 5&}5 5 5 5/6r*