$%hvddlmZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZddlmZdd lmZdd lmZmZmZd d lmZmZmZd dlmZmZmZd dlm Z ee!eefZ"e#e!e$fZ%ee%e!fZ&e#e'e%fZ(e#e'e!fZ)edZ*GddZ+GddeZ,GddeZ-Gddee-Z.Gdde.Z/Gddee.e-Z0Gddee(e-Z1Gdd ee'e-Z2Gd!d"ee)e-Z3Gd#d$ee'e-Z4y)%) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType)AnyTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc,eZdZddZ ddZy)_NullAsyncContextManagerc KywNselfs P/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/anyio/abc/_sockets.py __aenter__z#_NullAsyncContextManager.__aenter__s  c Kywrr)r!exc_typeexc_valexc_tbs r" __aexit__z"_NullAsyncContextManager.__aexit__!s r$N)returnNone)r&ztype[BaseException] | Noner'zBaseException | Noner(zTracebackType | Noner*z bool | None)__name__ __module__ __qualname__r#r)rr"rrs2 ,&%   r/rceZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <y ) SocketAttributer family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) r,r-r.rr2__annotations__r4r6r8r9r:rr/r"r1r1*sP+-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r/r1c:eZdZeddZeeddZy)_SocketProvidercddlmtjfdtjfdtj fdi} j jfd|tj<j jtjtjfvr3fd|tj<dfd |tj<|S#t$rdYwxYw) Nr)convert_ipv6_sockaddrc0jjSr) _raw_socketr2r sr"z2_SocketProvider.extra_attributes..?sD,<,<,C,Cr/cDjjSrrA getsockname)convertr!sr"rBz2_SocketProvider.extra_attributes..@s7  ,,.4r/cjSr)rAr sr"rBz2_SocketProvider.extra_attributes..Cs 0@0@r/cSrr)peernamesr"rBz2_SocketProvider.extra_attributes..Lsr/c>jjdS)NrrDr sr"rBz2_SocketProvider.extra_attributes..Qs((446q9r/rcSrr)r:sr"rBz2_SocketProvider.extra_attributes..Us+r/)_core._socketsr?r1r2r4r8rA getpeernameOSErrorr9r AF_INETAF_INET6r6r:)r! attributesrFrIr:s` @@@r"extra_attributesz _SocketProvider.extra_attributes:sE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U9 11 2#&qk :M ?667! H s C++ C98C9cyrrr s r"rAz_SocketProvider._raw_socketYs r/N)r*zMapping[Any, Callable[[], Any]])r*r7)r,r-r.propertyrRrrArr/r"r=r=9s0 <  r/r=ceZdZdZy) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr,r-r.__doc__rr/r"rVrV_r/rVc0eZdZeddZeddZy)UNIXSocketStreamc 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) Nr)r!messagefdss r"send_fdszUNIXSocketStream.send_fdshr$c 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) Nr)r!msglenmaxfdss r" receive_fdszUNIXSocketStream.receive_fdsrr`r$N)r]bytesr^zCollection[int | IOBase]r*r+)rbr5rcr5r*ztuple[bytes, list[int]])r,r-r.rr_rdrr/r"r[r[gs(    r/r[c8eZdZdZeddZ d ddZy)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c Kyw)zAccept an incoming connection.Nrr s r"acceptzSocketListener.acceptr`r$Nc Kddlm}t4d{}||j|d{} |j d{}|j ||+7P727#1d{7swYyxYww)Nr)create_task_group)rkrenter_async_contextri start_soon)r!handler task_grouprkstackstreams r"servezSocketListener.serves )!# 7 7u!#(#<#<=N=P#QQ #{{},%%gv6  7Q-  7 7 7sTBA(BA.A*A.A,A.(B*A.,A..B4A7 5B<B)r*rVr)rozCallable[[SocketStream], Any]rpzTaskGroup | Noner*r+)r,r-r.rXrrirsrr/r"rgrg}sA -- (, 7. 7% 7  7r/rgceZdZdZddZy) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cHK|j|||ffd{S7w)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r!datahostports r"sendtozUDPSocket.sendtos& YYtTl34444s " "N)ryrerzstrr{r5r*r+r,r-r.rXr|rr/r"rurus  5r/ruceZdZdZy)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrWrr/r"rrrYr/rceZdZdZddZy)UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cDK|j||fd{S7w)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nrw)r!rypaths r"r|zUNIXDatagramSocket.sendtosYYd|,,,,s   N)ryrerr}r*r+r~rr/r"rrs  -r/rceZdZdZy)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrWrr/r"rrrYr/r)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingrrr_core._typedattrrrr_streamsrrr_tasksrr} IPAddressTypetupler5IPSockAddrTyper3re UDPPacketTypeUNIXDatagramPacketTyperrr1r=rVr[rgrurrrrr/r"rs7" 99%. && CBc; 34 sCx^S() e^+, ucz* :    )' )# ,# L: | ,7Xl+_76 5&}5 5/6 -12O -"8"?r/