MhvddlmZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZddlmZdd lmZdd lmZmZmZd d lmZmZmZd dlmZmZmZd dlm Z ee!eefZ"e#e!e$fZ%ee%e!fZ&e#e'e%fZ(e#e'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)AnyTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_RetvalceZdZd dZdd Zd S)_NullAsyncContextManagerreturnNonec KdSNselfs R/var/www/html/test/jupyter/venv/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%r/r!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) r0r1r2rr5__annotations__r7r9r;r<r=r!r&r$r4r4*s+O--F----"1/"3"3M3333%o''J'''' / 1 1J1111#2?#4#4N4444&((K((((((r&r4cNeZdZeddZeeddZdS) _SocketProviderrMapping[Any, Callable[[], Any]]cddlmtjfdtjfdtjfdi} jn#t$rdYnwxYwfd|tj <jjtj tj fvr.fd|tj <dfd |tj<|S) Nr)convert_ipv6_sockaddrcjjSr ) _raw_socketr5r"sr$z2_SocketProvider.extra_attributes..?s D,<,Cr&cHjSr rE getsockname)convertr#sr$rFz2_SocketProvider.extra_attributes..@s%77 ,,..44r&cjSr )rEr"sr$rFz2_SocketProvider.extra_attributes..Cs 0@r&cSr r!)peernamesr$rFz2_SocketProvider.extra_attributes..Lsr&cBjdS)NrrHr"sr$rFz2_SocketProvider.extra_attributes..Qs(4466q9r&rcSr r!)r=sr$rFz2_SocketProvider.extra_attributes..Us+r&)_core._socketsrCr4r5r7r;rE getpeernameOSErrorr<r AF_INETAF_INET6r9r=)r# attributesrJrMr=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$rEz_SocketProvider._raw_socketYs  r&N)rrA)rr:)r0r1r2propertyrVrrEr!r&r$r@r@9s\ X<   ^X   r&r@ceZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr0r1r2__doc__r!r&r$rZrZ_r&rZc>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#r`rbs r$send_fdszUNIXSocketStream.send_fdsh r&msglenr8maxfdstuple[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#rgrhs r$ receive_fdszUNIXSocketStream.receive_fdsrrfr&N)r`rarbrcrr)rgr8rhr8rri)r0r1r2rrerkr!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`. rrZc KdS)zAccept an incoming connection.Nr!r"s r$acceptzSocketListener.acceptrfr&NhandlerCallable[[SocketStream], Any] task_groupTaskGroup | NonercKddlm}t4d{V}|#||d{V} |d{V}|||1#1d{VswxYwYdS)Nr)create_task_group)rurenter_async_contextro start_soon)r#rprrrustackstreams 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?)rrZr )rprqrrrsrr)r0r1r2r\rror{r!r&r$rmrm}s\ ---^- (, 7 7 7 7 7 7 7r&rmceZdZdZd d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarahoststrportr8rrcDK||||ffd{VS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r#r~rrs r$sendtozUDPSocket.sendtos5 YYtTl3444444444r&N)r~rarrrr8rrr0r1r2r\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`. r~rapathrrrc@K|||fd{VS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r#r~rs r$rzUNIXDatagramSocket.sendtos.YYd|,,,,,,,,,r&N)r~rarrrrrr!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 typingrrr_core._typedattrrrr_streamsrrr_tasksrr IPAddressTypetupler8IPSockAddrTyper6ra UDPPacketTypeUNIXDatagramPacketTyperrr4r@rZr_rmr}rrrr!r&r$rsf"""""" 9999999999%%%%%%........ &&&&&&&&&& CBBBBBBBBBc; 34 sCx^S() e^+, ucz* 7:           ) ) ) ) )' ) ) )# # # # # ,# # # L:     |   ,77777Xl+_7776 5 5 5 5 5&}5 5 5 5/6 - - - - -12O - - -"8"?r&