📁 File Manager Pro
v10.0.3 | PHP: 8.1.34
Server: Apache
2026-06-22 08:08:51
📂
/ (Root)
/
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
xray
/
internal
/
__pycache__
📍 /opt/cloudlinux/venv/lib/python3.11/site-packages/xray/internal/__pycache__
🔄 Refresh
✏️
Editing: local_counters.cpython-311.pyc
Read Only
� ݃j � �` � U d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlm Z m Z d dl m Z m Z ej e� � Ze G d� d� � � � Z e� � Ze eef ed< ej � � Zedd ed e eddf fd �� � Zd � Zd� Zdd�Zd� Z d edefd�Z d efd�Z dS )� N)�contextmanager)� dataclass)�Dict� Generator)�request_data_storage�safe_id_patternc �H � e Zd ZU dZej ed< eed< ed� � � Z dS )�TaskCounterStoragezH Typing that has lock and value storage with some syntax sugar. �lock�next_request_idc � � | j dz S )N� )r )�selfs �S/opt/cloudlinux/venv/lib64/python3.11/site-packages/xray/internal/local_counters.py�processed_requestsz%TaskCounterStorage.processed_requests s � ��#�a�'�'� N) �__name__� __module__� __qualname__�__doc__� threading�Lock�__annotations__�int�propertyr � r r r r sU � � � � � � �� � �.�������� �(� (� �X�(� (� (r r �_request_id_storageF� fake_task_id�returnc # � K � t � d| � � t | � � }|j 5 |V � |r+t � d| � � t | |� � ddd� � dS # 1 swxY w Y dS )z� Open local task information storage. @param fake_task_id: unique string, usually obtained as task.fake_id @param flush: whether to save data to file right after update zOpening storage %sz)Updating task %s requests counter in fileN)�logger�debug�_get_or_create_recordr �info�_save_data_to_file)r �flush�storages r �open_local_storager( % s� � � � � �L�L�%�|�4�4�4�#�L�1�1�G� � � 6� 6�� � � � � 6� �K�K�C�\� R� R� R� �|�W� 5� 5� 5� 6� 6� 6� 6� 6� 6� 6� 6� 6� 6� 6� 6���� 6� 6� 6� 6� 6� 6s �2A3�3A7�:A7c � � t � d| � � t 5 | t v rt | = ddd� � dS # 1 swxY w Y dS )zw Remove local storage record. @param fake_task_id: unique string, usually obtained as task.fake_id z#Removing memory storage for task %sN)r! r$ �_global_storage_lockr )r s r �remove_local_storager+ 8 s� � � �K�K�5�|�D�D�D� � 2� 2� �.� .� .�#�L�1�2� 2� 2� 2� 2� 2� 2� 2� 2� 2� 2� 2���� 2� 2� 2� 2� 2� 2s �A�A� Ac �* � t t � � S )�8 List all fake task ids saved in local storage. )�listr r r r � get_task_idsr/ D s � � �#� $� $�$r Tc � � t t � � � � � D ]^}t � d|� � t |� � 5 }t ||� � | rt |= ddd� � n # 1 swxY w Y �_dS )r- zFlushing task id %s on diskN)r. r �keysr! r$ r( r% )�remover r' s r �flush_memory_storager3 K s� � � � 0� 5� 5� 7� 7�8�8� 6� 6� �� � �1�<�@�@�@� � � -� -� 6�� �|�W� 5� 5� 5�� 6�'� �5� 6� 6� 6� 6� 6� 6� 6� 6� 6� 6� 6���� 6� 6� 6� 6��6� 6s �A:�:A> �A> c �H � t j | |t j z d� � S )Ni� )�os�open� O_NOFOLLOW)�path�flagss r �_nofollow_openerr: W s � � �7�4��� �.�� 6� 6�6r r' c �� � | rt j | � � st d| � �� � �t j � t | � � } t |dt �� � 5 }|� t |j � � � � ddd� � dS # 1 swxY w Y dS # t $ r<}|j t j k r!t � d|� � Y d}~dS � d}~ww xY w)z1 Saves storage data from memory to file. zInvalid task_id format: �w��openerN� Refusing to follow symlink: %s)r �match� ValueErrorr5 r8 �joinr r6 r: �write�strr �OSError�errno�ELOOPr! �warning�r r' � req_id_file�f�es r r% r% [ s9 � � � D�� 4�\� B� B� D��B�L�B�B�C�C�C��'�,�,� 3�\�B�B�K�� �+�s�+;� <� <� <� 2�� �G�G�C��/�0�0� 1� 1� 1� 2� 2� 2� 2� 2� 2� 2� 2� 2� 2� 2� 2���� 2� 2� 2� 2� 2� 2�� � � � � �7�e�k� !� !� �N�N�;�[� I� I� I� �F�F�F�F�F� ����� ���sB �B( �&(B� B( �B � B( �"B �#B( �( C.�20C)�(C)�)C.c �� � t 5 | t v�r-t t j � � d�� � t | < t | }t j � t | � � } t |dt �� � 5 }t |� � � � � |_ ddd� � n # 1 swxY w Y n�# t $ r Y n{t $ r t � d| � � Y nUt$ $ r<}|j t& j k r t � d|� � n� Y d}~nd}~ww xY wt | }ddd� � n # 1 swxY w Y |S )zO Takes record from local storage or creates new one and returns object r )r r �rr= Nz8Corrupted counter file for task %s, resetting to defaultr? )r* r r r r r5 r8 rB r r6 r: r �readr �FileNotFoundErrorrA r! rH rE rF rG rI s r r# r# l s � � � 8� 8� � 2� 2� 2�0B� �^�%�%� !�1� 1� 1� � � -� *�,�7�G� �'�,�,�';�\�J�J�K� ��+�s�3C�D�D�D� <��.1�!�&�&�(�(�m�m�G�+�<� <� <� <� <� <� <� <� <� <� <���� <� <� <� <���$� � � ��� � E� E� E���� 6�7C�E� E� E� E� E�� � � ��7�e�k�)�)��N�N�#C�#.�0� 0� 0� 0� �0� 0� 0� 0� 0����� ���� *�,�7�G�38� 8� 8� 8� 8� 8� 8� 8� 8� 8� 8���� 8� 8� 8� 8�4 �Nsx �A'E�0C�'B:�. C�:B> �>C�B> �C�E� D=�E�$D=�6E�8 D=�2D8�3E�8D=�=E�E � E )F)T) rF �loggingr5 r � contextlibr � dataclassesr �typingr r �xray.internal.constantsr r � getLoggerr r! r �dictr rD r r r* r( r+ r/ r3 r: r% r# r r r �<module>rX s� �� � � � � � ���� � � � � � � � � %� %� %� %� %� %� !� !� !� !� !� !� "� "� "� "� "� "� "� "� I� I� I� I� I� I� I� I� �� �8� $� $�� � (� (� (� (� (� (� (� �� (� 6:�T�V�V� �T�#� 1�1�2� ;� ;� ;�%�y�~�'�'� � �6� 6�S� 6�)�DV�X\�^b�Db�:c� 6� 6� 6� � �6�$ 2� 2� 2�%� %� %� 6� 6� 6� 6�7� 7� 7��S� �3E� � � � �" �+=� � � � � � r
💾 Save Changes
❌ Cancel