Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/amqp/__pycache__/method_framing.cpython-39.pyc
Ðазад
a k�hN � @ s� d Z ddlmZ ddlmZmZmZ ddlmZ ddl m Z ddl m Z ddl mZ d Zeejjejjejjg�Zd Zeefd d �ZG d d� d�Zeeeeeee fdd�Z dS )z5Convert between frames and higher-level AMQP methods.� �� defaultdict)�pack� pack_into� unpack_from� )�spec)�Message)�UnexpectedFrame)� str_to_bytes)� frame_handler� frame_writer�( c s* t dd� ��i �� �����fdd�}|S )z!Create closure that reads frames.c S s dS )Nr � r r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/amqp/method_framing.py�<lambda> � z frame_handler.<locals>.<lambda>c s< | \}}}� j d7 _ |�| dfvr>td�|�| ���n�|dkr��d|d�}|�v rvt||d��|< d�|< dS � |||d � n�|dkrڈ| }|�|� |js�d �|< dS d�|< ��|d � � ||j|j|� n^|d k�r*�| }|� |� |j�sdS d�|< ��|d � � ||j|j|� n|dk�r8dS d S ) Nr � z*Received frame {} while expecting type: {}�>HHr )� frame_method� frame_args� F� T) Z bytes_recvr �formatr Zinbound_header�ready�popr r Z inbound_body)�frameZ frame_type�channel�buf� method_sig�msg��callback� connection�content_methodsZexpected_typesZpartial_messagesr r r �on_frame" sJ �� � z frame_handler.<locals>.on_framer )r# r" r r$ r% r r! r r s 1r c @ s. e Zd Zdd� Zedd� �Zejdd� �ZdS )�Bufferc C s || _ d S �N)r ��selfr r r r �__init__W s zBuffer.__init__c C s | j S r' )�_buf)r) r r r r Z s z Buffer.bufc C s || _ t|�| _d S r' )r+ � memoryview�viewr( r r r r ^ s N)�__name__� __module__� __qualname__r* �propertyr �setterr r r r r& V s r& c s6 |j �tt�jd ��� � �������fdd�} | S )z"Create closure that writes frames.r c s� �j d }d}d }�|�}|r�|j}t|t�rF|j�dd�} |�| �}|�� }�|�} �|�p`d} �|�| | t } | |k} n d\}} } | �rj| dkr�d� �dg|�R � |g�nd}�|�} ��d | | || |d �� |�r�d� �d |d d�|��|g�}�|�} ��d | d || |d �� �d| |�D ]8}|||| � }�|�} ��d | d || |d �� �q,�n |�� j �k�r�t |�� _ � j }| dk�r�d� �dg|�R � |g�nd}�|�} �d | ||| || |d � |d| 7 }|d u�rtd� �d |d d�|��|g�}�|�} �d | ||d || |d � |d| 7 }�|�} | dk�rt| } �d | ||d || |d � |d| 7 }�� j d |� � � j d7 _ d S )Nr r �content_encodingzutf-8)Nr r r r r z>BHI%dsB�� z>HHQr r )� frame_max�body� isinstance�str� properties� setdefault�encodeZ_serialize_properties�FRAME_OVERHEAD�joinr � bytearrayr- Z bytes_sent)�type_r r �args�content� chunk_size�offsetr9 r6 �encodingZbodylenZproperties_lenZframelenZbigbodyr �ir �Z buffer_storer# �lenr r �ranger �writer r � write_frameo s� � � � �� � � � � � � � � z!frame_writer.<locals>.write_frame)rI r& r> r5 ) r# � transportr r rH rG �bytesr Ztext_trJ r rF r r g s Nr N) �__doc__� collectionsr �structr r r � r Z basic_messager � exceptionsr �utilsr �__all__� frozensetZBasic�ReturnZDeliverZGetOkZ_CONTENT_METHODSr< r r& rH rG rL r8 r r r r r �<module> s& � � :�
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0.05 |
proxy
|
phpinfo
|
ÐаÑтройка