a %gv@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.eZdZddddZddddd d d Zd S) _NullAsyncContextManagerNonereturncsdSNselfrrU/var/www/html/llm_bihealth/app/venv/lib/python3.9/site-packages/anyio/abc/_sockets.py __aenter__sz#_NullAsyncContextManager.__aenter__ztype[BaseException] | NonezBaseException | NonezTracebackType | Nonez bool | None)exc_typeexc_valexc_tbrcsdSrr)r!r$r%r&rrr" __aexit__!sz"_NullAsyncContextManager.__aexit__N)__name__ __module__ __qualname__r#r'rrrr"rsrc@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*rr,__annotations__r.r0r2r3r4rrrr"r+*s r+c@s4eZdZeddddZeeddddZdS) _SocketProviderzMapping[Any, Callable[[], Any]]rcsddlmtjfddtjfddtjfddi}zjWntyddYn0durfdd|tj <jjt j t j fvrȇfdd|tj <durȈd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSr) _raw_socketr,rr rr"?z2_SocketProvider.extra_attributes..csjSrr8 getsocknamer)convertr!rr"r9@scsjSr)r8rr rr"r9Cr:csSrrr)peernamerr"r9Lr:csjdS)Nrr;rr rr"r9Qr:rcsSrrr)r4rr"r9Ur:)Z_core._socketsr7r+r,r.r2r8 getpeernameOSErrorr3r AF_INETAF_INET6r0r4)r! attributesr)r=r>r4r!r"extra_attributes:s$    z _SocketProvider.extra_attributesr1cCsdSrrr rrr"r8Ysz_SocketProvider._raw_socketN)r(r)r*propertyrDrr8rrrr"r69s r6c@seZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr(r)r*__doc__rrrr"rF_srFc@s8eZdZeddddddZedddd d d Zd S) UNIXSocketStreambyteszCollection[int | IOBase]r)messagefdsrcsdS)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!rKrLrrr"send_fdshszUNIXSocketStream.send_fdsr/ztuple[bytes, list[int]])msglenmaxfdsrcsdS)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!rNrOrrr" receive_fdsrszUNIXSocketStream.receive_fdsN)r(r)r*rrMrPrrrr"rIgs rIc@s6eZdZdZeddddZd ddd d d d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rFrcsdS)zAccept an incoming connection.Nrr rrr"acceptszSocketListener.acceptNzCallable[[SocketStream], Any]zTaskGroup | Noner)handler task_grouprc sddlm}t4IdHL}|dur6||IdH}|IdH}|||q6WdIdHq|1IdHsr0YdS)Nr)create_task_group)rUrenter_async_contextrRZ start_soon)r!rSrTrUstackstreamrrr"serves  zSocketListener.serve)N)r(r)r*rHrrRrZrrrr"rQ}s rQc@s$eZdZdZdddddddZd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rJstrr/r)datahostportrcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r!r]r^r_rrr"sendtoszUDPSocket.sendtoNr(r)r*rHrbrrrr"r[sr[c@seZdZdZdS)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrGrrrr"rdsrdc@s"eZdZdZddddddZdS) UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rJr\r)r]pathrcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr`)r!r]rfrrr"rbszUNIXDatagramSocket.sendtoNrcrrrr"resrec@seZdZdZdS)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrGrrrr"rgsrg)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingr rrZ_core._typedattrrrrZ_streamsrrrZ_tasksrr\Z IPAddressTypetupler/ZIPSockAddrTyper-rJZ UDPPacketTypeZUNIXDatagramPacketTyperrr+r6rFrIrQr[rdrergrrrr"s<            &