o Oh{@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)_/var/www/html/HyperOracle/crypto_trader/venv/lib/python3.10/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:)_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'propertyrArr0r)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*rDXrDc@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))r2rIrKr)r)r*send_fdsar7zUNIXSocketStream.send_fdsmsglenrmaxfdstuple[bytes, list[int]]crN)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))r2rPrQr)r)r* receive_fdskr7zUNIXSocketStream.receive_fdsN)rIrJrKrLr,rM)rPrrQrr,rR)r%r&r'rrOrSr)r)r)r*rH`s   rHc@s,eZdZdZedddZ ddd d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r,rDcrN)zAccept an incoming connection.Nr)r1r)r)r*accept}r7zSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | NonerMc sdt4IdH}|dur|tIdH} |IdH}|||q1IdHs+wYdSr/)renter_async_contextrrU start_soon)r2rVrX exit_stackstreamr)r)r*serves zSocketListener.serve)r,rDr/)rVrWrXrYr,rM)r%r&r'rFrrUr^r)r)r)r*rTvs  rTc@seZdZdZd d d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarJhoststrportrr,rMcs||||ffIdHS)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r2r`rarcr)r)r*sendtoszUDPSocket.sendtoN)r`rJrarbrcrr,rM)r%r&r'rFrer)r)r)r*r_sr_c@rC)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrEr)r)r)r*rfrGrf)0 __future__rsocketabcr contextlibrior ipaddressrrrtypingr r r r r rr _core._tasksr_core._typedattrrrr_streamsrrr_tasksrrb IPAddressTyperIPSockAddrTyperrJ UDPPacketTyperrr+rDrHrTr_rfr)r)r)r*s0     $     &