o "h3@s,UddlmZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZmZddlmZdd lmZmZmZd d lmZd d lmZmZmZd dlmZmZm Z d dl!m"Z"ej#dkrsddlm$Z$nddl%m$Z$ee&eefZ'de(d<e)e&e*fZ+de(d<ee+e&fZ,de(d<e)e-e+fZ.de(d<e)e-e&fZ/de(d<edZ0ej1fdddd:d&d'Z2Gd(d)d)eZ3Gd*d+d+eZ4Gd,d-d-ee4Z5Gd.d/d/e5Z6Gd0d1d1ee5e4Z7Gd2d3d3e e.e4Z8Gd4d5d5e e-e4Z9Gd6d7d7e e/e4Z:Gd8d9d9e e-e4Z;dS);) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyTypeVarUnion)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroup) ) TypeAliasr IPAddressTypeIPSockAddrType SockAddrType UDPPacketTypeUNIXDatagramPacketTypeT_RetvalF)require_connected require_bound sock_or_fdsocket.socket | int sock_typesocket.SocketKind addr_familysocket.AddressFamilyr"boolr#return socket.socketc Cst|tr4ztj|d}Wn:ty3}z|jtjkr td||r'td||r.td|d}~wwt|tjr=|}n tdt|j dzo|rcz| Wntyb}ztd|d}~ww|rz|j tj tj fvrv|d}n|}Wn tyd}Ynw|std|tjkr|j |krtd|jd |j j|j|krtd |jd |jjWntyt|tr|w|d |S) N)filenoz.the file descriptor does not refer to a socketzthe socket must be connectedz+the socket must be bound to a local addresszexpected an int or socket, got z insteadrz"address family mismatch: expected z, got zsocket type mismatch: expected F) isinstanceintsocketOSErrorerrnoENOTSOCK ValueError TypeErrortype __qualname__ getpeernamefamilyAF_INETAF_INET6 getsockname AF_UNSPECname BaseExceptiondetach setblocking)r$r&r(r"r#sockexc bound_addrrEE/var/www/html/venv/lib/python3.10/site-packages/anyio/abc/_sockets.py_validate_socket$sv             rGc@sfeZdZUdZeZded<eZded<eZded<eZ ded <eZ ded <eZ ded <d S) SocketAttributea .. attribute:: family :type: socket.AddressFamily the address family of the underlying socket .. attribute:: local_address :type: tuple[str, int] | str the local address the underlying socket is connected to .. attribute:: local_port :type: int for IP based sockets, the local port the underlying socket is bound to .. attribute:: raw_socket :type: socket.socket the underlying stdlib socket object .. attribute:: remote_address :type: tuple[str, int] | str the remote address the underlying socket is connected to .. attribute:: remote_port :type: int for IP based sockets, the remote port the underlying socket is connected to r r9r local_addressr/ local_portr, raw_socketremote_address remote_portN) __name__ __module__r7__doc__rr9__annotations__rIrJrKrLrMrErErErFrHis  rHc@s,eZdZed ddZeed ddZdS) _SocketProviderr+Mapping[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_socketr9rEselfrErFsz2_SocketProvider.extra_attributes..csjSrUrVr<rE)convertrXrErFrYscsjSrU)rVrErWrErFrYcSrUrErE)peernamerErFrYcsjdS)NrrZrErWrErFrYsrcr]rUrErE)rMrErFrYr_)_core._socketsrTrHr9rIrKrVr8r1rLr r:r;rJrM)rX attributesrE)r[r^rMrXrFextra_attributess&   z _SocketProvider.extra_attributesr,cCsdSrUrErWrErErFrVsz_SocketProvider._raw_socketN)r+rS)r+r,)rNrOr7propertyrbrrVrErErErFrRs  rRc@eZdZdZedddZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+c$t|tjdd}t|IdHS)aH Wrap an existing socket object or file descriptor as a socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a socket stream Tr"N)rGr0 SOCK_STREAMrwrap_stream_socketclsr$rBrErErF from_socket zSocketStream.from_socketN)r$r%r+rerNrOr7rP classmethodrlrErErErFrerec@s6eZdZedddZedd d ZedddZdS)UNIXSocketStreamr$r%r+c(t|tjtjdd}t|IdHS)aR Wrap an existing socket object or file descriptor as a UNIX socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a UNIX socket stream TrgN)rGr0rhAF_UNIXrwrap_unix_stream_socketrjrErErFrls  zUNIXSocketStream.from_socketmessagebytesfdsCollection[int | IOBase]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) NrE)rXrurwrErErFsend_fdsr\zUNIXSocketStream.send_fdsmsglenr/maxfdstuple[bytes, list[int]]crz)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) NrE)rXr|r}rErErF receive_fdsr\zUNIXSocketStream.receive_fdsN)r$r%r+rq)rurvrwrxr+ry)r|r/r}r/r+r~)rNrOr7rorlrr{rrErErErFrqs   rqc@s:eZdZdZedddZeddd Z ddddZd S)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crf)a Wrap an existing socket object or file descriptor as a socket listener. The newly created listener takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a socket listener Tr#N)rGr0rhrwrap_listener_socketrjrErErFrlszSocketListener.from_socketrecrz)zAccept an incoming connection.NrErWrErErFacceptr\zSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Noneryc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rrenter_async_contextr start_soon)rXrrrstackstreamrErErFserves  zSocketListener.serve)r$r%r+r)r+rerU)rrrrr+ry) rNrOr7rProrlrrrrErErErFrs  rc@s(eZdZdZedddZdddZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crf)aI Wrap an existing socket object or file descriptor as a UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must be bound to a local address. :param sock_or_fd: a socket object or file descriptor :return: a UDP socket TrN)rGr0 SOCK_DGRAMrwrap_udp_socketrjrErErFrl)rmzUDPSocket.from_socketdatarvhoststrportr/rycs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rXrrrrErErFsendto8szUDPSocket.sendtoN)r$r%r+r)rrvrrrr/r+ryrNrOr7rProrlrrErErErFr"s  rc@rd) ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crf)aV Wrap an existing socket object or file descriptor as a connected UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UDP socket TrgN)rGr0rrwrap_connected_udp_socketrjrErErFrlGs zConnectedUDPSocket.from_socketN)r$r%r+rrnrErErErFr@rprc@s(eZdZdZedddZdd d ZdS)UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cs$t|tjtj}t|IdHS)a' Wrap an existing socket object or file descriptor as a UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a UNIX datagram socket N)rGr0rrsrwrap_unix_datagram_socketrjrErErFrldszUNIXDatagramSocket.from_socketrrvpathrrycs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rXrrrErErFrvszUNIXDatagramSocket.sendtoN)r$r%r+r)rrvrrr+ryrrErErErFr[s  rc@rd) ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crr)ar Wrap an existing socket object or file descriptor as a connected UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UNIX datagram socket TrgN)rGr0rrsr#wrap_connected_unix_datagram_socketrjrErErFrls  z'ConnectedUNIXDatagramSocket.from_socketN)r$r%r+rrnrErErErFr{rpr) r$r%r&r'r(r)r"r*r#r*r+r,)< __future__rr2r0sysabcrcollections.abcrrr contextlibrior ipaddressr r r typingr r r_core._eventloopr_core._typedattrrrr_streamsrrr_tasksr version_infortyping_extensionsrrrQtupler/rrrvrr r!r=rGrHrRrerqrrrrrrErErErFsP        E)&',