[c@`s dZddlmZmZmZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddlmZddlmZddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZm Z dd l!m"Z"m#Z#yddl$Z$ddl%m&Z&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-ddl.m/Z/ddl0m1Z1m2Z2ddl3m4Z4e5Z6Wne7k re8Z6nXyIddl9m:Z:m;Z;ddl<m=Z=ddl>m?Z?e j@dYkZAWne7k r>e8ZAnXe rTddlBZCnddlCZCdZEyddlFZFWne7k rdZFnXejGe6dZHdZIdZJdejKfdYZLeHdeLfdYZMeHdeLfd YZNeHd!eLfd"YZOeHd#eLfd$YZPeHd%eLfd&YZQe6re4e*d'eRfd(YZSe4e+d)eRfd*YZTneHd+eLfd,YZUeHejVeA d-d.ejKfd/YZWeHd0ejKfd1YZXe6rigd26d3d4gd56d6gd76d8d9d:gd;6d<gd=6d>d?d@dAgdB6gdC6gdD6gdE6gdF6gdG6gdH6dIdJdKdLdMdNgdO6dJgdP6gdQ6ZYe j@dZkreYd;=nxeYjZD]\Z[Z\yee[Z]Wne7e^fk rqnXx3e\D]+Z_e`e]e_r$eae]e_dRq$q$WdSZbebe]ZcedjeecjfqWe/jgjhyddTlimjZjWne7k rqXejjkgdUe8ne6rdVe2fdWYZlnemdXkrejnndS([s) Unittest for the twisted-style reactor. i(tabsolute_importtdivisiontprint_functionN(tutf8(tgen(tAsyncHTTPClient(t HTTPServer(tIOLoopt PollIOLoop(tset_close_exec(tbind_unused_port(tunittest(t import_objecttPY3(tRequestHandlert Application(tDeferredtinlineCallbackst returnValue(tIReadDescriptortIWriteDescriptor(tProtocol(tlog(tTornadoReactort TwistedIOLoop(t implementer(tAgenttreadBody(tResource(tSiteistwisted module not presentcC`syi}x3tjtjtjgD]}tj|||R4R@tanotherWhenRunningCallbacktstop(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRAzs cC`s t|_dS(N(R2R?(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyREs(R:R;RDRARE(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR<ps  tReactorCallLaterTestcB`seZdZdZRS(cC`st|_|jj|_d|_|jj|j|j}|j|jj |g|jj |j |j|j |j |j|jk|j|jj gdS(NgMbP?( R=t _laterCalledR4tsecondst_nowt_timeoutt callLatertcallLaterCallbackt assertEqualtgetDelayedCallsRBRCt_called(R5tdc((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyttest_callLaters    cC`s,t|_|jj|_|jjdS(N(R2RHR4RIRPRF(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRMs (R:R;RRRM(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRGs tReactorTwoCallLaterTestcB`s#eZdZdZdZRS(cC`s3t|_t|_|jj|_d|_|jj|j|j}d|_ |jj|j |j }|j |jj ||gkp|jj ||gk|jj |j |j|j |j|j |j|j|jk|j |j|j|j k|j|jj gdS(NgMb@?gMbP?(R=t _later1Calledt _later2CalledR4RIRJt _timeout1RLtcallLaterCallback1t _timeout2tcallLaterCallback2RCRORBt_called1t_called2RN(R5tdc1tdc2((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRRs    !   cC`st|_|jj|_dS(N(R2RTR4RIRZ(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRWs cC`s,t|_|jj|_|jjdS(N(R2RUR4RIR[RF(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRYs (R:R;RRRWRY(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRSs  tReactorCallFromThreadTestcB`s>eZdZdZdZdZdZdZRS(cC`s&tt|jtj|_dS(N(tsuperR^R6tthreadt get_identt _mainThread(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR6scC`s$|jjtt|jdS(N(t_threadtjoinR_R^R9(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR9s cC`sa|j|jtjt|jdrJ|j|jjtjn|jj |j dS(Ntident( tassertNotEqualRbR`RathasattrRcRNReR4tcallFromThreadt_fnCalledFromThread(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt _newThreadRunscC`s*|j|jtj|jjdS(N(RNRbR`RaR4RF(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRiscC`s)tjd|j|_|jjdS(Nttarget(t threadingtThreadRjRctstart(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt_whenRunningCallbackscC`s$|jj|j|jjdS(N(R4R@RoRB(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyttestCallFromThreads(R:R;R6R9RjRiRoRp(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR^s      tReactorCallInThreadcB`s,eZdZdZdZdZRS(cC`s&tt|jtj|_dS(N(R_RqR6R`RaRb(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR6sc`s6jtjjjjfddS(Nc`s jjS(N(R4RF((R5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyts(RfR`RaRbR4Rh(R5targstkwargs((R5s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt_fnCalledInThreadscC`s|jj|jdS(N(R4t callInThreadRu(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRoscC`s$|jj|j|jjdS(N(R4R@RoRB(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyttestCallInThreads(R:R;R6RuRoRw(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRqs   tReadercB`sGeZdZdZdZdZdZdZdZRS(cC`s||_||_dS(N(t_fdt _callback(R5tfdtcallback((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt__init__s cC`sdS(NRx((R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt logPrefixscC`s|jjdS(N(RyR8(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR8scC`s |jjS(N(Rytfileno(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRscC`s|jdS(N(R8(R5treason((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytreadConnectionLostscC`s|jdS(N(R8(R5R((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytconnectionLostscC`s|j|jdS(N(RzRy(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytdoReads( R:R;R}R~R8RRRR(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRxs      tWritercB`s>eZdZdZdZdZdZdZRS(cC`s||_||_dS(N(RyRz(R5R{R|((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR}s cC`sdS(NR((R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR~scC`s|jjdS(N(RyR8(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR8scC`s |jjS(N(RyR(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRscC`s|jdS(N(R8(R5R((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR scC`s|j|jdS(N(RzRy(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytdoWrite s(R:R;R}R~R8RRR(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRs      tReactorReaderWriterTestcB`sGeZdZdZdZdZdZdZdZRS(cC`s6tj|tj}tj|tj|tjBdS(N(tfcntltF_GETFLtF_SETFLtost O_NONBLOCK(R5R{tflags((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt_set_nonblockingscC`stt|jtj\}}|j||j|t|t|tj|dd|_tj|dd|_ dS(Ntrbitwb( R_RR6RtpipeRR tfdopent_p1t_p2(R5trtw((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR6s    cC`s1tt|j|jj|jjdS(N(R_RR9RR8R(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR9!s c`st_fd}fd}tj|_tj|_jj jjj jjj jdS(s In this test the writer writes an 'x' to its fd. The reader reads it, check the value and ends the test. c`s*j|jddjjdS(Nitx(t assertEqualstreadR4RF(R{(R5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pytcheckReadInput-sc`s&jr"t_|jdndS(NR(t shouldWriteR=twrite(R{(R5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt writeOnce1s  N( R2RRxRt_readerRRt_writerR4t addWritert addReader(R5RR((R5s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt_testReadWrite&s cC`s$|jj|j|jjdS(N(R4R@RRB(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt testReadWrite?sc`sfd}fd}tj|_tjd_jjjjjjjj jjj d|dS(se In this test we have no writer. Make sure the reader doesn't read anything. c`sjddS(NsMust not be called.(tfail(R{(R5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRHsc`sjjjjdS(N(RR8R4RF((R5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pytstopTestKs cS`s |jdS(NR(R(R{((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRrSsgMbP?N( RxRRRRRR4Rt removeWriterRRL(R5RR((R5s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt _testNoWriterCscC`s$|jj|j|jjdS(N(R4R@RRB(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt testNoWriter`s( R:R;RR6R9RRRR(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRs     stwisted web not presenttCompatibilityTestscB`seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZRS(cC`s5t|_t|_|jjt|_dS(N(R*t saved_signalsRtio_loopR/Rtreactor(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR6ks   cC`s>|jj|jj|jjdtt|jdS(NR7(Rt disconnectAllRR1R8R2R-R(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR9qs  cC`sVdtfdY}t|}|jjd|dd}|jj|_dS(Nt HelloResourcecB`seZeZdZRS(cS`sdS(NsHello from twisted!((R5trequest((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt render_GET{s(R:R;R2tisLeafR(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRxsit interfaces 127.0.0.1(RRRt listenTCPtgetHosttportt twisted_port(R5RtsiteR((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytstart_twisted_serverwscC`sfdtfdY}td|fgdd}t|}t\}|_|j|gdS(Nt HelloHandlercB`seZdZRS(cS`s|jddS(NsHello from tornado!(R(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytgets(R:R;R(((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRst/t log_functioncS`sdS(N(tNone(R((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRrs(RRRR t tornado_portt add_sockets(R5Rtapptservertsock((s8lib/python2.7/site-packages/tornado/test/twisted_test.pytstart_tornado_servers   cC`s0|jj|_|jj|jjddS(Ntshutdown(RRFt stop_loopRnRtfireSystemEvent(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt run_ioloops cC`s/|jj|_|jj|_|jjdS(N(RRFRRB(R5((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt run_reactorsc`sggt}fd}|j|d||jtddjdS(Nc`sj|jdS(N(tappendR(tresponse(t responsesR5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR|s R|ii(RtfetchRNtlentrethrow(R5turltrunnertclientR|((RR5s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt tornado_fetchs c`sgtj}|jdt|}dtffdYfd}|j|fd}|j||jdjS(NtGETt Accumulatorc`s)eZdZfdZdZRS(cS`s ||_dS(N(tfinished(R5R((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR}sc`sj|dS(N(R(R5tdata(tchunks(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt dataReceivedscS`s|jjddS(N(RR|R(R5R((s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRs(R:R;R}RR((R(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRs c`s t}|j||S(N(Rt deliverBody(RR(R(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyR|s c`sZtdrjn:|dk rVy|jWqVtjddtqVXndS(NRsexception before starting looptexc_info(RgRRtraiseExceptiontloggingterrorR2(tfailure(R5(s8lib/python2.7/site-packages/tornado/test/twisted_test.pyRs  t( RRRRRt addCallbacktaddBothRCRd(R5RRRtdR|R((RRR5s8lib/python2.7/site-packages/tornado/test/twisted_test.pyt twisted_fetchs    c`sFdgtjfd}jj||dS(Nc3`smtj}|jdtV}tj)tjddtt|Vds                       V            4   $