o <^öhÊ3ã@s,UddlmZddlZddlZddlZddlmZddlmZm Z m Z ddlmZddl mZddlmZmZddlmZdd lmZmZmZd dlmZd dlmZmZmZd dlmZmZm Z d dl!m"Z"ej#dkrsddlm$Z$nddl%m$Z$ee&eefZ'de(d<e)e&e*fZ+de(d<ee+e&fZ,de(d<e)e-e+fZ.de(d<e)e-e&fZ/de(d<edƒZ0ej1fdddœd:d&d'„Z2Gd(d)„d)eƒZ3Gd*d+„d+eƒZ4Gd,d-„d-ee4ƒZ5Gd.d/„d/e5ƒZ6Gd0d1„d1ee5e4ƒZ7Gd2d3„d3e e.e4ƒZ8Gd4d5„d5e e-e4ƒZ9Gd6d7„d7e e/e4ƒZ:Gd8d9„d9e e-e4ƒZ;dS);é)ÚannotationsN)Úabstractmethod)ÚCallableÚ CollectionÚMapping)ÚAsyncExitStack)ÚIOBase)ÚIPv4AddressÚIPv6Address)Ú AddressFamily)ÚAnyÚTypeVarÚUnioné)Úget_async_backend)ÚTypedAttributeProviderÚTypedAttributeSetÚtyped_attributeé)Ú ByteStreamÚListenerÚUnreliableObjectStream)Ú TaskGroup)éé )Ú TypeAliasrÚ IPAddressTypeÚIPSockAddrTypeÚSockAddrTypeÚ UDPPacketTypeÚUNIXDatagramPacketTypeÚT_RetvalF)Úrequire_connectedÚ require_boundÚ sock_or_fdúsocket.socket | intÚ sock_typeúsocket.SocketKindÚaddr_familyúsocket.AddressFamilyr"Úboolr#Úreturnú socket.socketc Cs t|tƒr4ztj|d}Wn:ty3}z|jtjkr tdƒ|‚|r'tdƒ|‚|r.tdƒ|‚‚d}~wwt|tjƒr=|}ntdt|ƒj ›dƒ‚zo|rcz| ¡Wntyb}ztdƒ|‚d}~ww|rz|jtjtj fvrv| ¡d}n| ¡}Wnty†d}Ynw|stdƒ‚|tjkr¤|j|kr¤td|j›d |jj›ƒ‚|j|kr¶td |j›d |jj›ƒ‚WntyÈt|tƒrÇ| ¡‚w| d¡|S)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)Ú isinstanceÚintÚsocketÚOSErrorÚerrnoÚENOTSOCKÚ ValueErrorÚ TypeErrorÚtypeÚ__qualname__ÚgetpeernameÚfamilyÚAF_INETÚAF_INET6ÚgetsocknameÚ AF_UNSPECÚnameÚ BaseExceptionÚdetachÚsetblocking)r$r&r(r"r#ÚsockÚexcÚ bound_addr©rEúR/home/air/websocket/korean/venv/lib/python3.10/site-packages/anyio/abc/_sockets.pyÚ_validate_socket$sv ÿþ €öÿ €ÿ€ÿ ÿÿ ÿÿ û rGc@sfeZdZUdZeƒZded<eƒZded<eƒZded<eƒZ ded <eƒZ ded <eƒZded<dS) ÚSocketAttributeaý .. 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 rr9rÚ local_addressr/Ú local_portr,Ú raw_socketÚremote_addressÚremote_portN)Ú__name__Ú __module__r7Ú__doc__rr9Ú__annotations__rIrJrKrLrMrErErErFrHis rHc@s,eZdZed dd„ƒZeed dd„ƒƒZdS)Ú_SocketProviderr+úMapping[Any, Callable[[], Any]]csÌddlm‰tj‡fdd„tj‡‡fdd„tj‡fdd„i}z ˆˆj ¡ƒ‰Wnty2d‰Ynwˆdur@‡fdd„|tj <ˆjjt jt jfvrd‡fdd„|tj <ˆdurdˆd ‰‡fd d„|tj<|S)Nr)Úconvert_ipv6_sockaddrcsˆjjS©N)Ú_raw_socketr9rE©ÚselfrErFÚ˜sz2_SocketProvider.extra_attributes..csˆˆj ¡ƒSrU©rVr<rE)ÚconvertrXrErFrY™sÿcsˆjSrU)rVrErWrErFrYœócóˆSrUrErE)ÚpeernamerErFrY¥ócsˆj ¡dS)NrrZrErWrErFrYªsrcr]rUrErE)rMrErFrY®r_)Ú_core._socketsrTrHr9rIrKrVr8r1rLrr:r;rJrM)rXÚ attributesrE)r[r^rMrXrFÚextra_attributes“s&ûÿ ÿz _SocketProvider.extra_attributesr,cCsdSrUrErWrErErFrV²sz_SocketProvider._raw_socketN)r+rS)r+r,)rNrOr7ÚpropertyrbrrVrErErErFrR’srRc@óeZdZdZeddd„ƒZdS) ÚSocketStreamzu Transports bytes over a socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cÃó$t|tjdd}tƒ |¡IdHS)aH 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 T©r"N)rGr0ÚSOCK_STREAMrÚwrap_stream_socket©Úclsr$rBrErErFÚfrom_socket¿ó€zSocketStream.from_socketN)r$r%r+re©rNrOr7rPÚclassmethodrlrErErErFre¸órec@s6eZdZeddd„ƒZeddd„ƒZeddd„ƒZdS)ÚUNIXSocketStreamr$r%r+cÃó(t|tjtjdd}tƒ |¡IdHS)aR 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 TrgN)rGr0rhÚAF_UNIXrÚwrap_unix_stream_socketrjrErErFrlÐs €ÿzUNIXSocketStream.from_socketÚmessageÚbytesÚfdsúCollection[int | IOBase]ÚNonecÃódS)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) NrE)rXrurwrErErFÚsend_fdsár\zUNIXSocketStream.send_fdsÚmsglenr/Úmaxfdsútuple[bytes, list[int]]cÃrz)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) NrE)rXr|r}rErErFÚreceive_fdsër\zUNIXSocketStream.receive_fdsN)r$r%r+rq)rurvrwrxr+ry)r|r/r}r/r+r~)rNrOr7rorlrr{rrErErErFrqÏs rqc@s:eZdZdZeddd„ƒZeddd „ƒZ dddd„Zd S)ÚSocketListenerz} Listens to incoming socket connections. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cÃrf)a 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 T©r#N)rGr0rhrÚwrap_listener_socketrjrErErFrlýs€zSocketListener.from_socketrecÃrz)zAccept an incoming connection.NrErWrErErFÚacceptr\zSocketListener.acceptNÚhandlerúCallable[[SocketStream], Any]Ú task_groupúTaskGroup | Noneryc Ãspddlm}tƒ4IdHš}|dur| |ƒ¡IdH} | ¡IdH}| ||¡q1IdHs1wYdS)Nr)Úcreate_task_group)ÚrˆrÚenter_async_contextrƒÚ start_soon)rXr„r†rˆÚstackÚstreamrErErFÚserves€þüzSocketListener.serve)r$r%r+r€)r+rerU)r„r…r†r‡r+ry) rNrOr7rProrlrrƒrŽrErErErFr€ösýr€c@s(eZdZdZeddd„ƒZddd„ZdS)Ú UDPSocketz{ Represents an unconnected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cÃrf)aI 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)rGr0Ú SOCK_DGRAMrÚwrap_udp_socketrjrErErFrl)rmzUDPSocket.from_socketÚdatarvÚhostÚstrÚportr/rycÃs| |||ff¡IdHS)z^ Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, (host, port))). N©Úsend)rXr’r“r•rErErFÚsendto8s€zUDPSocket.sendtoN)r$r%r+r)r’rvr“r”r•r/r+ry©rNrOr7rProrlr˜rErErErFr"s rc@rd) ÚConnectedUDPSocketzy Represents an connected UDP socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cÃrf)aV 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 TrgN)rGr0rrÚwrap_connected_udp_socketrjrErErFrlGs€ýzConnectedUDPSocket.from_socketN)r$r%r+ršrnrErErErFrš@rpršc@s(eZdZdZeddd„ƒZddd „ZdS)ÚUNIXDatagramSocketz… Represents an unconnected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cÃs$t|tjtjƒ}tƒ |¡IdHS)a' 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)rGr0rrsrÚwrap_unix_datagram_socketrjrErErFrlds€zUNIXDatagramSocket.from_socketr’rvÚpathr”rycÃs| ||f¡IdHS)zCAlias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).Nr–)rXr’ržrErErFr˜vs€zUNIXDatagramSocket.sendtoN)r$r%r+rœ)r’rvržr”r+ryr™rErErErFrœ[s rœc@rd) ÚConnectedUNIXDatagramSocketz‚ Represents a connected Unix datagram socket. Supports all relevant extra attributes from :class:`~SocketAttribute`. r$r%r+cÃrr)ar 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 TrgN)rGr0rrsrÚ#wrap_connected_unix_datagram_socketrjrErErFrl‚s €ÿz'ConnectedUNIXDatagramSocket.from_socketN)r$r%r+rŸrnrErErErFrŸ{rprŸ)r$r%r&r'r(r)r"r*r#r*r+r,)<Ú __future__rr2r0ÚsysÚabcrÚcollections.abcrrrÚ contextlibrÚiorÚ ipaddressr r rÚtypingrr rÚ_core._eventlooprÚ_core._typedattrrrrÚ_streamsrrrÚ_tasksrÚversion_inforÚtyping_extensionsr”rrQÚtupler/rrrvrr r!r=rGrHrRrerqr€rršrœrŸrErErErFÚsP ýúE)&', ÿ