a ^ŠÝgvã@sÄddlmZddlZddlmZddlmZmZmZddl 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)edƒZ*Gdd„dƒZ+Gdd„deƒZ,Gdd„deƒZ-Gdd„dee-ƒZ.Gdd„de.ƒZ/Gdd„dee.e-ƒZ0Gdd„dee(e-ƒZ1Gdd „d ee'e-ƒZ2Gd!d"„d"ee)e-ƒZ3Gd#d$„d$ee'e-ƒZ4dS)%é)Ú annotationsN)Úabstractmethod)ÚCallableÚ CollectionÚMapping)ÚAsyncExitStack)ÚIOBase)Ú IPv4AddressÚ IPv6Address)Ú AddressFamily)Ú TracebackType)ÚAnyÚTypeVarÚUnioné)ÚTypedAttributeProviderÚTypedAttributeSetÚtyped_attributeé)Ú ByteStreamÚListenerÚUnreliableObjectStream)Ú TaskGroupÚT_Retvalc@s.eZdZddœdd„Zddddd œd d „Zd S) Ú_NullAsyncContextManagerÚNone©ÚreturncÃsdS©N©©Úselfrrú`/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/anyio/abc/_sockets.pyÚ __aenter__sz#_NullAsyncContextManager.__aenter__ztype[BaseException] | NonezBaseException | NonezTracebackType | Nonez bool | None)Úexc_typeÚexc_valÚexc_tbrcÃsdSrr)r!r$r%r&rrr"Ú __aexit__!sz"_NullAsyncContextManager.__aexit__N)Ú__name__Ú __module__Ú __qualname__r#r'rrrr"rsrc@sbeZdZUeƒZded<eƒZded<eƒZded<eƒZded<eƒZ ded <eƒZ ded <d S) ÚSocketAttributer ÚfamilyÚ SockAddrTypeÚ local_addressÚintÚ local_portú socket.socketÚ raw_socketÚremote_addressÚ remote_portN) r(r)r*rr,Ú__annotations__r.r0r2r3r4rrrr"r+*s r+c@s4eZdZeddœdd„ƒZeeddœdd„ƒƒZdS) Ú_SocketProviderzMapping[Any, Callable[[], Any]]rcsÌddlm‰tj‡fdd„tj‡‡fdd„tj‡fdd„i}zˆˆj ¡ƒ‰Wntydd‰Yn0ˆdur€‡fdd„|tj <ˆjjt j t j fvrȇfdd„|tj <ˆdurȈd ‰‡fd d„|tj<|S) Nr)Úconvert_ipv6_sockaddrcsˆjjSr)Ú _raw_socketr,rr rr"Ú?óz2_SocketProvider.extra_attributes..csˆˆj ¡ƒSr©r8Ú getsocknamer)Úconvertr!rr"r9@sÿcsˆjSr)r8rr rr"r9Cr:csˆSrrr)Úpeernamerr"r9Lr:csˆj ¡dS)Nrr;rr rr"r9Qr:rcsˆSrrr)r4rr"r9Ur:)Z_core._socketsr7r+r,r.r2r8Ú getpeernameÚOSErrorr3r ÚAF_INETÚAF_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`. N©r(r)r*Ú__doc__rrrr"rF_srFc@s8eZdZeddddœdd„ƒZedddd œd d „ƒZd S) ÚUNIXSocketStreamÚbyteszCollection[int | IOBase]r)ÚmessageÚfdsrcÃsdS)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]])ÚmsglenÚmaxfdsrcÃsdS)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@s6eZdZdZeddœdd„ƒZd ddd d œd d „ZdS)ÚSocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rFrcÃsdS)zAccept an incoming connection.Nrr rrr"Úaccept„szSocketListener.acceptNzCallable[[SocketStream], Any]zTaskGroup | Noner)ÚhandlerÚ task_grouprc Ãs€ddlm}tƒ4IdHšL}|dur6| |ƒ¡IdH}| ¡IdH}| ||¡q6WdƒIdHq|1IdHsr0YdS)Nr)Úcreate_task_group)ÚrUrÚenter_async_contextrRZ start_soon)r!rSrTrUÚstackÚstreamrrr"Úserveˆs  zSocketListener.serve)N)r(r)r*rHrrRrZrrrr"rQ}s ýrQc@s$eZdZdZdddddœdd„Zd S) Ú UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rJÚstrr/r)ÚdataÚhostÚportrcÃs| |||ff¡IdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). N©Úsend)r!r]r^r_rrr"ÚsendtoŸszUDPSocket.sendtoN©r(r)r*rHrbrrrr"r[˜sr[c@seZdZdZdS)ÚConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrGrrrr"rd§srdc@s"eZdZdZddddœdd„ZdS) ÚUNIXDatagramSocketz… Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rJr\r)r]ÚpathrcÃs| ||f¡IdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr`)r!r]rfrrr"rb¸szUNIXDatagramSocket.sendtoNrcrrrr"re¯srec@seZdZdZdS)ÚConnectedUNIXDatagramSocketz‚ Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrGrrrr"rg½srg)5Ú __future__rÚsocketÚabcrÚcollections.abcrrrÚ contextlibrÚiorÚ ipaddressr r r Útypesr Útypingr rrZ_core._typedattrrrrZ_streamsrrrÚ_tasksrr\Z IPAddressTypeÚtupler/ZIPSockAddrTyper-rJZ UDPPacketTypeZUNIXDatagramPacketTyperrr+r6rFrIrQr[rdrergrrrr"Ús<            & ÿ