o >hB@svdZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZed krkdd lmZdd lmZdd lmZmZmZmZmZmZmZeeeegZeeeegZeZeZeZ eZ!nddlm Z mZm!Z!mZmZm"Z"e e!e"gZegZddl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+ee)j,e)j-e)j.Gddde&j/Z0ee)j1Gddde e0Z2dS)a Various asynchronous UDP classes. Please do not use this module directly. @var _sockErrReadIgnore: list of symbolic error constants (from the C{errno} module) representing socket errors where the error is temporary and can be ignored. @var _sockErrReadRefuse: list of symbolic error constants (from the C{errno} module) representing socket errors that indicate connection refused. ) annotationsN)Optional) implementer)MulticastMixin)IReactorMulticast)AbstractDatagramProtocol) platformTypewin32)WSAEINPROGRESS)WSAEWOULDBLOCK)WSAECONNREFUSED WSAECONNRESETWSAEINTR WSAEMSGSIZE WSAENETRESETWSAENOPROTOOPT WSAETIMEDOUT)EAGAIN ECONNREFUSEDEINTREMSGSIZE ENOPROTOOPT EWOULDBLOCK)abstractaddressbasedefererror interfaces)logc@seZdZUdZejZded<ejZ ded<dZ dZ ded <dZ d8d d Z eddZd9ddZddZddZddZddZddZd:ddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd:d*d+Zd,d-Zd.d/Zd0d1Zd2d3Z d4d5Z!d6d7Z"dS);Porta UDP port, listening for packets. @ivar maxThroughput: Maximum number of bytes read in one event loop iteration. @ivar addressFamily: L{socket.AF_INET} or L{socket.AF_INET6}, depending on whether this port is listening on an IPv4 address or an IPv6 address. @ivar _realPortNumber: Actual port number being listened on. The value will be L{None} until this L{Port} is listening. @ivar _preexistingSocket: If not L{None}, a L{socket.socket} instance which was created and initialized outside of the reactor and will be used to listen for connections (instead of a new socket being created by this L{Port}). zsocket.AddressFamily addressFamilyzsocket.SocketKind socketTypeiNz Optional[int]_realPortNumber cCs@tj||||_||_||_||_|d|_| dS)a @param port: A port number on which to listen. @type port: L{int} @param proto: A C{DatagramProtocol} instance which will be connected to the given C{port}. @type proto: L{twisted.internet.protocol.DatagramProtocol} @param interface: The local IPv4 or IPv6 address to which to bind; defaults to '', ie all IPv4 addresses. @type interface: L{str} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: L{int} @param reactor: A reactor which will notify this C{Port} when its socket is ready for reading or writing. Defaults to L{None}, ie the default global reactor. @type reactor: L{interfaces.IReactorFDSet} N) rBasePort__init__portprotocol maxPacketSize interface setLogStr_connectedAddr_setAddressFamily)selfr(protor+r*reactorr2t/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/twisted/internet/udp.pyr']s z Port.__init__c Cs8t|||j}|d}|d||||d}||_|S)a Create a new L{Port} based on an existing listening I{SOCK_DGRAM} socket. @param reactor: A reactor which will notify this L{Port} when its socket is ready for reading or writing. Defaults to L{None}, ie the default global reactor. @type reactor: L{interfaces.IReactorFDSet} @param fd: An integer file descriptor associated with a listening socket. The socket must be in non-blocking mode. Any additional attributes desired, such as I{FD_CLOEXEC}, must also be set already. @type fd: L{int} @param addressFamily: The address family (sometimes called I{domain}) of the existing socket. For example, L{socket.AF_INET}. @type addressFamily: L{int} @param protocol: A C{DatagramProtocol} instance which will be connected to the C{port}. @type protocol: L{twisted.internet.protocol.DatagramProtocol} @param maxPacketSize: The maximum packet size to accept. @type maxPacketSize: L{int} @return: A new instance of C{cls} wrapping the socket given by C{fd}. @rtype: L{Port} rN)r+r1r*)socketfromfdr" getsockname_preexistingSocket) clsr1fdr!r)r*r(r+r/r2r2r3_fromListeningDescriptor{s zPort._fromListeningDescriptorreturnstrcCs2|jdurd|jjd|jdSd|jjdS)Nz not connected>)r#r) __class__r/r2r2r3__repr__s z Port.__repr__cC|jS)z) Return a socket object. )r4r@r2r2r3 getHandlezPort.getHandlecCs||dS)z Create and bind my socket, and begin listening on it. This is called on unserialization, and must be called after creating a server to begin listening on the specified port. N) _bindSocket_connectToProtocolr@r2r2r3startListenings zPort.startListeningc Cs|jdur*z|}||j|jfWnty)}z t|j|j|d}~ww|j}d|_|d|_ t d| |j |j fd|_||_|jj|_dS)aJ Prepare and assign a L{socket.socket} instance to C{self.socket}. Either creates a new SOCK_DGRAM L{socket.socket} bound to C{self.interface} and C{self.port} or takes an existing L{socket.socket} provided via the L{interfaces.IReactorSocket.adoptDatagramPort} interface. Nz%s starting on %s)r7createInternetSocketbindr+r(OSErrorrCannotListenErrorr6r#rmsg _getLogPrefixr) connectedr4filenor/sktler2r2r3rEs& zPort._bindSocketcCs|j||dSN)r)makeConnection startReadingr@r2r2r3rFs  zPort._connectToProtocolc Csd}||jkrsz |j|j\}}Wn0tyB}z$|jd}|tvr*WYd}~dS|tvr=|jr6|j WYd}~dSd}~ww|t |7}|j tj krU|dd}z |j ||Wn tyktYnw||jksdSdS)z= Called when my socket is ready for reading. rN) maxThroughputr4recvfromr*rKargs_sockErrReadIgnore_sockErrReadRefuser-r)connectionRefusedlenr!AF_INET6datagramReceived BaseExceptionrerr)r/readdataaddrsenor2r2r3doReads0       z Port.doReadc Cs|jrO|d|jfvs Jz|j|WStyN}z/|jd}|tkr/||WYd}~S|tkr8t d|t krB|j nWYd}~dSd}~ww|dksUJt |dsqt |dsq|ddkrqt|ddt |ds~|ddkr|jtjkrt|ddt |dr|jtjkrt|ddz|j||WSty}z*|jd}|tkr|||WYd}~S|tkrt d|t krWYd}~dSd}~ww)az Write a datagram. @type datagram: L{bytes} @param datagram: The datagram to be sent. @type addr: L{tuple} containing L{str} as first element and L{int} as second element, or L{None} @param addr: A tuple of (I{stringified IPv4 or IPv6 address}, I{integer port number}); can be L{None} in connected mode. Nrzmessage too longz z0write() only accepts IP addresses, not hostnamesz7IPv6 port write() called with IPv4 or broadcast addressz*IPv4 port write() called with IPv6 address)r-r4sendrKrZrwriterrMessageLengthErrorrr)r]r isIPAddress isIPv6AddressInvalidAddressErrorr!r_AF_INETsendto)r/datagramrerfrgr2r2r3rjsb            z Port.writecCs|d||dS)a Write a datagram constructed from an iterable of L{bytes}. @param seq: The data that will make up the complete datagram to be written. @type seq: an iterable of L{bytes} @type addr: L{tuple} containing L{str} as first element and L{int} as second element, or L{None} @param addr: A tuple of (I{stringified IPv4 or IPv6 address}, I{integer port number}); can be L{None} in connected mode. N)rjjoin)r/seqrer2r2r3 writeSequenceBs zPort.writeSequencecCsL|jrtdt|st|st|d||f|_|j||fdS)z- 'Connect' to remote server. z:already connected, reconnecting is not currently supportednot an IPv4 or IPv6 address.N) r- RuntimeErrorrrlrmrrnr4connect)r/hostr(r2r2r3rxQs  z Port.connectcCs&||jr|jd|jdSdS)Nr) stopReadingrOr1 callLaterconnectionLostr@r2r2r3_loseConnection^szPort._loseConnectioncCs&|jr t}|_nd}||SrT)rOrDeferreddr})r/resultr2r2r3 stopListeningcs zPort.stopListeningcCstjdtdd|dS)Nz-Please use stopListening() to disconnect portrW) stacklevel)warningswarnDeprecationWarningrr@r2r2r3loseConnectionks  zPort.loseConnectioncCshtd|jd|_d|_tj|||j|j |` |` t |dr2|j d|` dSdS)z& Cleans up my socket. z(UDP Port %s Closed)Nr)rrMr#rXrr&r|r)doStopr4closerPhasattrrcallback)r/reasonr2r2r3r|ss    zPort.connectionLostcCs||j}d||_dS)zP Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)rNr)logstr)r/ logPrefixr2r2r3r,s zPort.setLogStrcCsHt|jr tj|_dSt|jrtj|_dS|jr"t |jddS)z8 Resolve address family for the socket. rvN) rrmr+r4r_r!rlrorrnr@r2r2r3r.s    zPort._setAddressFamilycCrB)z0 Return the prefix to log with. )rr@r2r2r3rrDzPort.logPrefixcCsR|j}|jtjkrtjdg|RS|jtjkr'tjdg|ddRSdS)z Return the local address of the UDP connection @returns: the local address of the UDP connection @rtype: L{IPv4Address} or L{IPv6Address} UDPNrW)r4r6r!ror IPv4Addressr_ IPv6Address)r/rer2r2r3getHosts   z Port.getHostcCs|jtjtj|dS)z Set whether this port may broadcast. This is disabled by default. @param enabled: Whether the port may broadcast. @type enabled: L{bool} N)r4 setsockopt SOL_SOCKET SO_BROADCAST)r/enabledr2r2r3setBroadcastAllowedszPort.setBroadcastAllowedcCst|jtjtjS)z Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )boolr4 getsockoptrrr@r2r2r3getBroadcastAllowedszPort.getBroadcastAllowed)r$r%N)r;r<rT)#__name__ __module__ __qualname____doc__r4ror!__annotations__ SOCK_DGRAMr"rXr#r7r' classmethodr:rArCrGrErFrhrjrurxr}rrr|r,r.rrrrr2r2r2r3r @s:     + # >    r c@s.eZdZdZ    ddddZdddZdS) MulticastPortz. UDP Port that supports multicasting. r$r%NFr(intr0rr+r<r*r1IReactorMulticast | NonelistenMultiplerr;NonecCst||||||||_dS)zX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)r r'r)r/r(r0r+r*r1rr2r2r3r's zMulticastPort.__init__ socket.socketc Cs~t|}|jr=|tjtjdttdr=z |tjtjdW|St y<}z|j t kr0nWYd}~|Sd}~ww|S)z Override L{Port.createInternetSocket} to configure the socket to honor the C{listenMultiple} argument to L{IReactorMulticast.listenMultiple}. rH SO_REUSEPORTN) r rIrrr4r SO_REUSEADDRrrrKerrnorrQr2r2r3rIs    z"MulticastPort.createInternetSocket)r$r%NF)r(rr0rr+r<r*rr1rrrr;r)r;r)rrrrr'rIr2r2r2r3rs r)3r __future__rr4rtypingrzope.interfacertwisted.internet._multicastrtwisted.internet.interfacesrtwisted.internet.protocolrtwisted.python.runtimerrr r r r rrrrrrr[r\rrrrrtwisted.internetrrrrrrtwisted.pythonrIListeningPort IUDPTransport ISystemHandler&r IMulticastTransportrr2r2r2r3sB         $      |