hvSSKJr SSKrSSKJr SSKJrJrJr SSK J r SSK J r SSK JrJr SSKJr SS KJr SS KJrJrJr S S KJrJrJr S SKJrJrJr S SKJ r \\!\\4r"\#\!\$4r%\\%\!4r&\#\'\%4r(\#\'\!4r)\"S5r*"SS5r+"SS\5r,"SS\5r-"SS\\-5r."SS\.5r/"SS\\.\-5r0"SS\\(\-5r1"SS \\'\-5r2"S!S"\\)\-5r3"S#S$\\'\-5r4g)%) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType)AnyTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc8\rSrSrSSjrSSjrSrg)_NullAsyncContextManagerc # g7fNselfs D/var/www/html/env/lib/python3.13/site-packages/anyio/abc/_sockets.py __aenter__#_NullAsyncContextManager.__aenter__s c # g7frr )r"exc_typeexc_valexc_tbs r# __aexit__"_NullAsyncContextManager.__aexit__!s r&r N)returnNone)r(ztype[BaseException] | Noner)zBaseException | Noner*zTracebackType | Noner-z bool | None)__name__ __module__ __qualname____firstlineno__r$r+__static_attributes__r r#rrs2 ,&%   r4rc\rSrSr%\"5rS\S'\"5rS\S'\"5rS\S'\"5r S\S '\"5r S\S '\"5r S\S 'S r g )SocketAttribute*r family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portr N) r/r0r1r2rr8__annotations__r:r<r>r?r@r3r r4r#r6r6*sP+-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r4r6cF\rSrSr\SSj5r\\SSj55rSrg)_SocketProvider9c^^^^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$r) _raw_socketr8r!sr#2_SocketProvider.extra_attributes..?sD,<,<,C,Cr4cD>T"TRR55$rrH getsockname)convertr"sr#rIrJ@s7  ,,.4r4c>TR$r)rHr!sr#rIrJCs 0@0@r4c>T$rr )peernamesr#rIrJLsr4c>>TRR5S$)NrrLr!sr#rIrJQs((446q9r4rc>T$rr )r@sr#rIrJUs+r4)_core._socketsrFr6r8r:r>rH getpeernameOSErrorr?r AF_INETAF_INET6r<r@)r" attributesrNrQr@s` @@@r#extra_attributes _SocketProvider.extra_attributes:sE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U9 11 2#&qk :M ?667! H s C55 DDcgrr r!s r#rH_SocketProvider._raw_socketYs r4r N)r-zMapping[Any, Callable[[], Any]])r-r=) r/r0r1r2propertyrZrrHr3r r4r#rCrC9s0 <  r4rCc\rSrSrSrSrg) SocketStream_zi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r Nr/r0r1r2__doc__r3r r4r#r`r`_r4r`c<\rSrSr\SSj5r\SSj5rSrg)UNIXSocketStreamgc # 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) Nr )r"messagefdss r#send_fdsUNIXSocketStream.send_fdshr&c # 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) Nr )r"msglenmaxfdss r# receive_fdsUNIXSocketStream.receive_fdsrrmr&r N)ribytesrjzCollection[int | IOBase]r-r.)ror;rpr;r-ztuple[bytes, list[int]])r/r0r1r2rrkrqr3r r4r#rfrfgs(    r4rfcF\rSrSrSr\SSj5rSS SjjrSrg) SocketListener}zq Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c # g7f)zAccept an incoming connection.Nr r!s r#acceptSocketListener.acceptrmr&Nc# SSKJn [5IShvN nUcURU"55IShvN nUR 5IShvN nUR X5 M+NQN2N!,IShvN (df  g=f7f)Nr)create_task_group)r{renter_async_contextrx start_soon)r"handler task_groupr{stackstreams r#serveSocketListener.servesn )!##u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $##sTB A)B A/A+A/A-A/)B +A/-A//B5A8 6 BB r )r-r`r)rzCallable[[SocketStream], Any]rzTaskGroup | Noner-r.) r/r0r1r2rcrrxrr3r r4r#ruru}sF -- (, 7. 7% 7  7 7r4ruc"\rSrSrSrSSjrSrg) UDPSocketzo Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cF# URXU445IShvN $N7f)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r"datahostports r#sendtoUDPSocket.sendtos# YYTl34444s !!r N)rrsrstrrr;r-r.r/r0r1r2rcrr3r r4r#rrs  5r4rc\rSrSrSrSrg)ConnectedUDPSocketzm Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r Nrbr r4r#rrrdr4rc"\rSrSrSrSSjrSrg)UNIXDatagramSocketzy Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cB# URX45IShvN $N7f)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r"rpaths r#rUNIXDatagramSocket.sendtosYY|,,,,s r N)rrsrrr-r.rr r4r#rrs  -r4rc\rSrSrSrSrg)ConnectedUNIXDatagramSocketzv Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r Nrbr r4r#rrrdr4r)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingrrr_core._typedattrrrr_streamsrrr_tasksrr IPAddressTypetupler;IPSockAddrTyper9rs UDPPacketTypeUNIXDatagramPacketTyperrr6rCr`rfrurrrrr r4r#rs7" 99%. && CBc; 34 sCx^S() e^+, ucz* :    )' )# ,# L: | ,7Xl+_76 5&}5 5/6 -12O -"8"?r4