Yf dZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z ddlmZee Gd d Zee eee Gd d eZee ed S)z$ Utilities for Twisted.names tests. ) randrange) implementer) verifyClass) IPv4Address)succeed) IReactorUDP IUDPTransport)Clockc>eZdZdZdZdZdZd dZdZdZ d Z dS) MemoryDatagramTransporta This L{IUDPTransport} implementation enforces the usual connection rules and captures sent traffic in a list for later inspection. @ivar _host: The host address to which this transport is bound. @ivar _protocol: The protocol connected to this transport. @ivar _sentPackets: A C{list} of two-tuples of the datagrams passed to C{write} and the addresses to which they are destined. @ivar _connectedTo: L{None} if this transport is unconnected, otherwise an address to which all traffic is supposedly sent. @ivar _maxPacketSize: An C{int} giving the maximum length of a datagram which will be successfully handled by C{write}. cL||_||_g|_d|_||_dSN)_host _protocol _sentPackets _connectedTo_maxPacketSize)selfhostprotocol maxPacketSizes N/var/www/html/env/lib/python3.11/site-packages/twisted/names/test/test_util.py__init__z MemoryDatagramTransport.__init__&s. ! +c&tdg|jRS)z_ Return the address which this transport is pretending to be bound to. UDP)rrrs rgetHostzMemoryDatagramTransport.getHost-s 5.4:....rcD|jtd||f|_dS)z> Connect this transport to the given address. NzAlready connected)r ValueError)rrports rconnectzMemoryDatagramTransport.connect4s.   (011 1!4LrNc||j}|tdt||jkrtd|j||fdS)z* Send the given datagram. NzNeed an addresszPacket too big)rr lenrrappend)rdatagramaddrs rwritezMemoryDatagramTransport.write<sj <$D <.// / x==4. . .-.. .   (D!122222rcR|jtdS)z+ Shut down this transport. N)r stopProtocolrrs r stopListeningz%MemoryDatagramTransport.stopListeningHs$ ##%%%t}}rcdSzC Dummy implementation to satisfy L{IUDPTransport}. N)renableds rsetBroadcastAllowedz+MemoryDatagramTransport.setBroadcastAllowedO  rcdSr-r.rs rgetBroadcastAllowedz+MemoryDatagramTransport.getBroadcastAllowedUr1rr) __name__ __module__ __qualname____doc__rrr"r(r+r0r3r.rrr r s ,,,///))) 3 3 3 3        rr c eZdZdZdZddZdS) MemoryReactoraO An L{IReactorTime} and L{IReactorUDP} provider. Time is controlled deterministically via the base class, L{Clock}. UDP is handled in-memory by connecting protocols to instances of L{MemoryDatagramTransport}. @ivar udpPorts: A C{dict} mapping port numbers to instances of L{MemoryDatagramTransport}. c<tj|i|_dSr)r rudpPortsrs rrzMemoryReactor.__init__ls t r c|dkr tdd}||jvrn||jvrtdt||f||}||j|<|||S)zR Pretend to bind a UDP port and connect the given protocol to it. rTizAddress in use)rr;r r makeConnection)rr!r interfacer transports r listenUDPzMemoryReactor.listenUDPps 199  E**t},,  4= -.. .+Y,=xWW ' d ***rN)r<r=)r4r5r6r7rrCr.rrr9r9_sA  rr9N)r7randomrzope.interfacerzope.interface.verifyrtwisted.internet.addressrtwisted.internet.deferrtwisted.internet.interfacesrr twisted.internet.taskr r r9r.rrrKsN &&&&&&------000000******BBBBBBBB'''''' ]D D D D D D D D N M2333 [EB K'''''r