1j d dl Z d dlZd dlZd dlZdZ ej d j Z ej d j Z ej d j Z
ej d j Z d Z d Z
d dZ G d d e Zd
ZdS ) Ni i dc 4 t | | ||dz < d S )N )_pack_double_funcdataposvalues m/builddir/build/BUILD/cloudlinux-venv-1.0.11/venv/lib/python3.11/site-packages/prometheus_client/mmap_dict.py _pack_doubler
s" )%00DS1W c 4 t | | ||dz < d S )N )_pack_integer_funcr s r
_pack_integerr s" *511DS1Wr c # r K |dk rt | d d }d}||k rt | | d }||z |k rt d |dz
}| |||z }|d|dz dz z
z }||z
}t | | d }| d ||fV |dz
}||k dS dS )1Yield (key, value, pos). No locking is performed.r r z2Read beyond file size detected, file is corrupted.r utf-8N)_unpack_integer RuntimeError_unpack_doubledecode)r usedr
encoded_len encoded_key
padded_lenr s r _read_all_valuesr s qyy tQ''*
C
**%dC003 t # # STT T q3{!223 Aq A(=$=>
z tS))!, ))5#5555 q ******r c T e Zd ZdZd dZed Zd Zd Zd Z d Z
d Z d
Z d S )
MmapedDicta A dict of doubles, backed by an mmapped file.
The file starts with a 4 byte int, indicating how much of it is used.
Then 4 bytes of padding.
There's then a number of entries, consisting of a 4 byte int which is the
size of the next field, a utf-8 encoded string key, padding to a 8 byte
alignment, and then a 8 byte float which is the value.
Not thread safe.
Fc t ||rdnd | _ || _ t j | j j }|dk r&| j t t }|| _ t j
| j | j |r t j n t j | _
i | _ t | j
d d | _ | j dk r$d| _ t# | j
d| j d S |s%| D ]\ }}}|| j |< d S d S )Nrbza+br )accessr )open_f_fnameosfstatfilenost_sizetruncate_INITIAL_MMAP_SIZE _capacitymmap ACCESS_READ ACCESS_WRITE_m
_positionsr _usedr r )selffilename read_modecapacitykey_r
s r __init__zMmapedDict.__init__< sH x!=>> 8DGNN , ,--5 q== G / 0 0 0)H!)DGNN , ,dn7@#W4#3#3dFWY Y Y $TWa003
:??DJ $'1dj 1 1 1 1 1
/#'#8#8#:#: / /KCC+.DOC((
/
// /r c R t | d 5 }| t j }t |d d }|t | k r(|| |t | z
z
}d d d n # 1 swxY w Y t
|| S )Nr" r )r$ readr. PAGESIZEr lenr )r5 infpr r s r read_all_values_from_filez$MmapedDict.read_all_values_from_fileQ s
(D
!
! 4T 99T]++D"4++A.Dc$ii $T"2333
4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 d+++s A1BBBc B | d }|ddt | dz dz z
z z }t j d t | t | |d }| j t | z | j k r| xj dz c_ | j | j t j | j
| j | _ | j t | z | j k || j | j | j t | z < | xj t | z
c_ t | j d| j | j dz
| j
|< d S )
z0Initialize a value. Lock must be held by caller.r r r zi{0}sdg r N)encoder> structpackformatr3 r- r% r+ r. r) r1 r r2 )r4 r8 encodedpaddedr s r _init_valuezMmapedDict._init_value\ sY **W%%DAW )9Q(>$> ?@ HOOCKK 8 8 ? ? A A3w<>>>r c # L K | D ] \ }}}||fV
dS )z,Yield (key, value). No locking is performed.N)r )r4 kvr9 s r read_all_valueszMmapedDict.read_all_valuesq s@ ,,.. GAq!Q$JJJJ r c || j vr| | | j | }t | j | d S )Nr )r2 rJ r r1 )r4 r8 r
s r
read_valuezMmapedDict.read_valuev sF do % % S ! ! !oc" dgs++A..r c || j vr| | | j | }t | j || d S N)r2 rJ r
r1 )r4 r8 r r
s r write_valuezMmapedDict.write_value} sI do % % S ! ! !oc"TWc5)))))r c | j rB| j d | _ | j d | _ d S d S rT )r% r1 closerL s r rW zMmapedDict.close sF 7 GMMOOODG GMMOOODGGG r N)F)
__name__
__module__ __qualname____doc__r: staticmethodr@ rJ r rP rR rU rW r r r r 0 s / / / /* , , \,. . ."? ? ?
/ / /* * * r r c n t t || }t j | ||gd S )z&Format a key for use in the mmap file.T) sort_keys)dictzipjsondumps) metric_namename
labelnames labelvalueslabelss r mmap_keyri s7 #j+..
/
/F :{D&1T B B BBr )r )rb r. r' rE r, StructrF r r unpack_fromr r r
r r objectr ri r] r r rm s
"V]4((- !FM$'', &-%%1 t$$01 1 12 2 2 .Y Y Y Y Y Y Y YxC C C C Cr