ó L]c@sBddlZddlZddlZddlZddlZddlmZmZyddlm Z Wn!e k r‰ddl m Z nXddl m Z ddl Z ddlmZmZmZmZmZmZde jfd„ƒYZde jfd „ƒYZd efd „ƒYZer>d eefd „ƒYZndS(iÿÿÿÿN(tThreadtEvent(tQueue(tmark(tBaseZMQTestCaset have_geventt GreenTestt skip_greentPYPYtSkipTesttKwargTestSocketcBseZdZd„ZRS(cOs2|jddƒ|_tt|ƒj||ŽdS(Nt test_kwarg(tpoptNonettest_kwarg_valuetsuperR t__init__(tselftargstkwargs((s5lib/python2.7/site-packages/zmq/tests/test_context.pyRsN(t__name__t __module__R RR(((s5lib/python2.7/site-packages/zmq/tests/test_context.pyR stKwargTestContextcBseZeZRS((RRR t _socket_class(((s5lib/python2.7/site-packages/zmq/tests/test_context.pyRst TestContextcBseZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z e jejjd ƒd d ƒd„ƒZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Ze jejjd ƒd dƒd„ƒZRS(cCs||jƒ}|jt||jƒƒ~|jƒ}|jt||jƒƒ~|jƒ}|jt||jƒƒ~dS(N(tContexttassert_t isinstance(Rtc1tc2tc3((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_init%s   cCsa|jƒ}|jdt|ƒkƒtjƒdkrS|jdt|ƒkƒn|jƒdS(Ntsocketit IO_THREADS(i(Rt assertTruetdirtzmqtzmq_version_infotterm(Rtctx((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_dir0s  cCs*|jƒ}|jƒ|j|jƒdS(N(RR&Rtclosed(Rtc((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_term7s  cCs)|jƒ}WdQX|j|jƒdS(N(RRR)(RR*((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_context_manager<scCs|jtj|jdƒdS(Niÿÿÿÿ(tassertRaisesErrnoR$tEINVALR(R((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_fail_initAscCsi|jtjtjƒ\}}|jtjdƒ|jddtƒ|jƒ|jƒ|j j ƒdS(Nithellotcopy( tcreate_bound_pairR$tROUTERtDEALERt setsockopttLINGERtsendtFalsetclosetcontextR&(Rtreptreq((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_term_hangDs   cCs™|jjƒ}|jjddƒ}|j||kƒ|jƒ|jjƒ}|jjƒ}|j||kƒ|j|jƒ|j||kƒdS(Nt io_threadsi(RtinstanceR"R&t assertFalseR)(RR'RRtc4((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_instanceLs cs|jjƒtƒ‰d|jf‡fd†ƒY‰‡‡fd†}d}gt|ƒD]}td|ƒ^qZ}g|D]}|jƒ^q|ˆjƒ}t|ˆƒs³t ‚x8t|ƒD]*}ˆj ddƒ}||ksÀt ‚qÀW|jƒg|D]}|j ddƒ^qÿdS(Nt SlowContextcseZ‡fd†ZRS(cs*tjdƒtˆ|ƒj||ŽdS(Ni(ttimetsleepRR(Rtatkw(RC(s5lib/python2.7/site-packages/zmq/tests/test_context.pyR^s (RRR((RC(s5lib/python2.7/site-packages/zmq/tests/test_context.pyRC]scsˆjˆjƒƒdS(N(tputR?((RCtq(s5lib/python2.7/site-packages/zmq/tests/test_context.pytfbsittargetttimeouti( R:R&RRtrangeRtstartR?RtAssertionErrortgettjoin(RRJtNtitthreadsttR't thread_ctx((RCRIs5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_instance_threadsafeWs  (  c CsSd}tƒ>}|jtjd|ƒ}|j|j|kƒWdQXWdQXdS(Nstesting one two threeR (RR R$R4R"R(RRR'R ((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_socket_passes_kwargsts cCs†|jƒ}xitdƒD][}gtdƒD]}|jtjƒ^q,}g|D]}|jƒ^qQtjdƒqW|jƒdS(s9opening and closing many sockets shouldn't cause problemsiiAg{®Gáz„?N( RRMR R$tREPR9RDRER&(RR'RStsocketsts((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_many_socketszs  +cCs¦|jƒ}d|_|j|jdƒ|jtjƒ}|j|jdƒ|j|jtjƒdƒ|jƒd|_ |jtjƒ}|jƒ|j ƒdS(s*setting socket options with ctx attributesitN( Rtlingert assertEqualR R$tREQt getsockoptR6R9t subscribeR&(RR'R[((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_sockopts„s     twintreasonsSegfaults on WindowscCs|jƒ}gtdƒD]}|jtjƒ^q}g|ddd…D]}|jƒ^qK|jƒtjdƒx|D]}|j |j ƒqWdS(s$Context.destroy should close socketsiANig{®Gáz„?( RRMR R$RYR9tdestroyRDRER"R)(RR'RSRZR[((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_destroy”s +*   cCsƒ|jtjtjƒ\}}|jdƒtjdƒ|jjddƒtjdƒx$||fD]}|j |j ƒqeWdS(s4Context.destroy should set linger on closing socketsthig{®Gáz„?R^iN( R2R$R`RYR7RDRER:RfR"R)(RR<R;R[((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_destroy_linger¥s   cCs¤|jƒ}|jtjƒ}|j|jƒtd|jƒ}|jƒ|j ddƒ|j |j ƒdƒ|j ƒ|j ddƒ|j|j ƒdƒdS(s Context.term won't close socketsRKRLgš™™™™™¹?sContext should be waitingsContext should have closedN( RR R$R`R@R)RR&RNRQR"tis_aliveR9(RR'R[RU((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_term_noclose°s   csgtrtdƒ‚n‡fd†}td|ƒ}|jƒ|jddƒˆj|jƒdƒdS(s+test close&term by garbage collection alonesGC doesn't work cs$‡fd†}|ƒtjƒdS(Ncs"ˆjƒ}|jtjƒ}dS(N(RR R$tPUSH(R'R[(R(s5lib/python2.7/site-packages/zmq/tests/test_context.pytinnerÄs (tgctcollect(Rm(R(s5lib/python2.7/site-packages/zmq/tests/test_context.pytgcfÃsRKRLis1Garbage collection should have cleaned up contextN(RR RRNRQR@Rj(RRpRU((Rs5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_gc½s cs9dtf‡fd†ƒY‰‡‡fd†}|ƒdS(s6ctx.destroy should succeed when cyclic ref prevents gctCyclicReferencecs#eZdd„Z‡fd†ZRS(cSs ||_dS(N(tparent(RRs((s5lib/python2.7/site-packages/zmq/tests/test_context.pyRÒscs||_ˆ|ƒ|_dS(N(tsocktchild(RRt(Rr(s5lib/python2.7/site-packages/zmq/tests/test_context.pytcrashÕs N(RRR RRv((Rr(s5lib/python2.7/site-packages/zmq/tests/test_context.pyRrÑs csBˆjƒ}|jtjƒ}ˆƒ}|j|ƒ|jƒdS(N(RR R$tPULLRvRf(R'RtR*(RrR(s5lib/python2.7/site-packages/zmq/tests/test_context.pyt crash_zmqÙs    N(tobject(RRx((RrRs5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_cyclic_destroyÎscs±ˆjƒ‰tƒ‰ˆjƒ‡‡‡fd†}td|ƒ}|jƒˆjdƒˆjˆjƒdƒtj dƒˆj ƒ|j ddƒˆj |j ƒdƒdS( s/ctx.term should not crash active threads (#139)csŠˆjtjƒ}|jdƒˆjƒzBy|jƒWn-tjk ri}ˆj|jtj ƒdSXWd|j ƒXˆj dƒdS(Nstcp://127.0.0.1s,recv should have been interrupted with ETERM( R R$RYtbind_to_random_porttsettrecvtZMQErrorR_terrnotETERMR9tfail(R[te(R'tevtR(s5lib/python2.7/site-packages/zmq/tests/test_context.pytblockès    RKissync event never firedg{®Gáz„?RLs%term should have interrupted s.recv()N(RRtclearRRNtwaitR"tis_setRDRER&RQR@Rj(RR„RU((R'RƒRs5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_term_threadâs        cCsa|jƒ}|jtjƒ}|jdƒ|jƒ|jƒ|jsNt‚|js]t‚dS(Nstcp://127.0.0.1( RR R$tPUBR{R9RfR)RO(RR'R[((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_destroy_no_socketsþs    cCs˜tjƒdkr!tdƒ‚n|jƒ}|jtjdƒ|j|jtjƒdƒd|_|j|jdƒ|j|jtjƒdƒdS(Nis context options require libzmq 3iid(i( R$R%R RR|t MAX_SOCKETSR_RPt max_sockets(RR'((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_ctx_optss  cCsÅ|jƒ}tj|ƒ}tj|ƒ}tj|ƒ}|j|jƒ|j|jƒ|j|j|jƒ|j|j|jƒ|j|j|jƒ|jtj ƒ}|j ƒ|j ƒdS(N( RR1tdeepcopyRt_shadowR_t underlyingR R$R‰R9R&(RRRtc2bRR[((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_copys  cCsà|jƒ}|jj|jƒ}|j|j|jƒ|jtjƒ}|jƒ~|j|j ƒ|jtjƒ}|jj|jƒ}|jtjƒ}|jƒ|jƒ|j ƒ|j tj |jtjƒ~dS(N( RtshadowRR_R R$R‰R9R@R)R&R-tEFAULT(RR'tctx2R[ts2((s5lib/python2.7/site-packages/zmq/tests/test_context.pyt test_shadows     c Csßy ddlm}m}m}Wntk r?tdƒ‚nX|jƒ}|j|tjƒ}|j |dƒ|j j |ƒ}|j tj ƒ}|jdƒ|j|dƒ|j|ƒ}|j|dƒ|jƒdS(Niÿÿÿÿ(tzctxtzsockettzstrsRequires pyczmqs inproc://aRh(tpyczmqR˜R™Ršt ExceptionR tnewR$RltbindRt shadow_pyczmqR RwtconnectR7R}R_R9( RR˜R™RšR'RFR•tbtrcvd((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_shadow_pyczmq0s    sNo fork on Windowsc Cs|jjƒ}t|ƒ}tjƒ\}}tj|dƒ}tjƒ}|dkrÉ|jjƒ}tj|dƒ}t|ƒ}|jƒ|jt |ƒdƒ|j ƒ|j ƒtj dƒn tj |ƒ|j ƒ} |j ƒ| søt‚t| ƒ|kst‚|jƒdS(Ntritws (RR?tidtostpipetfdopentforkR&twritetstrtflushR9t_exittreadlineROtint( RR't parent_ctx_idtr_fdtw_fdtreadert child_pidtwritert child_ctx_idt child_id_s((s5lib/python2.7/site-packages/zmq/tests/test_context.pyttest_fork_instanceAs(           (RRRR(R+R,R/R=RBRWRXR\RcRtskipiftsystplatformt startswithRgRiRkRqRzRˆRŠRR’R—R£R¹(((s5lib/python2.7/site-packages/zmq/tests/test_context.pyR#s6              tTestContextGreencBs)eZdZejZejZejZRS(s gevent subclass of context tests(RRt__doc__RRRqRˆRi(((s5lib/python2.7/site-packages/zmq/tests/test_context.pyR¾^s  (R1RnR§R»RDt threadingRRtqueueRt ImportErrortpytestRR$t zmq.testsRRRRRR tSocketR RRRR8R¾(((s5lib/python2.7/site-packages/zmq/tests/test_context.pyts$       .ÿ;