U ‰¾úg}ã@sÈddlmZddlZddlmZddlmZmZmZddl 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)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ÚTupleÚ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©©Úselfr r ú6/tmp/pip-unpacked-wheel-3u0cc9gf/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'r r r#Ú __aexit__!sz"_NullAsyncContextManager.__aexit__N)Ú__name__Ú __module__Ú __qualname__r$r(r r r r#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/r1r3r4r5r r r r#r,*s r,c@s4eZdZeddœdd„ƒZeeddœdd„ƒƒZdS) Ú_SocketProviderzMapping[Any, Callable[[], Any]]rcsÎddlm‰tj‡fdd„tj‡‡fdd„tj‡fdd„i}zˆˆj ¡ƒ‰Wntk rfd‰YnXˆdk r‚‡fdd„|tj <ˆjjt j t j fkrʇfdd„|tj <ˆdk rʈd ‰‡fd d„|tj<|S) Nr)Úconvert_ipv6_sockaddrcsˆjjSr)Ú _raw_socketr-r r!r r#Ú?óz2_SocketProvider.extra_attributes..csˆˆj ¡ƒSr©r9Ú getsocknamer )Úconvertr"r r#r:@sÿcsˆjSr)r9r r!r r#r:Cr;csˆSrr r )Úpeernamer r#r:Lr;csˆj ¡dS)Nrr<r r!r r#r:Qr;rcsˆSrr r )r5r r#r:Ur;)Z_core._socketsr8r,r-r/r3r9Ú getpeernameÚOSErrorr4r ÚAF_INETÚAF_INET6r1r5)r"Ú attributesr )r>r?r5r"r#Úextra_attributes:s*    û  ÿz _SocketProvider.extra_attributesr2cCsdSrr r!r r r#r9Ysz_SocketProvider._raw_socketN)r)r*r+ÚpropertyrErr9r r r r#r79s r7c@seZdZdZdS)Ú SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. N©r)r*r+Ú__doc__r r r r#rG_srGc@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"rLrMr r r#Úsend_fdshszUNIXSocketStream.send_fdsr0ztuple[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"rOrPr r r#Ú receive_fdsrszUNIXSocketStream.receive_fdsN)r)r*r+rrNrQr r r r#rJgs rJc@s6eZdZdZeddœdd„ƒZd ddd d œd d „ZdS)ÚSocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rGrcÃsdS)zAccept an incoming connection.Nr r!r r r#Úaccept„szSocketListener.acceptNzCallable[[SocketStream], Any]zTaskGroup | Noner)ÚhandlerÚ task_grouprc Ãsfddlm}tƒ4IdHš<}|dkr6| |ƒ¡IdH}| ¡IdH}| ||¡q6W5QIdHRXdS)Nr)Úcreate_task_group)ÚrVrÚenter_async_contextrSZ start_soon)r"rTrUrVÚstackÚstreamr r r#Úserveˆs  zSocketListener.serve)N)r)r*r+rIrrSr[r r r r#rR}s ýrRc@s$eZdZdZdddddœdd„Zd S) Ú UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rKÚstrr0r)ÚdataÚhostÚportrcÃs| |||ff¡IdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). N©Úsend)r"r^r_r`r r r#ÚsendtoŸszUDPSocket.sendtoN©r)r*r+rIrcr r r r#r\˜sr\c@seZdZdZdS)ÚConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrHr r r r#re§srec@s"eZdZdZddddœdd„ZdS) ÚUNIXDatagramSocketz… Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rKr]r)r^ÚpathrcÃs| ||f¡IdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nra)r"r^rgr r r#rc¸szUNIXDatagramSocket.sendtoNrdr r r r#rf¯srfc@seZdZdZdS)ÚConnectedUNIXDatagramSocketz‚ Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrHr r r r#rh½srh)5Ú __future__rÚsocketÚabcrÚcollections.abcrrrÚ contextlibrÚiorÚ ipaddressr r r Útypesr Útypingr rrrZ_core._typedattrrrrZ_streamsrrrZ_tasksrr]Z IPAddressTyper0ZIPSockAddrTyper.rKZ UDPPacketTypeZUNIXDatagramPacketTyperrr,r7rGrJrRr\rerfrhr r r r#Ús>            & ÿ