o #6d{@szddlmZddlZddlmZddlmZddlmZddl m Z m Z ddlm Z ddl mZmZmZmZmZmZmZd d lmZd d lmZmZmZd d lmZmZmZd dlm Z ee!e e fZ"ee!e#fZ$ee$e!fZ%ee&e$fZ'edZ(GdddeZ)GdddeZ*Gdddee*Z+Gddde+Z,Gdddee+e*Z-Gdddee'e*Z.Gdddee&e*Z/dS)) annotationsN)abstractmethod)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyCallable CollectionMappingTupleTypeVarUnion)create_task_group)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc@sbeZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <d S) SocketAttributerfamily SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) __name__ __module__ __qualname__rr__annotations__rr r"r#r$r)r)iC:\Users\jesus\OneDrive\Desktop\erpjis_fastapi\backend\jisbackend\Lib\site-packages\anyio/abc/_sockets.pyr#s rc@s,eZdZed ddZeed ddZdS) _SocketProviderreturnMapping[Any, Callable[[], Any]]csddlmtjfddtjfddtjfddi}z jWn ty2dYnwdur@fdd|tj <jjt j t j fvrdfdd|tj <durdd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSN) _raw_socketrr)selfr)r*8sz2_SocketProvider.extra_attributes..csjSr/r0 getsocknamer))convertr2r)r*r39scsjSr/)r0r)r1r)r*r3<cSr/r)r))peernamer)r*r3EcsjdS)Nrr4r)r1r)r*r3Ksrcr8r/r)r))r$r)r*r3Nr:)Z_core._socketsr.rrrr"r0 getpeernameOSErrorr#rAF_INETAF_INET6r r$)r2 attributesr))r6r9r$r2r*extra_attributes3s*   z _SocketProvider.extra_attributesr!cCsdSr/r)r1r)r)r*r0Rsz_SocketProvider._raw_socketN)r,r-)r,r!)r%r&r'propertyr@rr0r)r)r)r*r+2s  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*rCXrCc@s(eZdZedddZedd dZdS)UNIXSocketStreammessagebytesfdsCollection[int | IOBase]r,NonecdS)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))r2rHrJr)r)r*send_fdsar7zUNIXSocketStream.send_fdsmsglenrmaxfdstuple[bytes, list[int]]crM)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))r2rOrPr)r)r* receive_fdskr7zUNIXSocketStream.receive_fdsN)rHrIrJrKr,rL)rOrrPrr,rQ)r%r&r'rrNrRr)r)r)r*rG`s   rGc@s,eZdZdZedddZ ddd d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r,rCcrM)zAccept an incoming connection.Nr)r1r)r)r*accept}r7zSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | NonerLc sdt4IdH}|dur|tIdH} |IdH}|||q1IdHs+wYdSr/)renter_async_contextrrTZ start_soon)r2rUrWZ exit_stackstreamr)r)r*serves zSocketListener.serve)r,rCr/)rUrVrWrXr,rL)r%r&r'rErrTr[r)r)r)r*rSvs  rSc@seZdZdZd d d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarIhoststrportrr,rLcs||||ffIdHS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r2r]r^r`r)r)r*sendtoszUDPSocket.sendtoN)r]rIr^r_r`rr,rL)r%r&r'rErbr)r)r)r*r\sr\c@rB)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrDr)r)r)r*rcrFrc)0 __future__rsocketabcr contextlibrior ipaddressrrrtypingr r r r r rrZ _core._tasksrZ_core._typedattrrrrZ_streamsrrr_tasksrr_Z IPAddressTyperZIPSockAddrTyperrIZ UDPPacketTyperrr+rCrGrSr\rcr)r)r)r*s0     $     &