o ;'hv@sddlmZddlZddlmZddlmZmZmZddl 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*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)AnyTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc@s eZdZdddZdd d ZdS)_NullAsyncContextManagerreturnNonecdSNselfrrHC:\Users\shubh\Videos\agent\nova\Lib\site-packages\anyio/abc/_sockets.py __aenter__sz#_NullAsyncContextManager.__aenter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | Nonecrrr)r!r$r&r(rrr" __aexit__!sz"_NullAsyncContextManager.__aexit__N)rr)r$r%r&r'r(r)rr*)__name__ __module__ __qualname__r#r+rrrr"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.rr0__annotations__r2r4r6r7r8rrrr"r/*s r/c@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_socketr0rr rr"?sz2_SocketProvider.extra_attributes..csjSrr= getsocknamer)convertr!rr"r>@scsjSr)r=rr rr"r>CcSrrr)peernamerr"r>LcsjdS)Nrr?rr rr"r>QsrcrCrrr)r8rr"r>UrE)Z_core._socketsr<r/r0r2r6r= getpeernameOSErrorr7r AF_INETAF_INET6r4r8)r! attributesr)rArDr8r!r"extra_attributes:s&   z _SocketProvider.extra_attributesr5cCsdSrrr rrr"r=Ysz_SocketProvider._raw_socketN)rr;)rr5)r,r-r.propertyrKrr=rrrr"r:9s  r:c@eZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr,r-r.__doc__rrrr"rN_rNc@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!rSrUrrr"send_fdshrBzUNIXSocketStream.send_fdsmsglenr3maxfdstuple[bytes, list[int]]crW)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!rYrZrrr" receive_fdsrrBzUNIXSocketStream.receive_fdsN)rSrTrUrVrr)rYr3rZr3rr[)r,r-r.rrXr\rrrr"rRgs   rRc@s,eZdZdZedddZ ddd d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rrNcrW)zAccept an incoming connection.Nrr rrr"acceptrBzSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Nonerc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rcrenter_async_contextr^Z start_soon)r!r_rarcstackstreamrrr"serves  zSocketListener.serve)rrNr)r_r`rarbrr)r,r-r.rPrr^rhrrrr"r]}s  r]c@seZdZdZd d d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarThoststrportr3rrcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r!rjrkrmrrr"sendtoszUDPSocket.sendtoN)rjrTrkrlrmr3rrr,r-r.rPrprrrr"risric@rM)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrOrrrr"rrrQrrc@seZdZdZd dd Zd S) UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rjrTpathrlrrcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nrn)r!rjrtrrr"rpszUNIXDatagramSocket.sendtoN)rjrTrtrlrrrqrrrr"rssrsc@rM)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrOrrrr"rurQru)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingr rrZ_core._typedattrrrrZ_streamsrrr_tasksrrlZ IPAddressTypetupler3ZIPSockAddrTyper1rTZ UDPPacketTypeZUNIXDatagramPacketTyperrr/r:rNrRr]rirrrsrurrrr"s>            &