Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/amqp/__pycache__/ |
a
��ShN � @ 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 �=/usr/local/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& �
�
:�