ó L]c@sèdZddlZddlZddlmZddlZddlmZddl m Z ddl m Z ddl m Z mZmZdd lmZdd lmZead „Zejeƒd ee fd „ƒYZd gZdS(sPython bindings for 0MQ.iÿÿÿÿN(tLock(tContexti(t constants(tAttributeSetter(tENOTSUPtLINGERt ctx_opt_names(tSocket(tZMQErrorcCs tadS(N(tTruet_exiting(((s0lib/python2.7/site-packages/zmq/sugar/context.pyt_notice_atexitsRcBs eZdZdZdZeƒZdZe Z dZ dd„Z d„Z d„Zd„Zdd„ZeZed„ƒZed„ƒZedd „ƒZd „Zd „Zd „Zdd „Zed„ƒZd„Zd„Zd„Zd„Zd„Z d„Z!RS(s[Create a zmq Context A zmq Context creates sockets via its ``ctx.socket`` method. icKs\tt|ƒjd|||jdtƒr:t|_n t|_i|_tƒ|_ dS(Nt io_threadstshadow( tsuperRt__init__tgettFalseR t_shadowtsockoptstsett_sockets(tselfR tkwargs((s0lib/python2.7/site-packages/zmq/sugar/context.pyR&s    cCs"|j rt r|jƒndS(sMdeleting a Context should terminate it, without trying non-threadsafe destroyN(RR tterm(R((s0lib/python2.7/site-packages/zmq/sugar/context.pyt__del__/scCs|S(N((R((s0lib/python2.7/site-packages/zmq/sugar/context.pyt __enter__4scOs|jƒdS(N(R(RtargsR((s0lib/python2.7/site-packages/zmq/sugar/context.pyt__exit__7scCs|jj|jƒS(s'Copying a Context creates a shadow copy(t __class__R t underlying(Rtmemo((s0lib/python2.7/site-packages/zmq/sugar/context.pyt__copy__:scCs)ddlm}||ƒ}|d|ƒS(s¹Shadow an existing libzmq context address is the integer address of the libzmq context or an FFI pointer to it. .. versionadded:: 14.1 iÿÿÿÿ(t cast_int_addrR (tzmq.utils.interopR!(tclstaddressR!((s0lib/python2.7/site-packages/zmq/sugar/context.pyR @s  cCsHddlm}ddlm}|j|ƒ}||ƒ}|d|ƒS(s…Shadow an existing pyczmq context ctx is the FFI `zctx_t *` pointer .. versionadded:: 14.1 iÿÿÿÿ(tzctx(R!R (tpyczmqR%R"R!R(R#tctxR%R!RR$((s0lib/python2.7/site-packages/zmq/sugar/context.pyt shadow_pyczmqMs  cCsž|jdks0|jtjƒks0|jjr—|jY|jdksj|jtjƒksj|jjrŽ|d|ƒ|_tjƒ|_nWdQXn|jS(sReturns a global Context instance. Most single-threaded applications have a single, global Context. Use this method instead of passing around Context instances throughout your code. A common pattern for classes that depend on Contexts is to use a default argument to enable programs with multiple Contexts but not require the argument for simpler applications:: class MyClass(object): def __init__(self, context=None): self.context = context or Context.instance() .. versionchanged:: 18.1 When called in a subprocess after forking, a new global instance is created instead of inheriting a Context that won't work from the parent process. R N(t _instancetNonet _instance_pidtostgetpidtclosedt_instance_lock(R#R ((s0lib/python2.7/site-packages/zmq/sugar/context.pytinstance]s   cCs4t|jƒ}xtfD]}|j|ƒqW|S(N(tdirRRtextend(Rtkeyst collection((s0lib/python2.7/site-packages/zmq/sugar/context.pyt__dir__†s  cCs#tj|ƒ}|jj|ƒ|S(N(tweakreftrefRtadd(RtsocketR7((s0lib/python2.7/site-packages/zmq/sugar/context.pyt _add_socket“scCs5tj|ƒ}||jkr1|jj|ƒndS(N(R6R7Rtremove(RR9R7((s0lib/python2.7/site-packages/zmq/sugar/context.pyt _rm_socket˜scCs†|jr dS|j}tƒ|_xS|D]K}|ƒ}|r)|j r)|dk rg|jt|ƒn|jƒq)q)W|jƒdS(sªClose all sockets associated with this context and then terminate the context. .. warning:: destroy involves calling ``zmq_close()``, which is **NOT** threadsafe. If there are active sockets in other threads, this must not be called. Parameters ---------- linger : int, optional If specified, set LINGER on sockets prior to closing them. N(R.RRR*t setsockoptRtcloseR(Rtlingertsocketsts((s0lib/python2.7/site-packages/zmq/sugar/context.pytdestroys      cCstS(N(R(R((s0lib/python2.7/site-packages/zmq/sugar/context.pyt _socket_classºscKs†|jrttƒ‚n|j|||}xE|jjƒD]4\}}y|j||ƒWq=tk rpq=Xq=W|j|ƒ|S(s]Create a Socket associated with this Context. Parameters ---------- socket_type : int The socket type, which can be any of the 0MQ socket types: REQ, REP, PUB, SUB, PAIR, DEALER, ROUTER, PULL, PUSH, etc. kwargs: will be passed to the __init__ method of the socket class. (R.RRRCRtitemsR=R:(Rt socket_typeRRAtopttvalue((s0lib/python2.7/site-packages/zmq/sugar/context.pyR9¾s   cCs||j|s     ê