o * i3@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#sockexcZ bound_addrrD^/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/anyio/abc/_sockets.py_validate_socket$sv             rFc@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__rHrIrJrKrLrDrDrDrErGis  rGc@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_socketr9rDselfrDrEsz2_SocketProvider.extra_attributes..csjSrTrUr<rD)convertrWrDrErXscsjSrT)rUrDrVrDrErXcSrTrDrD)peernamerDrErXcsjdS)NrrYrDrVrDrErXsrcr\rTrDrD)rLrDrErXr^)Z_core._socketsrSrGr9rHrJrUr8r1rKr r:r;rIrL)rW attributesrD)rZr]rLrWrEextra_attributess&   z _SocketProvider.extra_attributesr,cCsdSrTrDrVrDrDrErUsz_SocketProvider._raw_socketN)r+rR)r+r,)rMrNr7propertyr`rrUrDrDrDrErQs  rQc@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)rFr0 SOCK_STREAMrZwrap_stream_socketclsr$rBrDrDrE from_socket zSocketStream.from_socketN)r$r%r+rcrMrNr7rO classmethodrirDrDrDrErcrcc@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 TreN)rFr0rfAF_UNIXrZwrap_unix_stream_socketrgrDrDrEris  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) NrD)rWrqrsrDrDrEsend_fdsr[zUNIXSocketStream.send_fdsmsglenr/maxfdstuple[bytes, list[int]]crv)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) NrD)rWrxryrDrDrE receive_fdsr[zUNIXSocketStream.receive_fdsN)r$r%r+rn)rqrrrsrtr+ru)rxr/ryr/r+rz)rMrNr7rlrirrwr{rDrDrDrErns   rnc@s:eZdZdZedddZeddd Z ddddZd S)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crd)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)rFr0rfrZwrap_listener_socketrgrDrDrEriszSocketListener.from_socketrccrv)zAccept an incoming connection.NrDrVrDrDrEacceptr[zSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Noneruc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rrenter_async_contextr~Z start_soon)rWrrrstackstreamrDrDrEserves  zSocketListener.serve)r$r%r+r|)r+rcrT)rrrrr+ru) rMrNr7rOrlrirr~rrDrDrDrEr|s  r|c@s(eZdZdZedddZdddZdS) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crd)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 Tr}N)rFr0 SOCK_DGRAMrZwrap_udp_socketrgrDrDrEri)rjzUDPSocket.from_socketdatarrhoststrportr/rucs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rWrrrrDrDrEsendto8szUDPSocket.sendtoN)r$r%r+r)rrrrrrr/r+rurMrNr7rOrlrirrDrDrDrEr"s  rc@rb) ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+crd)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 TreN)rFr0rrZwrap_connected_udp_socketrgrDrDrEriGs zConnectedUDPSocket.from_socketN)r$r%r+rrkrDrDrDrEr@rmrc@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)rFr0rrprZwrap_unix_datagram_socketrgrDrDrEridszUNIXDatagramSocket.from_socketrrrpathrrucs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rWrrrDrDrErvszUNIXDatagramSocket.sendtoN)r$r%r+r)rrrrrr+rurrDrDrDrEr[s  rc@rb) ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cro)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 TreN)rFr0rrprZ#wrap_connected_unix_datagram_socketrgrDrDrEris  z'ConnectedUNIXDatagramSocket.from_socketN)r$r%r+rrkrDrDrDrEr{rmr) r$r%r&r'r(r)r"r*r#r*r+r,)< __future__rr2r0sysabcrcollections.abcrrr contextlibrior ipaddressr r r typingr r rZ_core._eventlooprZ_core._typedattrrrrZ_streamsrrr_tasksr version_inforZtyping_extensionsrrrPtupler/rrrrrr r!r=rFrGrQrcrnr|rrrrrDrDrDrEsP        E)&',