\dHdZddlZddlZddlZddlmZddlmZddlm Z e dkr3ddl m Z ddl m Z dd l m Z mZmZmZmZmZmZee ee gZe eeegZeZe Ze ZeZndd l mZmZmZmZmZmZeeegZegZdd lmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%ee"j&e"j'e"j(Gd dej)Z*GddZ+ee"j,Gdde+e*Z-dS)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. N)Optional) implementer) platformTypewin32)WSAEINPROGRESS)WSAEWOULDBLOCK)WSAECONNREFUSED WSAECONNRESETWSAEINTR WSAEMSGSIZE WSAENETRESETWSAENOPROTOOPT WSAETIMEDOUT)EAGAIN ECONNREFUSEDEINTREMSGSIZE ENOPROTOOPT EWOULDBLOCK)abstractaddressbasedefererror interfaces)failurelogceZdZUdZejZejZdZ dZ e e e d<dZddZedZd efd Zd Zd Zd ZdZdZddZdZdZdZdZdZddZdZ dZ!dZ"dZ#dZ$dZ%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}). iN_realPortNumber ctj||||_||_||_||_|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(reactors 4lib/python3.11/site-packages/twisted/internet/udp.pyr%z Port.__init__[si* tW---  *" "      ctj|||j}|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)r/r()socketfromfd socketType getsockname_preexistingSocket) clsr/fd addressFamilyr'r(r&r)r-s r0_fromListeningDescriptorzPort._fromListeningDescriptorysd@}R??$$&&q) s  '    #' r1returnc`|jd|jjd|jdSd|jjdS)Nz not connected>)r r' __class__r-s r0__repr__z Port.__repr__sB   +Kt}.KKD4HKKK K?t}.??? ?r1c|jS)z) Return a socket object. )r3rAs r0 getHandlezPort.getHandle {r1cV||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_connectToProtocolrAs r0startListeningzPort.startListenings.  !!!!!r1c|ji |}||j|jfn@#t $r%}t j|j|j|d}~wwxYw|j}d|_|d|_ tj | |j d|j d|_||_|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 starting on )r7createInternetSocketbindr)r&OSErrorrCannotListenErrorr6r rmsg _getLogPrefixr' connectedr3filenor-sktles r0rGzPort._bindSockets  " * M//11$.$)45555 M M M-dndiLLL M)C&*D # #003 !!$-0000$2F2F H    k( s5? A. A))A.cb|j||dSN)r'makeConnection startReadingrAs r0rHzPort._connectToProtocols0 $$T*** r1cd}||jkr |j|j\}}|t |z }|jtjkr |dd} |j||n#t$rtj YnbwxYw#t$rQ}|j d}|tvrYd}~dS|tvr&|jr|jYd}~dSd}~wwxYw||jkdSdS)z= Called when my socket is ready for reading. rN) maxThroughputr3recvfromr(lenr:AF_INET6r'datagramReceived BaseExceptionrerrrNargs_sockErrReadIgnore_sockErrReadRefuser+connectionRefused)r-readdataaddrsenos r0doReadz Port.doReadsOT''' ![11$2DEE dD !%88 8DM224>>>>$GIIIII+   WQZ+++FFFFF+++*: 77999FFFFF T'''''''s5"B"#A??BB" C=,C8)C87C88C=c|jr|d|jfvsJ |j|S#t$r}|jd}|t kr||cYd}~S|tkrtj d|tkr|j nYd}~dSd}~wwxYw|dksJtj|dsAtj|ds'|ddkrtj|ddtj|ds |ddkr0|jtjkrtj|ddtj|dr0|jtjkrtj|dd |j||S#t$ri}|jd}|t kr|||cYd}~S|tkrtj d|tkrYd}~dSd}~wwxYw)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+r3sendrNrdrwriterrMessageLengthErrorrr'rgr isIPAddress isIPv6AddressInvalidAddressErrorr:r`AF_INETsendto)r-datagramrjrkrls r0rpz Port.writes  0 D$"566666 {''111   WQZ;;::h////////8^^23EFFF<''M335555655555 4<<<<(a11  .tAw77 G},,/GO$T!W-- 15aM1I1I$77/GV%d1g.. 43E3W3W/GI {))(D999   WQZ;;::h555555558^^23EFFF<''FFFFF sK0 B<,B7&B<,AB77B<G I(-I I*I  I  IcX|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. r1N)rpjoin)r-seqrjs r0 writeSequencezPort.writeSequence@s( 388C==$'''''r1c|jrtdtj|s)tj|st j|d||f|_|j||fdS)z- 'Connect' to remote server. z:already connected, reconnecting is not currently supportednot an IPv4 or IPv6 address.N) r+ RuntimeErrorrrrrsrrtr3connect)r-hostr&s r0rz Port.connectOs   L #D)) R(2H2N2N R+D2PQQ Q#Tl T4L)))))r1c||jr"|jd|jdSdS)Nr) stopReadingrRr/ callLaterconnectionLostrAs r0_loseConnectionzPort._loseConnection\sI  > ; L " "1d&9 : : : : : ; ;r1cv|jrtjx}|_nd}||SrX)rRrDeferreddr)r-results r0 stopListeningzPort.stopListeningas> > #n.. .FTVVF  r1cftjdtd|dS)Nz-Please use stopListening() to disconnect portr\) stacklevel)warningswarnDeprecationWarningrrAs r0loseConnectionzPort.loseConnectionis> ;     r1cbtjd|jzd|_d|_tj|||j|j |` |` t|dr|j d|` dSdS)z& Cleans up my socket. z(UDP Port %s Closed)Nr)rrPr r]rr$rr'doStopr3closerShasattrrcallback)r-reasons r0rzPort.connectionLostqs &)==>>># $$T6222   K K 4    FOOD ! ! !  r1cN||j}d|z|_dS)zP Initialize the C{logstr} attribute to be used by C{logPrefix}. z%s (UDP)N)rQr'logstr)r- logPrefixs r0r*zPort.setLogStrs)&&t}55  9, r1ctj|jrtj|_dStj|jrtj|_dS|jrtj |jddS)z8 Resolve address family for the socket. r}N) rrsr)r3r`r:rrrurrtrAs r0r,zPort._setAddressFamilys  !$. 1 1 !'D     !$. 1 1 !'D    ^ + >   r1c|jS)z0 Return the prefix to log with. )rrAs r0rzPort.logPrefixrEr1c|j}|jtjkrt jdg|RS|jtjkrt jdg|ddRSdS)z Return the local address of the UDP connection @returns: the local address of the UDP connection @rtype: L{IPv4Address} or L{IPv6Address} UDPNr\)r3r6r:rur IPv4Addressr` IPv6Addressr-rjs r0getHostz Port.getHostsy{&&((   / /&u4t444 4  6? 2 2&u:RaR::: :3 2r1cf|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)r3 setsockopt SOL_SOCKET SO_BROADCAST)r-enableds r0setBroadcastAllowedzPort.setBroadcastAlloweds* v0&2EwOOOOOr1czt|jtjtjS)z Checks if broadcast is currently allowed on this port. @return: Whether this port may broadcast. @rtype: L{bool} )boolr3 getsockoptrrrAs r0getBroadcastAllowedzPort.getBroadcastAlloweds*DK**6+QRRSSSr1)r!r"NrX)&__name__ __module__ __qualname____doc__r3rur: SOCK_DGRAMr5r]r rint__annotations__r7r% classmethodr;strrBrDrIrGrHrmrpr{rrrrrr*r,rrrrr1r0rr>s$NM"JM%)OXc])))!!!!<))[)V@#@@@@  """!)!)!)F@<<<<| ( ( ( * * *;;;  ---    ; ; ;PPPTTTTTr1rcXeZdZdZdZdZdZdZdZdZ dZ dd Z d Z d Z dd ZdS)MulticastMixinz, Implement multicast functionality. c|jtjtj}tjt jd|S)Nz@i)r3r IPPROTO_IPIP_MULTICAST_IF inet_ntoastructpack)r-is r0getOutgoingInterfacez#MulticastMixin.getOutgoingInterfaces< K " "6#4f6L M M D! 4 4555r1cf|j||jS)zReturns Deferred of success.)r/resolve addCallback _setInterfacers r0setOutgoingInterfacez#MulticastMixin.setOutgoingInterfaces)|##D))55d6HIIIr1ctj|}|jtjtj|dS)NrK)r3 inet_atonrrr)r-rjrs r0rzMulticastMixin._setInterfaces7  T " " v0&2H!LLLqr1c`|jtjtjSrX)r3rrIP_MULTICAST_LOOPrAs r0getLoopbackModezMulticastMixin.getLoopbackModes {%%f&79QRRRr1ctjdt|}|jtjtj|dS)Nb)rrrr3rrr)r-modes r0setLoopbackModezMulticastMixin.setLoopbackModes?{3T ++ v0&2JDQQQQQr1c`|jtjtjSrX)r3rrIP_MULTICAST_TTLrAs r0getTTLzMulticastMixin.getTTLs {%%f&79PQQQr1ctjd|}|jtjtj|dS)NB)rrr3rrr)r-ttls r0setTTLzMulticastMixin.setTTLs9k#s## v0&2I3OOOOOr1r!cj|j||j|dS)z4Join a multicast group. Returns Deferred of success.rKr/rr _joinAddr1r-rjr)s r0 joinGroupzMulticastMixin.joinGroup-|##D))55doyRSTTTr1cj|j||j||SrX)r/rr _joinAddr2)r-rjr)rys r0rzMulticastMixin._joinAddr1s-|##I..::4?DRVWWWr1cbtj|}tj|}|r tj}n tj} |jtj|||zdS#t $r4}tjtj ||g|j RcYd}~Sd}~wwxYwrX) r3rIP_ADD_MEMBERSHIPIP_DROP_MEMBERSHIPrrrNrFailurerMulticastJoinErrorrd)r-r)rjrycmdes r0rzMulticastMixin._joinAddr2s%%$Y//  ,*CC+C W K " "6#4c4);K L L L L L W W W?5#;D)#Uaf#U#U#UVV V V V V V V Ws)A00 B.:)B)#B.)B.cj|j||j|dS)z2Leave multicast group, return Deferred of success.rrrs r0 leaveGroupzMulticastMixin.leaveGrouprr1N)r!)rrrrrrrrrrrrrrrrr1r0rrs666JJJ SSSRRRRRRPPPUUUUXXX W W WUUUUUUr1rc(eZdZdZ ddZdZdS) MulticastPortz. UDP Port that supports multicasting. r!r"NFcRt||||||||_dS)zX @see: L{twisted.internet.interfaces.IReactorMulticast.listenMulticast} N)rr%listenMultiple)r-r&r.r)r(r/rs r0r%zMulticastPort.__init__s. dD%M7KKK,r1ctt|}|jr|tjtjdttdrV |tjtjdn)#t$r}|j tkrnYd}~nd}~wwxYw|S)NrK SO_REUSEPORT) rrLrrr3r SO_REUSEADDRrrrNerrnorrTs r0rLz"MulticastPort.createInternetSockets''--    NN6,f.A1 E E Ev~.. NN6#4f6I1MMMMx;..  s#+B B5B00B5)r!r"NF)rrrrr%rLrr1r0rrsO - - - -     r1r).rr3rrtypingrzope.interfacertwisted.python.runtimerrrrr r r r r rrrrerfrrrrrtwisted.internetrrrrrrtwisted.pythonrrIListeningPort IUDPTransport ISystemHandler$rrIMulticastTransportrrr1r0rs   &&&&&&//////7$$$$$$$$$$$$#NKP)=, UH"L F EEUUUUUUUUUUUUUUUU %5&ONNNNNNNNNNNNNNN'''''''' z79QwTwTwTwTwT4=wTwTwTt 5U5U5U5U5U5U5U5Up Z +,,!!!!!ND!!-,!!!r1