o f}@sddlmZddlZddlmZddlmZmZmZddl 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*GdddZ+GdddeZ,GdddeZ-Gdddee-Z.Gddde.Z/Gdddee.e-Z0Gdddee(e-Z1Gdd d ee'e-Z2Gd!d"d"ee)e-Z3Gd#d$d$ee'e-Z4dS)%) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType)AnyTupleTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc@s eZdZdddZdd d ZdS)_NullAsyncContextManagerreturnNonecdSNselfr r J/var/www/NoticeGen/venv/lib/python3.10/site-packages/anyio/abc/_sockets.py __aenter__sz#_NullAsyncContextManager.__aenter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | Nonecrrr )r"r%r'r)r r r# __aexit__!sz"_NullAsyncContextManager.__aexit__N)rr)r%r&r'r(r)r*rr+)__name__ __module__ __qualname__r$r,r r r r#rs rc@sbeZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <d S) SocketAttributer family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) r-r.r/rr1__annotations__r3r5r7r8r9r r r r#r0*s r0c@s,eZdZed ddZeed ddZdS) _SocketProviderrMapping[Any, Callable[[], Any]]csddlmtjfddtjfddtjfddi}z jWn ty2dYnwdur@fdd|tj <jjt j t j fvrdfdd|tj <durdd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSr) _raw_socketr1r r!r r#?sz2_SocketProvider.extra_attributes..csjSrr> getsocknamer )convertr"r r#r?@scsjSr)r>r r!r r#r?CcSrr r )peernamer r#r?LcsjdS)Nrr@r r!r r#r?QsrcrDrr r )r9r r#r?UrF)_core._socketsr=r0r1r3r7r> getpeernameOSErrorr8r AF_INETAF_INET6r5r9)r" attributesr )rBrEr9r"r#extra_attributes:s&   z _SocketProvider.extra_attributesr6cCsdSrr r!r r r#r>Ysz_SocketProvider._raw_socketN)rr<)rr6)r-r.r/propertyrMrr>r r r r#r;9s  r;c@eZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr-r.r/__doc__r r r r#rP_rPc@s(eZdZedddZedd dZdS)UNIXSocketStreammessagebytesfdsCollection[int | IOBase]rrcdS)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"rUrWr r r#send_fdshrCzUNIXSocketStream.send_fdsmsglenr4maxfdstuple[bytes, list[int]]crY)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"r[r\r r r# receive_fdsrrCzUNIXSocketStream.receive_fdsN)rUrVrWrXrr)r[r4r\r4rr])r-r.r/rrZr^r r r r#rTgs   rTc@s,eZdZdZedddZ ddd d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rrPcrY)zAccept an incoming connection.Nr r!r r r#acceptrCzSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Nonerc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rerenter_async_contextr` start_soon)r"rarcrestackstreamr r r#serves  zSocketListener.serve)rrPr)rarbrcrdrr)r-r.r/rRrr`rkr r r r#r_}s  r_c@seZdZdZd d d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarVhoststrportr4rrcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r"rmrnrpr r r#sendtoszUDPSocket.sendtoN)rmrVrnrorpr4rrr-r.r/rRrsr r r r#rlsrlc@rO)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrQr r r r#rurSruc@seZdZdZd dd Zd S) UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rmrVpathrorrcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nrq)r"rmrwr r r#rsszUNIXDatagramSocket.sendtoN)rmrVrwrorrrtr r r r#rvsrvc@rO)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrQr r r r#rxrSrx)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingr rrr_core._typedattrrrr_streamsrrr_tasksrro IPAddressTyper4IPSockAddrTyper2rV UDPPacketTypeUNIXDatagramPacketTyperrr0r;rPrTr_rlrurvrxr r r r#s>            &