1h{SSKJr SSKrSSKJr SSKJr SSKJr SSK J r J r SSKJ r SSK JrJrJrJrJrJrJr S S KJr S S KJrJrJr S S KJrJrJr S SKJ r \\!\ \ 4r"\\!\#4r$\\$\!4r%\\&\$4r'\"S5r("SS\5r)"SS\5r*"SS\\*5r+"SS\+5r,"SS\\+\*5r-"SS\\'\*5r."SS\\&\*5r/g)) annotationsN)abstractmethod)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyCallable CollectionMappingTupleTypeVarUnion)create_task_group)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc\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_portN) __name__ __module__ __qualname____firstlineno__rr__annotations__r!r#r%r&r'__static_attributes__r(J/var/www/auris/envauris/lib/python3.13/site-packages/anyio/abc/_sockets.pyrr#sP+-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(r/rcF\rSrSr\SSj5r\\SSj55rSrg)_SocketProvider2c^^^^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_socketrselfsr02_SocketProvider.extra_attributes..8sD,<,<,C,Cr/cD>T"TRR55$r7r8 getsockname)convertr:sr0r;r<9s7  ,,.4r/c>TR$r7)r8r9sr0r;r<<s 0@0@r/c>T$r7r()peernamesr0r;r<Esr/c>>TRR5S$)Nrr>r9sr0r;r<Ks((446q9r/rc>T$r7r()r'sr0r;r<Ns+r/)_core._socketsr5rrr!r%r8 getpeernameOSErrorr&r AF_INETAF_INET6r#r')r: attributesr@rCr's` @@@r0extra_attributes _SocketProvider.extra_attributes3sE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U: ** #&qk :M ?667! H s C55 DDcgr7r(r9s r0r8_SocketProvider._raw_socketRs r/r(N)returnzMapping[Any, Callable[[], Any]])rPr$) r)r*r+r,propertyrLrr8r.r(r/r0r2r22s0 <  r/r2c\rSrSrSrSrg) SocketStreamXzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r(Nr)r*r+r,__doc__r.r(r/r0rSrSXr/rSc<\rSrSr\SSj5r\SSj5rSrg)UNIXSocketStream`c # 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 r0send_fdsUNIXSocketStream.send_fdsac # 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 r0 receive_fdsUNIXSocketStream.receive_fdskr`rar(N)r\bytesr]zCollection[int | IOBase]rPNone)rcr"rdr"rPztuple[bytes, list[int]])r)r*r+r,rr^rer.r(r/r0rYrY`s(    r/rYcF\rSrSrSr\SSj5rSS SjjrSrg) SocketListenervzq Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c # g7f)zAccept an incoming connection.Nr(r9s r0acceptSocketListener.accept}r`raNc# [5IShvN nUc!UR[55IShvN nUR5IShvN nUR X5 M+NTN2N!,IShvN (df  g=f7fr7)renter_async_contextrrm start_soon)r:handler task_group exit_stackstreams r0serveSocketListener.servesk "##z!#-#A#ABSBU#VV #{{},%%g6 $V- $##sTBA&B A,A(A,A*A,&B(A,*A,,B2A5 3 B?Br()rPrSr7)rrzCallable[[SocketStream], Any]rszTaskGroup | NonerPrh) r)r*r+r,rVrrmrvr.r(r/r0rjrjvsF -- (, 7. 7% 7  7 7r/rjc"\rSrSrSrSSjrSrg) UDPSocketzo Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. cF# URXU445IShvN $N7f)zKAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))).N)send)r:datahostports r0sendtoUDPSocket.sendtos!YYTl34444s !!r(N)r}rgr~strrr"rPrh)r)r*r+r,rVrr.r(r/r0ryrys  5r/ryc\rSrSrSrSrg)ConnectedUDPSocketzm Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r(NrUr(r/r0rrrWr/r)0 __future__rsocketabcr contextlibrior ipaddressrrr typingr r r r rrr _core._tasksr_core._typedattrrrr_streamsrrr_tasksrr IPAddressTyper"IPSockAddrTyper rg UDPPacketTyperrr2rSrYrjryrr(r/r0rs" %. - CBc; 34 sCx^S() e^+, :  )' )# ,# L: | ,7Xl+_72 5&}5 5/6r/