h3<SrSSKrSSKrSSKrSSKJr SSKJrJrJ r J r J r J r SSK JrJrJrJr SSKJr SSKr\"\ R,"\ S5(+S5"SS \55r"S S 5r\"\ R,"\ S5(+S5"S S \55r"SS\5rSr"SS\ R85r\"\ R,"\ S5(+S5\"\ R<"\ S5(+S5"SS\555rg!\a Nf=f)zC Test methods in twisted.internet.threads and reactor thread APIs. N)skipIf)defererror interfacesprotocolreactorthreads)failurelog threadable threadpool)TestCasez(No thread support, nothing to test here.cT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rg)ReactorThreadsTestsz& Tests for the reactor threading API. c[R"S5 UR[RRS5 [R"S5 UR[RRS5 g)z* Try to change maximum number of threads. "N)rsuggestThreadPoolSize assertEqualr maxselfs `/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_threads.pytest_suggestThreadPoolSize.ReactorThreadsTests.test_suggestThreadPoolSize"sX %%b) ++//4%%a( ++//3cL[R"[RS5$)z The reactor's threadpool is only available when the reactor is running, so to have a sane behavior during the tests we make a dummy L{threads.deferToThread} call. r)r deferToThreadtimesleeprs r_waitForThread"ReactorThreadsTests._waitForThread+s $$TZZ33rcN^U4SjnTR5RU5$)zh Test callInThread functionality: set a C{threading.Event}, and check that it's not in the main thread. c>^^[R"5m/mUU4Sjn[R"U5 TR S5 TR 5(dTR S5 gTRTS/5 g)Ncn>TR[R"55 TR5 gN)appendr isInIOThreadset)resultwaitersr threadedFuncGReactorThreadsTests.test_callInThread..cb..threadedFunc=s! j5578 rxzTimed out waiting for event.F) threadingEventr callInThreadwaitisSetfailr)ignr-r+r,rs @@rcb1ReactorThreadsTests.test_callInThread..cb9s___&FF    . KK <<>> 89  %1rr" addCallbackrr7s` rtest_callInThread%ReactorThreadsTests.test_callInThread3s$ 2""$0044rcFSnUR5RU5$)zS Test callFromThread functionality: from the main thread, and from another thread. c^[R"5n[R"5mU4Sjn[R"U5 [R"UR S5 [R "UT/SS9$)NcH>[R"TRS5 gr')rcallFromThreadcallback)firedByOtherThreadsrr-IReactorThreadsTests.test_callFromThread..cb..threadedFuncTs&&'9'B'BDIrT)fireOnOneErrback)rDeferredrr2rArB DeferredList)r6firedByReactorThreadr-rCs @rr73ReactorThreadsTests.test_callFromThread..cbPsh#(>>#3 !&!1  J   .  " "#7#@#@$ G%%%'9:T rr9r;s rtest_callFromThread'ReactorThreadsTests.test_callFromThreadJs# ""$0044rcN^U4SjnTR5RU5$)zD Try to make an overflow on the reactor waker using callFromThread. cB>^STl[R"5mUU4Sjn[R"U5 TR S5 TR 5(dTRS5 TRb [R"TR5$g)Nc>[S5Hn[R"S5 M TR 5 g![a [R "5Tl M9f=f)Nicgr'rPrr^ReactorThreadsTests.test_wakerOverflow..cb..threadedFunction..nstr)rangerrA BaseExceptionr Failurer*)irr,s rthreadedFunctionLReactorThreadsTests.test_wakerOverflow..cb..threadedFunctionisSvA..|<'  )'.'8 s=$A&%A&r/Timed out waiting for event) r r0r1rr2r3r4r5r)r6rWr,rs @rr72ReactorThreadsTests.test_wakerOverflow..cbesrDL__&F   !1 2 KK <<>> 78||'zz$,,//(rr9r;s` rtest_wakerOverflow&ReactorThreadsTests.test_wakerOverflow`s$  0,""$0044rc^^^^^[R"5m/m/mUUUUU4SjnUUUU4SjnTR5RU5R U5$)z; Utility method to test L{threads.blockingCallFromThread}. c>UUUU4Sjn[R"U5 [R"TRTR 55$)Nc>[R"[T5nTRU5 TR 5 g![anTRU5 SnAN1SnAff=fr')r blockingCallFromThreadrr( Exceptionr*)reerrors reactorFuncresultsr,s rr-RReactorThreadsTests._testBlockingCallFromThread..cb1..threadedFuncsR&66w LANN1% !%MM!$$%sA A% A  A%)rr2r rr3 getTimeout)r6r-rdrerfrr,s rcb1.cb1s;     .((doo6GH HrcX>TR5(dTRS5 TT4$)NrY)r4r5)r6rdrfrr,s rcb2.cb2s%<<>> 78F? "r)r0r1r"r:addBoth)rrerirlrdrfr,s`` @@@r_testBlockingCallFromThread/ReactorThreadsTests._testBlockingCallFromThread}sX" I I # # ""$005==cBBrcV^SnU4SjnTRU5RU5$)z Test blockingCallFromThread facility: create a thread, call a function in the reactor using L{threads.blockingCallFromThread}, and verify the result returned. c.[R"S5$)Nfoo)rsucceedrPrrreDReactorThreadsTests.test_blockingCallFromThread..reactorFuncs==' 'rc6>TRUSSS5 g)Nrrsrresrs rr7;ReactorThreadsTests.test_blockingCallFromThread..cb   SVAY .rror:rrer7s` rtest_blockingCallFromThread/ReactorThreadsTests.test_blockingCallFromThreads+ ( /// <HHLLrcV^SnU4SjnTRU5RU5$)z` Test blockingCallFromThread as above, but be sure the resulting Deferred is not already fired. ct[R"5n[R"SURS5 U$)N皙?egg)rrFr callLaterrBds rreIReactorThreadsTests.test_asyncBlockingCallFromThread..reactorFuncs) A   c1::u 5Hrc6>TRUSSS5 g)Nrrrwrxs rr7@ReactorThreadsTests.test_asyncBlockingCallFromThread..cbr{rr|r}s` r test_asyncBlockingCallFromThread4ReactorThreadsTests.test_asyncBlockingCallFromThreads+    /// <HHLLrcV^SnU4SjnTRU5RU5$)z/ Test error report for blockingCallFromThread. c@[R"[S55$)Nbar)rr5 RuntimeErrorrPrrreIReactorThreadsTests.test_errorBlockingCallFromThread..reactorFuncs::l512 2rc>TRUSS[5 TRUSSRSS5 g)NrrassertIsInstancerrargsrxs rr7@ReactorThreadsTests.test_errorBlockingCallFromThread..cbs<  ! !#a&)\ :   SVAY^^A. 6rr|r}s` r test_errorBlockingCallFromThread4ReactorThreadsTests.test_errorBlockingCallFromThreads+  3 7// <HHLLrcV^SnU4SjnTRU5RU5$)zq Test error report for blockingCallFromThread as above, but be sure the resulting Deferred is not already fired. c[R"5n[R"SUR[ S55 U$)Nrspam)rrFrrerrbackrrs rreNReactorThreadsTests.test_asyncErrorBlockingCallFromThread..reactorFuncs. A   c199l6.B CHrc>TRUSS[5 TRUSSRSS5 g)Nrrrrrxs rr7EReactorThreadsTests.test_asyncErrorBlockingCallFromThread..cbs<  ! !#a&)\ :   SVAY^^A. 7rr|r}s` r%test_asyncErrorBlockingCallFromThread9ReactorThreadsTests.test_asyncErrorBlockingCallFromThreads+    8// <HHLLr)r N)__name__ __module__ __qualname____firstlineno____doc__rr"r<rJr[ror~rrr__static_attributes__rPrrrrs> 445.5,5:C8 MM MMrrc"\rSrSrSrSrSrSrg)CounterrclURS-nXRS-:wa SUl[eXlg)zA non thread-safe method.rN)indexproblem ValueError)rnexts radd Counter.adds1zzA~ ::> !DL   r)rrN)rrrrrrrrrPrrrrs EG rrc<\rSrSrSrSrSrSrSrSr Sr S r g ) DeferredResultTestsz Test twisted.internet.threads. c0[R"S5 g)Nrrrs rsetUpDeferredResultTests.setUp%%a(rc0[R"S5 g)Nrrrs rtearDownDeferredResultTests.tearDownrrc^^^^/mSm[R"5mUUUU4Sjn[R"[ T5Vs/sHnTR U404PM sn[ RU404/-5 T$s snf)zG L{threads.callMultipleInThread} calls multiple functions in a thread. cp>TRT[[T555 TRS5 gr')rlistrSrB)LNrrsrfinished7DeferredResultTests.test_callMultiple..finisheds'   QU1X / JJt r)rrFr callMultipleInThreadrSr(rrA)rrrVrrrs` @@@rtest_callMultiple%DeferredResultTests.test_callMultiples~   NN    $$+08 48aahhb !8 4&& R89 :  5sA=cp[R"SSjSSS9nURURS5 U$)zz L{threads.deferToThread} executes the function passed, and correctly handles the positional and keyword arguments given. c X-$r'rPxys rrQ9DeferredResultTests.test_deferredResult..srrr)r rr:rrrs rtest_deferredResult'DeferredResultTests.test_deferredResult s2  ! !"6Q ? d&&*rc~^"SS[5mU4Sjn[R"U5nURUT5$)z Check that L{threads.deferToThread} return a failure object with an appropriate exception instance when the called function raises an exception. c\rSrSrSrg):DeferredResultTests.test_deferredFailure..NewErrorirPNrrrrrrPrrNewErrorr rrc>T"5er'rPrsr raiseError.raiseError * r)rar r assertFailurerrrrs @rtest_deferredFailure(DeferredResultTests.test_deferredFailures9 y    ! !* -!!!X..rc[R"S5nURS5 URU[5$)z| Check that a successful L{threads.deferToThread} followed by a one that raises an exception correctly result as a failure. cgr'rPrPrrrQFDeferredResultTests.test_deferredFailureAfterSuccess..3s$rc0[R"S5$)Nc SS-$)NrrrPrPrrrQXDeferredResultTests.test_deferredFailureAfterSuccess....4sQr)r r)r6s rrQr4s'"7"7"Gr)r rr:rZeroDivisionErrorrs r test_deferredFailureAfterSuccess4DeferredResultTests.test_deferredFailureAfterSuccess$s5  ! !, / GH!!!%677rrPN) rrrrrrrrrrrrrPrrrrs% ))$/ 8rrc0\rSrSrSrSrSrSrSrSr g) DeferToThreadPoolTestsi8z5 Test L{twisted.internet.threads.deferToThreadPool}. cp[R"SS5UlURR5 g)Nrr)r ThreadPooltpstartrs rrDeferToThreadPoolTests.setUp=s#''1-  rc8URR5 gr')rstoprs rrDeferToThreadPoolTests.tearDownAs  rc[R"[URSSjSSS9nUR UR S5 U$)z~ L{threads.deferToThreadPool} executes the function passed, and correctly handles the positional and keyword arguments given. c X-$r'rPrs rrQ.Isqurrrrrr)r deferToThreadPoolrrr:rrs rr*DeferToThreadPoolTests.test_deferredResultDs;  % %gtww8LaST U d&&*rc^"SS[5mU4Sjn[R"[URU5nUR UT5$)z Check that L{threads.deferToThreadPool} return a failure object with an appropriate exception instance when the called function raises an exception. c\rSrSrSrg)=DeferToThreadPoolTests.test_deferredFailure..NewErroriTrPNrrPrrrrTrrrc>T"5er'rPrsrr?DeferToThreadPoolTests.test_deferredFailure..raiseErrorWrr)rar rrrrrs @rr+DeferToThreadPoolTests.test_deferredFailureMsA y    % %gtww C!!!X..r)rN) rrrrrrrrrrrPrrrr8s/rra_ import time import %(reactor)s %(reactor)s.install() from twisted.internet import reactor def threadedCall(): print('threaded call') reactor.callInThread(threadedCall) # Spin very briefly to try to give the thread a chance to run, if it # is going to. Is there a better way to achieve this behavior? for i in range(100): time.sleep(0.0) c,\rSrSrSrSrSrSrSrg)ThreadStartupProcessProtocoliqc,Xl/Ul/Ulgr')routerr)rrs r__init__%ThreadStartupProcessProtocol.__init__rs rc:URRU5 gr')rr()rrs r outReceived(ThreadStartupProcessProtocol.outReceivedw rc:URRU5 gr')rr()rrs r errReceived(ThreadStartupProcessProtocol.errReceivedzrrchURRURURU45 gr')rrBrr)rreasons r processEnded)ThreadStartupProcessProtocol.processEnded}s# $((F;UupnUR[R5(aTRSUSUS35 U(a[R "SU35 TR USU35 g)Nz#Process did not exit cleanly (out: z err: )z%Unexpected output on standard error: z&Expected no output, instead received: )checkrProcessTerminatedr5r msg assertFalse)r+rrrrs rprogramFinishedMStartupBehaviorTests.testCallBeforeStartupUnexecuted..programFinishedsm!' Sv||E3344 ?uF3%qQR?uEF   S$KC5"Q Rrch>UR[R5 TRS5 U$)NKILL)trapr TimeoutError signalProcess)rprotos rprogramTimeoutLStartupBehaviorTests.testCallBeforeStartupUnexecuted..programTimeouts( HHU'' (    'Jr PYTHONPATHpython)mktempopenwrite_callBeforeStartupProgramrrosenvironcopypathsepjoinsyspathrrF addCallbacksr spawnProcess executable)rprognameprogfiler r(envrr's` @rtestCallBeforeStartupUnexecuted4StartupBehaviorTests.testCallBeforeStartupUnexecuteds;;= (C H NN4 7CUCU7VV W! S  jjooJJOOCHH5L NN  ) )/ J,Q/UCNNXx4H#N-! s )D DrPN)rrrrrr=rrPrrrrs  rr) rr0r5r unittestrtwisted.internetrrrrrr twisted.pythonr r r r twisted.trial.unittestrr0 ImportErrorIReactorThreadsrrrrr/ProcessProtocolrIReactorProcessrrPrrrGsG   QQ??+  ""7D11.xM(xM xMv$""7D11.G8(G8 G8T#/X#/L& =8#;#; = ""7D11.""7D11=&8&  &i   sDDD