a õ…båã@sˆddlZddlmZddlmZddlmZmZddlmZddl m Z ddl m Z m Z mZmZmZmZmZmZmZmZmZmZdd lmZmZmZd d lmZmZmZm Z d d l!m"Z"ee#eefZ$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„de e)e-ƒZ1Gdd„de e(e-ƒZ2dS)éN)Úabstractmethod)ÚIOBase)Ú IPv4AddressÚ IPv6Address)Ú AddressFamily)Ú TracebackType) ÚAnyÚAsyncContextManagerÚCallableÚ CollectionÚDictÚListÚMappingÚOptionalÚTupleÚTypeÚTypeVarÚUnioné)ÚTypedAttributeProviderÚTypedAttributeSetÚtyped_attributeé)Ú ByteStreamÚListenerÚT_StreamÚUnreliableObjectStream)Ú TaskGroupÚT_Retvalc@sBeZdZddœdd„Zeeeeeeeeedœdd„Z dS)Ú_NullAsyncContextManagerN©ÚreturncÃsdS©N©©Úselfr#r#ú1lib/python3.9/site-packages/anyio/abc/_sockets.pyÚ __aenter__sz#_NullAsyncContextManager.__aenter__)Úexc_typeÚexc_valÚexc_tbr!cÃsdSr"r#)r%r(r)r*r#r#r&Ú __aexit__sz"_NullAsyncContextManager.__aexit__) Ú__name__Ú __module__Ú __qualname__r'rrÚ BaseExceptionrÚboolr+r#r#r#r&rs   þrc@sdeZdZUeƒZeed<eƒZeed<eƒZ e ed<eƒZ e j ed<eƒZ eed<eƒZe ed<dS)ÚSocketAttributeÚfamilyÚ local_addressÚ local_portÚ raw_socketÚremote_addressÚ remote_portN)r,r-r.rr2rÚ__annotations__r3Ú SockAddrTyper4Úintr5Úsocketr6r7r#r#r#r&r1 s r1c@sFeZdZeeeegeffdœdd„ƒZeee j dœdd„ƒƒZ dS)Ú_SocketProviderr csÌ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_socketr2r#r$r#r&Ú5óz2_SocketProvider.extra_attributes..csˆˆj ¡ƒSr"©r>Z getsocknamer#)Úconvertr%r#r&r?6r@csˆjSr")r>r#r$r#r&r?7r@csˆSr"r#r#)Úpeernamer#r&r?@r@csˆj ¡dS)NrrAr#r$r#r&r?Dr@rcsˆSr"r#r#)r7r#r&r?Gr@)Z_core._socketsr=r1r2r3r5r>Z getpeernameÚOSErrorr6rZAF_INETZAF_INET6r4r7)r%Z attributesr#)rBrCr7r%r&Úextra_attributes0s" ý  z _SocketProvider.extra_attributescCsdSr"r#r$r#r#r&r>Ksz_SocketProvider._raw_socketN) r,r-r.Úpropertyrrr rErr;r>r#r#r#r&r</s  r<c@seZdZdZdS)Ú SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. N©r,r-r.Ú__doc__r#r#r#r&rGQsrGc@sPeZdZeeeeeefddœdd„ƒZ eeee ee efdœdd„ƒZ dS)ÚUNIXSocketStreamN)ÚmessageÚfdsr!cÃ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%rKrLr#r#r&Úsend_fdsZszUNIXSocketStream.send_fds)ÚmsglenÚmaxfdsr!cÃ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%rNrOr#r#r&Ú receive_fdsdszUNIXSocketStream.receive_fds) r,r-r.rÚbytesr rr:rrMrr rPr#r#r#r&rJYs rJc@sDeZdZdZeedœdd„ƒZd eege fe e ddœdd„Z dS) ÚSocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r cÃsdS)zAccept an incoming connection.Nr#r$r#r#r&ÚacceptvszSocketListener.acceptN)ÚhandlerÚ task_groupr!c Ãs~ddlm}|dur |ƒ}}ntƒ}|4IdHš2| ¡IdH}| ||¡q4WdƒIdHqz1IdHsp0YdS)Nr)Úcreate_task_group)ÚrVrrSZ start_soon)r%rTrUrVZcontext_managerÚstreamr#r#r&Úservezs  zSocketListener.serve)N) r,r-r.rIrrGrSr rrrrrYr#r#r#r&rRosÿÿrRc@s$eZdZdZeeeddœdd„ZdS)Ú UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. N)ÚdataÚhostÚportr!cÃs| |||ff¡IdHS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)Úsend)r%r[r\r]r#r#r&Úsendto’szUDPSocket.sendto)r,r-r.rIrQÚstrr:r_r#r#r#r&rZ‹srZc@seZdZdZdS)ÚConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrHr#r#r#r&ra—sra)3r;ÚabcrÚiorZ ipaddressrrrÚtypesrÚtypingrr r r r r rrrrrrZ_core._typedattrrrrZ_streamsrrrrZ_tasksrr`Z IPAddressTyper:ZIPSockAddrTyper9rQZ UDPPacketTyperrr1r<rGrJrRrZrar#r#r#r&Ús,    8     "