🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-06-15 01:17:50 | PHP 8.1.34
📂
/ (Root)
/
opt
/
cloudlinux
/
venv
/
lib
/
python3.11
/
site-packages
/
clwpos
/
__pycache__
📍 /opt/cloudlinux/venv/lib/python3.11/site-packages/clwpos/__pycache__
🔄 Refresh
✏️
Editing: socket_utils.cpython-311.pyc
Read Only
� rB��w 0�� �0 � d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ ej e � � Z dZ dZ dZdej defd �Zd edefd �Zdej d ed edee fd�Zdej dee fd�Zdej dee fd�Zdej defd�ZdS )� )�absolute_importN)�Optionalz>I� i � sock_object�returnc � � d}| � t j t j t j |� � � � }t j ||� � \ }}}|S )z� Retrieve credentials from SO_PEERCRED option :param sock_object: Socket object :return: uid of user, which connects to this socket. �3I)� getsockopt�socket� SOL_SOCKET� SO_PEERCRED�struct�calcsize�unpack)r �_format_string�creds�_�_uids �py/clwpos/socket_utils.py�get_uid_from_socketr ! sM � � �N� � "� "�6�#4�f�6H�&�/�Zh�Ji�Ji� j� j�E�� �~�u�5�5�J�A�t�Q� �K� � data_dictc � � t j | � � � d� � }t j t t |� � � � |z S )z� Prefix message with a 4-byte length :param data_dict: Data dict for send :return: byte array for send to socket �utf-8)�json�dumps�encoder �pack�_format�len)r � msg_bytess r �pack_data_for_socketr" . s@ � � � �9�%�%�,�,�W�5�5�I� �;�w��I��� /� /�)� ;�;r � num_bytes� timeout_secc � � | � � � }t j � � |z }t � � } t |� � |k r�|t j � � z }|dk r | � |� � dS | � |� � | � |t |� � z � � }|s | � |� � dS ||z }t |� � |k ��n+# t j $ r Y | � |� � dS w xY w| � |� � n# | � |� � w xY w|S )z� Read amount data from socket :param sock_object: Socket object to read data from :param num_bytes: Bytes number to read :param timeout_sec: Read timeout, None - timeout expired, data not received r N) � gettimeout�time� monotonic�bytesr � settimeout�recvr �timeout)r r# r$ � prev_timeout�deadline�msg� remaining�chunks r �$_read_bytes_from_socket_with_timeoutr2 ; sn � � �)�)�+�+�L��~� � �+�-�H� �'�'�C� -��#�h�h��"�"� �4�>�#3�#3�3�I��A�~�~�� � � �|�,�,�,�,�,� � "� "�9� -� -� -� �$�$�Y��S���%9�:�:�E�� �� � � �|�,�,�,�,�,� �5�L�C� �#�h�h��"�"��� �>� � � ��� � �|�,�,�,�,�,����� � � �|�,�,�,�,�� � � �|�,�,�,�,���� �Js5 �/C. �<C. �C. �-D/ �.D�=D/ �D�D/ �/Ec � � t | dt � � }|�dS t j t |� � d }|t k rdS t | |t � � }|�dS t j |� d� � � � S )�� Read length-prefixed amount of data from socket :param sock_object: Socket object to read data :return: Data received from socket dictionary. None - socket data format error � Nr r ) r2 � _WPOS_SOCKET_READ_TIMEOUT_SECr r r � _MAX_MSG_SIZEr �loads�decode�r � raw_msglen�msglenr/ s r �'read_unpack_response_from_socket_daemonr= Z s � � 6�k�1�Fc�d�d�J����t� �]�7�J� /� /�� 2�F� � � � ��t� .�{�F�Da� b� b�C� �{��t� �:�c�j�j��)�)� *� *�*r c � � | � d� � }t j t |� � d }|t k rdS t � � }t |� � |k r+|| � d� � z }t |� � |k �+n# t j $ r Y dS w xY wt j |� d� � � � S )r4 r5 r Ni r ) r+ r r r r7 r) r r r, r r8 r9 r: s r �'read_unpack_response_from_socket_clientr? p s� � � � �%�%�a�(�(� �� �w� �3�3�A�6�� �M� !� !��4��g�g���#�h�h�&� � � �;�#�#�D�)�)� )�C� �#�h�h�&� � ��� �>� � � ��t�t����� �:�c�j�j��)�)� *� *�*s �A B �A B �B$�#B$� connection� data_to_sendc �� � | � � � dk rdS n# t $ r Y dS w xY wt |� � } | � t � � | � |� � n2# t $ r%}t � d|� � Y d}~nd}~ww xY w | � � � dS # t $ r Y dS w xY w# | � � � w # t $ r Y w w xY wxY w)uS Send a dictionary to a socket connection and close it. This is a fire-and-forget terminal send. It never re-raises socket I/O errors to the caller — callers in daemon.py and daemon_subscription_handler.py already treat it that way (no try/except around the call). Delivery failures are logged at WARNING level only; the socket is always closed on the way out (best-effort). The function does still propagate programming errors (e.g., TypeError from a non-serializable dict) so they surface during development instead of being silently swallowed. r Nz-Failed to deliver response to socket peer: %s) �fileno�OSErrorr" r* r6 �sendall�logger�warning�close)r@ rA � bytes_to_send�excs r �(send_dict_to_socket_connection_and_closerK � sR � �,� � � � � �� "� "� �F� #�� � � � �������� )� �6�6�M�� � � � ;�<�<�<����=�)�)�)�)�� � M� M� M� ���F��L�L�L�L�L�L�L�L����� M���� � � � � � � � � ��� � � � �D�D� ����� � � � � � � � ��� � � � �D� ������sq � � +�+�/A. �-C �. B �8B�C �B � C �!B7 �7 C�C�C/� C � C/� C,�)C/�+C,�,C/)� __future__r r �loggingr r r' �typingr � getLogger�__name__rF r r6 r7 �intr �dictr) r" r2 r= r? rK � r r �<module>rT s� �� '� &� &� &� &� &� � � � � ���� � � � � � � � � � � � � � � � � � � �� �8� $� $�� �� !#� � � � �V�]� �s� � � � � <�D� <�U� <� <� <� <� �f�m� �PS� �69� �>F�u�o� � � � �>+�� � +�8�TX�>� +� +� +� +�,+�� � +�8�TX�>� +� +� +� +�,5�� � 5�VZ� 5� 5� 5� 5� 5� 5r
💾 Save Changes
❌ Cancel