관리-도구
편집 파일: mmap_dict.cpython-311.pyc
� �܋f� � � � 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 d�Z G d� d e� � Zd � ZdS ) � Ni � i� dc �4 � t |� � | ||dz �< d S )N� )�_pack_double_func��data�pos�values �l/builddir/build/BUILD/cloudlinux-venv-1.0.6/venv/lib/python3.11/site-packages/prometheus_client/mmap_dict.py� _pack_doubler s" � �)�%�0�0�D��S�1�W����� c �4 � t |� � | ||dz �< d S )N� )�_pack_integer_funcr s r � _pack_integerr s" � �*�5�1�1�D��S�1�W����r c # �r K � |dk rt | d� � d }d}||k r�t | |� � 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_double�decode)r �usedr � encoded_len� encoded_key� padded_lenr s r �_read_all_valuesr s� � � � � �q�y�y� �t�Q�'�'��*�� �C� ��*�*�%�d�C�0�0��3� � �� �t� #� #� � S�T�T� T� �q����3��{�!2�2�3� � �A��q� �A�(=�$=�>� � �z��� �t�S�)�)�!�,��� � ��)�)�5�#�5�5�5�5� �q��� ��*�*�*�*�*�*r c �T � e Zd ZdZd d�Zed� � � 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 )N�rbza+br )�accessr )�open�_f�_fname�os�fstat�fileno�st_size�truncate�_INITIAL_MMAP_SIZE� _capacity�mmap� ACCESS_READ� ACCESS_WRITE�_m� _positionsr �_usedr r )�self�filename� read_mode�capacity�key�_r s r �__init__zMmapedDict.__init__< sH � ��x��!=����>�>��� �� ��8�D�G�N�N� ,� ,�-�-�5�� �q�=�=� �G� � � /� 0� 0� 0�)�H�!����)�D�G�N�N� ,� ,�d�n�7@�#W�4�#3�#3�d�FW�Y� Y� Y��� ���$�T�W�a�0�0��3�� � �:��?�?��D�J� �$�'�1�d�j� 1� 1� 1� 1� 1� � /�#'�#8�#8�#:�#:� /� /�K�C��C�+.�D�O�C�(�(� /� /�/� /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� !� !� 4�T� �9�9�T�]�+�+�D�"�4��+�+�A�.�D��c�$�i�i� � ��� � �$��T���"2�3�3�3�� 4� 4� 4� 4� 4� 4� 4� 4� 4� 4� 4���� 4� 4� 4� 4� ��d�+�+�+s �A1B�B�Bc �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> �struct�pack�formatr3 r- r% r+ r. r) r1 r r2 )r4 r8 �encoded�paddedr s r � _init_valuezMmapedDict._init_value\ sY � ��*�*�W�%�%���D�A��W� � ��)9�Q�(>�$>� ?�@��� �H�O�O�C��K�K� 8� 8� ?� ?� A� A�3�w�<�<�QW�Y\�]�]���j�3�u�:�:�%���6�6� �N�N�a� �N�N� �G� � �T�^� ,� ,� ,��i����� 0� 0�$�.�A�A�D�G� �j�3�u�:�:�%���6�6� 7<���� �4�:��E� � �2�2�3� � � �c�%�j�j� � � ��d�g�q�$�*�-�-�-� #�z�A�~���� � � r c �8 � t | j | j �� � S )r )r r )r r1 r3 �r4 s r r zMmapedDict._read_all_valuesm s � � �T�W�4�:�>�>�>�>r c # �L K � | � � � D ] \ }}}||fV � � dS )z,Yield (key, value). No locking is performed.N)r )r4 �k�vr9 s r �read_all_valueszMmapedDict.read_all_valuesq s@ � � � ��,�,�.�.� � �G�A�q�!��Q�$�J�J�J�J� � r c � � || j vr| � |� � | j | }t | j |� � d S )Nr )r2 rJ r r1 )r4 r8 r s r � read_valuezMmapedDict.read_valuev sF � � �d�o� %� %� � � �S� !� !� !��o�c�"�� �d�g�s�+�+�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 � � �d�o� %� %� � � �S� !� !� !��o�c�"���T�W�c�5�)�)�)�)�)r c � � | j rB| j � � � d | _ | j � � � d | _ d S d S rT )r% r1 �closerL s r rW zMmapedDict.close� sF � � �7� � �G�M�M�O�O�O��D�G� �G�M�M�O�O�O��D�G�G�G� � 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)�dict�zip�json�dumps)� metric_name�name� labelnames� labelvalues�labelss r �mmap_keyri � s7 � � �#�j�+�.�.� /� /�F� �:�{�D�&�1�T� B� B� B�Br )r )rb r. r' rE r, �StructrF r r � unpack_fromr r r r r �objectr ri r] r r �<module>rm s �� � � � � � � � � � � � � � � � � � �"�V�]�4�(�(�-� �!�F�M�$�'�'�,� � �&�-��%�%�1�� �� �t�$�$�0��1� 1� 1�2� 2� 2�� � � �.Y� Y� Y� Y� Y�� Y� Y� Y�xC� C� C� C� Cr