ó úR‹_c@`sEddlmZmZmZddlZddlZddlmZmZddl j Z ddl m Z ddlmZddlmZddlmZddlmZeeZd efd „ƒYZd efd „ƒYZd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZde jfd„ƒYZde jfd„ƒYZde jfd„ƒYZdefd„ƒYZdefd„ƒYZ de jfd „ƒYZ!d!e!fd"„ƒYZ"d#e!fd$„ƒYZ#d%e!fd&„ƒYZ$d'e jfd(„ƒYZ%[[e&d)krAe j'ƒndS(*i(tabsolute_importtprint_functiontdivisionN(tEventt AsyncResult(txrange(tAbstractGenericGetTestCase(tAbstractGenericWaitTestCase(t SMALL_TICK(tSMALL_TICK_MAX_ADJt TestEventWaitcB`seZd„Zd„ZRS(cC`stƒjd|ƒdS(Nttimeout(Rtwait(tselfR ((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR scC`sttƒƒdS(N(tstrR(R ((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyt test_covers(t__name__t __module__R R(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR s t TestWaitEventcB`seZd„Zd„ZRS(cC`stjtƒgd|ƒdS(NR (tgeventR R(R R ((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR sc`sDtƒ‰‡fd†‰‡‡‡fd†}tj|ƒjƒdS(Nc`sˆjƒdS(N(tset((tevent(sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pytsetter(sc`s¡tjˆƒ}ˆjƒ}ˆj|ƒˆjˆjƒƒ|jƒˆjƒˆjˆjƒƒtjˆfddƒ}ˆjˆjƒƒˆjˆ|ƒdS(NR g{®Gáz„?( RtspawnR t assertTruetreadytjointcleart assertFalset assertNotIn(tstresto(RR R(sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pytwaiter+s    (RRRR(R R!((RR RsQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyttest_set_during_wait!s (RRR R"(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRs tTestAsyncResultWaitcB`seZd„ZRS(cC`stƒjd|ƒdS(NR (RR (R R ((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR Es(RRR (((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR#CstTestWaitAsyncResultcB`seZd„ZRS(cC`stjtƒgd|ƒdS(NR (RR R(R R ((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR Ks(RRR (((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR$IstTestAsyncResultGetcB`seZd„ZRS(cC`stƒjd|ƒdS(NR (Rtget(R R ((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR Qs(RRR (((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR%Ost MyExceptioncB`seZRS((RR(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR'TstTestAsyncResultcB`s5eZd„Zd„Zd„Zd„Zd„ZRS(cC`sGtƒ}|jt|jdƒ|jdƒ|jdƒt|ƒdS(N(Rt assertRaisest TypeErrortrawlinktNonetunlinkR(R tar((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyt test_linkYs    c`s—g‰tƒ‰ˆjˆjdƒˆjˆjdƒ‡‡‡fd†}tj|ƒtƒ}ˆj|ƒtj dƒˆjˆd|fgƒdS(Nc`s<ˆjtƒ}ˆjƒWdQXˆjd|jfƒdS(Ntcaught(R)R'R&tappendt exception(texc(tetlogR (sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR!fsiR0(( Rt assertEqualtexc_infoR2R,RRR't set_exceptiontsleep(R R!tobj((R4R5R sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyt test_set_exc`s     c C`s’tƒ}tdƒ}tjt|jdƒ}|j|jƒtjj d|ƒ:|j tƒ}|j ƒWdQX|j ||j ƒWdQXdS(Nt interrupteds hello event1i(RR'Rt spawn_latertDELAYRt_close_on_teardowntkilltTimeoutt start_newR)R&tassertIsR2(R tevent1t timer_exctgR3((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyttest_setps  cC`sKtƒ}tƒ}tjt|jd|ƒ}|j||d|fƒdS(Nt timeout_values1Nobody sent anything to event2 yet it received %r(RtobjectRt with_timeoutR>R&RC(R tevent2tXtresult((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyttest_set_with_timeouts   cC`s?tƒ}|jtj|jdtƒ|jtj|jƒdS(Ntblock(RR)RRAR&tFalset get_nowait(R R.((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyttest_nonblocking_getˆs (RRR/R;RGRNRR(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR(Ws     tTestAsyncResultAsLinkTargetcB`s eZeZd„Zd„ZRS(cC`sºtjd„ƒ}tƒtƒtƒ}}}|j|ƒ|j|ƒ|j|ƒ|j|jƒdƒ|j|jƒdƒtƒ}tj t |jd|ƒ}|j ||ƒdS(NcS`sdS(Ni((((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyt’tiRH( RRRtlinkt link_valuetlink_exceptionR6R&RIRJR>RC(R RFts1ts2ts3RLRM((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRG‘s    cC`sÀd„}tj|ƒ}tƒtƒtƒ}}}|j|ƒ|j|ƒ|j|ƒ|jtj|j ƒt ƒ}tj t |j d|ƒ}|j ||ƒ|jtj|j ƒdS(NcS`stjdƒ‚dS(Ns.TestAsyncResultAsLinkTarget.test_set_exception(t greentesttExpectedException(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pytfuncžsRH(RRRRVRWRXR)R\R]R&RIRJR>RC(R R^RFRYRZR[RLRM((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyttest_set_exceptions     (RRRPt error_fatalRGR_(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRSŽs tTestEvent_SetThenClearcB`seZdZd„ZRS(icC`swtƒ}gt|jƒD]}tj|jƒ^q}tjdƒ|jƒ|jƒx|D]}|j ƒq_WdS(Ngü©ñÒMbP?( RtrangetNRRR R9RRR(R R4titwaiterstgreenlet((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyttest¯s .    (RRRcRg(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRa¬stTestEvent_SetThenClear100cB`seZdZRS(id(RRRc(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRh¹stTestEvent_SetThenClear1000cB`seZdZRS(iè(RRRc(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRi½stTestWaitcB`sEeZdZdZdZedZd„Zej dƒd„ƒZ RS(iigY@cC`sixb|s|rdtj|jƒ|r8|jƒjƒntj|jƒ|r|jƒjƒqqWdS(N(RR9tperiodtpopR(R teventstasyncs((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyt_senderÇss:Not all results have arrived sometimes due to timer issuescC`sTgt|jƒD]}tƒ^q}gt|jƒD]}tƒ^q5}t|ƒt|ƒ}tj|j||ƒ}tj||d|j d|j ƒ}|j dkrµ|}nt ||j |j ƒ}|j dkrö|j|jƒ|ƒn2t |j |ƒ}|j|jƒ|ƒ|jƒ|j|t|ƒ|t|ƒ|fƒdS(NtcountR (RRcRRtlenRRRoR RpR R,tminRkRRRR@R6(R t_RmRntmax_lentsendertresultst expected_len((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRgÐs%%%  N( RRRcR,RpR RkRoR\tskipOnAppVeyorRg(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRjÁs   tTestWait_notimeoutcB`seZdZRS(N(RRR,R (((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRyästTestWait_count1cB`seZdZRS(i(RRRp(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyRzèstTestWait_count2cB`seZdZRS(i(RRRp(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR{ìstTestEventBasicscB`seZd„ZRS(cC`s5tƒ}tj|ƒ}|j||ƒƒ~~dS(N(RtweakreftrefRC(R R4tr((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyt test_weakrefñs  (RRR€(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyR|ïst__main__((t __future__RRRR}Rt gevent.eventRRtgevent.testingttestingR\tgevent.testing.sixRtgevent.testing.timingRRRR R>R RR#R$R%t ExceptionR'tTestCaseR(RSRaRhRiRjRyRzR{R|Rtmain(((sQ/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test__event.pyts<    '7 #