ޠjj3%SSKJr SSKrSSKrSSKJr SSKJrJrJ r SSK J r SSK J r SSKJrJr SSKJr SS KJrJrJrJr S S KJr S S KJrJrJr S SKJrJrJ r \(aS SK!J"r" \#\-\-r$S\%S'\&\#\'4r(S\%S'\(\#-r)S\%S'\&\*\(4r+S\%S'\&\*\#4r,S\%S'\"S5r-\R\4SSS.S,Sjjjr/"SS\5r0"SS\5r1"SS\\15r2"S S!\25r3"S"S#\\2\15r4"S$S%\ \+\15r5"S&S'\ \*\15r6"S(S)\ \,\15r7"S*S+\ \*\15r8g)-) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TYPE_CHECKINGAny TypeAliasTypeVar)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupr IPAddressTypeIPSockAddrType SockAddrType UDPPacketTypeUNIXDatagramPacketTypeT_RetvalF)require_connected require_boundc[U[5(a[R"US9nOD[U[R5(aUnO"[S[U5RS35eU(aUR5 U(afUR[R[R4;aUR5SnOUR5nU(d [ S5eU[R:wa?URU:wa/[ SUR S URR 35eURU:wa/[ S UR S URR 35eUR'S 5 U$![aVnUR[R :Xa [ S5UeU(a [ S5UeU(a [ S5UeeSnAff=f![an[ S5UeSnAff=f![a SnGNHf=f!["a' [U[5(aUR%5 ef=f) N)filenoz.the file descriptor does not refer to a socketzthe socket must be connectedz+the socket must be bound to a local addresszexpected an int or socket, got z insteadrz"address family mismatch: expected z, got zsocket type mismatch: expected F) isinstanceintsocketOSErrorerrnoENOTSOCK ValueError TypeErrortype __qualname__ getpeernamefamilyAF_INETAF_INET6 getsockname AF_UNSPECname BaseExceptiondetach setblocking) sock_or_fd sock_type addr_familyr!r"sockexc bound_addrs L/var/www/html/gaurav/venv/lib/python3.13/site-packages/anyio/abc/_sockets.py_validate_socketr@ s+*c"" == 3D J . .-d:.>.K.K-LH U  "  J  "  ";;6>>6??"CC!%!1!1!3A!6J!%!1!1!3J !NOO &** *t{{k/I4[5E5E4Ff;;##$&  99 !1)..1A GWX  " U Ko yyENN* D# !?@cI !NOUXX , J !?@cI J "!  "  j# & & KKM szF1H09G? H0AHH0H#B%H0 G<&AG77G<? H HHH0 H-)H0,H--H001I!c\rSrSr%Sr\"5rS\S'\"5rS\S'\"5r S\S'\"5r S \S '\"5r S\S '\"5r S\S 'S r g)SocketAttributeea .. attribute:: family :type: socket.AddressFamily the address family of the underlying socket .. attribute:: local_address :type: tuple[str, int] | str the local address the underlying socket is connected to .. attribute:: local_port :type: int for IP based sockets, the local port the underlying socket is bound to .. attribute:: raw_socket :type: socket.socket the underlying stdlib socket object .. attribute:: remote_address :type: tuple[str, int] | str the remote address the underlying socket is connected to .. attribute:: remote_port :type: int for IP based sockets, the remote port the underlying socket is connected to r r0r local_addressr& local_port socket.socket raw_socketremote_address remote_portN)__name__ __module__r.__firstlineno____doc__rr0__annotations__rDrErGrHrI__static_attributes__rJr?rBrBesX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(rQrBcF\rSrSr\SSj5r\\SSj55rSrg)_SocketProviderc^^^^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_socketr0selfsr?2_SocketProvider.extra_attributes..sD,<,<,C,CrQcD>T"TRR55$rXrYr3)convertr[sr?r\r]s7  ,,.4rQc>TR$rX)rYrZsr?r\r]s 0@0@rQc>T$rXrJ)peernamesr?r\r]srQc>>TRR5S$)Nrr_rZsr?r\r]s  ,,.q1rQrc>T$rXrJ)rIsr?r\r]s+rQ)_core._socketsrVrBr0rDrGrYr/r(rHr r1r2rErI)r[ attributesr`rcrIs` @@@r?extra_attributes _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U6J11 2#&qk :M ?667! H s C55 DDcgrXrJrZs r?rY_SocketProvider._raw_sockets rQrJN)returnzMapping[Any, Callable[[], Any]])rlrF) rKrLr.rMpropertyrhrrYrPrJrQr?rSrSs0 <  rQrSc,\rSrSrSr\SSj5rSrg) SocketStreamzi Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)a Wrap an existing socket object or file descriptor as a socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a socket stream Tr!N)r@r' SOCK_STREAMrwrap_stream_socketclsr9r<s r? from_socketSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA 6?=?rJN)r9socket.socket | intrlrorKrLr.rMrN classmethodrwrPrJrQr?roros  B BrQrocP\rSrSr\SSj5r\SSj5r\S Sj5rSr g) UNIXSocketStreamc# [U[R[RSS9n[ 5R U5IShvN $N7f)a" Wrap an existing socket object or file descriptor as a UNIX socket stream. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a UNIX socket stream TrrN)r@r'rsAF_UNIXrwrap_unix_stream_socketrus r?rwUNIXSocketStream.from_sockets@ **FNNd '(@@FFFFAAA Ac # 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) NrJ)r[messagefdss r?send_fdsUNIXSocketStream.send_fdsc # 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) NrJ)r[msglenmaxfdss r? receive_fdsUNIXSocketStream.receive_fdsrrrJN)r9rzrlr~)rbytesrzCollection[int | IOBase]rlNone)rr&rr&rlztuple[bytes, list[int]]) rKrLr.rMr|rwrrrrPrJrQr?r~r~s>GG     rQr~cb\rSrSrSr\SSj5r\S Sj5rS S Sjjr Sr g) SocketListenerzq Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)z Wrap an existing socket object or file descriptor as a socket listener. The newly created listener takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a socket listener Tr"N)r@r'rsrwrap_listener_socketrus r?rwSocketListener.from_sockets5 F,>,>dS&(==dCCCCryc # g7f)zAccept an incoming connection.NrJrZs r?acceptSocketListener.accept rrNc# SSKJn [5IShvN nUcURU"55IShvN nUR 5IShvN nUR X5 M+NQN2N!,IShvN (df  g=f7f)Nr)create_task_group)rrenter_async_contextr start_soon)r[handler task_grouprstackstreams r?serveSocketListener.servesn )!##u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $##sTB A)B A/A+A/A-A/)B +A/-A//B5A8 6 BB rJ)r9rzrlr)rlrorX)rzCallable[[SocketStream], Any]rzTaskGroup | Nonerlr) rKrLr.rMrNr|rwrrrrPrJrQr?rrsp D'D DD -- (, 7. 7% 7  7 7rQrc6\rSrSrSr\SSj5rSSjrSrg) UDPSocketizo Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)a Wrap an existing socket object or file descriptor as a UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must be bound to a local address. :param sock_or_fd: a socket object or file descriptor :return: a UDP socket TrN)r@r' SOCK_DGRAMrwrap_udp_socketrus r?rwUDPSocket.from_socket%s5 F,=,=TR&(88>>>>rycF# URXU445IShvN $N7f)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r[datahostports r?sendtoUDPSocket.sendto4s# YYTl34444s !!rJN)r9rzrlr)rrrstrrr&rlr rKrLr.rMrNr|rwrrPrJrQr?rrs   ? ?5rQrc,\rSrSrSr\SSj5rSrg)ConnectedUDPSocketi<zm Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[RSS9n[5R U5IShvN $N7f)a& Wrap an existing socket object or file descriptor as a connected UDP socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UDP socket TrrN)r@r'rrwrap_connected_udp_socketrus r?rwConnectedUDPSocket.from_socketCs<    "  '(BB4HHHHryrJN)r9rzrlrr{rJrQr?rr<s IIrQrc>\rSrSrSr\SSj5rSSjrSrg) UNIXDatagramSocketiWzy Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[R[R5n[ 5R U5IShvN $N7f)z Wrap an existing socket object or file descriptor as a UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. :param sock_or_fd: a socket object or file descriptor :return: a UNIX datagram socket N)r@r'rrrwrap_unix_datagram_socketrus r?rwUNIXDatagramSocket.from_socket`s9 F,=,=v~~N&(BB4HHHHsAAA  AcB# URX45IShvN $N7f)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r[rpaths r?rUNIXDatagramSocket.sendtorsYY|,,,,s rJN)r9rzrlr)rrrrrlrrrJrQr?rrWs6 I'I II"-rQrc4\rSrSrSr\SSj5rSrg)ConnectedUNIXDatagramSocketiwzv Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. c# [U[R[RSS9n[ 5R U5IShvN $N7f)a: Wrap an existing socket object or file descriptor as a connected UNIX datagram socket. The newly created socket wrapper takes ownership of the socket being passed in. The existing socket must already be connected. :param sock_or_fd: a socket object or file descriptor :return: a connected UNIX datagram socket TrrN)r@r'rrr#wrap_connected_unix_datagram_socketrus r?rw'ConnectedUNIXDatagramSocket.from_socket~s@  ))6>>T '(LLTRRRRrrJN)r9rzrlrr{rJrQr?rrws1 S'S %SSrQr) r9rzr:zsocket.SocketKindr;zsocket.AddressFamilyr!boolr"rrlrF)9 __future__rr)r'abcrcollections.abcrrr contextlibrior ipaddressr r r typingr rrr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksrrrrOtupler&rrrrrr r4r@rBrSror~rrrrrrJrQr?rs" 99%. 990 CB!,{: y:!#s(O +(3. i. !67 y7$)%*$5 5 :  )/(8(8B $ B#B B&B  B  BBJ&)'&)R# ,# LB:B.$ |$ N)7Xl+_)7X5&}55<I/6I6-12O-@S"8"?SrQ