o hv@sddlmZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZmZddlmZdd lmZdd lmZmZmZd d lmZmZmZd dlmZmZmZd dlm Z ee!eefZ"e#e!e$fZ%ee%e!fZ&e#e'e%fZ(e#e'e!fZ)edZ*GdddZ+GdddeZ,GdddeZ-Gdddee-Z.Gddde.Z/Gdddee.e-Z0Gdddee(e-Z1Gdd d ee'e-Z2Gd!d"d"ee)e-Z3Gd#d$d$ee'e-Z4dS)%) annotationsN)abstractmethod)Callable CollectionMapping)AsyncExitStack)IOBase) IPv4Address IPv6Address) AddressFamily) TracebackType)AnyTypeVarUnion)TypedAttributeProviderTypedAttributeSettyped_attribute) ByteStreamListenerUnreliableObjectStream) TaskGroupT_Retvalc@s eZdZdddZdd d ZdS)_NullAsyncContextManagerreturnNonecdSNselfrrf/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/anyio/abc/_sockets.py __aenter__sz#_NullAsyncContextManager.__aenter__exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | None bool | Nonecrrr)r!r$r&r(rrr" __aexit__!sz"_NullAsyncContextManager.__aexit__N)rr)r$r%r&r'r(r)rr*)__name__ __module__ __qualname__r#r+rrrr"rs rc@sbeZdZUeZded<eZded<eZded<eZded<eZ ded <eZ ded <d S) SocketAttributer family SockAddrType local_addressint local_port socket.socket raw_socketremote_address remote_portN) r,r-r.rr0__annotations__r2r4r6r7r8rrrr"r/*s r/c@s,eZdZed ddZeed ddZdS) _SocketProviderrMapping[Any, Callable[[], Any]]csddlmtjfddtjfddtjfddi}z jWn ty2dYnwdur@fdd|tj <jjt j t j fvrdfdd|tj <durdd fd d|tj<|S) Nr)convert_ipv6_sockaddrcsjjSr) _raw_socketr0rr rr"?sz2_SocketProvider.extra_attributes..csjSrr= getsocknamer)convertr!rr"r>@scsjSr)r=rr rr"r>CcSrrr)peernamerr"r>LcsjdS)Nrr?rr rr"r>QsrcrCrrr)r8rr"r>UrE)_core._socketsr<r/r0r2r6r= getpeernameOSErrorr7r AF_INETAF_INET6r4r8)r! attributesr)rArDr8r!r"extra_attributes:s&   z _SocketProvider.extra_attributesr5cCsdSrrr rrr"r=Ysz_SocketProvider._raw_socketN)rr;)rr5)r,r-r.propertyrLrr=rrrr"r:9s  r:c@eZdZdZdS) SocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. Nr,r-r.__doc__rrrr"rO_rOc@s(eZdZedddZedd dZdS)UNIXSocketStreammessagebytesfdsCollection[int | IOBase]rrcdS)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!rTrVrrr"send_fdshrBzUNIXSocketStream.send_fdsmsglenr3maxfdstuple[bytes, list[int]]crX)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!rZr[rrr" receive_fdsrrBzUNIXSocketStream.receive_fdsN)rTrUrVrWrr)rZr3r[r3rr\)r,r-r.rrYr]rrrr"rSgs   rSc@s,eZdZdZedddZ ddd d ZdS)SocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. rrOcrX)zAccept an incoming connection.Nrr rrr"acceptrBzSocketListener.acceptNhandlerCallable[[SocketStream], Any] task_groupTaskGroup | Nonerc spddlm}t4IdH}|dur||IdH} |IdH}|||q1IdHs1wYdS)Nr)create_task_group)rdrenter_async_contextr_ start_soon)r!r`rbrdstackstreamrrr"serves  zSocketListener.serve)rrOr)r`rarbrcrr)r,r-r.rQrr_rjrrrr"r^}s  r^c@seZdZdZd d d Zd S) UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. datarUhoststrportr3rrcs||||ffIdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). Nsend)r!rlrmrorrr"sendtoszUDPSocket.sendtoN)rlrUrmrnror3rrr,r-r.rQrrrrrr"rksrkc@rN)ConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrPrrrr"rtrRrtc@seZdZdZd dd Zd S) UNIXDatagramSocketz Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. rlrUpathrnrrcs|||fIdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nrp)r!rlrvrrr"rrszUNIXDatagramSocket.sendtoN)rlrUrvrnrrrsrrrr"rusruc@rN)ConnectedUNIXDatagramSocketz Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. NrPrrrr"rwrRrw)5 __future__rsocketabcrcollections.abcrrr contextlibrior ipaddressr r r typesr typingr rr_core._typedattrrrr_streamsrrr_tasksrrn IPAddressTypetupler3IPSockAddrTyper1rU UDPPacketTypeUNIXDatagramPacketTyperrr/r:rOrSr^rkrtrurwrrrr"s>            &