MhzddlZddlmZddlZddlmZmZGddZejfdZ dZ e Z dS) NLock)mmap_key MmapedDictc<eZdZdZdZdZdZd dZdZdZ d Z dS) MutexValuezA float protected by a mutex.Fc Hd|_d|_t|_dSNg)_value _exemplarr_lock)selftyp metric_namename labelnames labelvalues help_textkwargss X/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/prometheus_client/values.py__init__zMutexValue.__init__ s VV cf|j5|xj|z c_ddddS#1swxYwYdSNrr )ramounts rinczMutexValue.incs~ Z " " KK6 !KK " " " " " " " " " " " " " " " " " "s &**NcT|j5||_ddddS#1swxYwYdSrr)rvalue timestamps rsetzMutexValue.setsu Z  DK                  !!cT|j5||_ddddS#1swxYwYdSrrr rexemplars r set_exemplarzMutexValue.set_exemplarsu Z & &%DN & & & & & & & & & & & & & & & & & &r#cR|j5|jcdddS#1swxYwYdSrrrs rgetzMutexValue.getss Z  ;                     cR|j5|jcdddS#1swxYwYdSrr%r*s r get_exemplarzMutexValue.get_exemplar"ss Z " "> " " " " " " " " " " " " " " " " " "r,r) __name__ __module__ __qualname____doc__ _multiprocessrrr"r(r+r.rrr r s~''M """    &&&"""""rr crigditGfdd}|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 cneZdZdZdZd fd ZfdZfdZfdZdfd Z d Z fd Z d Z dS)&MultiProcessValue..MmapedValuezAA float protected by a mutex backed by a per-process mmaped file.Tc~|||||||f|_dtjvrGdtjvr9tjdtjd<tjdt  5|| |ddddS#1swxYwYdS)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_moderlockvaluess rrz/MultiProcessValue..MmapedValue.__init__<s  T:{IWhhDL)RZ77B22B69B6c|j\}}}}}}}|dkr |dz|z}n|}| vritjtjdd| d} t|  |< ||_t||||||_ |j |j \|_ |_ dS)Ngauge_r;z{}_{}.dbr )r<r=pathjoinr>r+formatr_filer_key read_valuer _timestamp) rrrrrrrrE file_prefixfilenamefilespids r__resetz.MultiProcessValue..MmapedValue.__resetGs\`\h YCdJ YHYg~~!Ci*;; ! %''7<<JNN#=>>%%k3w<@@BB&0%9%9k"{+DJ dJ YWWDI+/:+@+@+K+K (DKrc}d|kr]|d<D]}|D]}|dSdS)Nr )rGcloseclearrC)r actual_pidfr rTrUprocess_identifierrGs r__check_for_pid_changez=MultiProcessValue..MmapedValue.__check_for_pid_changeWs++--J7|z)))G AGGIIII #$$EMMOOOO*) $$rc5||xj|z c_d|_|j|j|j|jddddS#1swxYwYdSr rBr rQrN write_valuerO)rrrFs rrz*MultiProcessValue..MmapedValue.incbs P P++--- v% "% &&ty$+tOOO  P P P P P P P P P P P P P P P P P PsAA((A,/A,Nc5|||_|pd|_|j|j|j|jddddS#1swxYwYdSr r_)rr r!rFs rr"z*MultiProcessValue..MmapedValue.setis P P++---# "+"2s &&ty$+tOOO  P P P P P P P P P P P P P P P P P PsAA!!A%(A%cdSrr4r&s rr(z3MultiProcessValue..MmapedValue.set_exemplarps Frcr5||jcdddS#1swxYwYdSr)rBr )rrFs rr+z*MultiProcessValue..MmapedValue.getts # #++---{ # # # # # # # # # # # # # # # # # #s ,00cdSrr4r*s rr.z3MultiProcessValue..MmapedValue.get_exemplarys4r)r8r) r/r0r1r2r3rrCrBrr"r(r+r.)rTrFrUr\rGsr MmapedValuer77sOO  $ $ $ $ $ $ $ L L L L L L $ $ $ $ $ $ $ $ P P P P P P P P P P P    # # # # #      rrer)r\rerTrFrUrGs` @@@@rMultiProcessValuerf's E F &&(( )C 66DDDDDDDDDDDDDDDL rcddtjvsdtjvrtStS)Nr:r;)r=r>rfr r4rrget_value_classrhs2 "RZ//3MQSQ[3[3[ """r) r= threadingrr? mmap_dictrrr getpidrfrh ValueClassr4rrrms ++++++++"""""""">*,VVVVr_   r