כh@ pSrSSKrSSKrSSKJr SSKJr SSKJrJ r J r J r J r J r JrJrJrJr SSKJrJr SSKJrJrJr SSKJr SS KJrJrJr SS KJ r J!r! SS K"J#r# SS K$J%r% SS K&J'r' SSK(J)r) SSK*J+r+ SSK,J-r- SSK.J/r/J0r0 SSK1J2r2 SSK3J4r4 SSK5J6r6J7r7 SSK8J9r9J:r: SSK;Jr>J?r?J@r@JArA SSKBJCrCJDrDJErE "SS\ \!5rFS\F4SjrG\"SS 55rH\"S!S"55rI\"S#S$55rJS%\KS&\/S\K4S'jrLS(\IS)\ \0S&\Nc`^# [U4SjUR55IShvN gN7f)z2 Run an action on all of the workers in the pool. c3F># UHn[T"U55v M g7fN)r,).0workerrYs r= (StartedWorkerPool.run..s! >MFM,v. / /os!N)rrX)selfrYs `r=runStartedWorkerPool.runs5 >Boo     s #.,.c # [URVs/sH'n[R"UR 55PM) snSS9IShvN n[ U5H1unupEU(aMUR RSUS3U5 M3 URSS2 URSS2 URR5 URR5 gs snfN7f)z^ Shut down all of the workers in the pool. The pool is unusable after this method is called. T) consumeErrorsNzjoining disttrial worker #z failed) rrWr fromCoroutineexit enumerate_loggerfailurerXrVcloserUunlock)rar^resultsn succeededrjs r=joinStartedWorkerPool.joins %AE NvX # #FKKM 2 N  (1'9 #A# 9 $$'A!G%LgV(: LLO OOA   ! O s#C,.C% C, C*C,.A=C,r5)r>N)r6r7r8r9r:rrrPrr r r/r0rrir1rbrpr;r5r<r=rSrScsX$sm# O + ^$$hGl3&7D"r<rSc h\rSrSr%Sr\\S'S\\S\ \ S\ S\ \ 4SjrS rS \S\4S jrS rg ) WorkerPoolz Manage a fixed-size collection of child processes which can run tests. @ivar _config: Configuration for the precise way in which the pool is run. _config protocolsrLrNr>c [U5VVs/sH)upE[XRR[U55U5PM+ snn$s snnf)aL Create local worker protocol instances and return them. @param protocols: The process/protocol adapters to use for the created workers. @param workingDirectory: The base path in which we should run the workers. @param logFile: The test log, for workers to write to. @return: A list of C{quantity} C{LocalWorker} instances. )rhr/childrQ)rarvrLrNxprotocols r=_createLocalWorkersWorkerPool._createLocalWorkerssF* )3 3  "8"8Q"@' J3   s0Ac [SRRnSSSSSS[S[S0n[ R R5n[ RR[R5US'UH=n[RU/nURU5 U"U[RXUS9 M? g ) z Spawn processes from a list of process protocols. @param spawner: A C{IReactorProcess.spawnProcess} implementation. @param protocols: An iterable of C{ProcessProtocol} instances. @param arguments: Extra arguments passed to the processes. ztwisted.trial._dist.workertrialrwr'rr PYTHONPATH)argschildFDsenvN) rfilePathpathr(r)osenvironcopypathseprpsys executableextend) raspawnerrv argumentsworkertrialPathrrr^rs r=_launchWorkerProcesses!WorkerPool._launchWorkerProcessess((IJSSXX s s s s   **//#!#  9 FNNO4D KK " FCNNg V r<rBcR# [URR5up#[URR5(a [ URR5nO%UR URR5n[U5n[URR5Vs/sH n[5PM nnURUUU5nURURUURR5 [UUUUU5$s snf7f)zo Launch all of the workers for this pool. @return: A started pool object that can run jobs using the workers. )r%rurLrrNr preauthChildr&rangerKr0r{r spawnProcessrMrS) rarBtestDirrU testLogPathrVryrXrWs r=startWorkerPool.starts 4 LL ) )  %% & &"4<<#7#78K "..t||/C/CDKk*05dll6M6M0NO0N1n&0N O**     ##   LL ( ( !        PsB7D'9D" AD'r5N)r6r7r8r9r:rIrPrr0rrr r r/r{rrrSrr;r5r<r=rsrssb  N+ #3-   k   0W6& ?& 7H& r<rs untilFailureresultc4U=(a UR5$)z Determine whether the test suite should be iterated again. @param untilFailure: C{True} if the suite is supposed to run until failure. @param result: The test result of the test suite iteration which just completed. ) wasSuccessful)rrs r=shouldContinuers  2F0022r<pool testCases driveWorkerc# UR[X2U55IShvN gN![a0 URR [ S5[ 55 gf=f7f)Nz )rbr ExceptionoriginaladdErrorr$r)rrrrs r=runTestsrsQFhhw{I>??? F   L!979E Fs1A'*(*A'*7A$!A'#A$$A'c\rSrSr%Sr\r\"5r\ S\ 4\ S'\ \ S'\ \\ S'Sr\\ S'\"S \"\S 9S 9r\\ S '\"S \"\R.5S 9r\\ S 'Sr\\ S'Sr\\ S'Sr\\ S'Sr\\ S'Sr\\ S'\r \ \!/\4\ S'S\4Sjr"Sr#S\S\$\%S\&SS 4Sjr'S&S\(\)\*4S\S\4S jjr+S!\(\)\*4S\S\ 4S"jr,S!\(\)\*4S\ 4S#jr-S!\(\)\*4S\ 4S$jr.S%r/g )'DistTrialRunneri!a A specialized runner for distributed trial. The runner launches a number of local worker processes which will run tests. @ivar _maxWorkers: the number of workers to be spawned. @ivar _exitFirst: ``True`` to stop the run as soon as a test case fails. ``False`` to run through the whole suite and report all of the results at the end. @ivar stream: stream which the reporter will use. @ivar _reporterFactory: the reporter class to be used. ._reporterFactory _maxWorkers_workerArgumentsF _exitFirstN)factory)default converter_reactorstreamr_tracebackFormat_realTimeErrors_uncleanWarningsztest.log_logfile _trial_temp_workingDirectory_workerPoolFactoryr>cURURURURS9nUR(a [ U5nUR U5$)z< Make reporter factory, and wrap it with a L{DistReporter}. )realtime)rrrrrr#_distReporterFactory)rareporters r= _makeResultDistTrialRunner._makeResultJsV(( KK..9M9M)   5h?H((22r<c$UR5 g)zr Write test run final outcome to result. @param result: A C{TestResult} which will print errors and the summary. N)done)rars r= writeResultsDistTrialRunner.writeResultsUs  r<rrr^cT^^# UU4SjnUHnU"U5IShvN M gN 7f)aP Drive a L{LocalWorkerAMP} instance, iterating the tests and calling C{run} for every one of them. @param worker: The L{LocalWorkerAMP} to drive. @param result: The global L{DistReporter} instance. @param testCases: The global list of tests to iterate. @return: A coroutine that completes after all of the tests have completed. c># TRUT5IShvN gN![a' TRRU[ 55 gf=f7fr\)rbrrrr)caserr^s r=task*DistTrialRunner._driveWorker..taskqsC :jjv... :((wy9 :s1A" "A".AAAANr5)rarrr^rrs ` ` r= _driveWorkerDistTrialRunner._driveWorker]s'( : Dt*   s (& (suiterc ^^^^# [[U55mTR[[ [ T5TR 5[TR5TRTR55nTRRSUR5S35 URTR5IShvN m[!["T5n[$S[&S[(4UUUU4Sjj5n[+XE5IShvN TR-5IShvN $N`NN !TR-5IShvN f=f7f)z Spawn local worker processes and load tests. After that, run them. @param suite: A test or suite to be run. @param untilFailure: If C{True}, continue to run the tests until they fail. @return: A coroutine that completes with the test result. zRunning z tests. Nrnr>c4>^# T(a"TRRSUS-S35 TR5mTR(aU4SjnOSn[ T[ UT5TTR 5IShvN TRT5 T$N7f)Nz Test Pass r' c8>TRR5$r\)rr)_rs r=@DistTrialRunner.runAsync..runAndReport..s6??+H+H+Jr<cgNTr5)rs r=rrs4r<)rwriterrrr.rr)rncasesConditionrra startedPoolrrs @r= runAndReport.DistTrialRunner.runAsync..runAndReports !!Jq1ugR"89%%'F"K!/.)4!!      f %M sA:B>B?B)listr rrIminlenrrrrrrrcountTestCasesrrrrr+rOr*r-rp)rarr poolStarter conditionrrrs` ` @@r=runAsyncDistTrialRunner.runAsynczs!"u-. -- C ND$4$45//0%%    HU%9%9%;$>""$ $ $M=F? %+""$ $ $sZCE D(4E =D. D* D.E "D,#E *D.,E .E EE  E testcb^^^^SmSmS[[[4SS4U4SjjnS[[[ 4UUU4SjjnS[ S[ 4UU4SjjnTR RSS U5 [R"TRX55RU5RU5mTR R5 [T[5(aTR5 [T[5(d TS 35e[[TR 5$) NFrr>c >Umgr\r5)rrs r=capture%DistTrialRunner._run..capturesFr<c4>SmTcTR5 T$gr)cancel)reactorStoppingrtestsInProgresssr=maybeStopTests,DistTrialRunner._run..maybeStopTestss""O~&&(&&r<rcJ>T(dTRR5 U$r\)rstop)rrras r=maybeStopReactor.DistTrialRunner._run..maybeStopReactors" ""$Mr<beforeshutdownz is not DistReporter)r rr*r robjectraddSystemEventTriggerrfraddBothrb isinstanceraiseExceptionrr!r) rarrrrrrrrs ` @@@r=_runDistTrialRunner._runs59 % uWl23   &)9 :   V    ++Hj.Q  " "4==#D E WW  W% &   fg & &  ! ! # &,//PF8;O1PP/Iv//r<c"URUSS9$)zI Run a reactor and a test suite. @param test: The test or suite to run. Frrrars r=rbDistTrialRunner.runs yyEy22r<c"URUSS9$)zd Run the tests with local worker processes until they fail. @param test: The test or suite to run. Trrrs r=runUntilFailureDistTrialRunner.runUntilFailures yyDy11r<r5)F)0r6r7r8r9r:r*rrrirr!rPrOr rQrboolrrrGrr3rstdoutrr rrrrrrsrrIrrr r"r0rr rrrrrbrr;r5r<r=rr!s (hGsI~..3iJ"'!/:#H 4?3::3NOFFO%c%!OT!"d"Hc*s*CM"2!3Z!?@M 3\ 3I&   @#J%Xy()J%J%  J%X*0x23*04*0I*0X3h 123y32E(I*=$>292r<r)Or:rr functoolsros.pathrtypingrrrrr r r r r runittestrrattrsrrrattrs.convertersrtwisted.internet.deferrrrtwisted.internet.interfacesrrtwisted.loggerrtwisted.python.failurertwisted.python.filepathrtwisted.python.lockfilertwisted.python.modulesr _asyncrunnerr itrialr!r"rr#runnerr$utilr%r&r(r) distreporterr* functionalr+r,r-r.r^r/r0r1r3rGrIrSrsrrrrr5r<r=rsl     )'',HHE!*,20()543&MM== o E*E(*5"5"5"pb b b J 3 3y 3T 3F F "F F x *N;Yt_L F F$^2^2^2r<