Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/amqp/__pycache__/serialization.cpython-39.pyc
Ðазад
a k�h C � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZm Z ddl m Z dd l m Z dd lmZ dd lmZ d Zd ZdZdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Z e j e iZ G d d � d �Z dS )!zeConvert between bytestreams and higher-level AMQP types. 2007-11-05 Barry Pederson <bp@barryp.org> � N)�datetime)�Decimal)�BytesIO)�pack� unpack_from� )�FrameSyntaxError)�Basic)� bytes_to_str)� str_to_bytesz* Table type {0!r} not handled by amqp. zCTable type {0!r} for key {1!r} not handled by amqp. [value: {2!r}] z9 Table type {0!r} not handled by amqp. [value: {1!r}] c C s� t | | �}|d7 }|dkrztd| |�\}|d7 }zt| ||| � �}W n" tyl | ||| � }Y n0 ||7 }�n||dkr�td| |�\}|d7 }t| ||| � �}||7 }�n>|dkr�td| |�\}|d7 }| ||| � }||7 }�n|dk�rtd| |�\}|d7 }�n�|d k�r:td | |�\}|d7 }�n�|d k�r^td | |�\}|d 7 }�n�|dk�r�td| |�\}|d 7 }�nt|dk�r�td| |�\}|d7 }�nP|dk�r�td| |�\}|d7 }�n,|dk�r�td| |�\}|d7 }�n|dk�rtd| |�\}|d7 }�n�|dk�r6td| |�\}|d7 }�n�|dk�rZtd| |�\}|d7 }�n�|d k�r�td| |�\}|d7 }td| |�\}|d7 }t|�td | � }�nN|d k�r(td| |�\}|d7 }|| } i }|| k �r�td| |�\} |d7 }t| ||| � �} || 7 }t| |�\|| < }�q�n�|d k�r|td| |�\} |d7 }|| } g }|| k �r�t| |�\} }|�| � �qTnz|d k�r�td| |�\}t|�}|d7 }nP|d!k�r�td| |�\}|d7 }t� |�}n$|d"k�r�d }nt d#� |t |����||fS )$Nr �S�>I� �s�>B�x�b�Bz>b�Uz>h� �u�>H�Iz>i�i�Lz>q� �l�>Q�f�>f�dz>d�D� �F�A�t�T�Vz#Unknown value in table: {!r} ({!r})) �chrr �pstr_t�UnicodeDecodeErrorr � _read_item�append�boolr �utcfromtimestampr �format�type)�buf�offsetZftype�slen�val�blenr �n�tlen�limit�keylen�key�alen�v� r= ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/amqp/serialization.pyr+ s� ��r+ c C sR d }}g }|j }t| �} | D �](}|dkrp|sPt|||d � �}|d7 }d}|d@ dk}|dL }|d8 }�n�|dkr�d }}td||�\}|d7 }�n�|dkr�d }}td||�\}|d 7 }�n||d kr�d }}td ||�\}|d 7 }�nR|d k�rd }}td||�\}|d7 }�n&|dk�rFd }}td||�\}|d 7 }�n�|dk�r�d }}td||�\} |d7 }|||| � �dd�}|| 7 }�n�|dk�r�d }}td ||�\} |d 7 }|||| � �dd�}|| 7 }�nb|dk�rtd ||�\} |d 7 }|||| � }|| 7 }�n&|dk�r�d }}td ||�\} |d 7 }|| } i }|| k �r@td||�\} |d7 }t|||| � �}|| 7 }t||�\||< }�qNn�|dk�r�d }}td ||�\}|d 7 }|| } g }|| k �r@t||�\}}|� |� �q�nB|dk�r2d }}td||�\}|d7 }t�|�}ntt � |���||� q ||fS )z�Deserialize amqp format. bit = b octet = o short = B long = l long long = L float = f shortstr = s longstr = S table = F array = A timestamp = T r r r r �or r r r r r r r r r r r �utf-8� surrogatepassr r r# r$ r& ) r, r) �ordr �decoder+ r r. r �ILLEGAL_TABLE_TYPEr/ )r/ r1 r2 �bitcount�bits�valuesr, �pr4 r3 r5 r7 r8 r9 r: r; Zavalr= r= r> �loads� s� rI c C s0 | r,|t dt| � g| �R � � g | d d �< dS )Nr r )r �len)rF �writer= r= r> � _flushbits� s rL c C sj d}g }t � }|j}t| �} t|�D �]0\}}| | }|dkr�|rFdnd}|d } | dkrd|�d� |d || > O < |d7 }q$|dkr�t||�}|td|�� q$|dkr�t||�}|tdt|��� q$|d kr�t||�}|td |�� q$|d k�rt||�}|td |�� q$|d k�r4t||�}|td|�� q$|dk�r�|�pFd}t||�}t|t ��rj|� dd�}|tdt |��� ||� q$|dk�s�|dk�r�|�p�d}t||�}t|t ��r�|� dd�}|td t |��� ||� q$|dk�r t||�}t |�p i ||� q$|dk�r2t||�}t |�p(g ||� q$|dkr$|td tt�|�� ���� q$t||� |�� S )z�Serialize AMQP arguments. Notes: bit = b octet = o short = B long = l long long = L shortstr = s longstr = S byte array = x table = F array = A r r r r ���r? r r r r r r r r r � r@ rA r r r# r$ r& )r rK r) � enumerater, rL r �int� isinstance�str�encoderJ � _write_table� _write_array�calendar�timegm� utctimetuple�getvalue) r/ rG rE rF �outrK r r4 rH �shiftr= r= r> �dumps� sj r\ c C s� t � }|j}| �� D ]r\}}t|t�r2|�dd�}|tdt|��� ||� zt|||� W q t y� t t � t |�||���Y q0 q|�� }|tdt|��� ||� d S )Nr@ rA r r )r rK �itemsrQ rR rS r rJ � _write_item� ValueErrorr �ILLEGAL_TABLE_TYPE_WITH_KEYr/ r0 rY )r rK rF rZ Ztwrite�kr< Z table_datar= r= r> rT E s � rT c C st t � }|j}| D ]<}zt|||� W q tyJ tt�t|�|���Y q0 q|�� }|t dt |��� ||� d S )Nr ) r rK r^ r_ r � ILLEGAL_TABLE_TYPE_WITH_VALUEr/ r0 rY r rJ )�list_rK rF rZ Zawriter< Z array_datar= r= r> rU W s � rU c C s� t | ttf�rDt | t�r$| �dd�} |tddt| ��� || � �nbt | t�rf|tddt| ��� �n@t | t�r�|tdd| �� �n"t | t�r�| d ks�| d k r�|td d | �� n|td d| �� n�t | t ��r| � � \}}}d} |D ]}| d | } q�|�r| } |tdd| | �� n�t | t ��rD|tddtt � | �� ���� nbt | t��rf|d� t| ||� n@t | ttf��r�|d� t| ||� n| d u �r�|d� nt� �d S )Nr@ rA z>cI� Sz>cB� tz>cd� di���i �z>cq� Lz>ci� Ir r" z>cBi� Dz>cQ� T� F� A� V)rQ rR �bytesrS r rJ r- rP �floatr �as_tupler rV rW rX �dictrT �list�tuplerU r_ )r< rK rF �sign�digits�exponentr r= r= r> r^ e sD � r^ c C s( i }t d| |�\}|d7 }|d@ rXt d| |�\}|d7 }t| ||| � �|d< ||7 }|d@ r�t d| |�\}|d7 }t| ||| � �|d< ||7 }|d @ r�td | |�\}}|\|d < |d @ r�t d| |�\|d < |d7 }|d@ r�t d| |�\|d< |d7 }|d@ �r<t d| |�\}|d7 }t| ||| � �|d< ||7 }|d@ �r|t d| |�\}|d7 }t| ||| � �|d< ||7 }|d@ �r�t d| |�\}|d7 }t| ||| � �|d< ||7 }|d@ �r�t d| |�\}|d7 }t| ||| � �|d< ||7 }|d@ �r t d| |�\|d< |d7 }|d @ �r`t d| |�\}|d7 }t| ||| � �|d < ||7 }|d @ �r�t d| |�\}|d7 }t| ||| � �|d < ||7 }|d@ �r�t d| |�\}|d7 }t| ||| � �|d < ||7 }|d!@ �r t d| |�\}|d7 }t| ||| � �|d"< ||7 }||fS )#zDecode basic properties.r r i � r r � content_typei @ �content_encodingi r# Zapplication_headersi Z delivery_modei �priorityi Zcorrelation_idi Zreply_to� Z expiration� Z message_id�@ r � timestampr � r0 � Zuser_idZapp_idr Z cluster_id)r r) rI )r1 r2 � properties�flagsr3 �_fr= r= r> �decode_properties_basic� s� r� c @ sR e Zd ZdZdZdgZddd�ZdZdd� Zd d � Z d d � Z ddd�Z dd� Z dS )�GenericContentzdAbstract base class for AMQP content. Subclasses should override the PROPERTIES attribute. N)�dummyr c K s. || _ || _|| _g | _d| _d| _d| _d S )Nr F)� frame_method� frame_argsr� �_pending_chunks� body_received� body_size�ready)�selfr� r� �propsr= r= r> �__init__� s zGenericContent.__init__) r� r� r� r� r� r� r� �__dict__� __weakref__c C s0 |dkrt d��|| jv r$| j| S t |��d S )N� __setstate__)�AttributeErrorr� )r� �namer= r= r> � __getattr__� s zGenericContent.__getattr__c C s t | ||�\}}|| _|S )z�Load AMQP properties. Given the raw bytes containing the property-flags and property-list from a content-frame-header, parse and insert into a dictionary stored in this object as an attribute named 'properties'. )�PROPERTY_CLASSESr� )r� �class_idr1 r2 r� r= r= r> �_load_properties s z GenericContent._load_propertiesc C s� d}d}g }g g }}| j }| jD ]j\}}|�|d�} | dur�|dkrX|�|� d}d}|d|> O }|dkr�|�t|�� |�| � |d8 }q"|�|� t� } | j} |D ]}| td|�� q�| td� |�|�� | � � S )z�Serialize AMQP properties. Serialize the 'properties' attribute (a dictionary) into the raw bytes making up a set of property flags and a property list, suitable for putting into a content frame header. � r Nr �bitr � ) r� � PROPERTIES�getr, r r rK r r\ �joinrY ) r� r[ � flag_bitsr� ZsformatZsvaluesr� r: Zproptyper4 �resultrK r= r= r> �_serialize_properties s0 z$GenericContent._serialize_propertiesr c C s8 t d||�\}| _|d7 }| �|||� | js4d| _|S )Nz>HxxQ� T)r r� r� r� )r� r1 r2 r� r= r= r> �inbound_header2 s z GenericContent.inbound_headerc C sj | j }| jt|�7 _| j| jkr\|rN|�|� t� �|�| _g |d d �< n|| _d| _n |�|� d S )NT) r� r� rJ r� r, rn r� �bodyr� )r� r1 �chunksr= r= r> � inbound_body: s zGenericContent.inbound_body)NN)r ) �__name__� __module__� __qualname__�__doc__�CLASS_IDr� r� � __slots__r� r� r� r� r� r= r= r= r> r� � s # r� ) r� rV r �decimalr �ior �structr r � exceptionsr �specr �utilsr r) r rD r` rb r+ rI rL r\ rT rU r^ r� r� r� r� r= r= r= r> �<module> s. rcI&I�
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка