o Tjj3@sUddlmZddlZddlZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZmZmZmZd d lmZd d lmZmZmZd dlmZmZm Z ergd dl!m"Z"e#eBeBZ$de%d<e&e#e'fZ(de%d<e(e#BZ)de%d<e&e*e(fZ+de%d<e&e*e#fZ,de%d<edZ-ej.fdddd8d$d%Z/Gd&d'd'eZ0Gd(d)d)eZ1Gd*d+d+ee1Z2Gd,d-d-e2Z3Gd.d/d/ee2e1Z4Gd0d1d1e e+e1Z5Gd2d3d3e e*e1Z6Gd4d5d5e e,e1Z7Gd6d7d7e e*e1Z8dS)9) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TYPE_CHECKINGAny TypeAliasTypeVar)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupr 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_addrrCU/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/anyio/abc/_sockets.py_validate_socket sv             rEc@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 r7r local_addressr- local_portr* raw_socketremote_address remote_portN) __name__ __module__r5__doc__rr7__annotations__rGrHrIrJrKrCrCrCrDrFes  rFc@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_socketr7rCselfrCrDsz2_SocketProvider.extra_attributes..csjSrSrTr:rC)convertrVrCrDrWscsjSrS)rTrCrUrCrDrWcSrSrCrC)peernamerCrDrWcsjdS)NrrXrCrUrCrDrWsrcr[rSrCrC)rKrCrDrWr])_core._socketsrRrFr7rGrIrTr6r/rJr r8r9rHrK)rV attributesrC)rYr\rKrVrDextra_attributess$  z _SocketProvider.extra_attributesr*cCsdSrSrCrUrCrCrDrTsz_SocketProvider._raw_socketN)r)rQ)r)r*)rLrMr5propertyr`rrTrCrCrCrDrPs  rPc@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)rEr. SOCK_STREAMrwrap_stream_socketclsr"r@rCrCrD from_socket zSocketStream.from_socketN)r"r#r)rcrLrMr5rN classmethodrjrCrCrCrDrcrcc@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)rEr.rfAF_UNIXrwrap_unix_stream_socketrhrCrCrDrjs  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) NrC)rVrsrurCrCrDsend_fdsrZzUNIXSocketStream.send_fdsmsglenr-maxfdstuple[bytes, list[int]]crx)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) NrC)rVrzr{rCrCrD receive_fdsrZzUNIXSocketStream.receive_fdsN)r"r#r)ro)rsrtrurvr)rw)rzr-r{r-r)r|)rLrMr5rmrjrryr}rCrCrCrDros   roc@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)rEr.rfrwrap_listener_socketrhrCrCrDrjszSocketListener.from_socketrccrx)zAccept an incoming connection.NrCrUrCrCrDaccept rZzSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Nonerwc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rrenter_async_contextr start_soon)rVrrrstackstreamrCrCrDserves  zSocketListener.serve)r"r#r)r~)r)rcrS)rrrrr)rw) rLrMr5rNrmrjrrrrCrCrCrDr~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 TrN)rEr. SOCK_DGRAMrwrap_udp_socketrhrCrCrDrj%rkzUDPSocket.from_socketdatarthoststrportr-rwcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rVrrrrCrCrDsendto4szUDPSocket.sendtoN)r"r#r)r)rrtrrrr-r)rwrLrMr5rNrmrjrrCrCrCrDrs  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)rEr.rrwrap_connected_udp_socketrhrCrCrDrjCs zConnectedUDPSocket.from_socketN)r"r#r)rrlrCrCrCrDr<rnrc@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)rEr.rrqrwrap_unix_datagram_socketrhrCrCrDrj`szUNIXDatagramSocket.from_socketrrtpathrrwcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rVrrrCrCrDrrszUNIXDatagramSocket.sendtoN)r"r#r)r)rrtrrr)rwrrCrCrCrDrWs  rc@rb) ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r"r#r)crp)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)rEr.rrqr#wrap_connected_unix_datagram_socketrhrCrCrDrj~s  z'ConnectedUNIXDatagramSocket.from_socketN)r"r#r)rrlrCrCrCrDrwrnr) r"r#r$r%r&r'r r(r!r(r)r*)9 __future__rr0r.abcrcollections.abcrrr contextlibrior ipaddressr r r typingr r rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrOtupler-rrrtrrrr;rErFrPrcror~rrrrrCrCrCrDsJ      E)&',