File: //usr/lib64/python3.9/site-packages/borg/testsuite/__pycache__/cache.cpython-39.opt-1.pyc
a
HZ�h.$ � @ s� d dl Z d dlZddlmZ d dlZddlmZ ddlm Z ddl
m Z ddl m
Z
dd lmZ dd
lmZ dd lmZmZ dd lmZ dd
lmZ G dd� d�ZG dd� d�ZdS )� N� )�packb� )�H)�TestKey)�
Statistics��
AdHocCache)�CompressionSpec)�RepoKey)�
ChunkIndex�CacheSynchronizer)�Manifest)�
Repositoryc @ s: e Zd Zejdd� �Zejdd� �Zdd� Zdd� Zd d
� Z ej
j d d d
idfe d�ddgfdddddfg d�d�ej
� ddd� d d� d d� f�d d � ��Z
ej
� d d!e d"�d
d#d$fgid%fd!e d"�d
fgid%fd!d&gid'fd!d e d"�d
fgid'fd!e d"�d(d
fgid)ff�d*d+� �Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4S )5�TestCacheSynchronizerc C s t � S �N)r )�self� r �:/usr/lib64/python3.9/site-packages/borg/testsuite/cache.py�index s zTestCacheSynchronizer.indexc C s t |�S r )r
)r r r r r �sync s zTestCacheSynchronizer.syncc C s" t ddddg d��}|�|� d S )N�bar�� �. �chunks�ZfooZbazr �userr )r �feed�r r r �datar r r �test_no_chunks s �
z$TestCacheSynchronizer.test_no_chunksc C s: t ddddtd�ddftd�ddfgd��}|�|� d S ) Nr r r r r r � r �r r r r r r r � test_simple' s ��
z!TestCacheSynchronizer.test_simplec C s� t ddddtd�ddftd�ddfgd��}|t dd d
�d gd ��7 }|t dd d
�td�ddftd�ddfgd gd
��7 }|t dtd�ddfgi�7 }|t dtd�ddfgi�7 }|d d� }|dd� }|dd � }|�|� |�|� |�|� d S )Nr r r r r r r! r Z123456)z security.foor �r r r! )�xattrs�stuff)r% r r& �F �x r" )r r r r Zpart1Zpart2Zpart3r r r �
test_multiple7 sV ��
���
� ���
�� ��
z#TestCacheSynchronizer.test_multiplez
elem,errorr r zUnexpected object: map�� z$Unexpected bytes in chunks structurezIncorrect key length)r �Unexpected object: integer)� �?�Unexpected object: double)TzUnexpected object: true)FzUnexpected object: false)NzUnexpected object: nil)�map�bytes�intZdouble�trueZfalse�none)Zids� structurec C s d| iS �Nr r ��elemr r r �<lambda>z � z TestCacheSynchronizer.<lambda>c C s
d| giS r4 r r5 r r r r7 { r8 c C s d| ddfgiS )Nr r r r r5 r r r r7 | r8 c C sb t ||��}t�t��}|�|� W d � n1 s60 Y t|t�rP|g}dd� |D �}d S )Nc S s g | ] }d | �qS )zcache_sync_feed failed: r )�.0�errorr r r �
<listcomp>� r8 z8TestCacheSynchronizer.test_corrupted.<locals>.<listcomp>)r �pytest�raises�
ValueErrorr �
isinstance�str)r r r3 r6 r: �packed�excinfoZpossible_errorsr r r �test_corruptedn s (
z$TestCacheSynchronizer.test_corruptedz
data,errorr � r! � z Invalid chunk list entry lengthr$ r+ r, r- c C s@ t |�}t�t��}|�|� W d � n1 s20 Y d S r )r r< r= r> r )r r r r r: rA rB r r r �test_corrupted_ancillary� s
(z.TestCacheSynchronizer.test_corrupted_ancillaryc C s� t �� }|�d� |�d�dd�� |�d�dd�� |�d�dd�� |�d�dd�� |�td�� |�|�dd�� |�d�dd�� |�d �dd�� |�d� t�|�}|S )
Ns BORG_IDXr rE �littlerD � r r r )�io�BytesIO�write�to_bytesr �seekr �read)r ZrefcountZ
index_datar r r r �make_index_with_refcount� s
z.TestCacheSynchronizer.make_index_with_refcountc C sh | � tjd �}t|�}tdtd�ddfgi�}t�t��}|� |� W d � n1 sZ0 Y d S �Nr r r r )
rO r � MAX_VALUEr
r r r< r= r> r )r r r r rB r r r �test_corrupted_refcount� s �� (z-TestCacheSynchronizer.test_corrupted_refcountc C s: | � tj�}t|�}tdtd�ddfgi�}|�|� d S )Nr r r r �rO r rQ r
r r r r r r r �test_refcount_max_value� s ��
z-TestCacheSynchronizer.test_refcount_max_valuec C sH | � tjd �}t|�}tdtd�ddfgi�}|�|� |�|� d S rP rS r r r r �!test_refcount_one_below_max_value� s ��
z7TestCacheSynchronizer.test_refcount_one_below_max_valueN)�__name__�
__module__� __qualname__r< �fixturer r r r# r) ZmarkZ parametrizer/ rC rF rO rR rT rU r r r r r sN
7
��
� � �
r c @ s� e Zd Zejdd� �Zejdd� �Zejdd� �Zejdd� �Zd d
� Z d d � Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� ZdS ) �TestAdHocCachec c sl t j�t|�d�| _t| jddd��4}|�td�d� |�tj d� |V W d � n1 s^0 Y d S )N�
repositoryT)Z exclusive�creater s 1234� 5678)
�os�path�joinr@ Zrepository_locationr Zputr r Z MANIFEST_ID)r Ztmpdirr[ r r r r[ � s
zTestAdHocCache.repositoryc C s, |� dd� t�|t�� �}td�j|_|S )NZBORG_PASSPHRASE�testr2 )Zsetenvr r\ r ZMockArgsr
Z
compressor)r r[ Z monkeypatch�keyr r r rb � s zTestAdHocCache.keyc C s$ t ||��� t j||t jd�d S )N)rb Z
operationsr )r rK �loadZNO_OPERATION_CHECK)r r[ rb r r r �manifest� s zTestAdHocCache.manifestc C s t |||�S r r )r r[ rb rd r r r �cache� s zTestAdHocCache.cachec C s d S r r �r re r r r � test_does_not_contain_manifest� s z-TestAdHocCache.test_does_not_contain_manifestc C s |� td�t� � d S )Nr )� chunk_decrefr r )r r[ re r r r �$test_does_not_delete_existing_chunks� s z3TestAdHocCache.test_does_not_delete_existing_chunksc C sF t �t��( |jtd�dt� dd� W d � n1 s80 Y d S )Nr r] T)Z overwrite)r< r= �AssertionError� add_chunkr r rf r r r �test_does_not_overwrite� s z&TestAdHocCache.test_does_not_overwritec C s d S r r rf r r r � test_seen_chunk_add_chunk_size� s z-TestAdHocCache.test_seen_chunk_add_chunk_sizec C sd |� td�dt� � |�td�t� � t�tj�� |�td�� W d � n1 sV0 Y dS )zE.g. checkpoint archives� s 1010N) rk r r rh r< r= r ZObjectNotFound�get)r re r[ r r r �#test_deletes_chunks_during_lifetime� s z2TestAdHocCache.test_deletes_chunks_during_lifetimec C s d S r r rf r r r �test_files_cache s z TestAdHocCache.test_files_cachec C s |� td�� |�� d S )Nrn )Z
seen_chunkr Zrollbackrf r r r �test_txn s zTestAdHocCache.test_txnc C s d S r r rf r r r �test_incref_after_add_chunk s z*TestAdHocCache.test_incref_after_add_chunkc C s dS )z9This case occurs with part files, see Archive.chunk_file.Nr rf r r r �$test_existing_incref_after_add_chunk s z3TestAdHocCache.test_existing_incref_after_add_chunkN)rV rW rX r< rY r[ rb rd re rg ri rl rm rp rq rr rs rt r r r r rZ � s"
rZ )rI Zos.pathr^ Zhelpers.msgpackr r< Z hashindexr rb r �archiver re r �compressr
Z
crypto.keyr r r
Zhelpersr r[ r r rZ r r r r �<module> s ?