o >Zcz@sddlZddlmZddlmZddlmZmZddlmZddl 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*GdddZ+GdddeZ,GdddeZ-Gdddee-Z.Gddde.Z/Gdddee.e-Z0Gddde e)e-Z1Gddde e(e-Z2dS)N)abstractmethod)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType) AnyAsyncContextManagerCallable CollectionDictListMappingOptionalTupleTypeTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerT_StreamUnreliableObjectStream) TaskGroupT_Retvalc @sDeZdZd ddZdeeedeedeedeefdd Z dS) _NullAsyncContextManagerreturnNcdSNselfr#r#H/var/www/chikooza/env/lib/python3.10/site-packages/anyio/abc/_sockets.py __aenter__&sz#_NullAsyncContextManager.__aenter__exc_typeexc_valexc_tbcr!r"r#)r%r(r)r*r#r#r& __aexit__)sz"_NullAsyncContextManager.__aexit__)r N) __name__ __module__ __qualname__r'rr BaseExceptionrboolr+r#r#r#r&r%s  rc@sdeZdZUeZeed<eZeed<eZ e ed<eZ e j ed<eZ eed<eZe ed<dS)SocketAttributefamily local_address local_port raw_socketremote_address remote_portN)r,r-r.rr2r__annotations__r3 SockAddrTyper4intr5socketr6r7r#r#r#r&r12s r1c@sFeZdZedeeegefffddZeede j fddZ dS)_SocketProviderr csddlmtjfddtjfddtjfddi}z jWn ty2dYnwdur@fdd|tj <jjt j t j fvrdfdd|tj <durdd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSr") _raw_socketr2r#r$r#r&Gsz2_SocketProvider.extra_attributes..csjSr"r> getsocknamer#)convertr%r#r&r?HscsjSr")r>r#r$r#r&r?KcSr"r#r#)peernamer#r&r?VcsjdS)Nrr@r#r$r#r&r?\srcrDr"r#r#)r7r#r&r?_rF)_core._socketsr=r1r2r3r5r> getpeernameOSErrorr6rAF_INETAF_INET6r4r7)r% attributesr#)rBrEr7r%r&extra_attributesBs.   z _SocketProvider.extra_attributescCsdSr"r#r$r#r#r&r>csz_SocketProvider._raw_socketN) r,r-r.propertyrrr rMrr;r>r#r#r#r&r<As   r<c@eZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr,r-r.__doc__r#r#r#r&rPirPc @sXeZdZededeeeefddfddZ ededede ee effd d Z dS) UNIXSocketStreammessagefdsr NcdS)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%rUrVr#r#r&send_fdsrrCzUNIXSocketStream.send_fdsmsglenmaxfdscrW)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%rYrZr#r#r& receive_fds~rCzUNIXSocketStream.receive_fds) r,r-r.rbytesr rr:rrXrr r[r#r#r#r&rTqs  (rTc@sJeZdZdZedefddZ d deege fde e ddfdd Z dS) SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r crW)zAccept an incoming connection.Nr#r$r#r#r&acceptrCzSocketListener.acceptNhandler task_groupc snddlm}|dur|}}nt}|4IdH |IdH}|||q1IdHs0wYdS)Nr)create_task_group)rarr^ start_soon)r%r_r`racontext_managerstreamr#r#r&serves   zSocketListener.server") r,r-r.rRrrPr^r rrrrrfr#r#r#r&r]s r]c@s*eZdZdZdedededdfddZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datahostportr Ncs||||ffIdHS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r%rhrirjr#r#r&sendtoszUDPSocket.sendto)r,r-r.rRr\strr:rlr#r#r#r&rgsrgc@rO)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrQr#r#r#r&rnrSrn)3r;abcrior ipaddressrrrtypesrtypingrr r r r r rrrrrr_core._typedattrrrr_streamsrrrr_tasksrrm IPAddressTyper:IPSockAddrTyper9r\ UDPPacketTyperrr1r<rPrTr]rgrnr#r#r#r&s.    8     (