+:j{ddlmZddlZddlmZddlmZddlmZddl m Z m Z ddlm Z ddl mZmZmZmZmZmZmZd d lmZd d lmZmZmZd d lmZmZmZd dlm Z ee!e e fZ"ee!e#fZ$ee$e!fZ%ee&e$fZ'edZ(GddeZ)GddeZ*Gddee*Z+Gdde+Z,Gddee+e*Z-Gddee'e*Z.Gddee&e*Z/y)) annotationsN)abstractmethod)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyCallable CollectionMappingTupleTypeVarUnion)create_task_group)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_RetvalceZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <y ) SocketAttributer family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) __name__ __module__ __qualname__rr__annotations__r r"r$r%r&T/var/www/html/tokenscope/api/venv/lib/python3.12/site-packages/anyio/abc/_sockets.pyrr#sP+-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r,rc:eZdZeddZeeddZy)_SocketProvidercddlmtjfdtjfdtj fdi} j jfd|tj<j jtjtjfvr3fd|tj<dfd |tj<|S#t$rdYwxYw) Nr)convert_ipv6_sockaddrc0jjSN) _raw_socketrselfsr-z2_SocketProvider.extra_attributes..8sD,<,<,C,Cr,cDjjSr3r4 getsockname)convertr6sr-r7z2_SocketProvider.extra_attributes..9s7  ,,.4r,cjSr3)r4r5sr-r7z2_SocketProvider.extra_attributes..<s 0@0@r,cSr3r+)peernamesr-r7z2_SocketProvider.extra_attributes..Esr,c>jjdS)Nrr9r5sr-r7z2_SocketProvider.extra_attributes..Ks((446q9r,rcSr3r+)r&sr-r7z2_SocketProvider.extra_attributes..Ns+r,)_core._socketsr1rrr r$r4 getpeernameOSErrorr%r AF_INETAF_INET6r"r&)r6 attributesr;r>r&s` @@@r-extra_attributesz _SocketProvider.extra_attributes3sE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U: ** #&qk :M ?667! H s C++ C98C9cyr3r+r5s r-r4z_SocketProvider._raw_socketRs r,N)returnzMapping[Any, Callable[[], Any]])rIr#)r'r(r)propertyrGrr4r+r,r-r/r/2s0 <  r,r/ceZdZdZy) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr'r(r)__doc__r+r,r-rLrLXr,rLc0eZdZeddZeddZy)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+)r6messagefdss r-send_fdszUNIXSocketStream.send_fdsac 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+)r6msglenmaxfdss r- receive_fdszUNIXSocketStream.receive_fdskrVrWN)rSbytesrTzCollection[int | IOBase]rINone)rYr!rZr!rIztuple[bytes, list[int]])r'r(r)rrUr[r+r,r-rQrQ`s(    r,rQc8eZdZdZeddZ d ddZy)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c Kyw)zAccept an incoming connection.Nr+r5s r-acceptzSocketListener.accept}rVrWNcKt4d{}|!|jtd{} |jd{}|j ||+7S727#1d{7swYyxYwwr3)renter_async_contextrra start_soon)r6handler task_group exit_stackstreams r-servezSocketListener.serves| "# 7 7z!#-#A#ABSBU#VV #{{},%%gv6  7V-  7 7 7sTBA%BA+A'A+ A)A+%B'A+)A++A=1A4 2A=9B)rIrLr3)rezCallable[[SocketStream], Any]rfzTaskGroup | NonerIr])r'r(r)rNrrarir+r,r-r_r_vsA -- (, 7. 7% 7  7r,r_ceZdZdZddZy) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cHK|j|||ffd{S7w)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r6datahostports r-sendtozUDPSocket.sendtos$YYtTl34444s " "N)rnr\rostrrpr!rIr])r'r(r)rNrqr+r,r-rkrks  5r,rkceZdZdZy)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrMr+r,r-rtrtrOr,rt)0 __future__rsocketabcr contextlibrior ipaddressrrr typingr r r r rrr _core._tasksr_core._typedattrrrr_streamsrrr_tasksrrr IPAddressTyper!IPSockAddrTyperr\ UDPPacketTyperrr/rLrQr_rkrtr+r,r-rs" %. - CBc; 34 sCx^S() e^+, :  )' )# ,# L: | ,7Xl+_72 5&}5 5/6r,