๓ จœž[c@`sfddlmZmZmZddlmZddlmZddlm Z ddl m Z m Z ddl mZmZmZmZyddlmZWnek rฑdZn!XddlmZmZmZeejedkd ƒd e fd „ƒYƒZejedkd ƒd ejfd „ƒYƒZejedkd ƒdejfd„ƒYƒZdS(i(tabsolute_importtdivisiontprint_function(tThreadPoolExecutor(tgen(tIOLoop(t AsyncTestCasetgen_test(tunittestt skipBefore33t skipBefore35t exec_test(tasyncio(t AsyncIOLooptto_asyncio_futuretAnyThreadEventLoopPolicysasyncio module not presenttAsyncIOLoopTestcB`sMeZd„Zd„Zed„ƒZeed„ƒƒZed„ƒZ RS(cC`s tƒ}|S(N(R (tselftio_loop((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pytget_new_ioloop!s cC`s$tjƒj|jƒ|jƒdS(N(R tget_event_loopt call_soontstoptwait(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_asyncio_callback%scc`s`ttdƒrtj}nttdƒ}|tjƒjdd„ƒƒV}|j|dƒdS(Nt ensure_futuretasynccS`sdS(Ni*((((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyt6si*(thasattrR RtgetattrRtrun_in_executortNonet assertEqual(RRtx((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_asyncio_future*s  cc`s:ttƒtƒdƒ}|dƒV}|j|dƒdS(Nsภ @gen.coroutine def f(): event_loop = asyncio.get_event_loop() x = yield from event_loop.run_in_executor(None, lambda: 42) return x tfi*(R tglobalstlocalsR (Rt namespacetresult((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_asyncio_yield_from9s cC`s$tjd„ƒ}ttƒtƒdƒd}ttƒtƒdƒd}ttƒtƒdƒd}|j|jj|ƒdƒ|j|jj|ƒdƒ|j|jj|ƒdƒ|jtj ƒj |ƒƒdƒ|jtj ƒj |ƒƒdƒ|jtj ƒj |ƒƒdƒdS( Ncs`stjVtjdƒ‚dS(Ni*(RtmomenttReturn(((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttornado_coroutineNssl async def native_coroutine_without_adapter(): return await tornado_coroutine() t native_coroutine_without_adapters| async def native_coroutine_with_adapter(): return await to_asyncio_future(tornado_coroutine()) tnative_coroutine_with_adaptersŒ async def native_coroutine_with_adapter2(): return await to_asyncio_future(native_coroutine_without_adapter()) tnative_coroutine_with_adapter2i*( Rt coroutineR R$R%R Rtrun_syncR Rtrun_until_complete(RR+R,R-R.((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_asyncio_adapterHs8         ( t__name__t __module__RRRR"R R(R R2(((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyRs   tLeakTestcB`s,eZd„Zd„Zd„Zd„ZRS(cC`s3tƒjƒtjƒ|_tjtjƒƒdS(N(R tcloseR tget_event_loop_policyt orig_policytset_event_loop_policytDefaultEventLoopPolicy(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pytsetUps cC`s$tjƒjƒtj|jƒdS(N(R RR6R9R8(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttearDown‡scC`s`ttjƒ}x'tdƒD]}tƒ}|jƒqWttjƒ|}|j|dƒdS(Ni i(tlenRt_ioloop_for_asynciotrangeR R6R (Rt orig_counttitloopt new_count((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_ioloop_close_leak‹s  cC`sttjƒ}xTtdƒD]F}tjƒ}|jtjƒ|j|jƒ|j ƒ|j ƒqWttjƒ|}|j |dƒdS(Ni i( R=RR>R?R tnew_event_loopRtcurrentRt run_foreverR6R (RR@RARBRC((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_asyncio_close_leak”s  (R3R4R;R<RDRH(((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyR5}s   tAnyThreadEventLoopPolicyTestcB`s>eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cC`s"tjƒ|_tdƒ|_dS(Ni(R R7R8Rtexecutor(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyR;ฅscC`s!tj|jƒ|jjƒdS(N(R R9R8RJtshutdown(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyR<ฉscC`s%d„}|jj|ƒ}|jƒS(NcS`stjƒ}|jƒ|S(s#Get the event loop. Close it if one is returned. Returns the (closed) event loop. This is a silly thing to do and leaves the thread in a broken state, but it's enough for this test. Closing the loop avoids resource leak warnings. (R RR6(RB((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pytget_and_close_event_loopฎs  (RJtsubmitR'(RRLtfuture((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pytget_event_loop_on_threadญs cC`st|jttf|jj|ƒjƒtjtƒƒ|j |jj|ƒjƒ|ƒ|jjd„ƒjƒdS(NcS`stjƒjƒS(N(R RR6(((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyRศs( t assertRaisest RuntimeErrortAssertionErrorRJRMR'R R9RtassertIsInstance(Rtaccessort expected_type((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pytrun_policy_testผscC`s|jtjtjƒdS(N(RVR RtAbstractEventLoop(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_asyncio_accessorสscC`s|jtjtƒdS(N(RVRRF(R((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyttest_tornado_accessorอs(R3R4R;R<RORVRXRY(((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyRIฃs      N(t __future__RRRtconcurrent.futuresRttornadoRttornado.ioloopRttornado.testingRRttornado.test.utilRR R R ttornado.platform.asyncioR t ImportErrorRR RRtskipIfRtTestCaseR5RI(((s8lib/python2.7/site-packages/tornado/test/asyncio_test.pyt s""  ]%