MhdZddlZddlZddlZddlmZddlmZddlm Z m Z m Z ddl Z edddgZ Gd d e ZGd d ZeZdS) zcGarbage collection thread for representing zmq refcount of Python objects used in zero-copy sends. N) namedtuple)getpid)EventLockThreadgcrefobjeventc(eZdZdZfdZdZxZS)GarbageCollectorThreadz4Thread in which garbage collection actually happens.ct||_d|_t |_t |_dS)NT)super__init__gcdaemonrpidrready)selfr __class__s Q/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/zmq/utils/garbage.pyrzGarbageCollectorThread.__init__sA  88WW ctt|jkr|jdS |jjtj}d|_ | |jj |jn#|jwxYw tt|jkrdS| }|dkrnvt|dkrdnd}tj||d}|jj|d}|r |jr|j~|dS)NrTDIELQ)rrrsetrcontextsocketzmqPULLlingerbindurlrecvlenstructunpackrefspopr close)rsmsgfmtkeytups rrunzGarbageCollectorThread.runsO >VXX11 JNN    F &&sx00AAH FF47;    JNN    DJNN     ~TX!5!5&&((Cf}}SQ##CC-S))!,C',""3--C sy     s AB$$B?)__name__ __module__ __qualname____doc__rr1 __classcell__rs@rr r sM>>rr ceZdZdZdZdZdZdZdfd Ze dZ e j dZ dZ dZ d Zd Ze d Zd Zd ZddZdZxZS)GarbageCollectoraFPyZMQ 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. Nzinproc://pyzmq.gc.01cti|_d|_d|_||_t |_d|_d|_ d|_ tj |j dS)NF)rrr)rthread_contextr_lock _stay_down_push _push_mutexatexitregister_atexit)rrrs rrzGarbageCollector.__init__Nsn    VV   %%%%%rc|jWtjdr ddlm}||_nt j|_|jS)Ngeventr)green)r<rr3 startswithr rFContext)rrFs rrzGarbageCollector.contextZs[ =  ++H55 .%%%%%% %  #  }rc|r5|jrtjdt|||_dS)Nz(Replacing gc context while gc is running)is_aliver)warningswarnRuntimeWarningstopr<)rctxs rrzGarbageCollector.contextfsO ==?? y  > IIKKK rc<d|_|dS)zxatexit callback sets _stay_down flag so that gc doesn't try to start up again in other atexit handlers TN)r>rNrs rrCzGarbageCollector._atexitps  rcZ|sdS|dS)z"stop the garbage-collection threadN)rJ_stoprQs rrNzGarbageCollector.stopxs(}}  F rcpd|_d|_d|_|jd|_dS)zSClear state called after stop or when setting up a new subprocess N)r?r@r;r)clearrrQs r_clearzGarbageCollector._clear~s7     rc|jtj}||j|d||jr|j|j |j | dS)Nr) rrr PUSHconnectr$sendr+r?r;jointermrV)rpushs rrSzGarbageCollector._stops|""38,, TX & :  J        rct|ddrtd|r|jH|jt j|_|j|j |jS)z?The PUSH socket for use in the zmq message destructor callback.r>Fz'zmq gc socket requested during shutdown) getattr RuntimeErrorrJr?rrr rXrYr$rQs r _push_socketzGarbageCollector._push_socketsx 4u - - JHII I}} )$*"4,,SX66DJ J  tx ( ( (zrc4|j+|jtkr|t|_i|_t ||_|j|jjdS)zStart 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;rrrVr)r startrwaitrQs rrczGarbageCollector.starts} ; "tx688';'; KKMMM88 ,T22        rct7t|jks |j|jsdSdS)zsIs the garbage collection thread currently running? Includes checks for process shutdown or fork. NFT)rrr;rJrQs rrJzGarbageCollector.is_alivesD Nxx48##{";''))#5trc |sP|jrdS|j5|s|dddn #1swxYwYt ||}t |}||j|<|S)z4store an object and (optionally) event for zero-copyrN)rJr>r=rcridr))rr r r0theids rstorezGarbageCollector.stores}} ! q ! !}}!JJLLL ! ! ! ! ! ! ! ! ! ! ! ! ! ! !C3 % s)AA!Ac|sdS |dS#t$r}|d}~wwxYwN)rJrN Exception)res r__del__zGarbageCollector.__del__sQ}}  F  IIKKKKK   I s. ?:?rk)r2r3r4r5r)r<r=r$rpropertyrsetterrCrNrVrSrarcrJrirnr6r7s@rr9r9:s-   DH E C & & & & & &  X  ^^      X!!!    rr9)r5rAr'rK collectionsrosr threadingrrrr rr r9rrrrus """"""))))))))))  7UG,--#####V###LXXXXXXXXvr