f d dl mZ d dlZd dlmZ ddlmZmZ G d de Z ej
fdZ d Z e Z
dS )
)unicode_literalsN)Lock )mmap_key
MmapedDictc . e Zd ZdZdZd Zd Zd Zd ZdS )
MutexValuez A float protected by a mutex.Fc : d| _ t | _ d S )Ng )_valuer _lock)selftyp metric_namename
labelnames labelvalueskwargss j/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/prometheus_client/values.py__init__zMutexValue.__init__ s VV
c f | j 5 | xj |z
c_ d d d d S # 1 swxY w Y d S Nr r )r
amounts r inczMutexValue.inc s~
Z " " KK6 !KK " " " " " " " " " " " " " " " " " "s &**c T | j 5 || _ d d d d S # 1 swxY w Y d S r r )r
values r setzMutexValue.set su
Z DK s !!c R | j 5 | j cd d d S # 1 swxY w Y d S r r )r
s r getzMutexValue.get ss
Z ; s N) __name__
__module__ __qualname____doc__
_multiprocessr r r r r r r r s[ ''M " " " r r c ~ i g d it G fddt }|S )a8 Returns 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 c ` e Zd ZdZdZd fd Z fdZ fdZfdZfdZ fd Z
d
S ) &MultiProcessValue..MmapedValuezAA float protected by a mutex backed by a per-process mmaped file.T c ||||||f| _ 5 | | | d d d d S # 1 swxY w Y d S r )_params"_MmapedValue__check_for_pid_change_MmapedValue__resetappend)
r
r r r r r multiprocess_moder lockvaluess
r r z/MultiProcessValue..MmapedValue.__init__4 s T:{L]]DL
$
$++---
d###
$
$
$
$
$
$
$
$
$
$
$
$
$
$
$
$
$
$s >A A #A c | j \ }}}}}}|dk r |dz |z }n|}| vr\t j t j d d |
d }t
| |< | | _ t |||| | _ | j
| j | _ d S )Ngauge_prometheus_multiproc_dirz
{0}_{1}.dbr ) r, ospathjoinenvironformatr _filer _key
read_valuer ) r
r r r r r r0 file_prefixfilenamefilespids r __resetz.MultiProcessValue..MmapedValue.__reset; s QUQ] NCdJ =Ng~~ !Ci*; ; ! %'' 7<<J 9: '' S\BB D D &0%9%9k" {+DJ dJ LLDI *// ::DKKKr c }d |k r]|d< D ]}| D ]}| d S d S )Nr )r2 closeclearr. )r
actual_pidfr rA rB process_identifierr2 s r __check_for_pid_changez=MultiProcessValue..MmapedValue.__check_for_pid_changeK s ++--J7|z)) )G AGGIIII
# $ $EMMOOOO *) $ $r c 5 | | xj |z
c_ | j | j | j d d d d S # 1 swxY w Y d S r r- r r< write_valuer= )r
r r1 s r r z*MultiProcessValue..MmapedValue.incV s
?
?++--- v%
&&ty$+>>>
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?s A
AA "A c 5 | || _ | j | j | j d d d d S # 1 swxY w Y d S r rL )r
r r1 s r r z*MultiProcessValue..MmapedValue.set\ s
?
?++--- #
&&ty$+>>>
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?s AAAAc r 5 | | j cd d d S # 1 swxY w Y d S r )r- r )r
r1 s r r z*MultiProcessValue..MmapedValue.getb s
#
#++---{
#
#
#
#
#
#
#
#
#
#
#
#
#
#
#
#
#
#s ,00N)r* ) r! r" r# r$ r% r r. r- r r r )rA r1 rB rI r2 s r MmapedValuer) / s OO
$ $ $ $ $ $ $ ; ; ; ; ; ; $ $ $ $ $ $ $ $ ? ? ? ? ? ? ? ? ? ? # # # # # # #r rP )r object)rI rP rA r1 rB r2 s ` @@@@r MultiProcessValuerR s
E
F &&((
)C 66D6# 6# 6# 6# 6# 6# 6# 6# 6# 6# 6#f 6# 6# 6#p r c H dt j v rt S t S )Nr6 )r7 r: rR r r& r r get_value_classrT j s#
"RZ// """r )
__future__r r7 threadingr mmap_dictr r rQ r getpidrR rT
ValueClassr& r r rZ s ' ' ' ' ' ' + + + + + + + + , *, H H H HV _
r