�
_��g� � �v � d dl Z d dlmZ d dlZddlmZmZ G d� d� Ze j fd�Z d� Z
e
� Z y) � N��Lock� )�mmap_key�
MmapedDictc �: � e Zd ZdZdZd� Zd� Zd
d�Zd� Zd� Z d � Z
y) �
MutexValuez A float protected by a mutex.Fc �> � d| _ d | _ t � | _ y �Ng )�_value� _exemplarr �_lock)�self�typ� metric_name�name�
labelnames� labelvalues� help_text�kwargss �G/opt/hc_python/lib/python3.12/site-packages/prometheus_client/values.py�__init__zMutexValue.__init__
s � ��� � ����V��
� c �p � | j 5 | xj |z
c_ d d d � y # 1 sw Y y xY w�N�r r )r �amounts r �inczMutexValue.inc s! � �
�Z�Z� �K�K�6� !�K� �Z�Z�s �,�5Nc �T � | j 5 || _ d d d � y # 1 sw Y y xY wr r )r �value� timestamps r �setzMutexValue.set s � �
�Z�Z� �D�K� �Z�Z�� � �'c �T � | j 5 || _ d d d � y # 1 sw Y y xY wr �r r
�r �exemplars r � set_exemplarzMutexValue.set_exemplar s � �
�Z�Z� %�D�N� �Z�Z�r# c �^ � | j 5 | j cd d d � S # 1 sw Y y xY wr r �r s r �getzMutexValue.get s � �
�Z�Z��;�;� �Z�Z�� � #�,c �^ � | j 5 | j cd d d � S # 1 sw Y y xY wr r% r* s r � get_exemplarzMutexValue.get_exemplar" s � �
�Z�Z��>�>� �Z�Z�r, r ) �__name__�
__module__� __qualname__�__doc__�
_multiprocessr r r" r( r+ r. � r r r r s( � �'��M� �
"� �&� �"r r c �^ � ����� i �g �d � � i�t � � G ���� �fd�d� }|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 �l �� e Zd ZdZdZd ��fd� Z� �fd�Z� ���fd�Z�fd�Zd
�fd� Z d � Z
�fd
�Z d � Z y)�&MultiProcessValue.<locals>.MmapedValuezAA float protected by a mutex backed by a per-process mmaped file.Tc �v �� |||||||f| _ dt j v rPdt j vr>t j d t j d< t j dt
� � 5 | j
� | j � �
j | � d d d � y # 1 sw Y y xY w)N�prometheus_multiproc_dir�PROMETHEUS_MULTIPROC_DIRzpprometheus_multiproc_dir variable has been deprecated in favor of the upper case naming PROMETHEUS_MULTIPROC_DIR) �_params�os�environ�warnings�warn�DeprecationWarning�"_MmapedValue__check_for_pid_change�_MmapedValue__reset�append) r r r r r r r �multiprocess_moder �lock�valuess ��r r z/MultiProcessValue.<locals>.MmapedValue.__init__< s� �� � � �T�:�{�I�Wh�h�D�L�)�R�Z�Z�7�<V�^`�^h�^h�<h�9;���D^�9_��
�
�5�6��
�
� Q� Se� f���+�+�-�� � ���
�
�d�#� ���s �42B/�/B8c � �� | j \ }}}}}}}|dk( r |dz |z }n|}|�
vr^t j j t j j d� dj
|� d � � } t | � �
|< �
| | _ t |||||� | _
| j j | j � \ | _ | _
y )N�gauge�_r: z{}_{}.dbr )r; r< �path�joinr= r+ �formatr �_filer �_key�
read_valuer �
_timestamp) r r r r r r r rD � file_prefix�filename�files�pids ��r �__resetz.MultiProcessValue.<locals>.MmapedValue.__resetG s� �� �\`�\h�\h� Y�C��d�J� �Y�HY��g�~� !�C�i�*;� ;� � !� ��%�'� �7�7�<�<��J�J�N�N�#=�>� �%�%�k�3�w�<�@� B�� &0��%9��k�"� �{�+�D�J� ��d�J� �Y�W�D�I�+/�:�:�+@�+@����+K� (�D�K�� r c �� �� �� }�d |k7 rR|�d< �j � D ] }|j � � �j � �D ] }|j � � y y )Nr )rF �close�clearrB )r �
actual_pid�fr rS rT �process_identifierrF s ����r �__check_for_pid_changez=MultiProcessValue.<locals>.MmapedValue.__check_for_pid_changeW sZ �� �+�-�J��7�|�z�)� )��G� � � � � �A��G�G�I� (�� � �
� #�E��M�M�O� $�
*r c � �� �5 | j � | xj |z
c_ d| _ | j j | j
| j | j � d d d � y # 1 sw Y y xY wr �rA r rP rM � write_valuerN )r r rE s �r r z*MultiProcessValue.<locals>.MmapedValue.incb sS �� ���+�+�-�� � �v�%� �"%����
�
�&�&�t�y�y�$�+�+�t���O� ���s �A(A5�5A>Nc �� �� �5 | j � || _ |xs d| _ | j j | j
| j | j � d d d � y # 1 sw Y y xY wr r^ )r r r! rE s �r r" z*MultiProcessValue.<locals>.MmapedValue.seti sQ �� ���+�+�-� #�� �"+�"2�s����
�
�&�&�t�y�y�$�+�+�t���O� ���s �A A+�+A4c � � y r r4 r& s r r( z3MultiProcessValue.<locals>.MmapedValue.set_exemplarp s � � r c �l �� �5 | j � | j cd d d � S # 1 sw Y y xY wr )rA r )r rE s �r r+ z*MultiProcessValue.<locals>.MmapedValue.gett s# �� ���+�+�-��{�{� ���s � *�3c � � y r r4 r* s r r. z3MultiProcessValue.<locals>.MmapedValue.get_exemplary s � �r )� r )
r/ r0 r1 r2 r3 r rB rA r r" r( r+ r. )rS rE rT r[ rF s �����r � MmapedValuer7 7 s6 �� �O� �
� $� L� $� P� P� � #�
r re r )r[ re rS rE rT rF s ` @@@@r �MultiProcessValuerf ' s; �� �
�E�
�F� �&�(�
)�C� �6�D�D� D�L �r c �j � dt j v sdt j v r
t � S t S )Nr9 r: )r< r= rf r r4 r r �get_value_classrh � s. � �
"�R�Z�Z�/�3M�QS�Q[�Q[�3[� �"�"��r ) r< � threadingr r> � mmap_dictr r r �getpidrf rh �
ValueClassr4 r r �<module>rm s: �� � � � +� "� "�> *,��� V�r� �
�
r