XiD3%SSKJr SSKrSSKrSSKJr SSKJrJrJ r SSK J r SSK J r SSKJrJr SSKJr SS KJrJrJr S S KJr S S KJrJrJr S SKJrJrJr S SK J!r! \"\-\-r#S\$S'\%\"\&4r'S\$S'\'\"-r(S\$S'\%\)\'4r*S\$S'\%\)\"4r+S\$S'\"S5r,\RZ4SSS.S,Sjjjr."SS\5r/"SS\5r0"SS\\05r1"S S!\15r2"S"S#\\1\05r3"S$S%\\*\05r4"S&S'\\)\05r5"S(S)\\+\05r6"S*S+\\)\05r7g)-) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)Any TypeAliasTypeVar)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupr IPAddressTypeIPSockAddrType SockAddrType UDPPacketTypeUNIXDatagramPacketTypeT_RetvalF)require_connected require_boundc[U[5(a[R"US9nOD[U[R5(aUnO"[S[U5RS35eU(aUR5 U(afUR[R[R4;aUR5SnOUR5nU(d [ S5eU[R:wa?URU:wa/[ SUR S URR 35eURU:wa/[ S UR S URR 35eUR'S 5 U$![aVnUR[R :Xa [ S5UeU(a [ S5UeU(a [ S5UeeSnAff=f![an[ S5UeSnAff=f![a SnGNHf=f!["a' [U[5(aUR%5 ef=f) 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 =/app/.venv/lib/python3.13/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 szF1H09G? H0AHH0H#B%H0 G<&AG77G<? H HHH0 H-)H0,H--H001I!c\rSrSr%Sr\"5rS\S'\"5rS\S'\"5r S\S'\"5r S \S '\"5r S\S '\"5r S\S 'S r g)SocketAttributeca .. 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 r/r local_addressr% local_port socket.socket raw_socketremote_address remote_portN)__name__ __module__r-__firstlineno____doc__rr/__annotations__rCrDrFrGrH__static_attributes__rIr>rArAcsX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(rPrAcF\rSrSr\SSj5r\\SSj55rSrg)_SocketProviderc^^^^SSKJm [RU4Sj[RUU4Sj[R U4Sj0nT"TR R55mTbU4SjU[R'TR R[R[R4;a6U4SjU[R'TbTSmU4S jU[R'U$![a SmNf=f) Nr)convert_ipv6_sockaddrc0>TRR$N) _raw_socketr/selfsr>2_SocketProvider.extra_attributes..sD,<,<,C,CrPcD>T"TRR55$rWrXr2)convertrZsr>r[r\s7  ,,.4rPc>TR$rW)rXrYsr>r[r\s 0@0@rPc>T$rWrI)peernamesr>r[r\srPc>>TRR5S$)Nrr^rYsr>r[r\s  ,,.q1rPrc>T$rWrI)rHsr>r[r\s+rP)_core._socketsrUrAr/rCrFrXr.r'rGr r0r1rDrH)rZ attributesr_rbrHs` @@@r>extra_attributes _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U6J11 2#&qk :M ?667! H s C55 DDcgrWrIrYs r>rX_SocketProvider._raw_sockets rPrIN)returnzMapping[Any, Callable[[], Any]])rkrE) rJrKr-rLpropertyrgrrXrOrIrPr>rRrRs0 <  rPrRc,\rSrSrSr\SSj5rSrg) SocketStreamzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)a 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_socketclsr8r;s r> from_socketSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA 6?=?rIN)r8socket.socket | intrkrnrJrKr-rLrM classmethodrvrOrIrPr>rnrns  B BrPrncP\rSrSr\SSj5r\SSj5r\S Sj5rSr g) UNIXSocketStreamc# [U[R[RSS9n[ 5R U5IShvN $N7f)a" 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 TrqN)r?r&rrAF_UNIXrwrap_unix_stream_socketrts r>rvUNIXSocketStream.from_sockets@ **FNNd '(@@FFFFAAA Ac # g7f)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) NrI)rZmessagefdss r>send_fdsUNIXSocketStream.send_fdsc # g7f)z 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) NrI)rZmsglenmaxfdss r> receive_fdsUNIXSocketStream.receive_fdsrrrIN)r8ryrkr})rbytesrzCollection[int | IOBase]rkNone)rr%rr%rkztuple[bytes, list[int]]) rJrKr-rLr{rvrrrrOrIrPr>r}r}s>GG     rPr}cb\rSrSrSr\SSj5r\S Sj5rS S Sjjr Sr g) SocketListenerzq Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)z 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&rrrwrap_listener_socketrts r>rvSocketListener.from_sockets5 F,>,>dS&(==dCCCCrxc # g7f)zAccept an incoming connection.NrIrYs r>acceptSocketListener.acceptrrNc# SSKJn [5IShvN nUcURU"55IShvN nUR 5IShvN nUR X5 M+NQN2N!,IShvN (df  g=f7f)Nr)create_task_group)rrenter_async_contextr start_soon)rZhandler task_grouprstackstreams r>serveSocketListener.serve sn )!##u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $##sTB A)B A/A+A/A-A/)B +A/-A//B5A8 6 BB rI)r8ryrkr)rkrnrW)rzCallable[[SocketStream], Any]rzTaskGroup | Nonerkr) rJrKr-rLrMr{rvrrrrOrIrPr>rrsp D'D DD -- (, 7. 7% 7  7 7rPrc6\rSrSrSr\SSj5rSSjrSrg) UDPSocketizo Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)a 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_socketrts r>rvUDPSocket.from_socket#s5 F,=,=TR&(88>>>>rxcF# URXU445IShvN $N7f)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)rZdatahostports r>sendtoUDPSocket.sendto2s# YYTl34444s !!rIN)r8ryrkr)rrrstrrr%rkr rJrKr-rLrMr{rvrrOrIrPr>rrs   ? ?5rPrc,\rSrSrSr\SSj5rSrg)ConnectedUDPSocketi:zm Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)a& 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 TrqN)r?r&rrwrap_connected_udp_socketrts r>rvConnectedUDPSocket.from_socketAs<    "  '(BB4HHHHrxrIN)r8ryrkrrzrIrPr>rr:s IIrPrc>\rSrSrSr\SSj5rSSjrSrg) UNIXDatagramSocketiUzy Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[R[R5n[ 5R U5IShvN $N7f)z 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&rrrwrap_unix_datagram_socketrts r>rvUNIXDatagramSocket.from_socket^s9 F,=,=v~~N&(BB4HHHHsAAA  AcB# URX45IShvN $N7f)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)rZrpaths r>rUNIXDatagramSocket.sendtopsYY|,,,,s rIN)r8ryrkr)rrrrrkrrrIrPr>rrUs6 I'I II"-rPrc4\rSrSrSr\SSj5rSrg)ConnectedUNIXDatagramSocketiuzv Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[R[RSS9n[ 5R U5IShvN $N7f)a: 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 TrqN)r?r&rrr#wrap_connected_unix_datagram_socketrts r>rv'ConnectedUNIXDatagramSocket.from_socket|s@  ))6>>T '(LLTRRRRrrIN)r8ryrkrrzrIrPr>rrus1 S'S %SSrPr) r8ryr9zsocket.SocketKindr:zsocket.AddressFamilyr boolr!rrkrE)8 __future__rr(r&abcrcollections.abcrrr contextlibrior ipaddressr r r typingr rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrNtupler%rrrrrrr3r?rArRrnr}rrrrrrIrPr>rs" 99%. **0 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"?SrP