@g{ddlmZddlZddlmZddlmZddlmZddl m Z m Z ddlm Z ddl mZmZmZmZmZmZmZd d lmZd d lmZmZmZd d lmZmZmZd dlm Z ee!e e fZ"ee!e#fZ$ee$e!fZ%ee&e$fZ'edZ(GddeZ)GddeZ*Gddee*Z+Gdde+Z,Gddee+e*Z-Gddee'e*Z.Gddee&e*Z/dS)) annotationsN)abstractmethod)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyCallable CollectionMappingTupleTypeVarUnion)create_task_group)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_RetvalceZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <d S) SocketAttributer family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) __name__ __module__ __qualname__rr__annotations__r r"r$r%r&F/var/www/piapp/venv/lib/python3.11/site-packages/anyio/abc/_sockets.pyrr#s+O--F----"1/"3"3M3333%o''J'''' / 1 1J1111#2?#4#4N4444&((K((((((r,rcNeZdZeddZeeddZdS) _SocketProviderreturnMapping[Any, Callable[[], Any]]cddlmtjfdtjfdtjfdi} jn#t$rdYnwxYwfd|tj <jjtj tj fvr.fd|tj <dfd |tj<|S) Nr)convert_ipv6_sockaddrcjjSN) _raw_socketrselfsr-z2_SocketProvider.extra_attributes..8s D,<,Cr,cHjSr5r6 getsockname)convertr8sr-r9z2_SocketProvider.extra_attributes..9s%77 ,,..44r,cjSr5)r6r7sr-r9z2_SocketProvider.extra_attributes..<s 0@r,cSr5r+)peernamesr-r9z2_SocketProvider.extra_attributes..Esr,cBjdS)Nrr;r7sr-r9z2_SocketProvider.extra_attributes..Ks(4466q9r,rcSr5r+)r&sr-r9z2_SocketProvider.extra_attributes..Ns+r,)_core._socketsr3rrr r$r6 getpeernameOSErrorr%r AF_INETAF_INET6r"r&)r8 attributesr=r@r&s` @@@r-extra_attributesz _SocketProvider.extra_attributes3s6EEEEEE  "$C$C$C$C  ),,,,,  &(@(@(@(@ 4  /6wt7G7S7S7U7U/V/VHH   HHH   9I9I9I9IJ5 6   "}'T&U U U:999 * #&qk :M:M:M:M ?67s"A A.-A.r#cdSr5r+r7s r-r6z_SocketProvider._raw_socketRs  r,N)r0r1)r0r#)r'r(r)propertyrIrr6r+r,r-r/r/2s\ X<   ^X   r,r/ceZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr'r(r)__doc__r+r,r-rMrMXr,rMc>eZdZeddZedd Zd S)UNIXSocketStreammessagebytesfdsCollection[int | IOBase]r0Nonec 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+)r8rSrUs r-send_fdszUNIXSocketStream.send_fdsa r,msglenr!maxfdstuple[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+)r8r[r\s r- receive_fdszUNIXSocketStream.receive_fdskrZr,N)rSrTrUrVr0rW)r[r!r\r!r0r])r'r(r)rrYr_r+r,r-rRrR`sR   ^    ^   r,rRc6eZdZdZed dZ d dd ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r0rMc KdS)zAccept an incoming connection.Nr+r7s r-acceptzSocketListener.accept}rZr,NhandlerCallable[[SocketStream], Any] task_groupTaskGroup | NonerWc Kt4d{V}|'|td{V} |d{V}|||1#1d{VswxYwYdSr5)renter_async_contextrrc start_soon)r8rdrf exit_stackstreams r-servezSocketListener.serves "## 7 7 7 7 7 7 7z!#-#A#ABSBUBU#V#VVVVVVV  7#{{}},,,,,,%%gv666 7  7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7sAA33 A=A=)r0rMr5)rdrerfrgr0rW)r'r(r)rOrrcrmr+r,r-raravs\ ---^- (, 7 7 7 7 7 7 7r,raceZdZdZd d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarThoststrportr!r0rWcDK||||ffd{VS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r8rprqrss r-sendtozUDPSocket.sendtos3YYtTl3444444444r,N)rprTrqrrrsr!r0rW)r'r(r)rOrvr+r,r-roros2 555555r,roceZdZdZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrNr+r,r-rxrxrPr,rx)0 __future__rsocketabcr contextlibrior ipaddressrrr typingr r r r rrr _core._tasksr_core._typedattrrrr_streamsrrr_tasksrrr IPAddressTyper!IPSockAddrTyperrT UDPPacketTyperrr/rMrRrarorxr+r,r-rs"""""" %%%%%%........ -,,,,, CBBBBBBBBBc; 34 sCx^S() e^+, 7:   ) ) ) ) )' ) ) )# # # # # ,# # # L:     |   ,77777Xl+_7772 5 5 5 5 5&}5 5 5 5/6r,