+ je8~Rt^RIt^RIHtHtHtHtHtHtH t H t ^RI H t ^RI Ht^RIHt^RIHtHt^RIHtHt^RIHt^R IHtHt^R IHt^R IHt^R IH t ^R I!H"t"^RI#H$t$^RI%H&t&^RI'H(t(H)t)H*t*H+t+^RI,H-t-^RI.H/t/^RI0H1t1H2t2^RI3H4t4^RI5H6t6H7t7H8t8]!RR7!RR]944t:!RR]4t;!RR]4t<] !R4t=]]<.]]=,3,t>!RR ] 4t?!R!R"] 4t@]!]4!R#R$44tA]!]4!R%R&44tB!R'R(]94tC!R)R*]4tDR#)+z: This module implements the worker classes. @since: 12.3 N)Any AwaitableCallableDictListOptionalTextIOTypeVar)TestCase) implementer)frozen)Protocol TypedDict)Deferred DeferredList) ProcessDone)IAddress ITransport)ProcessProtocol)Logger)AMPFailure)FilePath) namedObject)_WORKER_AMP_STDIN_WORKER_AMP_STDOUTmanagercommandsworkercommands)WorkerReporter) TestResult) TestLoader TrialSuite)Todo) StreamOpenStreamReceiver StreamWriteF)auto_excc0a]tRt^+toRtV3RltRtVtR#)WorkerExceptionz} An exception was reported by a test running in a worker process. @ivar message: An error message describing the exception. c&<V^8dQh/S[;R&#)message)str)format __classdict__s"s@r0r@r@6sr3r@c6a]tRt^>toRtV3RlRltRtVtR#)Workerz! An object that can run actions. c,<V^8dQhRS[RS[RS[/#)r+caseresultreturnr r r@)r.r/s"r0r1Worker.__annotate__Cs"  h  y r3c "R#5i)z Run a test case. Nr4)selfrHrIs&&&r0run Worker.runCssr4N)r6r7r8r9r:rOr<r=r>s@r0rFrF>s  r3rF_Tca]tRt^MtoRt]!4tRRlt]PPV3RlRl4t ]PPR4t RtVtR#) WorkerProtocolz- The worker-side trial distributed protocol. cP\4Vn\V4VnWnR#N)r!_loaderr_result_forceGarbageCollection)rNforceGarbageCollections&&r0__init__WorkerProtocol.__init__Ts!| %d+ '=$r3c&<V^8dQhRS[RS[/#)r+testCaserJ)r-r@)r.r/s"r0r1WorkerProtocol.__annotate__Zs*)*)#*))*)r3c h"VPP4;_uu_4pVPPV4p\ V.VP 4pVP VP4RRR4Rp\XRR7GRjxL FTwrgV'dKRpVPPRVVR7VPPVV4GRjxL KV RV/# +'giL;iLsL! \d TPPR4Ki;i5i) z Run a test case by name. NT) consumeErrorsFz Result reporting for {id} failed)failureidz5Additionally, reporting the reporting failure failed.rB) rWgatherReportingResultsrV loadByNamer"rXrOrloggerraaddErrorFallible BaseException)rNr]resultsrHsuite allSucceededrBrIs&& r0rOWorkerProtocol.runYs \\ 0 0 2 2g<<**84Dvt'C'CDE IIdll #3  %1'%NNNOG!L KK  2   ll33' O@<((M3 2 O& !  ##K  s_#D2AC.3D2 D3D2D!D"D&D2. C> 9 D2D&D/+D2.D//D2c 6\P!V4RR/#)zJ Set up the worker, moving into given directory for tests to run in them. rBT)oschdir)rN directorys&&r0startWorkerProtocol.starts 4  r3)rXrVrWN)F)r6r7r8r9r:rrerZrRun responderrOStartrpr<r=r>s@r0rSrSMsYXF> !!*)"*)X##!$!r3rScXaa]tRt^toRtRV3Rllt]PR4t] PR4t ] PPR4t V3RlRlt] PPV3RlR l4t] P"PV3R lR l4t] P&PR 4t] P*PV3R lRl4t] P.PR4t] P2PR4tV3RlRltRtRtVtV;t#)LocalWorkerAMPz/ Local implementation of the manager commands. cD<\SV`W4\4VnR#rU)superrZr%_streams)rN boxReceiverlocator __class__s&&&r0rZLocalWorkerAMP.__init__s .&( r3c:RVPP4/#)streamId)ryopenrNs&r0 streamOpenLocalWorkerAMP.streamOpensDMM..011r3c<VPPW4/#rU)rywrite)rNrdatas&&&r0 streamWriteLocalWorkerAMP.streamWrites H+ r3c TVPPVP4RR/#)z Add a success to the reporter. rBT)rW addSuccess _testCase)rNtestNames&&r0rLocalWorkerAMP.addSuccesss% /4  r3cB<V^8dQhRS[RS[RS[S[,RS[/#)r+error errorClassframesrJ)r)r-rr)r.r/s"r0r1LocalWorkerAMP.__annotate__s7S   r3c  \V4p\W4p\^\V4^4FLpVPP W6,W6^,,\ W6^,,4..34KN V#)a` Helper to build a C{Failure} with some traceback. @param error: An C{Exception} instance. @param errorClass: The class name of the C{error} class. @param frames: A flat list of strings representing the information need to approximatively rebuild C{Failure} frames. @return: A L{Failure} instance with enough information about a test error. )rrrangelenrappendint)rNrrr errorTyperais&&&& r0 _buildFailureLocalWorkerAMP._buildFailuresi& + %+q#f+q)A NN ! !Fq5M3v!e}+=r2F *r3c N<V^8dQhRS[RS[RS[RS[RS[S[S[3,/#)r+rr errorStreamIdframesStreamIdrJr-rrrC)r.r/s"r0r1rsE!!!! !  ! c4i !r3c xRPVPPV44PR4pVPPV4Uu.uFqfPR4NK ppVP \ V4W'4pVP PVPV4RR/#uupi)ao Add an error to the reporter. @param errorStreamId: The identifier of a stream over which the text of this error was previously completely sent to the peer. @param framesStreamId: The identifier of a stream over which the lines of the traceback for this error were previously completely sent to the peer. @param error: A message describing the error. r3utf-8rBT) joinryfinishdecoderr)rWaddErrorr) rNrrrrrframerras &&&&& r0rLocalWorkerAMP.addErrors(--m<=DDWM/3}}/C/CN/S /SeLL !/S  $$_U%;ZP dnng64   B7c N<V^8dQhRS[RS[RS[RS[RS[S[S[3,/#)r+r failStreamId failClassrrJr)r.r/s"r0r1rsE!!!! !  ! c4i !r3c xRPVPPV44PR4pVPPV4Uu.uFqfPR4NK ppVP \ V4W74pVP PVPV4RR/#uupi)aB Add a failure to the reporter. @param failStreamId: The identifier of a stream over which the text of this failure was previously completely sent to the peer. @param framesStreamId: The identifier of a stream over which the lines of the traceback for this error were previously completely sent to the peer. r3rrBT) rryrrrr)rW addFailurer) rNrrrrfailrrras &&&&& r0rLocalWorkerAMP.addFailures$xx ,,\:;BB7K/3}}/C/CN/S /SeLL !/S  $$_T%:IN 84   rc VVPPVPV4RR/#)z Add a skip to the reporter. rBT)rWaddSkipr)rNrreasons&&&r0rLocalWorkerAMP.addSkips' T^^V44  r3c X<V^8dQhRS[RS[RS[S[,RS[S[S[3,/#)r+rrtodorJ)r-rrrrC)r.r/s"r0r1r s9 ! ! !,/ !7?} ! c4i !r3c RPVPPV44PR4p\ VfRMT4pVP P VPWE4RR/#)z Add an expected failure to the reporter. @param errorStreamId: The identifier of a stream over which the text of this error was previously completely sent to the peer. r3rz rBT)rryrrr#rWaddExpectedFailurer)rNrrrr_todos&&&& r0r!LocalWorkerAMP.addExpectedFailures_--m<=DDWMDL[d; ''E4  r3c VVPPVPV4RR/#)z, Add an unexpected success to the reporter. rBT)rWaddUnexpectedSuccessr)rNrrs&&&r0r#LocalWorkerAMP.addUnexpectedSuccesss' ))$..$?4  r3c VPPVR,4VPP4RR/#)z$ Print test output from the worker.  rBT) _testStreamrflush)rNouts&&r0 testWriteLocalWorkerAMP.testWrites9 sTz*  4  r3c,<V^8dQhRS[RS[RS[/#)r+r]rIrJrK)r.r/s"r0r1r(s" , ,( ,J ,9 ,r3c F"WnW nVPPV4VP4pVP \ P VR7GRjxL VPPV4#L TPPT4i;i5i)z Run a test. )r]N)rrW startTestrb callRemoterrrstopTest)rNr]rI testCaseIds&&& r0rOLocalWorkerAMP.run(sw"  x([[]  ,););jQQ LL ! !( +R LL ! !( +s.8B!$BA? B#B!?BBB!c WnR#)z/ Set the stream used to log output from tests. N)r)rNstreams&&r0 setTestStreamLocalWorkerAMP.setTestStream5s "r3)rWryrr)NN) r6r7r8r9r:rZr$rsrr&rr AddSuccessrrAddErrorr AddFailurerAddSkiprAddExpectedFailurerAddUnexpectedSuccessr TestWriterrOrr<r= __classcell__)r|r/s@@r0rvrvsA)22))!*!6''!(!>))!*!4&&!'!''11 !2 !))33!4!((!)! , ,""r3rvc]tRtRtRtRtR#)LocalWorkerAddressi<zs A L{IAddress} implementation meant to provide stub addresses for L{ITransport.getPeer} and L{ITransport.getHost}. r4Nr6r7r8r9r:r<r4r3r0rr<sr3rcHa]tRtRtoRtRtRtRtRtRt Rt R t Vt R #) LocalWorkerTransportiDz] A stub transport implementation used to support L{AMP} over a L{ProcessProtocol} transport. cWnR#rU _transport)rN transports&&r0rZLocalWorkerTransport.__init__Ks#r3c FVPP\V4R#)z Forward data to transport. Nr writeToChildrrNrs&&r0rLocalWorkerTransport.writeNs $$%6=r3c XVF#pVPP\V4K% R#)z@ Emulate C{writeSequence} by iterating data in the C{sequence}. Nr)rNsequencers&& r0 writeSequence"LocalWorkerTransport.writeSequenceTs#D OO ( ():D Ar3c :VPP4R#)z Closes the transport. N)rloseConnectionrs&r0r#LocalWorkerTransport.loseConnection[s &&(r3c \4#z* Return a L{LocalWorkerAddress} instance. rrs&r0getHostLocalWorkerTransport.getHosta "##r3c \4#rrrs&r0getPeerLocalWorkerTransport.getPeergrr3rN) r6r7r8r9r:rZrrrrrr<r=r>s@r0rrDs. $> B) $ $$r3rc]tRtRtRtRtR#) NotRunninginzF An operation was attempted on a worker process which is not running. r4Nrr4r3r0rrnsr3rcxa]tRtRtoRtV3RlRltV3RlRltRtRtV3R lR lt R t R t R t Rt VtR#) LocalWorkerita0 Local process worker protocol. This worker runs as a local process and communicates via stdin/out. @ivar _ampProtocol: The L{AMP} protocol instance used to communicate with the worker. @ivar _logDirectory: The directory where logs will reside. @ivar _logFile: The main log file for tests output. c<<V^8dQhRS[RS[S[,RS[/#)r+ ampProtocol logDirectorylogFile)rvrrr)r.r/s"r0r1LocalWorker.__annotate__s- 6 6# 6sm 6 6r3cHWnW nW0n\4VnR#rU) _ampProtocol _logDirectory_logFiler endDeferred)rNrrrs&&&&r0rZLocalWorker.__init__s () +3:r3c<V^8dQhRR/#)r+rJNr4)r.r/s"r0r1rs  D r3c "VPf \4hVPpVPP\4VGRjxL R#L \ dR#i;i5i)z# Cause the worker process to exit. N)rrr closeChildFDrr)rNrs& r0exitLocalWorker.exitsV >> !, &&  ##$56      s<AA'A A AA'A A$ A'#A$$A'c BVPP\VP44VPP RR7VPP R4PR4VnVPP R4PR4Vn VPPVP4VPP\PVPPR7pVP!R4R#) z< When connection is made, create the AMP protocol instance. T)ignoreExistingDirectoryzout.logwzerr.log)rocR#rUr4)xs&r0,LocalWorker.connectionMade..str3N)rmakeConnectionrrrmakedirschildr_outLog_errLogrrrrrtpath addErrback)rNds& r0connectionMadeLocalWorker.connectionMades (()=dnn)MN ##D#A))// :??D ))// :??D  '' 6    ( (  ((-- )  ^$r3c |VPP4VPP4RVnR#)zS On connection lost, close the log files that we're managing for stdin and stdout. N)rcloserrrNrs&&r0connectionLostLocalWorker.connectionLosts+  r3c$<V^8dQhRS[RR/#)r+rrJNr)r.r/s"r0r1rs**7*t*r3c VPV4VPPV4VPPV4R#)zz When the process closes, call C{connectionLost} for cleanup purposes and forward the information to the C{_ampProtocol}. N)rrrcallbackrs&&r0 processEndedLocalWorker.processEndeds: F# ((0 !!&)r3c <VPPV4R#)z( Send data received from stdout to log. N)rrrs&&r0 outReceivedLocalWorker.outReceiveds 4 r3c <VPPV4R#)z Write error data to log. N)rrrs&&r0 errReceivedLocalWorker.errReceiveds 4 r3c V\8XdVPPV4R#\P!WV4R#)zD Handle data received on the specific pipe for the C{_ampProtocol}. N)rr dataReceivedrchildDataReceived)rNchildFDrs&&&r0r-LocalWorker.childDataReceiveds1 ( (    * *4 0  - -dT Br3)rrrrrrrN)r6r7r8r9r:rZrrrr#r&r)r-r<r=r>s@r0rrtsH  6 6  %"**!! CCr3r)Er:rmtypingrrrrrrrr unittestr zope.interfacer attrsr r rtwisted.internet.deferrrtwisted.internet.errorrtwisted.internet.interfacesrrtwisted.internet.protocolrtwisted.loggerrtwisted.protocols.amprtwisted.python.failurertwisted.python.filepathrtwisted.python.reflectrtwisted.trial._distrrrr"twisted.trial._dist.workerreporterrtwisted.trial.reporterr twisted.trial.runnerr!r"twisted.trial.unittestr#rr$r%r& Exceptionr)r@rFrQ WorkerActionrSrvrrrrr4r3r0rDs,   RRR&&9.<5!%*,. >-7';;i  X  T])B-/0 @!S@!Fi"Si"X X Z&$&$&$R ]C/]Cr3