hSrSSKrSSKrSSKrSSKJr SSKJr SSKJ r J r J r SSK r \"SSS/5r "S S \ 5r"S S 5r\"5rg) zcGarbage collection thread for representing zmq refcount of Python objects used in zero-copy sends. N) namedtuple)getpid)EventLockThreadgcrefobjeventc2^\rSrSrSrU4SjrSrSrU=r$)GarbageCollectorThreadz4Thread in which garbage collection actually happens.cx>[TU]5 XlSUl[ 5Ul[ 5Ulg)NT)super__init__gcdaemonrpidrready)selfr __class__s dC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\zmq/utils/garbage.pyrGarbageCollectorThread.__init__s,  8W cH[b[5UR:waURR5 gURR R [R5nSUl URURR5 URR5 [b[5UR:wagUR5nUS:XaO[U5S:XaSOSn[R"X25SnURR R#US5nU(a+UR$(aUR$R5 AMUR'5 g!URR5 f=f)NrDIELQ)rrrsetrcontextsocketzmqPULLlingerbindurlrecvlenstructunpackrefspopr close)rsmsgfmtkeytups rrunGarbageCollectorThread.runs >VX1 JJNN   &&sxx0AAH FF477;;  JJNN ~TXX!5&&(Cf}SQ#CC--)!,C'',,""3-Csyy    JJNN s AFF!)rrrr) __name__ __module__ __qualname____firstlineno____doc__rr3__static_attributes__ __classcell__rs@rr r s>rr c^\rSrSrSrSrSrSrSrSU4Sjjr \ S5r \ RS5r Sr S rS rS r\ S 5rS rSrSSjrSrSrU=r$)GarbageCollector:aPyZMQ 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.01c>[TU]5 0UlSUlSUlXl[ 5UlSUlSUl SUl [R"UR5 g)NF)rrr+rthread_contextr_lock _stay_down_push _push_mutexatexitregister_atexit)rr rs rrGarbageCollector.__init__NsW    V   %rcURce[RRS5(a'SSKJn UR 5UlUR$[R "5UlUR$)Ngeventr)green)rBrr6 startswithr"rMContext)rrMs rr GarbageCollector.contextZsX ==   ++H55% %  }}!$  }}rcUR5(a<UR(a[R"S[5 UR 5 Xlg)Nz(Replacing gc context while gc is running)is_aliver+warningswarnRuntimeWarningstoprB)rctxs rr rPfs5 ==??yy > IIK rc2SUlUR5 g)zhatexit callback sets _stay_down flag so that gc doesn't try to start up again in other atexit handlers TN)rDrVrs rrIGarbageCollector._atexitps  rcPUR5(dgUR5 g)z"stop the garbage-collection threadN)rR_stoprYs rrVGarbageCollector.stopxs}}  rcpSUlSUlSUlURR 5 SUlg)zCClear state called after stop or when setting up a new subprocess N)rErFrAr+clearr rYs r_clearGarbageCollector._clear~s/     rcURR[R5nUR UR 5 UR S5 UR5 UR(aURR5 URR5 URR5 UR5 g)Nr) r r!r"PUSHconnectr&sendr-rErAjointermr`)rpushs rr\GarbageCollector._stops||""388, TXX & :: JJ      rc>[USS5(a [S5eUR5(a URcSURR [ R5UlURRUR5 UR$)z?The PUSH socket for use in the zmq message destructor callback.rDFz'zmq gc socket requested during shutdown) getattr RuntimeErrorrRrEr r!r"rcrdr&rYs r _push_socketGarbageCollector._push_socketsm 4u - -HI I}}$**"4,,SXX6DJ JJ  txx (zzrc6URb(UR[5:waUR5 [5Ul0Ul[ U5UlURR 5 URRR5 g)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) rArrr`r+r startrwaitrYs rrpGarbageCollector.startsh ;; "txx68'; KKM8 ,T2    rc[bD[5UR:wd,URbURR5(dgg)zcIs the garbage collection thread currently running? Includes checks for process shutdown or fork. FT)rrrArRrYs rrRGarbageCollector.is_alives: Nx488#{{";;''))rc2UR5(dLUR(agUR UR5(dUR5 SSS5 [ X5n[ U5nX0R U'U$!,(df  N4=f)z4store an object and (optionally) event for zero-copyrN)rRrDrCrpridr+)rr r r2theids rstoreGarbageCollector.storesg}}}}JJLC3 % s &B BczUR5(dgUR5 g![anUeSnAff=fN)rRrV Exception)res r__del__GarbageCollector.__del__s3}}   IIK I s) :5:) rBrCrErFrDr rr+rAr{)r5r6r7r8r9r+rBrCr&rpropertyr setterrIrVr`r\rmrprRrxr~r:r;r<s@rr>r>:s  DH E C &   ^^  !  rr>)r9rGr)rS collectionsrosr threadingrrrr"rr r>rrrrsY ")) 7UG,-#V#LXXvr