| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/hgext/fsmonitor/pywatchman/__pycache__/ |
Upload File : |
a
�+�b H � @ s. d dl mZmZmZ d dlZd dlZd dlZd dlZd dlZddl m
Z
dZ dZ dZ
dZd Zd
Zd Zd Zd
ZdZdZdZdZdZe
jr�eefZ eZ dd� Z e Z n e efZ eZ dZ!dZ"dd� Z#dd� Z$G dd � d e%�Z&d.d d �Z'G d d � d e%�Z(G d!d"� d"e%�Z)d#d$� Z*d%d&� Z+d'd(� Z,d/d*d+�Z-d0d,d-�Z.dS )1� )�absolute_import�division�print_functionN� )�compat� � � � � � � � � � �
� � �
c C s t | ��d�S )N�ascii)�str�encode)�i� r �G/usr/lib64/python3.9/site-packages/hgext/fsmonitor/pywatchman/pybser.py�tobytes< s r s s c C s� d| krdkr n ndS d| kr0dkr8n ndS d| krLdkrTn nd S t d
�| krpt d �krxn nd S td
t| � ��dS )z5Return the smallest size int that can store the valuei����� r i ���i� � i �i���� l���� l ���� � zCannot represent value: N)�long� RuntimeErrorr )�xr r r � _int_sizeK s r# c C s& | | }t jr"t|t�s"t|f�}|S �N)r �PYTHON3�
isinstance�bytes)�buf�pos�retr r r �_buf_posY s
r+ c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) � _bser_bufferc C s� || _ t�d�| _| j dkrFt�ttt��d | jdt� tt�| _ n6| j dksTJ �t�ttt
��d | jdt
� tt
�| _ d S )Ni r � sr r ) � bser_version�ctypesZcreate_string_bufferr( �struct� pack_intor �len� EMPTY_HEADER�wpos�EMPTY_HEADER_V2)�self�versionr r r �__init__b s
� �z_bser_buffer.__init__c C s6 t �| j�| j |k r2t �| jt �| j�d � q d S )Nr )r/ Zsizeofr( r4 Zresize)r6 �sizer r r � ensure_sizet s z_bser_buffer.ensure_sizec C s� t |�}|d }| �|� |dkr:t�d| j| jt|� nh|dkrZt�d| j| jt|� nH|dkrzt�d| j| jt|� n(|dkr�t�d| j| jt |� nt
d ��| j|7 _d S )
Nr s =cbr s =chr s =cir s =cqz Cannot represent this long value) r# r: r0 r1 r( r4 � BSER_INT8�
BSER_INT16�
BSER_INT32�
BSER_INT64r! )r6 �valr9 �to_writer r r � append_longx s
z_bser_buffer.append_longc C s t |t�r|�d�}t|�}t|�}d| | }| �|� |dkrjt�dt|� d | j | j
t t ||� n�|dkr�t�dt|� d | j | j
t t
||� nh|dkr�t�dt|� d | j | j
t t||� n8|d kr�t�d
t|� d | j | j
t t||� ntd ��| j
|7 _
d S ) N�utf-8r r � =ccbr- � =cchr � =ccir � =ccqz"Cannot represent this string value)r& �unicoder r2 r# r: r0 r1 r r( r4 �BSER_BYTESTRINGr; r< r= r> r! )r6 �sZs_lenr9 r@ r r r �
append_string� s`
� � � �
z_bser_buffer.append_stringc C s* t |t�rLd}| �|� |r"t}nt}t�d| j| j|� | j|7 _�n�|d u r�d}| �|� t�d| j| jt � | j|7 _�n�t |t
t f�r�| � |� �n�t |t
�r�| �|� �njt |t�r�d}| �|� t�d| j| jt|� | j|7 _�n*t |tj��r"t |tj��r"t|�}t|�}d| }| �|� |dk�r^t�d| j| jtt|� nt|dk�r�t�d| j| jtt|� nP|dk�r�t�d | j| jtt|� n,|d
k�r�t�d | j| jtt|� ntd ��| j|7 _t j �r�|� � }n|� � }|D ] \}}| �|� | � |� �q��nt |tj!��r t |tj��r t|�}t|�}d| }| �|� |dk�r�t�d| j| jt"t|� nt|dk�r�t�d| j| jt"t|� nP|dk�r�t�d | j| jt"t|� n,|d
k�r�t�d | j| jt"t|� ntd
��| j|7 _|D ]}| � |� �q
ntd��d S )Nr s =c� s =cdr rC rD r rE r rF z#Cannot represent this mapping valuez$Cannot represent this sequence valuez#Cannot represent unknown value type)#r& �boolr: � BSER_TRUE�
BSER_FALSEr0 r1 r( r4 � BSER_NULL�intr rA � STRING_TYPESrJ �float� BSER_REAL� collections�Mapping�Sizedr2 r# � BSER_OBJECTr; r< r= r> r! r r% �items� iteritems�append_recursive�Iterable�
BSER_ARRAY) r6 r? �neededZ to_encodeZval_lenr9 rY �k�vr r r rZ � s�
�
�
�
�
�
�
�
�
�
� z _bser_buffer.append_recursiveN)�__name__�
__module__� __qualname__r8 r: rA rJ rZ r r r r r, a s
3r, c C s� t |d�}|�| � |dkr>|jtt� }t�d|jd|� n2|jtt� }t�d|jd|� t�d|jd|� |jj d |j� S )N)r7 r � =i� r � )
r, rZ r4 r2 r3 r0 r1 r( r5 �raw)�objr7 Z capabilitiesZbser_buf�obj_lenr r r �dumps7 s
ri c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) � _BunserDict��_keys�_valuesc C s || _ || _d S r$ rk )r6 �keys�valuesr r r r8 K s z_BunserDict.__init__c C s
| � |�S r$ )� __getitem__)r6 �namer r r � __getattr__O s z_BunserDict.__getattr__c C sf t |ttf�r| j| S |�d�r.|dd � }z| j| j�|� W S ty` td| ��Y n0 d S )NZst_rd z_BunserDict has no key %s) r& rP r rm �
startswithrl �index�
ValueError�KeyError)r6 �keyr r r rp R s
z_BunserDict.__getitem__c C s
t | j�S r$ )r2 rl )r6 r r r �__len__^ s z_BunserDict.__len__N)r` ra rb � __slots__r8 rr rp rx r r r r rj H s
rj c @ sR e Zd Zddd�Zedd� �Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�BunserTNc C s6 || _ || _|d u r d | _n|d u r,d| _n|| _d S )N�strict��mutable�value_encoding� value_errors)r6 r} r~ r r r r r8 c s zBunser.__init__c C s� zt | |�}W n ty( td��Y n0 |tkr<d}d}nR|tkrNd}d}n@|tkr`d}d}n.|tkrrd}d }n td
t�|�� d �|f ��t
� || |d �d
}||| fS )Nz+Invalid bser int encoding, pos out of ranger s =brd s =h� rc rK s =qz-Invalid bser int encoding 0x%s at position %sr r r ) r+ �
IndexErrorru r; r< r= r> �binascii�hexlify�decoder0 � unpack_from)r( r) Zint_typer] ZfmtZint_valr r r � unser_intn s. ��zBunser.unser_intc C s@ | � ||d �\}}t�t|�d ||�d }|�d�|| fS )Nr r- r rB )r� r0 r� r r� �r6 r( r) Zstr_lenZstr_valr r r �unser_utf8_string� s zBunser.unser_utf8_stringc C sT | � ||d �\}}t�t|�d ||�d }| jd urH|�| j| j�}||| fS )Nr r- r )r� r0 r� r r~ r� r r� r r r �unser_bytestring� s
zBunser.unser_bytestringc C sV | � ||d �\}}g }t|�D ] }| �||�\}}|�|� q | jsNt|�}||fS �Nr )r� �range�loads_recursive�appendr} �tuple)r6 r( r) Zarr_len�arr�_Zarr_itemr r r � unser_array� s zBunser.unser_arrayc
C s� | � ||d �\}}| jr i }ng }g }t|�D ]H}| �||�\}}| �||�\} }| jrd| ||< q0|�|� |�| � q0| js�t||�}||fS r� )r� r} r� r� r� r� rj )
r6 r( r) rh rg rn �valsr� rw r? r r r � unser_object� s
zBunser.unser_objectc C s� t ||d �}|tkr td��t| jdd�}|�||d �\}}| �||�\}}g }t|�D ]�}| jrli } ng }
tt|��D ]R} t ||�t kr�|d7 }d } n| �
||�\} }| jr�|| }
| | |
< q||
� | � q|| js�t ||
�} |� | � q\||fS )Nr z Expect ARRAY to follow TEMPLATErB )r} r~ )
r+ r\ r! rz r} r� r� r� r2 � BSER_SKIPr� r� rj )r6 r( r) �val_typeZ keys_bunserrn Znitemsr� r� rg r� ZkeyidxZelerw r r r �unser_template� s0
zBunser.unser_templatec C s t ||�}|tks*|tks*|tks*|tkr6| �||�S |tkr`t�d||d �d }||d fS |t krtd|d fS |t
kr�d|d fS |t kr�d |d fS |t kr�| �
||�S |tkr�| �||�S |tkr�| �||�S |tkr�| �||�S |tk�r| �||�S tdt�|��d� ��d S ) Ns =dr r rK TFzunhandled bser opcode 0x%sr )r+ r; r< r= r> r� rS r0 r� rM rN rO rH r� �BSER_UTF8STRINGr� r\ r� rW r� �
BSER_TEMPLATEr� ru r� r� r� )r6 r( r) r� r? r r r r� � sD
����
��zBunser.loads_recursive)TNN) r` ra rb r8 � staticmethodr� r� r� r� r� r� r� r r r r rz b s
"rz c C s� | dd� t dd� kr2d}d}t�| d�\}}n\| dd� tdd� kr�t| �dk r^td��d}t�d| d�d }t�| d�\}}ntd��||||fS )Nr r r r zInvalid BSER header�I� )r3 rz r� r5 r2 ru r0 r� )r( r. Zbser_capabilities� expected_lenZpos2r r r �_pdu_info_helper� s r� c C s& t | �}|d |d |d |d fS )Nr r r rd �r� �r( �infor r r �pdu_info
s r� c C s t | �}|d |d S )Nr rd r� r� r r r �pdu_len s r� Tc C s^ t | �}|d }|d }t| �|| kr@td|| t| �f ��t|||d�}|�| |�d S )au Deserialize a BSER-encoded blob.
@param buf: The buffer to deserialize.
@type buf: bytes
@param mutable: Whether to return mutable results.
@type mutable: bool
@param value_encoding: Optional codec to use to decode values. If
unspecified or None, return values as bytestrings.
@type value_encoding: str
@param value_errors: Optional error handler for codec. 'strict' by default.
The other most common argument is 'surrogateescape' on
Python 3. If value_encoding is None, this is ignored.
@type value_errors: str
r rd z!bser data len %d != header len %dr| r )r� r2 ru rz r� )r( r} r~ r r� r� r) Zbunserr r r �loads s ��r� c C s ddl m} |�| |||�S )Nr )�load)� r� )�fpr} r~ r r� r r r r� < s r� )r r )TNN)TNN)/Z
__future__r r r r� rT r/ r0 �sysr� r r\ rW rH r; r< r= r> rS rM rN rO r� r� r� r% r r' rQ rG r rP r r3 r5 r# r+ �objectr, ri rj rz r� r� r� r� r� r r r r �<module> sT W
%