֛h&SrSSKJr SSKJr SSKJr SSKJrJ r SSK J r SSK J r SS KJrJrJrJr "S S \"\S 55r"S S\ 5rg)z& Tests for L{twisted._threads._team}. ) annotations)Callable)proxyForInterface)callget)Failure)SynchronousTestCase) AlreadyQuitIWorkerTeamcreateMemoryWorkerc:^\rSrSrSrSSjrSU4SjjrSrU=r$)ContextualWorkerz2 A worker implementation that supplies a context. c XlX lg)z* Create with a real worker and a context. N) _realWorker_context)self realWorkerctxs cC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/_threads/test/test_team.py__init__ContextualWorker.__init__s& c2>^^[TT]UU4Sj5 g)zr Perform the given work with the context given to __init__. @param work: the work to pass on to the real worker. c0>[TRT5$N)rr)rworksr%ContextualWorker.do..%s4 t4rN)superdo)rr __class__s``rr#ContextualWorker.dos  45r)rr)rr robjectreturnNone)rzCallable[[], object]r'r() __name__ __module__ __qualname____firstlineno____doc__rr#__static_attributes__ __classcell__)r$s@rrrs66rrrc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSSjrSSjrSSjrSrg) TeamTests(z Tests for L{Team} c^[5unTl[USS9Tl/Tl/Tl/Tl/TlSTlSU4Sjjn/Tl SU4Sjjn[XU5Tl g) zT Set up a L{Team} with inspectable, synchronous workers that can be single-stepped. coordinatorworkercg)NFr8rrr !TeamTests.setUp..8sUrc>^^^TR5(ag[5unmTRRT5 TRRT5 [ U[ TR5S9mTRRT5 TRRT5 TRmSUUUU4SjjnUTl T$)Nr5c>T"5 TRRT5 TRRT5 gr)allUnquitWorkersremoveactivePerformers)cw performerrealQuitrsr quitAndRemove.createWorker..quitAndRemoveEs0 %%,,R0%%,,Y7rr'r() noMoreWorkersrworkerPerformersappendr>rlenallWorkersEverr<quit)r6rBr?r@rArs @@@r createWorker%TeamTests.setUp..createWorker:s!!## 2 4 FI  ! ! ( ( 3  ! ! ( ( 3!&T5J5J1KLB    & &r *  ! ! ( ( ,wwH 8 8 $BGIrcL>TRR[55 gr)failuresrGrrsr logException%TeamTests.setUp..logExceptionOs MM  +rN)r'zContextualWorker | NonerD) rcoordinateOncerr4rFrIr<r>rErNr team)rr4rKrPs` rsetUpTeamTests.setUp-so ,>+?( T(+K N<>688:<>* &(*  ,LA rcfSnUR5(aSnUR5(aMU$)z Perform all work currently scheduled in the coordinator. @return: whether any coordination work was performed; if the coordinator was idle when this was called, return L{False} (otherwise L{True}). FT)rR)rdids r coordinateTeamTests.coordinateTs3!!##C!!## rcSnU(a^UR5nURHnX R;dMU"5 M U=(d UR5nU(aM]gg)zR Perform all work on the coordinator and worker performers that needs to be done. TN)rXrFr>)r continuingr@s rperformAllOutstandingWork#TeamTests.performAllOutstandingWorkasS  *J!22  5 55K3$8t'8J jrc^SmSU4SjjnURRU5 UR5 URURR 5R S5 UR 5 URTS5 URURR 5R S5 g)zL L{Team.do} does the work in a worker created by the createWorker callable. Nc>[S5mg)Nr6)r)whosr something4TeamTests.test_doDoesWorkInWorker..somethingus h-CrrrD)rSr#rX assertEqual statisticsbusyWorkerCountr\)rrar`s @rtest_doDoesWorkInWorker!TeamTests.test_doDoesWorkInWorkerns   Y  --/??C &&( a  --/??CrcURR5nURURS5 URURS5 URUR S5 g)zy L{Team.statistics} returns an object with idleWorkerCount, busyWorkerCount, and backloggedWorkCount integer attributes. rN)rSrerdidleWorkerCountrfbackloggedWorkCount)rstatss rtest_initialStatistics TeamTests.test_initialStatisticssX  $$& ..2 ..2 22A6rcURRS5 UR5 UR[ UR 5S5 g)z> L{Team.grow} increases the number of available idle workers. N)rSgrowr\rdrHrFrOs rtest_growCreatesIdleWorkers%TeamTests.test_growCreatesIdleWorkerss; q &&( T223Q7rc$^U4SjTlTRRS5 TR5 TR [ TR 5S5 TR TRR5RS5 g)zw L{Team.grow} increases the number of available idle workers until the C{createWorker} callable starts returning None. c4>[TR5S:$)N)rHrIrOsrr 0TeamTests.test_growCreateLimit..sS)<)<%=%BrrprvN) rErSrqr\rdrHrIrerjrOs`rtest_growCreateLimitTeamTests.test_growCreateLimitsh C q &&( T00115 --/??CrcURRS5 UR5 URRS5 UR5 UR [ UR 5S5 g)z7 L{Team.shrink} will quit the given number of workers. rprvr N)rSrqr\shrinkrdrHr<rOs rtest_shrinkQuitsWorkers!TeamTests.test_shrinkQuitsWorkerssY q &&(  &&( T223Q7rcURRS5 UR5 UR[ UR 5S5 URR 5 UR[ UR 5S5 UR5 UR[ UR 5S5 g)zE L{Team.shrink} with no arguments will stop all outstanding workers. rN)rSrqr\rdrHr<r{rOs rtest_shrinkToZeroTeamTests.test_shrinkToZeros r &&( T223R8  T223R8 &&( T223Q7rc^URRS5 UR5 SmSU4SjjnURURR 5R S5 [ S5HnURRU5 M UR5 URURR 5R S5 SUlURRU5 UR5 URURR 5R S5 URURR 5RS5 UR5 URURR 5RS5 URTS5 g) zu When no additional workers are available, the given work is backlogged, and then performed later when the work was. rvrc>TS- mg)Nrcr8)timessrra@TeamTests.test_moreWorkWhenNoWorkersAvailable..somethings QJErcg)NTr8r8rrr ?TeamTests.test_moreWorkWhenNoWorkersAvailable..sTrrcNrD) rSrqrXrdrerjranger#rErkr\)rrairs @r#test_moreWorkWhenNoWorkersAvailable-TeamTests.test_moreWorkWhenNoWorkersAvailablesB q   --/??CqA IILL #  --/??C) Y  --/??C --/CCQG &&( --/CCQG "rcURRS5 UR5 UR[ UR 5S5 URUR SR [5 g)z When an exception is raised in a task passed to L{Team.do}, the C{logException} given to the L{Team} at construction is invoked in the exception context. c SS- $)Nrcrr8r8rrr 0TeamTests.test_exceptionInTask..sQUrrcrN)rSr#r\rdrHrNtypeZeroDivisionErrorrOs rtest_exceptionInTaskTeamTests.test_exceptionInTasksY ]# &&( T]]+Q/ q)..0ABrcURR5 UR[URR5 UR[URR[ 5 g)z` L{Team.quit} causes future invocations of L{Team.do} and L{Team.quit} to raise L{AlreadyQuit}. N)rSrJ assertRaisesr r#listrOs r test_quitTeamTests.test_quitsD  +tyy~~6 +tyy||T:rcx[S5H"nURR[5 M$ UR 5 URR 5 UR 5 UR [UR5S5 UR[URR 5 g)zS L{Team.quit} causes all idle workers, as well as the coordinator worker, to quit. rrN) rrSr#rr\rJrdrHr<rr r4rxs rtest_quitQuitsTeamTests.test_quitQuitss rA IILL  &&(  &&( T223Q7 +t'7'7'<'<=rcURRS5 [S5H"nURR[5 M$ UR 5 URR 5 UR 5 UR[UR5S5 UR5 UR[UR5S5 UR[URR 5 g)zd L{Team.quit} causes all busy workers to be quit once they've finished the work they've been given. rrprN)rSrqrr#rrXrJrdrHr<r\rr r4rs rtest_quitQuitsLaterWhenBusy%TeamTests.test_quitQuitsLaterWhenBusys rqA IILL     T223Q7 &&( T223Q7 +t'7'7'<'<=rc^^TRR[5 TRRRmSUU4SjjnUTRRlTRR 5 TR [TRR 5 TR [TRR[5 g)z If work happens after L{Team.quit} sets its C{Quit} flag, but before any other work takes place, the L{Team} should still exit gracefully. c4>T"5 TR5 gr)r\) originalSetrsrperformWorkConcurrentlyOTeamTests.test_quitConcurrentWithWorkHappening..performWorkConcurrently s M  * * ,rNrD)rSr#r_quitsetrJrr )rrrs` @r$test_quitConcurrentWithWorkHappening.TeamTests.test_quitConcurrentWithWorkHappenings Tiioo))  - -6   +tyy~~6 +tyy||T:rcp[S5H"nURR[5 M$ UR 5 UR [ UR5S5 URRS5 UR5 UR [ UR5S5 g)zT L{Team.shrink} will wait for busy workers to finish being busy and then quit them. rrvN) rrSr#rrXrdrHr<r{r\rs rtest_shrinkWhenBusyTeamTests.test_shrinkWhenBusys rA IILL   T223R8  &&( T223Q7r) r>r<rIrRr4rNrErSrFNrD)r'bool)r)r*r+r,r-rTrXr\rgrmrrrxr|rrrrrrrrr.r8rrr1r1(s\%BN  9D$78 D8 8#: C; >> ;" 8rr1N)r- __future__rtypingrtwisted.python.componentsrtwisted.python.contextrrtwisted.python.failurertwisted.trial.unittestr r r r rrr1r8rrrsG#7,*6==6(-@6*v8#v8r