ó L]c@sÀdZddlZddlZddlmZddlmZddlmZm Z m Z ddl Z ddl Z edddgƒZ d efd „ƒYZd efd „ƒYZeƒZdS( scGarbage collection thread for representing zmq refcount of Python objects used in zero-copy sends. iÿÿÿÿN(tgetpid(t namedtuple(tThreadtEventtLocktgcreftobjteventtGarbageCollectorThreadcBs eZdZd„Zd„ZRS(s4Thread in which garbage collection actually happens.cCsAtt|ƒjƒ||_t|_tƒ|_tƒ|_ dS(N( tsuperRt__init__tgctTruetdaemonRtpidRtready(tselfR ((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR s    cCs?tdkstƒ|jkr/|jjƒdSz8|jjjtj ƒ}d|_ |j |jj ƒWd|jjƒXx¶t r0tdksŸtƒ|jkr£dS|jƒ}|dkr¿Pnt|ƒdkr×dnd}tj||ƒd}|jjj|dƒ}|r*|jr*|jjƒn~q{W|jƒdS(NitDIEitLtQ(RtNoneRRtsetR tcontexttsockettzmqtPULLtlingertbindturlR trecvtlentstructtunpacktrefstpopRtclose(Rtstmsgtfmttkeyttup((s0lib/python2.7/site-packages/zmq/utils/garbage.pytruns*     (t__name__t __module__t__doc__R R)(((s0lib/python2.7/site-packages/zmq/utils/garbage.pyRs tGarbageCollectorcBs¤eZdZd Zd Zd ZdZd d„Ze d„ƒZ e j d„ƒZ d„Z d„Z d„Ze d„ƒZd „Zd „Zd d „Zd „ZRS(sNPyZMQ Garbage Collector Used for representing the reference held by libzmq during zero-copy sends. This object holds a dictionary, keyed by Python id, of the Python objects whose memory are currently in use by zeromq. When zeromq is done with the memory, it sends a message on an inproc PUSH socket containing the packed size_t (32 or 64-bit unsigned int), which is the key in the dict. When the PULL socket in the gc thread receives that message, the reference is popped from the dict, and any tracker events that should be signaled fire. sinproc://pyzmq.gc.01cCsrtt|ƒjƒi|_d|_d|_||_tƒ|_ t |_ d|_ d|_ tj|jƒdS(N(R R-R R!RRtthreadt_contextRt_locktFalset _stay_downt_pusht _push_mutextatexittregistert_atexit(RR((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR Os        cCs\|jdkrUtjjdƒrCddlm}|jƒ|_qUtjƒ|_n|jS(Ntgeventiÿÿÿÿ(tgreen(R/RRR+t startswithRR9tContext(RR9((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR[s cCsB|jƒr5|jr(tjdtƒn|jƒn||_dS(Ns(Replacing gc context while gc is running(tis_aliveR!twarningstwarntRuntimeWarningtstopR/(Rtctx((s0lib/python2.7/site-packages/zmq/utils/garbage.pyRfs    cCst|_|jƒdS(s€atexit callback sets _stay_down flag so that gc doesn't try to start up again in other atexit handlers N(R R2R@(R((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR7ns cCs|jƒsdS|jƒdS(s"stop the garbage-collection threadN(R<t_stop(R((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR@vs cCs›|jjtjƒ}|j|jƒ|jdƒ|jƒ|jr^|jjƒd|_nd|_ |j j ƒ|jj ƒ|jjƒd|_dS(NR(RRRtPUSHtconnectRtsendR#R3RR4R.tjointtermR!tclear(Rtpush((s0lib/python2.7/site-packages/zmq/utils/garbage.pyRB|s         cCsQ|jƒ s|jdkrJ|jjtjƒ|_|jj|jƒn|jS(sHThe PUSH socket for use in the zmq message destructor callback. N( R<R3RRRRRCRDR(R((s0lib/python2.7/site-packages/zmq/utils/garbage.pyt _push_socketŠscCss|jdk r.|jtƒkr.|jƒntƒ|_i|_t|ƒ|_|jjƒ|jjj ƒdS(sÄStart a new garbage collection thread. Creates a new zmq Context used for garbage collection. Under most circumstances, this will only be called once per process. N( R.RRRRBR!RtstartRtwait(R((s0lib/python2.7/site-packages/zmq/utils/garbage.pyRK“s!    cCsEtdks=tƒ|jks=|jdks=|jjƒ rAtStS(s{Is the garbage collection thread currently running? Includes checks for process shutdown or fork. N(RRRR.R<R1R (R((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR<£s  cCsq|jƒsE|jrdS|j|jƒs<|jƒnWdQXnt||ƒ}t|ƒ}||j|<|S(s4store an object and (optionally) event for zero-copyiN(R<R2R0RKRtidR!(RRRR(ttheid((s0lib/python2.7/site-packages/zmq/utils/garbage.pytstore°s      cCs>|jƒsdSy|jƒWntk r9}|‚nXdS(N(R<R@t Exception(Rte((s0lib/python2.7/site-packages/zmq/utils/garbage.pyt__del__Às  N(R*R+R,RR!R/R0RR tpropertyRtsetterR7R@RBRJRKR<RORR(((s0lib/python2.7/site-packages/zmq/utils/garbage.pyR-;s         (R,R5RtosRt collectionsRt threadingRRRR=RRRtobjectR-R (((s0lib/python2.7/site-packages/zmq/utils/garbage.pyts    %