File: //usr/lib64/python3.9/site-packages/borg/helpers/__pycache__/msgpack.cpython-39.opt-1.pyc
a
HZ�h�" � @ sP d dl mZ ddlT ddlmZ ddlmZ ddlmZ ddlm
Z dd lm Z
dd
lmZ dd lmZ dd lmZ dd
lmZ eZedkZG dd� de�ZG dd� de�ZG dd� de�Zddd�dd�Zddd�dd�ZG d d � d e �Z
d ddd d d d d d �d!d"�Z d ddd d d d d d �d#d$�Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Z dS )/� )�
StableDict� )�*� )�Packer)�packb)�pack)�Unpacker)�unpackb)�unpack)�version)�ExtType)� OutOfData)r r r c @ s e Zd ZdZdS )�
PackExceptionz Exception while msgpack packingN��__name__�
__module__� __qualname__�__doc__� r r �:/usr/lib64/python3.9/site-packages/borg/helpers/msgpack.pyr $ s r c @ s e Zd ZdZdS )�UnpackExceptionz!Exception while msgpack unpackingNr r r r r r ( s r c s8 e Zd Zddddddd�� fdd�
Z� fdd�Z� ZS ) r NFT��default�unicode_errors�use_single_float� autoreset� use_bin_type� strict_typesc s t � j||||||d� d S )Nr )�super�__init__)�selfr r r r r r �� __class__r r r - s
�zPacker.__init__c
s@ zt � �|�W S ty: } zt|��W Y d }~n
d }~0 0 d S �N)r r � Exceptionr )r! �obj�er" r r r 5 s z Packer.pack)r r r r r �
__classcell__r r r" r r , s
�r FN�r r c
K sJ zt | f||d�|��W S tyD } zt|��W Y d }~n
d }~0 0 d S �Nr) )�mp_packbr% r )�or r �kwargsr' r r r r < s r c
K sL zt | |f||d�|��W S tyF } zt|��W Y d }~n
d }~0 0 d S r* )�mp_packr% r )r, �streamr r r- r' r r r r D s r c s\ e Zd Zd
ddddddddeddddddd�� fdd� Z� fd d
�Z� fd d �ZeZ� ZS )r Nr TF��)� read_size�use_list�raw� object_hook�object_pairs_hook� list_hookr �max_buffer_size�ext_hook�strict_map_key� max_str_len� max_bin_len�
max_array_len� max_map_len� max_ext_lenc sH t ||||||||| |
| |
|||d�}tr2| |d< t� jf i |�� d S )N)� file_liker1 r2 r3 r4 r5 r6 r r7 r8 r: r; r< r= r> r9 )�dict� _post_100r r )r! r? r1 r2 r3 r4 r5 r6 r r7 r8 r9 r: r; r< r= r> �kwr" r r r R s
� zUnpacker.__init__c
sP z t � �� W S ty � Y n, tyJ } zt|��W Y d }~n
d }~0 0 d S r$ )r r r r% r �r! r' r" r r r k s zUnpacker.unpackc
sP z t � �� W S ty � Y n, tyJ } zt|��W Y d }~n
d }~0 0 d S r$ )r �__next__�
StopIterationr% r rC r" r r rD s s zUnpacker.__next__)N) r r r r
r r rD �nextr( r r r" r r Q s � r Tr0 )r3 r r9 r: r; r< r= r> c
K sp z>t |||||||d�}
|
�| � tr.||
d< t| fi |
��W S tyj } zt| ��W Y d } ~ n
d } ~ 0 0 d S �N)r3 r r: r; r< r= r> r9 )r@ �updaterA �
mp_unpackbr% r ) �packedr3 r r9 r: r; r< r= r> r- rB r' r r r r
~ s �
r
c
K sp z>t |||||||d�}
|
�| � tr.||
d< t| fi |
��W S tyj } zt| ��W Y d } ~ n
d } ~ 0 0 d S rG )r@ rH rA � mp_unpackr% r ) r/ r3 r r9 r: r; r< r= r> r- rB r' r r r r � s �
r c C s dd l } dd l} | j| jju S )Nr )�msgpackZmsgpack.fallbackr �fallback�rL r r r �is_slow_msgpack� s rO c C s4 dd l } d| jd d� ko$dkn o2| jdvS )Nr )r � � � )r r r ))r r r )rL r rN r r r �is_supported_msgpack� s "�rS c C s� t ddddttt� td�}| dkr8|�t ddd�� n�| dkrT|�t tdd�� nl| d krv|�t d
dtd td �� nJ| d
kr�|�t d
ddtd�� n*| dkr�|�t d
dddtd �� ntd��t f i |��S )zWreturn a limited Unpacker because we should not trust msgpack data received from remoteFr rR )r2 r; r> r7 r: Zserver�d )r< r= ZclientZmanifestT� )r2 r< r= r: r4 �archivei' )r2 r= r: r4 �key�
i� z4kind must be "server", "client", "manifest" or "key")
r@ �max�BUFSIZEZMAX_OBJECT_SIZErH ZLIST_SCAN_LIMITZ MAX_ARCHIVESr �
ValueErrorr )�kind�argsr r r �get_limited_unpacker� sH ��
�
�
�
�
r^ c C s t | t�rtj| ddd�S | S )z Convert bytearray to int
�littleT�Zsigned)�
isinstance�bytes�int�
from_bytes)�mtimer r r �
bigint_to_int� s
rf c C s, | � � dkr(| j| � � d d ddd�S | S )z[Convert integers larger than 64 bits to bytearray
Smaller integers are left alone
�? � � r_ Tr` )�
bit_length�to_bytes)�valuer r r �
int_to_bigint� s rm ) Z
datastructr Z constantsrL r Z mp_Packerr r+ r r. r Z mp_Unpackerr
rI r rK r Z
mp_versionr
r rA r% r r rO rS r^ rf rm r r r r �<module> sN
-� � )