RPf} ddlmZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZddlmZdd lmZdd lmZmZmZmZd d lmZmZmZd dlmZmZmZd dl m!Z!ee"eefZ#ee"e$fZ%ee%e"fZ&ee'e%fZ(ee'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)AnyTupleTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc,eZdZddZ ddZy)_NullAsyncContextManagerc KywNselfs L/var/www/fastapitest/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*r r#rrs2 ,&%   r0rceZdZUeZded<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/rr3__annotations__r5r7r9r:r;r r0r#r2r2*sP+-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r0r2c:eZdZeddZeeddZy)_SocketProvidercddlmtjfdtjfdtj fdi} j jfd|tj<j jtjtjfvr3fd|tj<dfd |tj<|S#t$rdYwxYw) Nr)convert_ipv6_sockaddrc0jjSr) _raw_socketr3r!sr#z2_SocketProvider.extra_attributes..?sD,<,<,C,Cr0cDjjSrrB getsockname)convertr"sr#rCz2_SocketProvider.extra_attributes..@s7  ,,.4r0cjSr)rBr!sr#rCz2_SocketProvider.extra_attributes..Cs 0@0@r0cSrr )peernamesr#rCz2_SocketProvider.extra_attributes..Lsr0c>jjdS)NrrEr!sr#rCz2_SocketProvider.extra_attributes..Qs((446q9r0rcSrr )r;sr#rCz2_SocketProvider.extra_attributes..Us+r0)_core._socketsr@r2r3r5r9rB getpeernameOSErrorr:r AF_INETAF_INET6r7r;)r" attributesrGrJr;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++ C98C9cyrr r!s r#rBz_SocketProvider._raw_socketYs r0N)r+zMapping[Any, Callable[[], Any]])r+r8)r-r.r/propertyrSrrBr r0r#r>r>9s0 <  r0r>ceZdZdZy) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr-r.r/__doc__r r0r#rWrW_r0rWc0eZdZeddZeddZy)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_fdsrrar%N)r^bytesr_zCollection[int | IOBase]r+r,)rcr6rdr6r+ztuple[bytes, list[int]])r-r.r/rr`rer r0r#r\r\gs(    r0r\c8eZdZdZeddZ d ddZy)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c Kyw)zAccept an incoming connection.Nr r!s r#acceptzSocketListener.acceptrar%Nc Kddlm}t4d{}||j|d{} |j d{}|j ||+7P727#1d{7swYyxYww)Nr)create_task_group)rlrenter_async_contextrj start_soon)r"handler task_grouprlstackstreams 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+rWr)rpzCallable[[SocketStream], Any]rqzTaskGroup | Noner+r,)r-r.r/rYrrjrtr r0r#rhrh}sA -- (, 7. 7% 7  7r0rhceZdZdZddZy) 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)rzrfr{strr|r6r+r,r-r.r/rYr}r r0r#rvrvs  5r0rvceZdZdZy)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrXr r0r#rrrZr0rceZdZdZddZy)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)).Nrx)r"rzpaths r#r}zUNIXDatagramSocket.sendtosYYd|,,,,s   N)rzrfrr~r+r,rr r0r#rrs  -r0rceZdZdZy)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrXr r0r#rrrZr0r)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingrrrr_core._typedattrrrr_streamsrrr_tasksrr~ IPAddressTyper6IPSockAddrTyper4rf UDPPacketTypeUNIXDatagramPacketTyperrr2r>rWr\rhrvrrrr r0r#rs7" 99%. -- CBc; 34 sCx^S() e^+, ucz* :    )' )# ,# L: | ,7Xl+_76 5&}5 5/6 -12O -"8"?r0