i3%SSKJr SSKrSSKrSSKrSSKJr SSKJrJ r J r SSK J r SSK Jr SSKJrJr SSKJr SS KJrJrJr S S KJr S S KJrJrJr S SKJrJrJ r S SK!J"r" \RFS:aSSKJ$r$ OSSK%J$r$ \\&\\4r'S\(S'\)\&\*4r+S\(S'\\+\&4r,S\(S'\)\-\+4r.S\(S'\)\-\&4r/S\(S'\"S5r0\Rb4SSS.S.Sjjjr2"SS\5r3"SS\5r4"S S!\\45r5"S"S#\55r6"S$S%\\5\45r7"S&S'\ \.\45r8"S(S)\ \-\45r9"S*S+\ \/\45r:"S,S-\ \-\45r;g)/) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily)AnyTypeVarUnion)get_async_backend)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroup) ) TypeAliasr 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 Z/var/www/html/qgis-automation/mouza_env/lib/python3.13/site-packages/anyio/abc/_sockets.py_validate_socketrB$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)SocketAttributeia .. 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 r2r local_addressr( local_port socket.socket raw_socketremote_address remote_portN)__name__ __module__r0__firstlineno____doc__rr2__annotations__rFrGrIrJrK__static_attributes__rLrArDrDisX@,-FM-"1"3M<3%'J' / 1J 1#2#4NL4&(K(rSrDcF\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_socketr2selfsrA2_SocketProvider.extra_attributes..sD,<,<,C,CrScD>T"TRR55$rZr[r5)convertr]srAr^r_s7  ,,.4rSc>TR$rZ)r[r\srAr^r_s 0@0@rSc>T$rZrL)peernamesrAr^r_srSc>>TRR5S$)Nrrar\srAr^r_s((446q9rSrc>T$rZrL)rKsrAr^r_s+rS)_core._socketsrXrDr2rFrIr[r1r*rJr r3r4rGrK)r] attributesrbrerKs` @@@rAextra_attributes _SocketProvider.extra_attributessE  " "$C  ) ),  & &(@ 4  /6t7G7G7S7S7U/VH  9IJ55 6    " "}'<'T>T&U U9 11 2#&qk :M ?667! H s C55 DDcgrZrLr\s rAr[_SocketProvider._raw_sockets rSrLN)returnzMapping[Any, Callable[[], Any]])rnrH) rMrNr0rOpropertyrjrr[rRrLrSrArUrUs0 <  rSrUc,\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)rBr) SOCK_STREAMrwrap_stream_socketclsr;r>s rA from_socketSocketStream.from_sockets6 F,>,>RVW&(;;DAAAA 6?=?rLN)r;socket.socket | intrnrqrMrNr0rOrP classmethodryrRrLrSrArqrqs  B BrSrqcP\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 TrtN)rBr)ruAF_UNIXrwrap_unix_stream_socketrws rAryUNIXSocketStream.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) NrL)r]messagefdss rAsend_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) NrL)r]msglenmaxfdss rA receive_fdsUNIXSocketStream.receive_fdsrrrLN)r;r|rnr)rbytesrzCollection[int | IOBase]rnNone)rr(rr(rnztuple[bytes, list[int]]) rMrNr0rOr~ryrrrrRrLrSrArrs>GG     rSrcb\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)rBr)rurwrap_listener_socketrws rArySocketListener.from_sockets5 F,>,>dS&(==dCCCCr{c # g7f)zAccept an incoming connection.NrLr\s rAacceptSocketListener.acceptrrNc# 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 rAserveSocketListener.servesn )!##u!#(#<#<=N=P#QQ #{{},%%g6 $Q- $##sTB A)B A/A+A/A-A/)B +A/-A//B5A8 6 BB rL)r;r|rnr)rnrqrZ)rzCallable[[SocketStream], Any]rzTaskGroup | Nonernr) rMrNr0rOrPr~ryrrrrRrLrSrArrsp D'D DD -- (, 7. 7% 7  7 7rSrc6\rSrSrSr\SSj5rSSjrSrg) UDPSocketi"zo 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)rBr) SOCK_DGRAMrwrap_udp_socketrws rAryUDPSocket.from_socket)s5 F,=,=TR&(88>>>>r{cF# URXU445IShvN $N7f)zN Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r]datahostports rAsendtoUDPSocket.sendto8s# YYTl34444s !!rLN)r;r|rnr)rrrstrrr(rnr rMrNr0rOrPr~ryrrRrLrSrArr"s   ? ?5rSrc,\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 TrtN)rBr)rrwrap_connected_udp_socketrws rAryConnectedUDPSocket.from_socketGs<    "  '(BB4HHHHr{rLN)r;r|rnrr}rLrSrArr@s IIrSrc>\rSrSrSr\SSj5rSSjrSrg) UNIXDatagramSocketi[zy 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)rBr)rrrwrap_unix_datagram_socketrws rAryUNIXDatagramSocket.from_socketds9 F,=,=v~~N&(BB4HHHHsAAA  AcB# URX45IShvN $N7f)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr)r]rpaths rArUNIXDatagramSocket.sendtovsYY|,,,,s rLN)r;r|rnr)rrrrrnrrrLrSrArr[s6 I'I II"-rSrc4\rSrSrSr\SSj5rSrg)ConnectedUNIXDatagramSocketi{zv 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 TrtN)rBr)rrr#wrap_connected_unix_datagram_socketrws rAry'ConnectedUNIXDatagramSocket.from_sockets@  ))6>>T '(LLTRRRRrrLN)r;r|rnrr}rLrSrArr{s1 S'S %SSrSr) r;r|r<zsocket.SocketKindr=zsocket.AddressFamilyr#boolr$rrnrH)< __future__rr+r)sysabcrcollections.abcrrr contextlibrior ipaddressr r r typingr rr_core._eventloopr_core._typedattrrrr_streamsrrr_tasksr version_infortyping_extensionsrrrQtupler(rrrr r!r"r6rBrDrUrqrrrrrrrLrSrArs" 99%. &&0 CBw + k;!>? y?!#s(O + 34 i4 !67 y7$)%*$5 5 :  )/(8(8B $ B#B B&B  B  BBJ&)'&)R# ,# LB:B.$ |$ N)7Xl+_)7X5&}55<I/6I6-12O-@S"8"?SrS