Q}bg}ddlmZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZddlmZdd lmZdd lmZmZmZmZd d lmZmZmZd dlmZmZmZd dl m!Z!ee"eefZ#ee"e$fZ%ee%e"fZ&ee'e%fZ(ee'e"fZ)edZ*GddZ+GddeZ,GddeZ-Gddee-Z.Gdde.Z/Gddee.e-Z0Gddee(e-Z1Gdd ee'e-Z2Gd!d"ee)e-Z3Gd#d$ee'e-Z4dS)%) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType)AnyTupleTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_RetvalceZdZd dZdd Zd S)_NullAsyncContextManagerreturnNonec KdSNselfs e/home/e360mart.nyusoft.in/public_html/e360mart_env/lib/python3.11/site-packages/anyio/abc/_sockets.py __aenter__z#_NullAsyncContextManager.__aenter__s  exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | Nonec KdSr!r")r$r(r*r,s r% __aexit__z"_NullAsyncContextManager.__aexit__!s tr'N)rr)r(r)r*r+r,r-rr.)__name__ __module__ __qualname__r&r0r"r'r%rrs<    r'rceZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <d S) SocketAttributer family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) r1r2r3rr6__annotations__r8r:r<r=r>r"r'r%r5r5*s+O--F----"1/"3"3M3333%o''J'''' / 1 1J1111#2?#4#4N4444&((K((((((r'r5cNeZdZeddZeeddZdS) _SocketProviderrMapping[Any, Callable[[], Any]]cddlmtjfdtjfdtjfdi} jn#t$rdYnwxYwfd|tj <jjtj tj fvr.fd|tj <dfd |tj<|S) Nr)convert_ipv6_sockaddrcjjSr!) _raw_socketr6r#sr%z2_SocketProvider.extra_attributes..?s D,<,Cr'cHjSr!rF getsockname)convertr$sr%rGz2_SocketProvider.extra_attributes..@s%77 ,,..44r'cjSr!)rFr#sr%rGz2_SocketProvider.extra_attributes..Cs 0@r'cSr!r")peernamesr%rGz2_SocketProvider.extra_attributes..Lsr'cBjdS)NrrIr#sr%rGz2_SocketProvider.extra_attributes..Qs(4466q9r'rcSr!r")r>sr%rGz2_SocketProvider.extra_attributes..Us+r')_core._socketsrDr5r6r8r<rF getpeernameOSErrorr=r AF_INETAF_INET6r:r>)r$ attributesrKrNr>s` @@@r%extra_attributesz _SocketProvider.extra_attributes:s1EEEEEE  "$C$C$C$C  ),,,,,  &(@(@(@(@ 4  /6wt7G7S7S7U7U/V/VHH   HHH   9I9I9I9IJ5 6   "}'T&U U U9999 1 2#&qk :M:M:M:M ?67s"A A.-A.r;cdSr!r"r#s r%rFz_SocketProvider._raw_socketYs  r'N)rrB)rr;)r1r2r3propertyrWrrFr"r'r%rArA9s\ X<   ^X   r'rAceZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr1r2r3__doc__r"r'r%r[r[_r'r[c>eZdZeddZedd Zd S)UNIXSocketStreammessagebytesfdsCollection[int | IOBase]rrc 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$rarcs r%send_fdszUNIXSocketStream.send_fdsh r'msglenr9maxfdstuple[bytes, list[int]]c 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$rhris r% receive_fdszUNIXSocketStream.receive_fdsrrgr'N)rarbrcrdrr)rhr9rir9rrj)r1r2r3rrfrlr"r'r%r`r`gsR   ^    ^   r'r`c6eZdZdZed dZ d dd ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rr[c KdS)zAccept an incoming connection.Nr"r#s r%acceptzSocketListener.acceptrgr'NhandlerCallable[[SocketStream], Any] task_groupTaskGroup | NonercKddlm}t4d{V}|#||d{V} |d{V}|||1#1d{VswxYwYdS)Nr)create_task_group)rvrenter_async_contextrp start_soon)r$rqrsrvstackstreams r%servezSocketListener.serves )(((((!## 7 7 7 7 7 7 7u!#(#<#<=N=N=P=P#Q#QQQQQQQ  7#{{}},,,,,,%%gv666 7  7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7sAA55 A?A?)rr[r!)rqrrrsrtrr)r1r2r3r]rrpr|r"r'r%rnrn}s\ ---^- (, 7 7 7 7 7 7 7r'rnceZdZdZd d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarbhoststrportr9rrcDK||||ffd{VS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r$rrrs r%sendtozUDPSocket.sendtos5 YYtTl3444444444r'N)rrbrrrr9rrr1r2r3r]rr"r'r%r~r~s2 555555r'r~ceZdZdZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr\r"r'r%rrr^r'rceZdZdZd dZd S) UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rrbpathrrrc@K|||fd{VS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r$rrs r%rzUNIXDatagramSocket.sendtos.YYd|,,,,,,,,,r'N)rrbrrrrrr"r'r%rrs2 ------r'rceZdZdZdS)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr\r"r'r%rrr^r'r)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingrrrr_core._typedattrrrr_streamsrrr_tasksrr IPAddressTyper9IPSockAddrTyper7rb UDPPacketTypeUNIXDatagramPacketTyperrr5rAr[r`rnr~rrrr"r'r%rsl"""""" 9999999999%%%%%%........ ------------ CBBBBBBBBBc; 34 sCx^S() e^+, ucz* 7:           ) ) ) ) )' ) ) )# # # # # ,# # # L:     |   ,77777Xl+_7776 5 5 5 5 5&}5 5 5 5/6 - - - - -12O - - -"8"?r'