ó [³XMc@s dZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z ddlmZddlmZdefd„ƒYZe jeƒd ejfd „ƒYZd ejfd „ƒYZd ejfd„ƒYZdS(s( Tests for L{twisted.python.threadpool} iÿÿÿÿN(tunittesttutil(t threadpoolt threadabletfailuretcontext(treactor(tDeferredtSynchronizationcBs)eZdZd„Zd„ZdgZRS(icCs.||_||_tjƒ|_g|_dS(N(tNtwaitingt threadingtLocktlocktruns(tselfR R ((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt__init__s  cCsª|jjtƒrEt|jƒds5tjdƒn|jjƒn|jd7_|jjƒ|jj dƒt|jƒ|j kr™|j jƒn|jjƒdS(Nig-Cëâ6*?i( R tacquiretFalsetlenRttimetsleeptreleasetfailurestappendtNoneR R (R((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pytruns R(t__name__t __module__RRRt synchronized(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRs  tThreadPoolTestCasecBsÎeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z e j d d d e ƒge _ d „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(s Test threadpools. cCsHxAtdƒD]&}|jtƒr&Pntjdƒq W|jdƒdS(Ni@Bgñh㈵øä>s%A long time passed without succeeding(txrangeRRRRtfail(RR ti((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt _waitForLock>s cCs<tjddƒ}|j|jdƒ|j|jdƒdS(sy L{ThreadPool.min} and L{ThreadPool.max} are set to the values passed to L{ThreadPool.__init__}. i iN(Rt ThreadPoolt assertEqualtmintmax(Rtpool((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_attributesGscCs§tjddƒ}|jƒ|j|jƒ|jt|jƒdƒtjddƒ}|jt|jƒdƒ|jƒ|j|jƒ|jt|jƒdƒdS(sV L{ThreadPool.start} creates the minimum number of threads specified. iiii N(RR#tstartt addCleanuptstopR$Rtthreads(RR'((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt test_startQs  cCsþtjddƒ}|jƒ|j|jƒ|j|jgƒd„}dtfd„ƒY}|ƒ}tj |ƒ}tj |ƒ}|j ||ƒt j ƒ}|j |j ƒ|j|jƒƒ~~tjƒ|j|ƒdƒ|j|ƒdƒdS(sü Test that creating threads in the threadpool with application-level objects as arguments doesn't results in those objects never being freed, with the thread maintaining a reference to them as long as it exists. iicSsdS(N((targ((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pytworkerpstDumbcBseZRS((RR(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR0ssN(RR#R)R*R+R$R,tobjecttweakreftreft callInThreadR tEventtsettwaitt getTimeouttgctcollectt assertEqualsR(RttpR/R0tuniquet workerReft uniqueReftevent((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_threadCreationArgumentsas$     cs†tjddƒ}|jƒˆj|jƒˆj|jgƒi‰tjƒ‰tjƒ‰g‰‡‡‡‡‡‡‡fd†}‡fd†}dt fd„ƒY‰ˆƒ}t j |ƒ}t j |ƒ‰t j |ƒ‰|j |||d|ƒ~~t jƒˆjƒˆjˆjƒƒˆjˆƒdƒˆjˆƒdƒ~t jƒˆj|ƒdƒˆjˆdƒdƒdS( se As C{test_threadCreationArguments} above, but for callInThreadWithCallback. iicsQˆjˆjƒƒˆƒˆd<ˆƒˆd<ˆjƒˆjtj|ƒƒdS(NR>R?(R7R8R6RR2R3(tsuccesstresult(t resultReft onResultDoneRR>t onResultWaitR?trefdict(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pytonResult s    csˆƒS(N((R.ttest(R0(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR/¨sR0cBseZRS((RR(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR0¬sRIN(RR#R)R*R+R$R,R R5R1R2R3tcallInThreadWithCallbackR9R:R6R7R8R;R(RR<RHR/R=t onResultRef((RDRER?R>RRFR0RGs@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt4test_threadCreationArgumentsCallInThreadWithCallbackŠs6   !    cCsztjddƒ}|j|jdƒ|j|jdƒtjtj|ƒƒ}|j|jdƒ|j|jdƒdS(s… Threadpools can be pickled and unpickled, which should preserve the number of threads and other parameters. iiN(RR#R;R%R&tpickletloadstdumps(RR'tcopy((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_persistenceÏs cCs£d}tjƒ}|jƒ|j|jƒtjƒ}|jƒt||ƒ}x!t |ƒD]}|||ƒq^W|j |ƒ|j |j d|j fƒdS(s  Test synchronization of calls made with C{method}, which should be one of the mechanisms of the threadpool to execute work in threads. i srun() re-entered %d timesN( RR#R)R*R+R R RRRR"tfailIfR(RtmethodR R<R tactorR!((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt_threadpoolTestàs      cCs|jd„ƒS(s; Call C{_threadpoolTest} with C{dispatch}. cSs|j||jƒS(N(tdispatchR(R<RT((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyts(RU(R((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt test_dispatchüstmessagesJdispatch\(\) is deprecated since Twisted 8.0, use callInThread\(\) insteadtcategorycCs|jd„ƒS(s? Call C{_threadpoolTest} with C{callInThread}. cSs|j|jƒS(N(R4R(R<RT((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRWs(RU(R((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_callInThread scsdtfd„ƒY‰‡fd†}tjddƒ}|j|ƒ|jƒ|jƒ|jˆƒ}|jt|ƒdƒdS(si L{ThreadPool.callInThread} logs exceptions raised by the callable it is passed. tNewErrorcBseZRS((RR(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR\scs ˆƒ‚dS(N(((R\(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt raiseErrorsiiN( t ExceptionRR#R4R)R+tflushLoggedErrorsR$R(RR]R<terrors((R\s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_callInThreadExceptions   cs¥tjƒ‰ˆjƒg‰‡‡fd†}tjddƒ}|j|d„ƒ|jƒz|jˆƒWd|jƒX|j ˆdƒ|j ˆddƒdS(sÀ L{ThreadPool.callInThreadWithCallback} calls C{onResult} with a two-tuple of C{(True, result)} where C{result} is the value returned by the callable supplied. cs(ˆjƒˆj|ƒˆj|ƒdS(N(RR(RBRC(twaitertresults(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRH0s  iicSsdS(NRI((((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRW6sNRI( R R RRR#RJR)R"R+t assertTrueR$(RRHR<((RbRcs@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_callInThreadWithCallback%s    csídtfd„ƒY‰‡fd†}tjƒ‰ˆjƒg‰‡‡fd†}tjddƒ}|j||ƒ|jƒz|jˆƒWd|j ƒX|j ˆdƒ|j t ˆdt jƒƒ|j tˆdjˆƒƒdS(sÍ L{ThreadPool.callInThreadWithCallback} calls C{onResult} with a two-tuple of C{(False, failure)} where C{failure} represents the exception raised by the callable supplied. R\cBseZRS((RR(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR\Hscs ˆƒ‚dS(N(((R\(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR]Kscs(ˆjƒˆj|ƒˆj|ƒdS(N(RR(RBRC(RbRc(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRHSs  iiN(R^R R RRR#RJR)R"R+t assertFalseRdt isinstanceRtFailuret issubclassttype(RR]RHR<((RbRcR\s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt0test_callInThreadWithCallbackExceptionInCallbackBs    csðdtfd„ƒY‰tjƒ}|jƒg‰‡‡fd†}tjddƒ}|j|d„ƒ|j|jƒ|j ƒz|j |ƒWd|j ƒX|j ˆƒ}|j t|ƒdƒ|jˆdƒ|j ˆddƒdS(sj L{ThreadPool.callInThreadWithCallback} logs the exception raised by C{onResult}. R\cBseZRS((RR(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyR\kscs'ˆj|ƒˆj|ƒˆƒ‚dS(N(R(RBRC(R\Rc(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRHss  iicSsdS(N(R(((s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRWysN(R^R R RRR#RJR4RR)R"R+R_R$RRdR(RRbRHR<R`((RcR\s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyt0test_callInThreadWithCallbackExceptionInOnResultfs     csÆg‰ddl‰tjƒ‰‡‡‡fd†}‡‡fd†}tjddƒ}|j||ƒ|jƒ|j|jƒˆj |j ƒƒ|j t ˆƒdƒ|j ˆdˆdƒdS(s L{ThreadPool.callInThreadWithCallback} calls the function it is given and the C{onResult} callback in the same thread. iÿÿÿÿNcs!ˆjˆjƒƒˆjƒdS(N(Rt get_identR6(RBRC(R@tthreadt threadIds(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyRH”scsˆjˆjƒƒdS(N(RRm((RnRo(s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pytfunc˜siii( RnR R5RR#RJR)R*R+R7R8R$R(RRHRpR<((RnRoR@s@/usr/lib/python2.7/dist-packages/twisted/test/test_threadpool.pyttest_callbackThread‰s   csätjjƒjd}d|ds<"# ÿÈD