ó ¨œž[c@`s¤ddlmZmZmZddlmZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZyddlmZWn;ek réyddlZWnek råeZnXnXddlmZddlmZddlmZmZmZmZddlmZdd lmZdd l m!Z!m"Z"m#Z#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)dd l*mZm+Z+m,Z,m-Z-m.Z.m/Z/ydd l0m1Z1Wnek rëeZ1nXyddl2Z2Wnek reZ2nXyddl3Z3Wnek r?eZ3nXdefd„ƒYZ4defd„ƒYZ5de&fd„ƒYZ6dej7fd„ƒYZ8de&fd„ƒYZ9de&fd„ƒYZ:de:fd„ƒYZ;ej<e1ekdƒde&fd„ƒYƒZ=dej7fd „ƒYZ>ej<e2ek d!ƒd"ej7fd#„ƒYƒZ?d$ej7fd%„ƒYZ@d&ej7fd'„ƒYZAeBd(kr ejCƒndS()i(tabsolute_importtdivisiontprint_function(tThreadPoolExecutorN(tmock(t native_str(tgen(tIOLoopt TimeoutErrort PollIOLooptPeriodicCallback(tapp_log(t_Select(tExceptionStackContextt StackContexttwrapt NullContext(t AsyncTestCasetbind_unused_portt ExpectLogtgen_test(tunittestt skipIfNonUnixt skipOnTravist skipBefore35t exec_testtignore_deprecation(tfuturestFakeTimeSelectcB`s,eZd„Zd„Zd„Zd„ZRS(cC`s d|_tt|ƒjƒdS(Niè(t_timetsuperRt__init__(tself((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR0s cC`s|jS(N(R(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttime4scC`s|j|7_dS(N(R(R tt((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytsleep7scC`s5tt|ƒjdƒ}|r"|S|j|7_gS(Ni(RRtpollR(R ttimeouttevents((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR$:s (t__name__t __module__RR!R#R$(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR/s   tFakeTimeIOLoopcB`s eZdZd„Zd„ZRS(säIOLoop implementation with a fake and deterministic clock. The clock advances as needed to trigger timeouts immediately. For use when testing code that involves the passage of time and no external dependencies. cC`s8tƒ|_tt|ƒjd|jd|jjƒdS(Ntimplt time_func(RtftsRR)t initializeR!(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR-Is cC`s|jj|ƒdS(s1Simulate a blocking sleep by advancing the clock.N(R,R#(R R"((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR#Ns(R'R(t__doc__R-R#(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR)Bs t TestIOLoopcB`s(eZd„Zed„ƒZed„ƒZd„Zd„Zd„Zd„Z d„Z d„Z d „Z e d „ƒZd „Zd „Zd „Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zed„ƒZd„Ze d„ƒZe d„ƒZ!RS(c`s¨d|_|j}|‰|j‰‡‡fd†}tj||ƒ|_|jd„ƒ|jd„ƒ|jtjddƒ|jƒ|j ƒ|j |jdƒdS(Nic`s#ˆjd7_ˆ|||ŽdS(Ni(tcalls(R tcallbacktargstkwargs(told_add_callbackttest(s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt add_callback\scS`siS(N((((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytascS`sgS(N((((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7bst millisecondsi2i ( R0tio_loopR6ttypest MethodTypet add_timeouttdatetimet timedeltatstoptstartt assertLess(R tloopR6((R4R5s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt!test_add_callback_return_sequenceTs    c`sz‡fd†‰‡‡fd†}ˆjjˆjjƒ|ƒˆjƒˆjtjƒˆjddƒˆjˆjƒdS(Nc`stˆ_ˆjƒdS(N(tTruetcalledR?((R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR1ks c`s,tˆ_ˆjjˆƒtjƒˆ_dS(N(tFalseRER9R6R!t start_time((R1R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytschedule_callbackos tplacesi(R9R<R!twaittassertAlmostEqualRGt assertTrueRE(R RH((R1R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_callback_wakeupgs  c`so‡fd†}tjd|ƒ}ˆjj|jƒˆjƒtjƒˆj}ˆj|dƒ|j ƒdS(Nc`s3tjdƒtjƒˆ_ˆjjˆjƒdS(Ng{®Gáz„?(R!R#t stop_timeR9R6R?((R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttarget{s ROgš™™™™™¹?( t threadingtThreadR9R6R@RJR!RNRAtjoin(R ROtthreadtdelta((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt%test_add_callback_wakeup_other_threadys cC`s0|jjtjddƒ|jƒ|jƒdS(Nt microsecondsi(R9R<R=R>R?RJ(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_timeout_timedelta‡s"cC`sˆtƒ\}}zQ|jj|jƒd„tjƒ|jt|jj|jƒd„tjƒWd|jj|jƒƒ|j ƒXdS(NcS`sdS(N(tNone(tfdR&((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7ŽscS`sdS(N(RX(RYR&((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7“s( RR9t add_handlertfilenoRtREADt assertRaisest Exceptiontremove_handlertclose(R tsocktport((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_multiple_add‹s cC`s;tƒ\}}z|jj|jƒƒWd|jƒXdS(N(RR9R_R[R`(R RaRb((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_remove_without_add™scC`s!|jj|jƒ|jƒdS(N(R9tadd_callback_from_signalR?RJ(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_callback_from_signal¢scC`sPtƒ}tjd|jƒ}|jƒ|j|jƒ|jƒ|jƒdS(NRO(RRPRQR@ReR?RRR`(R t other_ioloopRS((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt*test_add_callback_from_signal_other_thread¨s    c`sxtjƒ‰‡‡fd†}tƒ‰tjd|ƒ}|jƒˆjƒx$tdƒD]}ˆjd„ƒqZWdS(Nc`s8ˆjˆjƒˆjƒˆjƒˆjdtƒdS(Ntall_fds(R6R?R@tsetR`RD((tclosingRg(s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyRO¹s  ROiècS`sdS(N(RX(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7Ãs(RPtEventRRQR@RJtrangeR6(R RORSti((RkRgs7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_callback_while_closing³s    c`sL‡fd†}|ˆj_tƒˆjjd„ƒWdQXˆjƒdS(Nc`s(ˆjtjƒdtƒˆjƒdS(Ni(tassertIstsystexc_infotZeroDivisionErrorR?(R1(R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pythandle_callback_exceptionÈscS`sddS(Nii((((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7Ïs(R9RtRR6RJ(R Rt((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_handle_callback_exceptionÅs   c`s¯tjƒ\}}z‡fd†}ˆjj|jƒ|tjƒˆjjˆjjƒdt j |j dƒƒˆj ƒˆjj |jƒƒWd|jƒ|jƒXdS(Nc`s!ˆj|tjƒˆjƒdS(N(t assertEqualRR\R?(RYR&(R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pythandlerÙsg{®Gáz„?tasdf(tsockett socketpairR9RZR[RR\R<R!t functoolstpartialtsendRJR_R`(R tclienttserverRw((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_read_while_writeableÒs  cC`s?|jj|jjƒ|jƒ}|jƒ|jj|ƒdS(N(R9R<R!R?RJtremove_timeout(R thandle((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_remove_timeout_after_fireås! c`ssxItdƒD];}ˆjjˆjjƒdd„ƒ}ˆjj|ƒq Wˆjj‡fd†ƒˆjƒdS(NiÐicS`sdS(N(RX(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7ósc`sˆjjˆjƒS(N(R9R6R?((R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7ös(RmR9R<R!RR6RJ(R RnR%((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_remove_timeout_cleanupës  c`sºttg‰ˆjjƒ}‡‡‡fd†}ˆjj|d|ƒ‡fd†}ˆjj|d|ƒ‰ˆjj|dˆjƒtjdƒˆjƒˆjˆttgƒdS(Nc`stˆd<ˆjjˆƒdS(Ni(RDR9R((R0R t t2_handle(s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytt1s g{®Gáz„?c`stˆdtcall_att call_laterR?RJRvtsorted(R tresults((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_timeout_with_argumentss" " cC`sH|jj|jjƒd„ƒ}|j|dkƒ|jj|ƒdS(NcS`sdS(N(RX(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7s(R9R<R!t assertFalseRXR(R R‚((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_timeout_returns!cC`sH|jj|jjƒd„ƒ}|j|dkƒ|jj|ƒdS(NcS`sdS(N(RX(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7$s(R9RŒR!R‘RXR(R R‚((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_call_at_return#s!cC`s?|jjdd„ƒ}|j|dkƒ|jj|ƒdS(NicS`sdS(N(RX(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7)s(R9RR‘RXR(R R‚((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_call_later_return(scC`swdtfd„ƒY}tƒ\}}||ƒ}tƒ}|j|d„tjƒ|jdtƒ|j|jƒdS(s¦When a file object is used instead of a numeric file descriptor, the object should be closed (by IOLoop.close(all_fds=True), not just the fd. t SocketWrappercB`s#eZd„Zd„Zd„ZRS(cS`s||_t|_dS(N(tsockobjRFtclosed(R R–((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR6s cS`s |jjƒS(N(R–R[(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR[:scS`st|_|jjƒdS(N(RDR—R–R`(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR`=s (R'R(RR[R`(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR•5s  cS`sdS(N(RX(RYR&((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7CsRiN( tobjectRRRZR\R`RDRLR—(R R•R–Rbtsocket_wrapperR9((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_close_file_object-s    c`s:tƒ\‰}g‰‡‡‡fd†}ˆjjˆ|tjƒtjtjƒƒ$}|jd|fƒˆj ƒWdQXˆjj ˆƒˆjjˆj ƒ|tjƒtjtjƒƒ$}|jd|fƒˆj ƒWdQXˆj ˆdˆƒˆj ˆdˆj ƒƒˆjj ˆj ƒƒˆjƒdS(s>The handler callback receives the same fd object it passed in.c`s7ˆj|ƒˆjƒ\}}|jƒˆjƒdS(N(R‹tacceptR`R?(RYR&tconntaddr(tfdsR t server_sock(s7lib/python2.7/site-packages/tornado/test/ioloop_test.pythandle_connectionMs  s 127.0.0.1Nii(RR9RZRR\t contextlibRkRytconnectRJR_R[RpRvR`(R RbR t client_sock((RžR RŸs7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt!test_handler_callback_file_objectHs" cC`sŠtƒ\}}d„}|jj||tjƒ|jtƒ$|jj|jƒ|tjƒWdQX|jj|jƒƒ|j ƒdS(NcS`sdS(N((RYR&((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytfds( RR9RZRR\R]R^R[R_R`(R RŸRbR¥((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_mixed_fd_fileobjas %c`sgtg‰tg‰‡‡‡fd†}ˆjj|ƒˆjƒˆjˆdƒˆjˆdƒdS(s:Calling start() twice should raise an error, not deadlock.c`sGyˆjjƒtˆdeZd„Zd„Zejd„ƒZd„Zd„ZRS(cC`s tt|ƒjƒg|_dS(N(RRÍR½tactive_contexts(R ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR½scO`s|jj|||ŽdS(N(R9R6(R R1R2R3((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR6scc`s2|jj|ƒdV|j|jjƒ|ƒdS(N(RÎR‹Rvtpop(R tname((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytcontextsc `sŠ‡fd†}tƒbttjˆjdƒƒt|ƒ}WdQXttjˆjdƒƒˆj|ƒWdQXWdQXˆjƒdS(Nc`s4ˆjdˆjƒˆjdˆjƒˆjƒdS(Ntc1tc2(tassertInRÎt assertNotInR?((R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pytf1!sRÒRÓ(RRR{R|RÑRR6RJ(R RÖtwrapped((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt test_pre_wraps c`s¥‡fd†}tƒkttjˆjdƒƒt|ƒ}WdQXttjˆjdƒƒˆj|dddƒWdQXWdQXˆjƒ}ˆj|dƒdS(Nc`s=ˆjdˆjƒˆjdˆjƒˆj||fƒdS(NRÒRÓ(RÔRÎRÕR?(tfootbar(R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyRÖ4sRÒRÓiRÚi(ii( RRR{R|RÑRR6RJRv(R RÖR×tresult((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_pre_wrap_with_args/s " ( R'R(R½R6R¡tcontextmanagerRÑRØRÜ(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyRÍs    tTestIOLoopAddCallbackFromSignalcB`seZd„ZRS(cO`s|jj|||ŽdS(N(R9Re(R R1R2R3((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR6Fs(R'R(R6(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyRÞDssfutures module not presenttTestIOLoopFuturescB`sMeZd„Zd„Zed„ƒZeed„ƒƒZed„ƒZRS(c`s|tjdƒg}ˆjj|jd„ƒ‡fd†ƒˆjƒ}ˆj|jƒƒˆj|jƒdkƒWdQXdS(NicS`sdS(N(RX(((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7Nsc`s ˆj|ƒS(N(R?(tfuture(R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR7Os( RRR9t add_futureRÊRJRLtdoneRÛRX(R tpoolRà((R s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_future_threadsLs  c`sâtjƒ‰‡fd†}‡fd†}‡fd†}tƒ`tjdƒ@}t|ƒ!ˆjj|j|ƒ|ƒWdQXˆj ƒWdQXˆj ƒWdQXˆj ˆj j ddƒˆj ˆjj ƒj ddƒdS(Nc`s5ˆjdƒˆjƒs%tdƒ‚tdƒ‚dS(Nis timed outtworker(RJtisSettAssertionErrorR^((tready(s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttaskWs c`s|ˆ_tdƒ‚dS(NR1(RàR^(Rà(R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyR1`s c`s|ˆ_ˆjƒtS(N(t exceptionR?RD(ttyptvaluet traceback(R (s7lib/python2.7/site-packages/tornado/test/ioloop_test.pythandle_exceptionds  iiR1Rå(RPRlRRRR R9RáRÊRjRJRvRêR2Rà(R RéR1RîRã((RèR s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_add_future_stack_contextTs    "cc`sxtjƒ}tjƒ}d„}tjƒjd|||ƒtjƒjd|||ƒgV}|j||g|ƒdS(NcS`s|jƒ|jƒ|S(N(RjRJ(t self_eventt other_event((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyt sync_funczs  (RPRlRR¿R¹RXRv(R tevent1tevent2Ròtres((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_run_in_executor_genus    "cc`sztjƒ}tjƒ}d„}ttƒtƒdƒ}|d||ƒ|d||ƒgV}|j||g|ƒdS(NcS`s|jƒ|jƒ|S(N(RjRJ(RðRñ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyRò‘s  sÄ async def async_wrapper(self_event, other_event): return await IOLoop.current().run_in_executor( None, sync_func, self_event, other_event) t async_wrapper(RPRlRR­R®Rv(R RóRôRòR¯Rõ((s7lib/python2.7/site-packages/tornado/test/ioloop_test.pyttest_run_in_executor_native‹s    c#`s§dg‰dtjf‡‡fd†ƒY‰tjƒ‰‡fd†}ˆdƒ}tjƒ}|j|ƒ|jd|ƒV|j dˆdƒ|j ˆj ƒƒdS(Nit MyExecutorc`seZ‡‡fd†ZRS(c`s)ˆdcd7sn           """.      ÿˆ, 4q6 :F9