|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/hgext/fsmonitor/pywatchman/__pycache__/ |
Upload File : |
o
�]Lb H � @ s. d dl mZmZmZ d dlZd dlZd dlZd dlZd dlZddl m
Z
dZ dZ dZ
dZd Zd
Zd Zd Zd
ZdZdZdZdZdZe
jrPeefZ eZ dd� Z e Z ne 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-d/d,d-�Z.dS )0� )�absolute_import�division�print_functionN� )�compat� � � � � � � � � � �
� � �
c C s t | ��d�S )N�ascii)�str�encode)�i� r �C/usr/lib/python3/dist-packages/hgext/fsmonitor/pywatchman/pybser.py�tobytes< s r s s c C sx d| kr dkr dS d| krdkrdS d| kr#dkr$d S t d
�| kr3t d �kr4d S td
t| � ��)z5Return the smallest size int that can store the valuei����� r i ���i� � i �i���� l���� l ���� � zCannot represent value: )�long� RuntimeErrorr )�xr r r � _int_sizeK s ����r# c C s& | | }t jrt|t�st|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 dkr$t�ttt��d | jdt� tt�| _ d S | j dks+J �t�ttt
��d | jdt
� tt
�| _ d S )Ni r � sr r ) � bser_version�ctypes�create_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 sN t �| j�| j |k r%t �| jt �| j�d � t �| j�| j |k s d S d S )Nr )r/ �sizeofr( r5 �resize)r7 �sizer r r � ensure_sizet s �z_bser_buffer.ensure_sizec C s� t |�}|d }| �|� |dkr t�d| j| jt|� n4|dkr-t�d| j| jt|� n$|dkr=t�d| j| jt|� n|dkrMt�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= r1 r2 r( r5 � BSER_INT8�
BSER_INT16�
BSER_INT32�
BSER_INT64r! )r7 �valr< �to_writer r r � append_longx s
z_bser_buffer.append_longc C s t |t�r
|�d�}t|�}t|�}d| | }| �|� |dkr5t�dt|� d | j | j
t t ||� nL|dkrMt�dt|� d | j | j
t t
||� n4|dkret�dt|� d | j | j
t t||� n |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 r3 r# r= r1 r2 r r( r5 �BSER_BYTESTRINGr> r? r@ rA r! )r7 �s�s_lenr< rC r r r �
append_string� s`
� � � �
z_bser_buffer.append_stringc C s t |t�r&d}| �|� |rt}nt}t�d| j| j|� | j|7 _d S |d u rDd}| �|� t�d| j| jt � | j|7 _d S t |t
t f�rR| � |� d S t |t
�r^| �|� d S t |t�r~d}| �|� t�d| j| jt|� | j|7 _d S t |tj��r t |tj��r t|�}t|�}d| }| �|� |dkr�t�d| j| jtt|� n7|dkr�t�d| j| jtt|� n&|dkr�t�d | j| jtt|� n|d
kr�t�d | j| jtt|� ntd ��| j|7 _t j r�|� � }n|� � }|D ]\}}| �|� | � |� q�d S t |tj!��r�t |tj��r�t|�}t|�}d| }| �|� |dk�r<t�d| j| jt"t|� n:|dk�rNt�d| j| jt"t|� n(|dk�r`t�d | j| jt"t|� n|d
k�rrt�d | j| jt"t|� ntd
��| j|7 _|D ]}| � |� �qd S td��)Nr s =c� s =cdr rF rG r rH r rI z#Cannot represent this mapping valuez$Cannot represent this sequence valuez#Cannot represent unknown value type)#r& �boolr= � BSER_TRUE�
BSER_FALSEr1 r2 r( r5 � BSER_NULL�intr rD � STRING_TYPESrN �float� BSER_REAL� collections�Mapping�Sizedr3 r# � BSER_OBJECTr> r? r@ rA r! r r% �items� iteritems�append_recursive�Iterable�
BSER_ARRAY) r7 rB �needed� to_encode�val_lenr< r] �k�vr r r r^ � s�
�
����
��
�
�
�
� �z _bser_buffer.append_recursiveN)�__name__�
__module__� __qualname__r9 r= rD rN r^ r r r r r, a s 3r, c C s� t |d�}|�| � |dkr |jtt� }t�d|jd|� n|jtt� }t�d|jd|� t�d|jd|� |jj d |j� S )N)r8 r � =i� r � )
r, r^ r5 r3 r4 r1 r2 r( r6 �raw)�objr8 � capabilities�bser_buf�obj_lenr r r �dumps7 s
rq c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) � _BunserDict��_keys�_valuesc C s || _ || _d S r$ rs )r7 �keys�valuesr r r r9 K s
z_BunserDict.__init__c C s
| � |�S r$ )� __getitem__)r7 �namer r r � __getattr__O �
z_BunserDict.__getattr__c C s^ t |ttf�r | j| S |�d�r|dd � }z
| j| j�|� W S ty. td| ��w )N�st_rj z_BunserDict has no key %s) r& rT r ru �
startswithrt �index�
ValueError�KeyError)r7 �keyr r r rx R s
�z_BunserDict.__getitem__c C s
t | j�S r$ )r3 rt )r7 r r r �__len__^ r{ z_BunserDict.__len__N)rf rg rh � __slots__r9 rz rx r� r r r r rr H s rr c @ sR e Zd Zddd�Zedd� �Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dS )�BunserTNc C s: || _ || _|d u rd | _d S |d u rd| _d S || _d S )N�strict��mutable�value_encoding� value_errors)r7 r� r� r� r r r r9 c s
zBunser.__init__c C s� zt | |�}W n ty td��w |tkr d}d}n)|tkr%d}d}n |tkr.d}d}n|tkr7d}d }ntd
t�|�� d �|f ��t
� || |d �d
}||| fS )Nz+Invalid bser int encoding, pos out of ranger s =brj s =h� ri rO s =qz-Invalid bser int encoding 0x%s at position %sr r r ) r+ �
IndexErrorr r> r? r@ rA �binascii�hexlify�decoder1 � unpack_from)r( r) �int_typera �fmt�int_valr r r � unser_intn s0 ��� zBunser.unser_intc C s@ | � ||d �\}}t�t|�d ||�d }|�d�|| fS )Nr r- r rE )r� r1 r� r r� �r7 r( r) �str_len�str_valr r r �unser_utf8_string� s zBunser.unser_utf8_stringc C sT | � ||d �\}}t�t|�d ||�d }| jd ur$|�| j| j�}||| fS )Nr r- r )r� r1 r� r r� r� r� r� r r r �unser_bytestring� s
zBunser.unser_bytestringc C sV | � ||d �\}}g }t|�D ]}| �||�\}}|�|� q| js't|�}||fS �Nr )r� �range�loads_recursive�appendr� �tuple)r7 r( r) �arr_len�arr�_�arr_itemr r r � unser_array� s zBunser.unser_arrayc
C s� | � ||d �\}}| jri }ng }g }t|�D ]$}| �||�\}}| �||�\} }| jr2| ||< q|�|� |�| � q| jsEt||�}||fS r� )r� r� r� r� r� r� rr )
r7 r( r) rp rm rv �valsr� r� rB r r r � unser_object� s
zBunser.unser_objectc C s� t ||d �}|tkrtd��t| jdd�}|�||d �\}}| �||�\}}g }t|�D ]G}| jr6i } ng }
tt|��D ])} t ||�t krN|d7 }d } n| �
||�\} }| jrb|| }
| | |
< q>|
� | � q>| jspt ||
�} |� | � q.||fS )Nr z Expect ARRAY to follow TEMPLATErE )r� r� )
r+ r` r! r� r� r� r� r� r3 � BSER_SKIPr� r� rr )r7 r( r) �val_type� keys_bunserrv �nitemsr� r� rm r� �keyidx�eler� r r r �unser_template� s0
zBunser.unser_templatec C s t ||�}|tks|tks|tks|tkr| �||�S |tkr0t�d||d �d }||d fS |t kr:d|d fS |t
krDd|d fS |t krNd |d fS |t krX| �
||�S |tkrb| �||�S |tkrl| �||�S |tkrv| �||�S |tkr�| �||�S tdt�|��d� ��) Ns =dr r rO TFzunhandled bser opcode 0x%sr )r+ r> r? r@ rA r� rW r1 r� rQ rR rS rK r� �BSER_UTF8STRINGr� r` r� r[ r� �
BSER_TEMPLATEr� r r� r� r� )r7 r( r) r� rB r r r r� � s<
��zBunser.loads_recursive�TNN) rf rg rh r9 � staticmethodr� r� r� r� r� r� r� r r r r r� b s
"r� c C s� | dd� t dd� krd}d}t�| d�\}}n.| dd� tdd� krCt| �dk r/td��d}t�d| d�d }t�| d�\}}ntd��||||fS )Nr r r r zInvalid BSER header�I� )r4 r� r� r6 r3 r r1 r� )r( r. �bser_capabilities� expected_len�pos2r r r �_pdu_info_helper� s r� c C s& t | �}|d |d |d |d fS )Nr r r rj �r� �r( �infor r r �pdu_info
s r� c C s t | �}|d |d S )Nr rj 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 rj z!bser data len %d != header len %dr� r )r� r3 r r� r� )r( r� r� r� r� r� r) �bunserr 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 r� )/�
__future__r r r r� rX r/ r1 �sysr� r r` r[ rK r> r? r@ rA rW rQ rR rS r� r� r� r% r r' rU rJ r rT r r4 r6 r# r+ �objectr, rq rr r� r� r� r� r� r� r r r r �<module> sV
W
%