← Back
Editing: values.cpython-312.pyc
� ���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
Save File
Cancel