כhp8fSrSSKrSSKJrJrJrJrJrJrJ r J r SSK J r SSK Jr SSKJr SSKJrJr SSKJrJr SS KJr SS KJrJr SS KJr SS KJr SS K J!r! SSK"J#r# SSK$J%r% SSK&J'r' SSK(J)r)J*r*J+r+J,r, SSK-J.r. SSK/J0r0 SSK1J2r2J3r3 SSK4J5r5 SSK6J7r7J8r8J9r9 \"SS9"SS\:55r;"SS\5r<"SS\5r=\ "S 5r>\\=/\\>4r?"S!S"\!5r@"S#S$\!5rA\"\5"S%S&55rB\"\5"S'S(55rC"S)S*\:5rD"S+S,\5rEg)-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)AMP)Failure)FilePath) namedObject)_WORKER_AMP_STDIN_WORKER_AMP_STDOUTmanagercommandsworkercommands)WorkerReporter) TestResult) TestLoader TrialSuite)Todo) StreamOpenStreamReceiver StreamWriteF)auto_excc$\rSrSr%Sr\\S'Srg)WorkerException+z} An exception was reported by a test running in a worker process. @ivar message: An error message describing the exception. messageN)__name__ __module__ __qualname____firstlineno____doc__str__annotations____static_attributes__r-^C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/trial/_dist/worker.pyr*r*+s Lr6r*c$\rSrSr%Sr\\S'Srg) RunResult6z: Represent the result of a L{workercommands.Run} command. successr-N)r.r/r0r1r2boolr4r5r-r6r7r9r96sMr6r9c.\rSrSrSrS\S\S\4SjrSr g) Worker>z! An object that can run actions. caseresultreturnc # g7f)z Run a test case. Nr-)selfr@rAs r7run Worker.runCssr-N) r.r/r0r1r2r r r9rEr5r-r6r7r>r>>s! h  y r6r>_Tc\rSrSrSr\"5rS Sjr\RRS\ S\ 4Sj5r \RRS5rSrg ) WorkerProtocolMz- The worker-side trial distributed protocol. cN[5Ul[U5UlXlgN)r!_loaderr_result_forceGarbageCollection)rDforceGarbageCollections r7__init__WorkerProtocol.__init__Ts!| %d+ '=$r6testCaserBcD# URR5nURRU5n[ U/UR 5nUR UR5 SSS5 Sn[WSS9IShvN HPupgU(aMSnURRSUUS9 URRUU5IShvN MR SU0$!,(df  Nz=fNmN![a URRS5 Mf=f7f) z Run a test case by name. NT) consumeErrorsFz Result reporting for {id} failed)failureidz5Additionally, reporting the reporting failure failed.r;) rNgatherReportingResultsrM loadByNamer"rOrErloggerrVaddErrorFallible BaseException)rDrSresultsr@suite allSucceededr;rAs r7rEWorkerProtocol.runYs \\ 0 0 2g<<**84Dvt'C'CDE IIdll #3  %1'%NNNOG!L KK  2   ll33' O@<((M3 2 O& !  ##K  s_D AC+D C0/D 3C4C2C4D  C-)D 2C44%DD DD c6[R"U5 SS0$)zJ Set up the worker, moving into given directory for tests to run in them. r;T)oschdir)rD directorys r7startWorkerProtocol.starts 4  r6)rOrMrNN)F)r.r/r0r1r2rrZrQrRun responderr3r9rEStartrer5r-r6r7rIrIMsdXF> !!*)#*))*)"*)X##!$!r6rIc ^\rSrSrSrSU4Sjjr\RS5r\ RS5r \ RRS5r S\S\S \\S \4S jr\ R&RS \S\S \S\S \\\44 Sj5r\ R0RS \S\S\S\S \\\44 Sj5r\ R4RS5r\ R8RS \S \S\\S \\\44Sj5r\ R>RS5r \ RBRS5r"S\#S\$S \%4Sjr&Sr'Sr(U=r)$)LocalWorkerAMPz/ Local implementation of the manager commands. cB>[TU]X5 [5UlgrL)superrQr&_streams)rD boxReceiverlocator __class__s r7rQLocalWorkerAMP.__init__s .&( r6c:SURR50$)NstreamId)roopenrDs r7 streamOpenLocalWorkerAMP.streamOpensDMM..011r6c<URRX5 0$rL)rowrite)rDrudatas r7 streamWriteLocalWorkerAMP.streamWrites H+ r6cTURRUR5 SS0$)z Add a success to the reporter. r;T)rN addSuccess _testCase)rDtestNames r7rLocalWorkerAMP.addSuccesss% /4  r6error errorClassframesrBc [U5n[X5n[S[U5S5H8nURR X6X6S-[ X6S-5//45 M: U$)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. rr$)rrrangelenrappendint)rDrrr errorTyperVis r7 _buildFailureLocalWorkerAMP._buildFailuresi& + %+q#f+q)A NN ! !Fq5M3v!e}+=r2F *r6r errorStreamIdframesStreamIdczSRURRU55RS5nURRU5Vs/sHofRS5PM nnUR [ U5X'5nUR RURU5 SS0$s snf)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. r6utf-8r;T) joinrofinishdecoderr*rNaddErrorr) rDrrrrrframerrVs r7rLocalWorkerAMP.addErrors(--m<=DDWM/3}}/C/CN/S /SeLL !/S  $$_U%;ZP dnng64   B8 failStreamId failClassczSRURRU55RS5nURRU5Vs/sHofRS5PM nnUR [ U5X75nUR RURU5 SS0$s snf)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. r6rr;T) rrorrrr*rN addFailurer) rDrrrrfailrrrVs r7rLocalWorkerAMP.addFailures$xx ,,\:;BB7K/3}}/C/CN/S /SeLL !/S  $$_T%:IN 84   rcVURRURU5 SS0$)z Add a skip to the reporter. r;T)rNaddSkipr)rDrreasons r7rLocalWorkerAMP.addSkips' T^^V44  r6todocSRURRU55RS5n[ UcSOU5nUR R URXE5 SS0$)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. r6rz r;T)rrorrr#rNaddExpectedFailurer)rDrrrr_todos r7r!LocalWorkerAMP.addExpectedFailures_--m<=DDWMDL[d; ''E4  r6cVURRURU5 SS0$)z, Add an unexpected success to the reporter. r;T)rNaddUnexpectedSuccessr)rDrrs r7r#LocalWorkerAMP.addUnexpectedSuccesss' ))$..$?4  r6czURRUS-5 URR5 SS0$)z$ Print test output from the worker.  r;T) _testStreamr{flush)rDouts r7 testWriteLocalWorkerAMP.testWrites9 sTz*  4  r6rSrAc@# XlX lURRU5 UR5nUR [ R US9IShvN URRU5 $N!URRU5 f=f7f)z Run a test. )rSN)rrN startTestrW callRemoterrgstopTest)rDrSrA testCaseIds r7rELocalWorkerAMP.run(sw"  x([[]  ,););jQQ LL ! !( +R LL ! !( +s.8B!A>A<A> B<A>>BBcXlg)z/ Set the stream used to log output from tests. N)r)rDstreams r7 setTestStreamLocalWorkerAMP.setTestStream5s "r6)rNrorr)NN)*r.r/r0r1r2rQr%rhrxr'r}r AddSuccessrr*r3rrrAddErrorrrr<r AddFailurerAddSkiprAddExpectedFailurerrAddUnexpectedSuccessr TestWriterr r r9rErr5 __classcell__)rrs@r7rkrks)22))!*!S   6''!!! !  ! c4i !(!>))!!! !  ! c4i !*!4&&!'!''11 ! !,/ !7?} ! c4i !2 !))33!4!((!)! ,( ,J ,9 ,""r6rkc\rSrSrSrSrg)LocalWorkerAddressi<zs A L{IAddress} implementation meant to provide stub addresses for L{ITransport.getPeer} and L{ITransport.getHost}. r-Nr.r/r0r1r2r5r-r6r7rr<sr6rc<\rSrSrSrSrSrSrSrSr Sr S r g ) LocalWorkerTransportiDz] A stub transport implementation used to support L{AMP} over a L{ProcessProtocol} transport. cXlgrL _transport)rD transports r7rQLocalWorkerTransport.__init__Ks#r6cDURR[U5 g)z Forward data to transport. Nr writeToChildrrDr|s r7r{LocalWorkerTransport.writeNs $$%6=r6cVUH#nURR[U5 M% g)z@ Emulate C{writeSequence} by iterating data in the C{sequence}. Nr)rDsequencer|s r7 writeSequence"LocalWorkerTransport.writeSequenceTs#D OO ( ():D Ar6c8URR5 g)z Closes the transport. N)rloseConnectionrws r7r#LocalWorkerTransport.loseConnection[s &&(r6c[5$z* Return a L{LocalWorkerAddress} instance. rrws r7getHostLocalWorkerTransport.getHosta "##r6c[5$rrrws r7getPeerLocalWorkerTransport.getPeergrr6rN) r.r/r0r1r2rQr{rrrrr5r-r6r7rrDs& $> B) $ $r6rc\rSrSrSrSrg) NotRunninginzF An operation was attempted on a worker process which is not running. r-Nrr-r6r7rrnsr6rcn\rSrSrSrS\S\\S\4Sjr SS jr S r S r S \ SS4S jrSrSrSrSrg) 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. ampProtocol logDirectorylogFilecFXlX lX0l[5UlgrL) _ampProtocol _logDirectory_logFiler endDeferred)rDrrrs r7rQLocalWorker.__init__s () +3:r6rBNc# URc [5eURnURR[5 UIShvN gN![ a gf=f7f)z# Cause the worker process to exit. N)rrr closeChildFDrr)rDrs r7exitLocalWorker.exitsV >> !, &&  ##$56      s<AA#A A AA#A A A#A  A#c4URR[UR55 URR SS9 URR S5RS5UlURR S5RS5Ul URRUR5 URR[RURRS9nUR!S5 g) z< When connection is made, create the AMP protocol instance. T)ignoreExistingDirectoryzout.logwzerr.log)rdcgrLr-)xs r7,LocalWorker.connectionMade..str6N)rmakeConnectionrrrmakedirschildrv_outLog_errLogrrrrripath addErrback)rDds r7connectionMadeLocalWorker.connectionMades (()=dnn)MN ##D#A))// :??D ))// :??D  '' 6    ( (  ((-- )  ^$r6czURR5 URR5 SUlg)zS On connection lost, close the log files that we're managing for stdin and stdout. N)rcloserrrDrs r7connectionLostLocalWorker.connectionLosts+  r6rcURU5 URRU5 URRU5 g)zz When the process closes, call C{connectionLost} for cleanup purposes and forward the information to the C{_ampProtocol}. N)r rrcallbackr s r7 processEndedLocalWorker.processEndeds: F# ((0 !!&)r6c:URRU5 g)z( Send data received from stdout to log. N)rr{rs r7 outReceivedLocalWorker.outReceiveds 4 r6c:URRU5 g)z Write error data to log. N)rr{rs r7 errReceivedLocalWorker.errReceiveds 4 r6c~U[:XaURRU5 g[R"XU5 g)zD Handle data received on the specific pipe for the C{_ampProtocol}. N)rr dataReceivedrchildDataReceived)rDchildFDr|s r7rLocalWorker.childDataReceiveds1 ( (    * *4 0  - -dT Br6)rrrrrrr)rBN)r.r/r0r1r2rkrrr rQrrr rrrrrr5r-r6r7rrts^  6# 6sm 6 6 %"*7*t*!! Cr6r)Fr2rbtypingrrrrrrr r unittestr zope.interfacer attrsr typing_extensionsrrtwisted.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*r9r>rG WorkerActionrIrkrrrrr-r6r7r2s,   RRR&19.<5!%*,. >-7';;i  X  T])B-/0 @!S@!Fi"Si"X X Z&$&$&$R ]C/]Cr6