File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/transport/__pycache__/frame.cpython-310.pyc
Back
o ;j� � @ sD d Z ddlZddlZddd�Zddd�Zdd � Zd d � Zd d � ZdS )zE Helper functions for transport components to handle message framing � NFc C s. i }|du ri }||d< | |d< t jj�|�S )z8 Frame the given message with our wire protocol N�head�body)�salt�utils�msgpack�dumps)r �header�raw_body� framed_msg� r �H/opt/saltstack/salt/lib/python3.10/site-packages/salt/transport/frame.py� frame_msg s r c C sF i }|du ri }||d< | |d< t jjj|dd�}t�dt|��| S )a� Frame the given message with our wire protocol for IPC. Prefixes the msgpack payload with a 4-byte big-endian length so the receiver can read exactly the right number of bytes per message. This prevents msgpack stream corruption when concurrent large writes exceed the Unix socket PIPE_BUF atomic-write boundary (~65 536 bytes on Linux), which caused interleaved bytes and UnicodeDecodeError / ExtraData crashes in subscribers such as EventReturn under high event-bus load. Nr r T)Z use_bin_typez>I)r r r r �struct�pack�len)r r r r �payloadr r r � frame_msg_ipc s r c C sn g }| D ]0}t |t�rt|�}n t |t�rt|�}nt |t�r/z|�� }W n ty. Y nw |�|� q|S )zI Convert enbedded bytes to strings if possible. List helper. ) � isinstance�dict�_decode_embedded_dict�list�_decode_embedded_list�bytes�decode� UnicodeError�append)�src�output�elemr r r r , s � r c C s� i }| � � D ]F\}}t|t�rt|�}n t|t�r t|�}nt|t�r3z|�� }W n ty2 Y nw t|t�rHz|�� }W n tyG Y nw |||< q|S )zI Convert enbedded bytes to strings if possible. Dict helper. ) �itemsr r r r r r r r )r r �key�valr r r r @ s( � � r c C sT t | t�r t| �S t | t�rt| �S t | t�r(z| �� W S ty' | Y S w | S )a� Convert enbedded bytes to strings if possible. This is necessary because Python 3 makes a distinction between these types. This wouldn't be needed if we used "use_bin_type=True" when encoding and "encoding='utf-8'" when decoding. Unfortunately, this would break backwards compatibility due to a change in wire protocol, so this less than ideal solution is used instead. )r r r r r r r r )r r r r �decode_embedded_strsY s �r" )NF) �__doc__r Zsalt.utils.msgpackr r r r r r" r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings