:vjUddlZddlmZddlmZmZddlZddlmZm Z gZ eegdfe d<dZ Gdd Z ejfd Zd ZeZy) N)Lock)CallableList)mmap_key MmapedDict_multi_process_cleanupscPtD] }| tjyN)r clear)cleanups i/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/prometheus_client/values.pyclose_all_multiprocess_filesr s* +!!#c:eZdZdZdZdZdZd dZdZdZ d Z y) MutexValuezA float protected by a mutex.Fc >d|_d|_t|_yNg)_value _exemplarr_lock)selftyp metric_namename labelnames labelvalues help_textkwargss r__init__zMutexValue.__init__s V rcp|j5|xj|z c_dddy#1swYyxYwr rr)ramounts rinczMutexValue.incs! ZZ KK6 !KZZs,5NcT|j5||_dddy#1swYyxYwr r")rvalue timestamps rsetzMutexValue.sets ZZDKZZ'cT|j5||_dddy#1swYyxYwr rrrexemplars r set_exemplarzMutexValue.set_exemplar#s ZZ%DNZZr)c^|j5|jcdddS#1swYyxYwr r"rs rgetzMutexValue.get's ZZ;;ZZ #,c^|j5|jcdddS#1swYyxYwr r+r0s r get_exemplarzMutexValue.get_exemplar+s ZZ>>ZZr2r ) __name__ __module__ __qualname____doc__ _multiprocessr r$r(r.r1r4rrrrs('M " &"rrcigditfd}tj|Gfdd}|S)a8Returns a MmapedValue class based on a process_identifier function. The 'process_identifier' function MUST comply with this simple rule: when called in simultaneously running processes it MUST return distinct values. Using a different function than the default 'os.getpid' is at your own risk. r&cjD]}|jjjyr valuescloser )ffilesr>s rr z"MultiProcessValue..cleanup@s.A GGI   rceZdZdZdZd fd ZfdZfdZfdZdfd Z d Z fd Z d Z e fd Zy)&MultiProcessValue..MmapedValuezAA float protected by a mutex backed by a per-process mmaped file.Tcv|||||||f|_dtjvrPdtjvr>tjdtjd<tjdt  5|j |j j|dddy#1swYyxYw)Nprometheus_multiproc_dirPROMETHEUS_MULTIPROC_DIRzpprometheus_multiproc_dir variable has been deprecated in favor of the upper case naming PROMETHEUS_MULTIPROC_DIR) _paramsosenvironwarningswarnDeprecationWarning"_MmapedValue__check_for_pid_change_MmapedValue__resetappend) rrrrrrrmultiprocess_moderlockr>s rr z/MultiProcessValue..MmapedValue.__init__Ls T:{IWhhDL)RZZ7.MmapedValue.__resetWs\`\h\h YCdJ YHYg~!Ci*;; ! %'77<<JJNN#=>%%k3w<@B&0%9k"{+DJ dJ YWDI+/::+@+@+K (DKrc}d|k7rR|d<jD]}|jjD]}|jyy)Nr&)r>r?r rN)r actual_pidr@r&rAr^process_identifierr>s r__check_for_pid_changez=MultiProcessValue..MmapedValue.__check_for_pid_changegsZ+-J7|z))G AGGI( #EMMO$ *rc5|j|xj|z c_d|_|jj |j |j|jdddy#1swYyxYwrrMrr[rX write_valuerY)rr#rQs rr$z*MultiProcessValue..MmapedValue.incrsS++- v% "% &&tyy$++tO s A(A55A>Nc5|j||_|xsd|_|jj |j |j|jdddy#1swYyxYwrre)rr&r'rQs rr(z*MultiProcessValue..MmapedValue.setysQ++-# "+"2s &&tyy$++tO s AA++A4cyr r:r,s rr.z3MultiProcessValue..MmapedValue.set_exemplars rcl5|j|jcdddS#1swYyxYwr )rMr)rrQs rr1z*MultiProcessValue..MmapedValue.gets#++-{{s*3cyr r:r0s rr4z3MultiProcessValue..MmapedValue.get_exemplarsrc5jD]}|jjjdddy#1swYyxYwr r=)clsr@rArQr>s rclose_all_filesz6MultiProcessValue..MmapedValue.close_all_filess;AGGI(   s AAA)r )r5r6r7r8r9r rNrMr$r(r.r1r4 classmethodrm)rArQr^rbr>sr MmapedValuerCGsJO  $ L $ P P  #      rrp)rr rO)rbr rprArQr^r>s` @@@@rMultiProcessValuerq0sP E F &( )C 6D ""7+LL\ rcjdtjvsdtjvr tStS)NrErF)rHrIrqrr:rrget_value_classrss. "RZZ/3MQSQ[Q[3[ ""r)rH threadingrtypingrrrJ mmap_dictrrr __annotations__rrgetpidrqrs ValueClassr:rrrzs[ !+46hr4x016$ "">*,eP  r