Edit File: values.cpython-311.pyc
� m�d� � � � d dl mZ d dlZd dlmZ ddlmZmZ G d� de� � Z ej fd�Z 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)�self�typ� metric_name�name� labelnames� labelvalues�kwargss �i/builddir/build/BUILD/cloudlinux-venv-1.0.2/venv/lib/python3.11/site-packages/prometheus_client/values.py�__init__zMutexValue.__init__ s � ��� ��V�V�� � � � c �f � | j 5 | xj |z c_ d d d � � d S # 1 swxY w Y d S �N�r r )r �amounts r �inczMutexValue.inc s~ � � �Z� "� "� �K�K�6� !�K�K� "� "� "� "� "� "� "� "� "� "� "� "���� "� "� "� "� "� "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� � � �D�K� � � � � � � � � � � � ���� � � � � � 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 � � � i�t � � � G ���� �fd�dt � � }|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� �fd�Z� ���fd�Z�fd�Z�fd�Z �fd �Z d S ) �&MultiProcessValue.<locals>.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__reset�append) r r r r r r �multiprocess_moder �lock�valuess ��r r z/MultiProcessValue.<locals>.MmapedValue.__init__4 s� �� � � �T�:�{�L]�]�D�L�� $� $��+�+�-�-�-�� � ����� � �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 )N�gauge�_�prometheus_multiproc_dirz {0}_{1}.dbr ) r, �os�path�join�environ�formatr �_filer �_key� read_valuer ) r r r r r r r0 � file_prefix�filename�files�pids ��r �__resetz.MultiProcessValue.<locals>.MmapedValue.__reset; s� �� �QU�Q]� N�C��d�J� �=N��g�~�~� !�C�i�*;� ;� � � !� ��%�'�'� �7�<�<��J� 9�:� �'�'� �S��\�B�B� D� D�� &0��%9�%9��k�"� �{�+�D�J� ��d�J� �L�L�D�I� �*�/�/�� �:�:�D�K�K�Kr c �� �� �� � }�d |k r]|�d< �� � � D ]}|� � � ��� � � �D ]}|� � � �d S d S )Nr )r2 �close�clearr. )r � actual_pid�fr rA rB �process_identifierr2 s ����r �__check_for_pid_changez=MultiProcessValue.<locals>.MmapedValue.__check_for_pid_changeK s� �� �+�+�-�-�J��7�|�z�)�)� )��G� � � � � � � � �A��G�G�I�I�I�I�� � � � � � #� $� $�E��M�M�O�O�O�O� *�)� $� $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.<locals>.MmapedValue.incV s� �� �� ?� ?��+�+�-�-�-�� � �v�%� � �� �&�&�t�y�$�+�>�>�>� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?���� ?� ?� ?� ?� ?� ?s �A A�A �"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.<locals>.MmapedValue.set\ s� �� �� ?� ?��+�+�-�-�-� #�� �� �&�&�t�y�$�+�>�>�>� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?���� ?� ?� ?� ?� ?� ?s �AA�A�Ac �r �� �5 | � � � | j cd d d � � S # 1 swxY w Y d S r )r- r )r r1 s �r r z*MultiProcessValue.<locals>.MmapedValue.getb s� �� �� #� #��+�+�-�-�-��{� #� #� #� #� #� #� #� #� #� #� #� #���� #� #� #� #� #� #s �,�0�0N)r* ) r! r" r# r$ r% r r. r- r r r )rA r1 rB rI r2 s �����r � MmapedValuer) / s� �� � � � � �O�O� � � $� $� $� $� $� $� $� ;� ;� ;� ;� ;� ;� $� $� $� $� $� $� $� $� ?� ?� ?� ?� ?� ?� ?� ?� ?� ?� #� #� #� #� #� #� #r rP )r �object)rI rP rA r1 rB r2 s ` @@@@r �MultiProcessValuerR s� ������ � �E� �F� �&�&�(�(� )�C� �6�6�D�6#� 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# � � "�R�Z�/�/� �"�"�"��r )� __future__r r7 � threadingr � mmap_dictr r rQ r �getpidrR rT � ValueClassr& r r �<module>rZ s� �� '� '� '� '� '� '� � � � � � � � � � � +� +� +� +� +� +� +� +� � � � � �� � � �, *,�� H� H� H� H�V� � � �_� � � � � r