Ejj3UddlmZddlZddlZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZmZddlmZdd lmZmZmZmZd d lmZd d lmZmZmZd dlmZmZm Z erd dl!m"Z"e#ezezZ$de%d<e&e#e'fZ(de%d<e(e#zZ)de%d<e&e*e(fZ+de%d<e&e*e#fZ,de%d<edZ-ej\fddd d,dZ/GddeZ0GddeZ1Gddee1Z2Gd d!e2Z3Gd"d#ee2e1Z4Gd$d%e e+e1Z5Gd&d'e e*e1Z6Gd(d)e e,e1Z7Gd*d+e e*e1Z8y)-) 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_boundcft|tr tj|}n?t|tjr|}n"tdt|jd |r |j|r^ |jtjtjfvr|jd}n|j}|s t d|tjk7r>|j|k7r/t d|j d |jj |j|k7r/t d |j d |jj  |j'd |S#t$rK}|jtj k(r t d||r t d||r t d|d}~wwxYw#t$r}t d|d}~wwxYw#t$rd}Y2wxYw#t"$r"t|tr|j%wxYw) 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) sock_or_fd sock_type addr_familyr!r"sockexc bound_addrs P/root/workspace/ytshorts/venv/lib/python3.12/site-packages/anyio/abc/_sockets.py_validate_socketr@ s"*c" == 3D J .-d:.>.K.K-LH U  "  J  "  ";;6>>6??"CC!%!1!1!3A!6J!%!1!1!3J !NOO &** *t{{k/I4[5E5E4Ff;;##$&  99 !1)..1A GWX  " U Ko yyENN* D# !?@cI !NOUXX , J !?@cI J "!  "  j# & KKM snE?)H,G<H?AG3BH? GAGG G0 G++G00H3 H>HHH+H0ceZdZUdZeZded<eZded<eZded<eZ ded <eZ ded <eZ ded <y ) 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 r0r local_addressr& local_port socket.socket raw_socketremote_address remote_portN) __name__ __module__r.__doc__rr0__annotations__rCrDrFrGrHr?rBrBesX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(rNrBc:eZdZeddZeeddZy)_SocketProvidercddlmtjfdtjfdtj fdi} j jfd|tj<j jtjtjfvr3fd|tj<dfd |tj<|S#t$rdYwxYw) Nr)convert_ipv6_sockaddrc0jjSN) _raw_socketr0selfsr?z2_SocketProvider.extra_attributes..sD,<,<,C,CrNcDjjSrTrUr3)convertrWsr?rXz2_SocketProvider.extra_attributes..s7  ,,.4rNcjSrT)rUrVsr?rXz2_SocketProvider.extra_attributes..s 0@0@rNcSrTrM)peernamesr?rXz2_SocketProvider.extra_attributes..srNc>jjdS)NrrZrVsr?rXz2_SocketProvider.extra_attributes..s  ,,.q1rNrcSrTrM)rHsr?rXz2_SocketProvider.extra_attributes..s+rN)_core._socketsrRrBr0rCrFrUr/r(rGr r1r2rDrH)rW attributesr[r^rHs` @@@r?extra_attributesz _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U6J11 2#&qk :M ?667! H s C++ C98C9cyrTrMrVs r?rUz_SocketProvider._raw_sockets rNN)returnzMapping[Any, Callable[[], Any]])rerE)rIrJr.propertyrcrrUrMrNr?rPrPs0 <  rNrPc"eZdZdZeddZy) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cKt|tjd}tj |d{S7w)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)r@r' SOCK_STREAMrwrap_stream_socketclsr9r<s r? from_socketzSocketStream.from_sockets7 F,>,>RVW&(;;DAAAA9AAAN)r9socket.socket | intrerhrIrJr.rK classmethodrorMrNr?rhrhs  B BrNrhcBeZdZeddZeddZeddZy)UNIXSocketStreamcKt|tjtjd}t j |d{S7w)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 TrjN)r@r'rkAF_UNIXrwrap_unix_stream_socketrms r?rozUNIXSocketStream.from_socketsA **FNNd '(@@FFFFAA A Ac Kyw)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) NrM)rWmessagefdss r?send_fdszUNIXSocketStream.send_fdsc Kyw)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) NrM)rWmsglenmaxfdss r? receive_fdszUNIXSocketStream.receive_fdsr~rN)r9rqreru)r{bytesr|zCollection[int | IOBase]reNone)rr&rr&reztuple[bytes, list[int]])rIrJr.rsrorr}rrMrNr?rurus>GG     rNrucReZdZdZe ddZeddZ d d dZy) SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. cKt|tjd}tj |d{S7w)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)r@r'rkrwrap_listener_socketrms r?rozSocketListener.from_sockets6 F,>,>dS&(==dCCCCrpc Kyw)zAccept an incoming connection.NrMrVs r?acceptzSocketListener.accept r~rNc Kddlm}t4d{}||j|d{} |j d{}|j ||+7P727#1d{7swYyxYww)Nr)create_task_group)rrenter_async_contextr start_soon)rWhandler task_grouprstackstreams r?servezSocketListener.serves )!# 7 7u!#(#<#<=N=P#QQ #{{},%%gv6  7Q-  7 7 7sTBA(BA.A*A.A,A.(B*A.,A..B4A7 5B<B)r9rqrer)rerhrT)rzCallable[[SocketStream], Any]rzTaskGroup | Nonerer) rIrJr.rKrsrorrrrMrNr?rrsk D'D DD -- (, 7. 7% 7  7rNrc*eZdZdZeddZddZy) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cKt|tjd}tj |d{S7w)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)r@r' SOCK_DGRAMrwrap_udp_socketrms r?rozUDPSocket.from_socket%s6 F,=,=TR&(88>>>>rpcHK|j|||ffd{S7w)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rWdatahostports r?sendtozUDPSocket.sendto4s& YYtTl34444s " "N)r9rqrer)rrrstrrr&rerrIrJr.rKrsrorrMrNr?rrs   ? ?5rNrc"eZdZdZeddZy)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cKt|tjd}tj |d{S7w)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 TrjN)r@r'rrwrap_connected_udp_socketrms r?rozConnectedUDPSocket.from_socketCs=    "  '(BB4HHHHrpN)r9rqrerrrrMrNr?rr<s IIrNrc2eZdZdZe ddZddZy)UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cKt|tjtj}t j |d{S7w)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)r@r'rrwrwrap_unix_datagram_socketrms r?rozUNIXDatagramSocket.from_socket`s: F,=,=v~~N&(BB4HHHHsAAA  AcDK|j||fd{S7w)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rWrpaths r?rzUNIXDatagramSocket.sendtorsYYd|,,,,s   N)r9rqrer)rrrrrerrrMrNr?rrWs6 I'I II"-rNrc*eZdZdZe ddZy)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cKt|tjtjd}t j |d{S7w)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 TrjN)r@r'rrwr#wrap_connected_unix_datagram_socketrms r?roz'ConnectedUNIXDatagramSocket.from_socket~sA  ))6>>T '(LLTRRRRryN)r9rqrerrrrMrNr?rrws1 S'S %SSrNr) r9rqr:zsocket.SocketKindr;zsocket.AddressFamilyr!boolr"rrerE)9 __future__rr)r'abcrcollections.abcrrr contextlibrior ipaddressr r r typingr rrr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrLtupler&rrrrrr r4r@rBrPrhrurrrrrrMrNr?rs" 99%. 990 CB!,{: y:!#s(O +(3. i. !67 y7$)%*$5 5 :  )/(8(8B $ B#B B&B  B  BBJ&)'&)R# ,# LB:B.$ |$ N)7Xl+_)7X5&}55<I/6I6-12O-@S"8"?SrN