+ j JRt^RIHt^RIt^RIHt^RIH t H t ^RI H t H t ^RIHtHt^RIHt^RIHtHt^R IHtHt^R IHt!R R 4t] !] P84!R R44t] !] P<] P>] P@4!RR44t!Rt"Rt#!RR4t$RRlt%]"]#RRR3Rlt&Rt'!RR4t(RRlt)R# ]dLi;i)z0 Utilities and helpers for simulating a network ) annotationsN)Error)directlyProvides implementer)error interfaces)TCP4ClientEndpointTCP4ServerEndpoint)ConnectionRefusedError)FactoryProtocol) MemoryReactorMemoryReactorClock)Failurec.]tRt^tRtRRltRtRtR#)TLSNegotiationc 8WnW nRVnW nR#)FN)obj connectStatesent readyToSend)selfrrs&&&4/usr/lib/python3/dist-packages/twisted/test/iosim.py__init__TLSNegotiation.__init__s( 'cV^8dQhRR/#returnstr)formats"r __annotate__TLSNegotiation.__annotate__"s//#/rc $RVP: R2#)zTLSNegotiation())rrs&r__repr__TLSNegotiation.__repr__"s  A..rc VPPVP4'g"\4VnVP 4R#R#N)r iosimVerifyNativeOpenSSLErrordisconnectReasonloseConnection)rothertpts&&&rpretendToVerifyTLSNegotiation.pretendToVerify%s9xx##EII..#5#7C    /r)rrrrN)__name__ __module__ __qualname____firstlineno__rr(r2__static_attributes__r!rrrrs( /!rrc]tRt^.tRtRtR#) FakeAddresszQ The default address type for the host and peer of L{FakeTransport} connections. r!N)r4r5r6r7__doc__r8r!rrr:r:.srr:c0]tRt^6tRt]!]P!43Rl4t^t ^t ^t ] P!R4tRt^tRtR RltRRltRtR tR tR tR tR tRtRtRtRtRtRtRt Rt!Rt"R!Rlt#Rt$Rt%Rt&Rt'Rt(Rt)Rt*Rt+R#)" FakeTransportz A wrapper around a file-like object to make it behave as a Transport. This doesn't actually stream the file to the attached protocol, and is thus useful mainly as a utility for debugging protocols. c *\\V44#r+)intnext)counters&rFakeTransport.?s T']ASrzConnection doneNc WnW n.VnVP4VnVf \ 4pW0nVf \ 4pW@nR#)at @param protocol: This transport will deliver bytes to this protocol. @type protocol: L{IProtocol} provider @param isServer: C{True} if this is the accepting side of the connection, C{False} if it is the connecting side. @type isServer: L{bool} @param hostAddress: The value to return from C{getHost}. L{None} results in a new L{FakeAddress} being created to use as the value. @type hostAddress: L{IAddress} provider or L{None} @param peerAddress: The value to return from C{getPeer}. L{None} results in a new L{FakeAddress} being created to use as the value. @type peerAddress: L{IAddress} provider or L{None} N)protocolisServerstream _nextserialserialr: hostAddress peerAddress)rrErFrJrKs&&&&&rrFakeTransport.__init__HsK"!   &&(  %-K&  %-K&rcV^8dQhRR/#rr!)r"s"rr#FakeTransport.__annotate__ds  # rc RPVP;'d R;'gRVPVPPP 4#)zFakeTransport<{},{},{}>SC)r"rFrIrE __class__r4r's&rr(FakeTransport.__repr__dsF(// MM ! !c ( (S KK MM # # , ,  rc VP'dR#VPeVPPV4R#VPPV4R#r+) disconnectingtlstlsbufappendrG)rdatas&&rwriteFakeTransport.writeks?      88  KK  t $ KK  t $rc VP'd1VP'gVPP4R#R#R#r+producerstreamingProducerresumeProducingr's&r_checkProducerFakeTransport._checkProducerus/ ===!7!7!7 MM ) ) +"8=rc RWnW nV'gVP4R#R#)z From abstract.FileDescriptor Nr])rr^ streamings&&&rregisterProducerFakeTransport.registerProducer{s#! !*  $ $ &rc RVnR#r+)r^r's&runregisterProducer FakeTransport.unregisterProducers  rc FVP4VP4R#r+)rhr/r's&r stopConsumingFakeTransport.stopConsumings ! rc FVPRPV44R#)rN)rZjoin)riovecs&&r writeSequenceFakeTransport.writeSequences 388E?#rc RVnR#)TNrUr's&rr/FakeTransport.loseConnections !rc RVnR#)zX For the time being, this is the same as loseConnection; no buffered data will be lost. TNrsr's&rabortConnectionFakeTransport.abortConnections "rc VPe \4pM VPpVPP \ V44R#r+)rVr-r.rEconnectionLostr)rerrs& rreportDisconnectFakeTransport.reportDisconnects7 88 %&C''C $$WS\2rc R#)z= Identify this transport/event source to the logging system. iosimr!r's&r logPrefixFakeTransport.logPrefixsrc VP#r+)rKr's&rgetPeerFakeTransport.getPeerrc VP#r+)rJr's&rgetHostFakeTransport.getHostrrc R#r+r!r's&rr`FakeTransport.resumeProducing rc R#r+r!r's&rpauseProducingFakeTransport.pauseProducingrrc &VP4R#r+)r/r's&r stopProducingFakeTransport.stopProducings rc ZVPV, p\W4Vn.VnR#r+)rFrrVrW)rcontextFactorybeNormalrs&&& rstartTLSFakeTransport.startTLSs%}}x/ !.? rc VPpV'd.VnRPV4#VPe<VPP'dRVPnVP#R#R#)z Get the pending writes from this transport, clearing them from the pending buffer. @return: the bytes written with C{transport.write} @rtype: L{bytes} rNT)rGrnrVrr)rrPs& r getOutBufferFakeTransport.getOutBuffersY KK DK88A;  XX !xx### $ xxrc \V\4'dVPfQhVPP'dcVPP W4RVnVP Ruq nVP V4\V\P4R#RVPn R#VPPV4R#)NT) isinstancerrVrr2rWrprr ISSLTransportrrE dataReceived)rbufbs&& rbufferReceivedFakeTransport.bufferReceiveds c> * *88' ''xx}}}((3"&d;""1% z'?'?@(,$ MM & &s +rc R#r+r!r's&rgetTcpKeepAliveFakeTransport.getTcpKeepAliverrc R#r+r!r's&r getTcpNoDelayFakeTransport.getTcpNoDelayrrc R#r+r!r's&rloseWriteConnection!FakeTransport.loseWriteConnectionrrc R#r+r!renableds&&rsetTcpKeepAliveFakeTransport.setTcpKeepAliverrc R#r+r!rs&&r setTcpNoDelayFakeTransport.setTcpNoDelayrr) rUrJrFrKr^rErIrGr_rVrW)NN)T),r4r5r6r7r; staticmethod itertoolscountrHclosedrU disconnectedrConnectionDoner.r^r_rVrr(rZrarerhrkrpr/rvr{rrrr`rrrrrrrrrrr8r!rrr=r=6sioo.?STK FML++,=>H C'8 %, '$""3     ,,&     rr=c\VRR7#)z Create and return a new in-memory transport hooked up to the given protocol. @param clientProtocol: The client protocol to use. @type clientProtocol: L{IProtocol} provider @return: The transport. @rtype: L{FakeTransport} FrFr=)clientProtocols&rmakeFakeClientrs % 88rc\VRR7#)z Create and return a new in-memory transport hooked up to the given protocol. @param serverProtocol: The server protocol to use. @type serverProtocol: L{IProtocol} provider @return: The transport. @rtype: L{FakeTransport} Trr)serverProtocols&rmakeFakeServerr s $ 77rc8]tRtRtRtRRltR RltR RltRtR#) IOPumpiz Utility to pump data between clients and servers for protocol testing. Perhaps this is a utility worthy of being in protocol.py? Nc jWnW nW0nW@nWPnVf \ 4pW`nR#r+)clientserverclientIOserverIOdebugrclock)rrrrrrrs&&&&&&&rrIOPump.__init__s-     =&(E rc pRp\R4FpVPW4'dRpKV# QR4h)zS Pump until there is no more input or output. Returns whether any data was moved. FiTzToo long)rangepump)rr advanceClockresult_s&&& rflush IOPump.flush)sA tAyy--  !j 1rc XV'dVPP^4VP'g V'd \R4VPP 4pVP P 4pVP P4VPP4VP'g V'dR\R4V'd\R\V4,4V'd\R\V4,4V'dVPPV4V'dVP PV4V'g V'dR#VPP'dVPP'gdVP'g V'd \R4RVPn RVP n VP P4R#VP P'dVP P'gdVP'g V'd \R4RVP n RVPn VPP4R#R#) z Move data back and forth, while also triggering any currently pending scheduled calls (i.e. C{callLater(0, f)}). Returns whether any data was moved. z -- GLUG --.zC: zS: Tz* Cz* SF) radvancerprintrrrrareprrrUrr{)rrrsDatacDatas&&& rr IOPump.pump9s  JJ  q ! ::: ,  **, **, $$& $$& ::: #Jed5k)*ed5k)*  MM ( ( /  MM ( ( / E == & & &t}}/I/I/IzzzUe )-DMM &*.DMM ' MM * * , == & & &t}}/I/I/IzzzUe )-DMM &*.DMM ' MM * * ,r)rrrrrrr+FT) r4r5r6r7r;rrrr8r!rrrrs  **rrFTc VPV4VPV4\VVVVVVR7pV'dVP4V#)as Create a new L{IOPump} connecting two protocols. @param serverProtocol: The protocol to use on the accepting side of the connection. @type serverProtocol: L{IProtocol} provider @param serverTransport: The transport to associate with C{serverProtocol}. @type serverTransport: L{FakeTransport} @param clientProtocol: The protocol to use on the initiating side of the connection. @type clientProtocol: L{IProtocol} provider @param clientTransport: The transport to associate with C{clientProtocol}. @type clientTransport: L{FakeTransport} @param debug: A flag indicating whether to log information about what the L{IOPump} is doing. @type debug: L{bool} @param greet: Should the L{IOPump} be L{flushed } once before returning to put the protocols into their post-handshake or post-server-greeting state? @type greet: L{bool} @param clock: An optional L{Clock}. Pumping the resulting L{IOPump} will also increase clock time by a small increment. @return: An L{IOPump} which connects C{serverProtocol} and C{clientProtocol} and delivers bytes between them when it is pumped. @rtype: L{IOPump} r)makeConnectionrr)rserverTransportrclientTransportrgreetrrs&&&&&&& rconnectrfsPT!!/2!!/2    D  Krc `V!4pV!4pV!V4p V!V4p Wx\WWyWEVR73#)a Connect a given server and client class to each other. @param ServerClass: a callable that produces the server-side protocol. @type ServerClass: 0-argument callable returning L{IProtocol} provider. @param ClientClass: like C{ServerClass} but for the other side of the connection. @type ClientClass: 0-argument callable returning L{IProtocol} provider. @param clientTransportFactory: a callable that produces the transport which will be attached to the protocol returned from C{ClientClass}. @type clientTransportFactory: callable taking (L{IProtocol}) and returning L{FakeTransport} @param serverTransportFactory: a callable that produces the transport which will be attached to the protocol returned from C{ServerClass}. @type serverTransportFactory: callable taking (L{IProtocol}) and returning L{FakeTransport} @param debug: Should this dump an escaped version of all traffic on this connection to stdout for inspection? @type debug: L{bool} @param greet: Should the L{IOPump} be L{flushed } once before returning to put the protocols into their post-handshake or post-server-greeting state? @type greet: L{bool} @param clock: An optional L{Clock}. Pumping the resulting L{IOPump} will also increase clock time by a small increment. @return: the client protocol, the server protocol, and an L{IOPump} which, when its C{pump} and C{flush} methods are called, will move data between the created client and server protocol instances. @rtype: 3-L{tuple} of L{IProtocol}, L{IProtocol}, L{IOPump} r)r) ServerClass ClientClassclientTransportFactoryserverTransportFactoryrrrcsciosios &&&&&&& rconnectedServerAndClientrs=\  A A  #C  #C UC CCrc2VwpppppVwrxrWs8XdWH3#R#)a Should the client and server described by the arguments be connected to each other, i.e. do their port numbers match? @param clientInfo: the args for connectTCP @type clientInfo: L{tuple} @param serverInfo: the args for listenTCP @type serverInfo: L{tuple} @return: If they do match, return factories for the client and server that should connect; otherwise return L{None}, indicating they shouldn't be connected. @rtype: L{None} or 2-L{tuple} of (L{ClientFactory}, L{IProtocolFactory}) Nr!) clientInfo serverInfo clientHost clientPort clientFactory clientTimeoutclientBindAddress serverPort serverFactory serverBacklogserverInterfaces && r_factoriesShouldConnectrs7.  BL?Z ++rc^]tRtRtRtRRltR RRllt]!]!443RRllt R t R #) ConnectionCompleteriz A L{ConnectionCompleter} can cause synthetic TCP connections established by L{MemoryReactor.connectTCP} and L{MemoryReactor.listenTCP} to succeed or fail. c V^8dQhRRRR/#)r memoryReactorr rNoner!)r"s"rr# ConnectionCompleter.__annotate__s&&m&&rc WnR#)zk Create a L{ConnectionCompleter} from a L{MemoryReactor}. @param memoryReactor: The reactor to attach to. N_reactor)rrs&&rrConnectionCompleter.__init__s & rc$V^8dQhRRRRRR/#)rrboolrrz IOPump | Noner!)r"s"rr#rs!   d m rc  VPp\VP4FwrEVPFp\ WV4pV'gKVPP V4VP PV4VwrVPR4p V PR4p \V 4p \V 4p \V V V V VVR7pVuu# K R#)a Complete a single TCP connection established on this L{ConnectionCompleter}'s L{MemoryReactor}. @param debug: A flag; whether to dump output from the established connection to stdout. @return: a pump for the connection, or L{None} if no connection could be established. N)r) r enumerate tcpClients tcpServersrremove connectorspop buildProtocolrrr)rrrr clientIdxrr factoriesrrrrrrrs&&& r succeedOnceConnectionCompleter.succeedOnces %.}/G/G%H !I+66 3JK 9!,,33J?!,,00;3<0M%2%@%@%FN%2%@%@%FN&4^&DO&4^&DO%,&'&'# &F"M%7&I(rc V^8dQhRRRR/#)rreasonrrrr!)r"s"rr#r%s   w  t  rc VPPP^4^,PVPPP^4V4R#)z Fail a single TCP connection established on this L{ConnectionCompleter}'s L{MemoryReactor}. @param reason: the reason to provide that the connection failed. N)rrr clientConnectionFailedr )rrs&&rfailOnceConnectionCompleter.failOnce%sF   $$Q'*AA MM $ $ ( ( +V rrNr) r4r5r6r7r;rrrr rr8r!rrrrs* & D*11G1I)J   rrc\4p\VRR4p\VR4pVP\P !\ 44V\V43#)ae Create an endpoint that can be fired on demand. @param debug: A flag; whether to dump output from the established connection to stdout. @type debug: L{bool} @return: A client endpoint, and an object that will cause one of the L{Deferred}s returned by that client endpoint. @rtype: 2-L{tuple} of (L{IStreamClientEndpoint}, L{ConnectionCompleter}) z0.0.0.0i)rrr listenr forProtocolr r)rreactorclientEndpointserverEndpoints& rconnectableEndpointr1sP!"G'DAN'6N'--h78 .w7 77r)FTN)F)*r; __future__rr OpenSSL.SSLrr- ImportErrorzope.interfacerrtwisted.internetrrtwisted.internet.endpointsrr twisted.internet.errorr twisted.internet.protocolr r twisted.internet.testingr rtwisted.python.failurerrIAddressr: ITransport ITLSTransport IConsumerr=rrrrrrrrr!rrr,s # 79.M97F*!!& Z !" Z " "J$<$R>RSD D TD N 9 8KK\7z*)   2Dj>: : z8G  sCC#"C#