ó L]c@svddlZddlZddlmZddlmZyddlmZWn!ek roddlmZnXddl m Z ddl Z ddl m Z y&ddlZddl mZeZWnek rÛeZnXdejkZd „Ze jed d ƒZe je jƒdkd d ƒZdefd„ƒYZdefd„ƒYZddd„ƒYZd„ZdS(iÿÿÿÿN(tThread(tTestCase(tSkipTest(tmark(tjsonapi(tgreentPyPycCs|S(N((tx((s1lib/python2.7/site-packages/zmq/tests/__init__.pyt ttreasonsDoesn't work on PyPyisrequires zmq >= 4tBaseZMQTestCasecBs•eZeZdZed„ƒZd„Zd„Zd„Z e j e j dd„Z d„Z d„Zd „Zd „Zd „Zd „Zd „ZRS(i cCs|jrtjStjSdS(N(RtgzmqtContexttzmq(tself((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR -s cCs&|jj|ƒ}|jj|ƒ|S(N(tcontexttsockettsocketstappend(Rt socket_typets((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR4scCsQtt|ƒjƒ|jr2t r2tdƒ‚n|jjƒ|_g|_ dS(Nsrequires gevent( tsuperR tsetUpRt have_geventRR tinstanceRR(R((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR9s cCsÛt|jgƒ}x9|jrM|jjƒ}|j|jƒ|jdƒqWxs|D]k}td|jƒ}t|_ |j ƒ|j d|j ƒ|j ƒrUdtjjj_tdƒ‚qUqUWtt|ƒjƒdS(Nittargetttimeouts?context could not terminate, open sockets likely remain in test(tsetRRtpoptaddtcloseRttermtTruetdaemontstarttjointteardown_timeouttis_alivetNoneRtsugarR t _instancet RuntimeErrorRR ttearDown(Rtcontextstsocktctxtt((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR+@s     stcp://127.0.0.1cCs|jj|ƒ}|jtjdƒ|j|ƒ}|jj|ƒ}|jtjdƒ|jd||fƒ|jj||gƒ||fS(s/Create a bound socket pair using a random port.is%s:%s( RRt setsockoptRtLINGERtbind_to_random_porttconnectRtextend(Rttype1ttype2t interfacets1tportts2((s1lib/python2.7/site-packages/zmq/tests/__init__.pytcreate_bound_pairQscCs6|j|ƒ|jƒ}|j|ƒ|jƒ}|S(N(tsendtrecv(RR8R:tmsgtmsg2tmsg3((s1lib/python2.7/site-packages/zmq/tests/__init__.pyt ping_pong\s     cCsTtjdkrtdƒ‚n|j|ƒ|jƒ}|j|ƒ|jƒ}|S(NsNo json library(RtjsonmodR'Rt send_jsont recv_json(RR8R:toto2to3((s1lib/python2.7/site-packages/zmq/tests/__init__.pytping_pong_jsoncs    cCs6|j|ƒ|jƒ}|j|ƒ|jƒ}|S(N(t send_pyobjt recv_pyobj(RR8R:RERFRG((s1lib/python2.7/site-packages/zmq/tests/__init__.pytping_pong_pyobjls     cOspy|||ŽWnKtjk r^}|j|j|dtj|ƒtj|jƒfƒnX|jdƒdS(Ns*wrong error raised, expected '%s' got '%s's Function did not raise any error(RtZMQErrort assertEqualterrnotfail(RRNtfunctargstkwargste((s1lib/python2.7/site-packages/zmq/tests/__init__.pytassertRaisesErrnoss *cKs²tjƒd kr"tjdƒntj|gggd|jddƒƒ\}}}t|ƒdksstdƒ‚tj|j ddƒB|d<|rŸ|j n|j }||S( sIcall recv[_multipart] in a way that raises if there is nothing to receiveiiigš™™™™™¹?RisShould have received a messagetflags(iii( Rtzmq_version_infottimetsleeptselectRtlentAssertionErrortDONTWAITtgettrecv_multipartR=(Rt multipartRRRtrtwRR=((s1lib/python2.7/site-packages/zmq/tests/__init__.pyt _select_recv|s3cKs|jt||S(s=call recv in a way that raises if there is nothing to receive(RbtFalse(RRRR((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR=‹scKs|jt||S(sGcall recv_multipart in a way that raises if there is nothing to receive(RbR!(RRRR((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR^s(t__name__t __module__RcRR%tpropertyR RRR+RtPAIRR;RARHRKRTRbR=R^(((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR )s       tPollZMQTestCasecBseZRS((RdRe(((s1lib/python2.7/site-packages/zmq/tests/__init__.pyRh”st GreenTestcBs5eZdZeZdZd„Zd„Zd„ZRS(s/Mixin for making green versions of test classesi cOsœ|tjkrtdƒ‚ny|||ŽWnYtjk rŠtjƒd}|j|j|dtj|ƒtj|jƒfƒnX|jdƒdS(NsSkipping because we're green.is*wrong error raised, expected '%s' got '%s's Function did not raise any error( RtEAGAINRRLtsystexc_infoRMRNRO(RRNRPRQRRRS((s1lib/python2.7/site-packages/zmq/tests/__init__.pyRTœs*cCs±t|jgƒ}x6|jrJ|jjƒ}|j|jƒ|jƒqWy?tjg|D]}tj|j ƒ^q[d|j dt ƒWn tj k r¬t dƒ‚nXdS(NRt raise_errors?context could not terminate, open sockets likely remain in test(RRRRRRtgeventtjoinalltspawnR R%R!tTimeoutR*(RR,R-R.((s1lib/python2.7/site-packages/zmq/tests/__init__.pyR+¨s %  cCstdƒ‚dS(NsSkipping because we are green(R(R((s1lib/python2.7/site-packages/zmq/tests/__init__.pyt skip_green·s( RdRet__doc__R!RR%RTR+Rr(((s1lib/python2.7/site-packages/zmq/tests/__init__.pyRi—s  cs‡fd†}|S(Ncs,|jrtdƒ‚nˆ|||ŽSdS(NsSkipping because we are green(RR(RRQRR(tf(s1lib/python2.7/site-packages/zmq/tests/__init__.pyt skipping_test»s ((RtRu((Rts1lib/python2.7/site-packages/zmq/tests/__init__.pyRrºs(i((RkRWt threadingRtunittestRRt ImportErrort unittest2tpytestRRt zmq.utilsRRnRR R!RRctversiontPYPYt_idtskipift skip_pypyRVt require_zmq_4R RhRiRr(((s1lib/python2.7/site-packages/zmq/tests/__init__.pyts0         !k#