Linux srv25.usacloudserver.us 5.14.0-570.39.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Sep 4 05:08:52 EDT 2025 x86_64
LiteSpeed
Server IP : 23.137.84.82 & Your IP : 216.73.216.127
Domains :
Cant Read [ /etc/named.conf ]
User : epicgamerzoneco
Terminal
Auto Root
Create File
Create Folder
Localroot Suggester
Backdoor Destroyer
Readme
/
lib64 /
python3.9 /
site-packages /
borg /
__pycache__ /
Delete
Unzip
Name
Size
Permission
Date
Action
__init__.cpython-39.opt-1.pyc
316
B
-rw-r--r--
2025-10-13 20:00
__init__.cpython-39.pyc
738
B
-rw-r--r--
2025-10-13 20:00
__main__.cpython-39.opt-1.pyc
530
B
-rw-r--r--
2025-10-13 20:00
__main__.cpython-39.pyc
530
B
-rw-r--r--
2025-10-13 20:00
_version.cpython-39.opt-1.pyc
176
B
-rw-r--r--
2025-10-13 20:00
_version.cpython-39.pyc
176
B
-rw-r--r--
2025-10-13 20:00
archive.cpython-39.opt-1.pyc
72.4
KB
-rw-r--r--
2025-10-13 20:00
archive.cpython-39.pyc
72.68
KB
-rw-r--r--
2025-10-13 20:00
archiver.cpython-39.opt-1.pyc
193.39
KB
-rw-r--r--
2025-10-13 20:00
archiver.cpython-39.pyc
193.83
KB
-rw-r--r--
2025-10-13 20:00
cache.cpython-39.opt-1.pyc
40.23
KB
-rw-r--r--
2025-10-13 20:00
cache.cpython-39.pyc
40.44
KB
-rw-r--r--
2025-10-13 20:00
constants.cpython-39.opt-1.pyc
2.14
KB
-rw-r--r--
2025-10-13 20:00
constants.cpython-39.pyc
2.16
KB
-rw-r--r--
2025-10-13 20:00
fuse.cpython-39.opt-1.pyc
18.77
KB
-rw-r--r--
2025-10-13 20:00
fuse.cpython-39.pyc
18.86
KB
-rw-r--r--
2025-10-13 20:00
fuse_impl.cpython-39.opt-1.pyc
670
B
-rw-r--r--
2025-10-13 20:00
fuse_impl.cpython-39.pyc
670
B
-rw-r--r--
2025-10-13 20:00
locking.cpython-39.opt-1.pyc
14.36
KB
-rw-r--r--
2025-10-13 20:00
locking.cpython-39.pyc
14.41
KB
-rw-r--r--
2025-10-13 20:00
logger.cpython-39.opt-1.pyc
7.4
KB
-rw-r--r--
2025-10-13 20:00
logger.cpython-39.pyc
7.4
KB
-rw-r--r--
2025-10-13 20:00
lrucache.cpython-39.opt-1.pyc
1.99
KB
-rw-r--r--
2025-10-13 20:00
lrucache.cpython-39.pyc
2.16
KB
-rw-r--r--
2025-10-13 20:00
nanorst.cpython-39.opt-1.pyc
5.47
KB
-rw-r--r--
2025-10-13 20:00
nanorst.cpython-39.pyc
5.55
KB
-rw-r--r--
2025-10-13 20:00
patterns.cpython-39.opt-1.pyc
13.29
KB
-rw-r--r--
2025-10-13 20:00
patterns.cpython-39.pyc
13.29
KB
-rw-r--r--
2025-10-13 20:00
platformflags.cpython-39.opt-1.pyc
441
B
-rw-r--r--
2025-10-13 20:00
platformflags.cpython-39.pyc
441
B
-rw-r--r--
2025-10-13 20:00
remote.cpython-39.opt-1.pyc
35.84
KB
-rw-r--r--
2025-10-13 20:00
remote.cpython-39.pyc
36.01
KB
-rw-r--r--
2025-10-13 20:00
repository.cpython-39.opt-1.pyc
51.31
KB
-rw-r--r--
2025-10-13 20:00
repository.cpython-39.pyc
51.75
KB
-rw-r--r--
2025-10-13 20:00
selftest.cpython-39.opt-1.pyc
3.36
KB
-rw-r--r--
2025-10-13 20:00
selftest.cpython-39.pyc
3.5
KB
-rw-r--r--
2025-10-13 20:00
shellpattern.cpython-39.opt-1.pyc
1.76
KB
-rw-r--r--
2025-10-13 20:00
shellpattern.cpython-39.pyc
1.76
KB
-rw-r--r--
2025-10-13 20:00
upgrader.cpython-39.opt-1.pyc
11.91
KB
-rw-r--r--
2025-10-13 20:00
upgrader.cpython-39.pyc
11.91
KB
-rw-r--r--
2025-10-13 20:00
version.cpython-39.opt-1.pyc
1.88
KB
-rw-r--r--
2025-10-13 20:00
version.cpython-39.pyc
1.88
KB
-rw-r--r--
2025-10-13 20:00
xattr.cpython-39.opt-1.pyc
3.55
KB
-rw-r--r--
2025-10-13 20:00
xattr.cpython-39.pyc
3.55
KB
-rw-r--r--
2025-10-13 20:00
Save
Rename
a HZ�h�C � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl m Z d dl m Z d dlmZ d dlmZ ddlT dd lmZ dd lmZmZmZmZmZ dd lmZ dd lm Z dd lm Z ddlm Z m Z ddlm Z ddlm!Z! ddlm"Z" ddl#m$Z$m%Z%m&Z& ddl'm(Z( ddl)m*Z* ddl+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z1 ddl2m3Z3m4Z4 e(e5�Z'dZ6e7e6�Z8dZ9e7e9�e8k�s�J �d Z:dZ;dZ<dZ=ee e>�Z?G d d � d �Z@G d d � d �ZAeAjBjCd k�s�J �dS )!� N)�hexlify� unhexlify)� defaultdict)� ConfigParser)�partial)�islice� )�*)�NSIndex)�Error�ErrorWithTraceback�IntegrityError�format_file_size�parse_file_size)�Location)�ProgressIndicatorPercent)� bin_to_hex)� secure_erase� safe_unlink)�Manifest)�msgpack)�utcnow)�Lock� LockError� LockErrorT)� create_logger)�LRUCache)�SaveFile�SyncFile�sync_dir� safe_fadvise)�crc32)�IntegrityCheckedFile�FileIntegrityErrors BORG_SEGs ATTICSEG� � c @ sd e Zd ZdZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�Z G d d � d e�Z G dd� de�Z G dd� de �Z G dd� de �ZG dd� de�ZG dd� de�Zd}dd �Zd d � Zd d � Zd!d"� Zd#d$� Zed%d&� �Zed'd(� �Zd)d*� Zd+d,� Zd-d.� Z d/d0� Z d1d2� Z d3d4� Z d5d6� Z d7d8� Z!d9d:� Z"d;d<� Z#d=d>� Z$d?d@� Z%dAdB� Z&d~dCdD�Z'dEdF� Z(ddHdI�Z)dJdK� Z*d�dLdM�Z+d�dNdO�Z,dPdQ� Z-dRdS� Z.dTdU� Z/dVdW� Z0dXdY� Z1d�dZd[�Z2d\d]� Z3d�d_d`�Z4d�dadb�Z5dcdd� Z6dedf� Z7dgdh� Z8didj� Z9d�dkdl�Z:d�dmdn�Z;dodp� Z<d�dqdr�Z=d�dsdt�Z>d�dudv�Z?dwdx� Z@d�dydz�ZAd{d|� ZBdS )�� Repositorya� Filesystem based transactional key value store Transactionality is achieved by using a log (aka journal) to record changes. The log is a series of numbered files called segments. Each segment is a series of log entries. The segment number together with the offset of each entry relative to its segment start establishes an ordering of the log entries. This is the "definition" of time for the purposes of the log. Log entries are either PUT, DELETE or COMMIT. A COMMIT is always the final log entry in a segment and marks all data from the beginning of the log until the segment ending with the COMMIT as committed and consistent. The segment number of a segment ending with a COMMIT is called the transaction ID of that commit, and a segment ending with a COMMIT is called committed. When reading from a repository it is first checked whether the last segment is committed. If it is not, then all segments after the last committed segment are deleted; they contain log entries whose consistency is not established by a COMMIT. Note that the COMMIT can't establish consistency by itself, but only manages to do so with proper support from the platform (including the hardware). See platform.base.SyncFile for details. A PUT inserts a key-value pair. The value is stored in the log entry, hence the repository implements full data logging, meaning that all data is consistent, not just metadata (which is common in file systems). A DELETE marks a key as deleted. For a given key only the last entry regarding the key, which is called current (all other entries are called superseded), is relevant: If there is no entry or the last entry is a DELETE then the key does not exist. Otherwise the last PUT defines the value of the key. By superseding a PUT (with either another PUT or a DELETE) the log entry becomes obsolete. A segment containing such obsolete entries is called sparse, while a segment containing no such entries is called compact. Sparse segments can be compacted and thereby disk space freed. This destroys the transaction for which the superseded entries where current. On disk layout: dir/README dir/config dir/data/<X // SEGMENTS_PER_DIR>/<X> dir/index.X dir/hints.X File system interaction ----------------------- LoggedIO generally tries to rely on common behaviours across transactional file systems. Segments that are deleted are truncated first, which avoids problems if the FS needs to allocate space to delete the dirent of the segment. This mostly affects CoW file systems, traditional journaling file systems have a fairly good grip on this problem. Note that deletion, i.e. unlink(2), is atomic on every file system that uses inode reference counts, which includes pretty much all of them. To remove a dirent the inodes refcount has to be decreased, but you can't decrease the refcount before removing the dirent nor can you decrease the refcount after removing the dirent. File systems solve this with a lock, and by ensuring it all stays within the same FS transaction. Truncation is generally not atomic in itself, and combining truncate(2) and unlink(2) is of course never guaranteed to be atomic. Truncation in a classic extent-based FS is done in roughly two phases, first the extents are removed then the inode is updated. (In practice this is of course way more complex). LoggedIO gracefully handles truncate/unlink splits as long as the truncate resulted in a zero length file. Zero length segments are considered to not exist, while LoggedIO.cleanup() will still get rid of them. c @ s e Zd ZdZdS )zRepository.DoesNotExistz Repository {} does not exist.N��__name__� __module__� __qualname__�__doc__� r, r, �5/usr/lib64/python3.9/site-packages/borg/repository.py� DoesNotExist{ s r. c @ s e Zd ZdZdS )zRepository.AlreadyExistsz"A repository already exists at {}.Nr' r, r, r, r- � AlreadyExists~ s r/ c @ s e Zd ZdZdS )z Repository.PathAlreadyExistsz!There is already something at {}.Nr' r, r, r, r- �PathAlreadyExists� s r0 c @ s e Zd ZdZdS )z!Repository.ParentPathDoesNotExistz:The parent path of the repo directory [{}] does not exist.Nr' r, r, r, r- �ParentPathDoesNotExist� s r1 c @ s e Zd ZdZdS )z Repository.InvalidRepositoryz0{} is not a valid repository. Check repo config.Nr' r, r, r, r- �InvalidRepository� s r2 c @ s e Zd ZdZdS )z"Repository.InvalidRepositoryConfigz?{} does not have a valid configuration. Check repo config [{}].Nr' r, r, r, r- �InvalidRepositoryConfig� s r3 c @ s e Zd ZdZdS )zRepository.AtticRepositoryz8Attic repository detected. Please run "borg upgrade {}".Nr' r, r, r, r- �AtticRepository� s r4 c @ s e Zd ZdZdS )zRepository.CheckNeededz3Inconsistency detected. Please run "borg check {}".Nr' r, r, r, r- � CheckNeeded� s r5 c s e Zd ZdZ� fdd�Z� ZS )zRepository.ObjectNotFoundz.Object with key {} not found in repository {}.c s$ t |t�rt|�}t� �||� d S �N)� isinstance�bytesr �super�__init__)�self�idZrepo�� __class__r, r- r: � s z"Repository.ObjectNotFound.__init__)r( r) r* r+ r: � __classcell__r, r, r= r- �ObjectNotFound� s r@ c @ s e Zd ZdZdS )z%Repository.InsufficientFreeSpaceErrorzNInsufficient free space to complete transaction (required: {}, available: {}).Nr' r, r, r, r- �InsufficientFreeSpaceError� s rA c @ s e Zd ZdZdS )z Repository.StorageQuotaExceededzJThe storage quota ({}) has been exceeded ({}). Try deleting some archives.Nr' r, r, r, r- �StorageQuotaExceeded� s rB FNTc C s� t j�|�| _td| j �| _d | _d | _d | _i | _d| _ || _ || _ || _ d| _ || _|| _|| _d| _d | _|| _| | _d S )Nz file://%sFr )�os�path�abspathr Z _location�io�lock�index� shadow_index� _active_txn� lock_wait�do_lock� do_create�created� exclusive� append_only� storage_quota�storage_quota_use�transaction_doomed�check_segment_magic�make_parent_dirs) r; rD �createrO rK rG rP rQ rT rU r, r, r- r: � s$ zRepository.__init__c C s | j r| �� dsJ d��d S )NFz&cleanup happened in Repository.__del__)rG �close�r; r, r, r- �__del__� s zRepository.__del__c C s d| j j� d| j� d�S )N�<� �>)r> r( rD rX r, r, r- �__repr__� s zRepository.__repr__c C s@ | j r d| _ | �| j� d| _| j| jt| j�| j| jd� | S )NFT)rK rG ) rM rV rD rN �open�boolrO rK rL rX r, r, r- � __enter__� s zRepository.__enter__c C sR |d urF|t u o|jtjk}| jr6|r6t�d� d}nd}| j|d� | �� d S )NzGNo space left on device, cleaning up partial transaction to free space.TF��cleanup)�OSError�errno�ENOSPCrJ �logger�warning� _rollbackrW )r; �exc_typeZexc_valZexc_tbZno_space_left_on_devicerb r, r, r- �__exit__� s zRepository.__exit__c C s t | j�S r6 )r r< rX r, r, r- �id_str� s zRepository.id_strc C sn zTt tj�| d�d��,}|�d�}d|v p0d|v W d � W S 1 sH0 Y W n tyh Y dS 0 dS )z;Check whether there is already a Borg repository at *path*.�README�rb�d s Borg Backup repositorys Borg repositoryNF)r^ rC rD �join�readrc )rD �fdZ readme_headr, r, r- � is_repository� s 4 zRepository.is_repositoryc C s� zt �|�}W n ty Y n60 | �|�r6| �|��t�|j�rLt �|�rV| �|��|}t j � t j � |t j ��}||kr|q�| �|�rV| �|��qVdS )a� Raise an exception if a repository already exists at *path* or any parent directory. Checking parent directories is done for two reasons: (1) It's just a weird thing to do, and usually not intended. A Borg using the "parent" repository may be confused, or we may accidentally put stuff into the "data/" or "data/<n>/" directories. (2) When implementing repository quotas (which we currently don't), it's important to prohibit folks from creating quota-free repositories. Since no one can create a repository within another repository, user's can only use the quota'd repository, when their --restrict-to-path points at the user's repository. N) rC �stat�FileNotFoundErrorrr r/ �S_ISDIR�st_mode�listdirr0 rD rE ro �pardir)r; rD �stZ previous_pathr, r, r- �check_can_create_repository� s z&Repository.check_can_create_repositoryc C s� | � |� | jr.tj�|tj�}tj|dd� tj�|�szzt�|� W n0 t yx } z| � |�|�W Y d}~n d}~0 0 t tj�|d�d��}|� t � W d � n1 s�0 Y t�tj�|d�� tdd�}|�d� |�dd d � |�dd tt�� |�dd tt�� |�dd tt| j��� | j�rH|�ddt| j�� n|�ddd� |�ddd� |�ddtt�d��� | �||� dS )z0Create a new empty repository at `path` T)�exist_okNrl �w�data�Z interpolation� repository�version�1�segments_per_dir�max_segment_sizerP rQ �0�additional_free_spacer< � )rz rU rC rD ro rx �makedirs�exists�mkdirrt r1 r^ �writeZREPOSITORY_READMEr Z add_section�set�strZDEFAULT_SEGMENTS_PER_DIRZDEFAULT_MAX_SEGMENT_SIZE�intrP rQ r �urandom� save_config)r; rD � parent_path�errrq �configr, r, r- rV s0 "( zRepository.createc C sj t j�|d�}t j�|d�}t j�|�r>t�d� t|dd� t j�|�r�d}zt �||� W nn ty� } z<|j t j t j t j t j t jt jfv r�t�|� n� W Y d }~n$d }~0 ty� t�|� Y n0 z6t|��}|�|� W d � n1 s�0 Y W nF t�yJ } z,| j�r � t�d|j|jf � W Y d }~n d }~0 0 t j�|��rft|dd� d S )Nr� z config.oldz=Old config file not securely erased on previous config updateT)Zavoid_collateral_damagez�Failed to securely erase old repository config file (hardlinks not supported). Old repokey data, if any, might persist on physical storage.�T%s: Failed writing to '%s'. This is expected when working on read-only repositories.)rC rD ro �isfilerf rg r �linkrc rd ZEMLINKZENOSYS�EPERMZEACCES�ENOTSUPZEIO�AttributeErrorr r� �PermissionErrorrL �strerror�filename)r; rD r� Z config_pathZold_config_pathZlink_error_msg�erq r, r, r- r� . s4 " , � zRepository.save_configc C s8 | j s J �|�d�}| j �dd|� | �| j| j � d S )N�utf-8r �key)r� �decoder� r� rD �r; Zkeydatar, r, r- �save_keyQ s zRepository.save_keyc C s | j jdddd��� }|�d�S )Nr r� � ��fallbackr� )r� �get�strip�encoder� r, r, r- �load_keyW s zRepository.load_keyc C s� | j r| j�� std��tj�| jd�}zDt|��(}tj t |� � �dd�W d � W S 1 s`0 Y W n t y� Y d S 0 d S )N�-bug in code, exclusive lock should exist here�nonce�big�� byteorder) rL rG �got_exclusive_lock�AssertionErrorrC rD ro r^ r� � from_bytesr rp rt )r; � nonce_pathrq r, r, r- �get_free_nonce\ s : zRepository.get_free_noncec C s� | j r| j�� std��| �� |kr,td��tj�| jd�}zHt |dd��(}|� t |j ddd��� W d � n1 sx0 Y W nB t y� } z*| j r�� t�d |j|jf � W Y d }~n d }~0 0 d S ) Nr� z6nonce space reservation with mismatched previous stater� F�Zbinary� r� r� r� )rL rG r� r� r� � ExceptionrC rD ro r r� r �to_bytesr� rf rg r� r� )r; Znext_unreservedZ start_noncer� rq r� r, r, r- �commit_nonce_reservationg s : �z#Repository.commit_nonce_reservationc C sB | j rt| jd ��| �� t�tj�| jd�� t�| j� dS )z.Destroy the repository at `self.path` � is in append-only moder� N) rP � ValueErrorrD rW rC �removero �shutil�rmtreerX r, r, r- �destroyx s zRepository.destroyc s2 t � fdd�t�� j�D ��}|r*|d S d S d S )Nc 3 sT | ]L}|� d �r|dd� �� rt�tj�� j|��jdkrt|dd� �V qdS )�index.� Nr )� startswith�isdigitrC rs rD ro �st_sizer� )�.0�fnrX r, r- � <genexpr>� s 6�z6Repository.get_index_transaction_id.<locals>.<genexpr>���)�sortedrC rw rD )r; �indicesr, rX r- �get_index_transaction_id� s �z#Repository.get_index_transaction_idc C sh | � � }| j�� }|d ur6|d u r6d| j }| �|��||krd|d urT||krTd }n|}| �||� d S )Nz,%s" - although likely this is "beyond repair)r� rF �get_segments_transaction_idrD r5 �replay_segments)r; �index_transaction_id�segments_transaction_id�msgZ replay_fromr, r, r- �check_transaction� s z Repository.check_transactionc C s | � � | �� S r6 )r� r� rX r, r, r- �get_transaction_id� s z Repository.get_transaction_idc C s t tj�| jd���� d S )NrG )r rC rD ro � break_lockrX r, r, r- r� � s zRepository.break_lockc C s | j d ur| j �||� d S r6 )rG � migrate_lock)r; Zold_idZnew_idr, r, r- r� � s zRepository.migrate_lockc C sN || _ zt�|�}W n ty0 | �|��Y n0 t�|j�sH| �|��|rlttj � |d�||d�� � | _ nd | _ t d d�| _ zDttj � | j d��� }| j �|� W d � n1 s�0 Y W n& ty� | �� | �| j ��Y n0 d| j �� v�r| �� | �|d��| j �dd�}|dk�r>| �� | �|d | ��t| j �dd ��| _| jtk�rv| �� | �|d t ��| j �dd �| _t| j jdd dd��| _| j�p�| j jdddd�| _| j d u �r�t| j jdddd��| _ t | j �dd�� � �| _ t | j | j| j�| _!| j"�rJ| j!�#� }|d u�rJ| j!�$|�t%k�rJ| �� | �&|��d S )NrG )�timeoutr~ r� r zno repository section foundr� r z;repository version %d is not supported by this borg versionr� zmax_segment_size >= %dr� r� r r� rP FrQ r< )'rD rC rs rt r. ru rv r2 r ro �acquirerG r r� r^ Z read_filerW Zsectionsr3 �getintr r� r� ZMAX_SEGMENT_SIZE_LIMITr� r� rP Z getbooleanrQ r r� r< �LoggedIOrF rT �get_latest_segment�get_segment_magic� ATTIC_MAGICr4 ) r; rD rO rK rG ry rq Z repo_version�segmentr, r, r- r^ � sV . � zRepository.openc C s0 | j r,| jr| j�� d | _| j �� d | _ d S r6 )rG rF rW �releaserX r, r, r- rW � s zRepository.close皙�����?c C s� | j r| j }| �� |�| �� | �� | j�� }| j�|d� | j| t j j 7 < |r�| j s�|r�| j� � D ]0\}}tj�|�dkrnd| j|< t j j | j|< qn| �|� | �� | �� dS )zCommit transaction r � N)rS �rollback�check_free_space�log_storage_quotarF � write_commit�segments� setdefault�compactr� � header_fmt�sizerP �segment_iteratorrC rD �getsize�compact_segments� write_index)r; � save_spacer� � thresholdZcleanup_commits� exceptionr� r� r, r, r- �commit� s$ zRepository.commitc C s� d| }t j�| j|�}z8t|d��}t�|�}W d � n1 sD0 Y W n tyd Y d S 0 |�d�dkr�t� d|�d�|� d S || � � S )N� integrity.%drm � versionr$ z'Unknown integrity data version %r in %s) rC rD ro r^ r �unpackrt r� rf rg r� )r; �transaction_idr� �integrity_fileZintegrity_pathrq � integrityr, r, r- �_read_integrity� s , zRepository._read_integrityc C s� |d u rt � S tj�| jd| �}| �|d�}z>t|d|d�� }t �|�W d � W S 1 s`0 Y W nn ttt fy� } zPt � d|� t� |� |s�� | � | �� � | jdd� | �| �� �W Y d }~S d }~0 0 d S )N�index.%d� indexF�r� �integrity_datazARepository index missing or corrupted, trying to recover from: %s)r� )r rC rD ro r� r" rp r� rc r# rf rg �unlink� prepare_txnr� r� � open_index)r; r� � auto_recover� index_pathr� rq �excr, r, r- r� s . zRepository.open_indexc C s� d| _ | jrV| j�� sV| jd ur(td��z| j�� W n ttfyT d| _ � Y n0 | j rd|d u r�z| j |dd�| _ W nN t t t fy� } z0t�d|� | �� | j |dd�| _ W Y d }~n d }~0 0 |d u r�i | _t� | _d| _| j�� �n�|�r| j�|� tj�| jd| �}tj�| jd| �}| � |d �}z>t |d|d ��}t � |�}W d � n1 �sj0 Y W nn t j t!t f�y� } zLt�d | � t"| t!��s�t�#|� t�#|� | �� | �$|� W Y d } ~ d S d } ~ 0 0 |d d k�rTt�%d|� |d | _t� | _d| _i | _t&|d �D ] } t�%d| � | �'| � �q*t�%d� nT|d dk�rtt d|d ��n4|d | _t|d �| _|�(dd�| _|�(di �| _| �)� | j�*� D ].\} } t+| �D ]} | |k�r�| �,| � �qʐq�d S )NTr� F)r� z9Checking repository transaction due to previous error: %sr �hints.%dr� � hintsr� zARepository hints file missing or corrupted, trying to recover: %sr� r zUpgrading from v1 hints.%d� segments� compactz%Rebuilding sparse info for segment %dz Upgrade to v2 hints completer$ z Unknown hints file version: %d� storage_quota_use� shadow_index)-rJ rL rG r� rO r� Zupgrader r rH r� r� rc r# rf rg r� r� � FreeSpacer� rR rI �clearrF rb rC rD ro r� r" r r� ZUnpackExceptionrt r7 r� r� �debugr� �_rebuild_sparser� r� �items�listr� ) r; r� � do_cleanupr� Z hints_pathr� r� rq �hintsr� r� r� Zshadowed_segmentsr, r, r- r� st & . zRepository.prepare_txnc C sT dd� }dd� }d| j | j| j| jd�}ddi}| j�� }|d usFJ �| jr�ttj � | j d�d ��,}t d |t � � t�f |d � W d � n1 s�0 Y d | }tj � | j |�}t|d |dd��$} t�|| � || � W d � n1 s�0 Y | j|d< d| } tj � | j | �} t| d | dd��$} | j�| � || � W d � n1 �s\0 Y | j|d< d| } tj � | j | �} t| d d��$} t�|| � || � W d � n1 �s�0 Y || � t| j � ||� || � t| j � d| }t�| j �D ]<}|�d��s �q |�|��r0�q t�tj � | j |�� �q d | _d S )Nc S s | � � t�| �� � d S r6 )�flushrC �fsync�fileno�rq r, r, r- �flush_and_syncf s z.Repository.write_index.<locals>.flush_and_syncc S s t �| d | � d S )N�.tmp)rC �replace��filer, r, r- � rename_tmpj s z*Repository.write_index.<locals>.rename_tmpr$ )r� r r r r r� Z transactions�aztransaction %d, UTC time %sr r r T)r� r� r r� r� r� �wbz.%d)r� zhints.z integrity.)r� r� rR rI rF r� rP r^ rC rD ro �printr �strftimeZ ISO_FORMATr" r �packr� rH r� r rw r� �endswithr� )r; r r r r� r� �logZ hints_nameZ hints_filerq Z index_nameZ index_fileZintegrity_namer� �current�namer, r, r- r� e sb � � ��$ & ( ( zRepository.write_indexc C s� | j �� d }t| j�d t| j�d d }||7 }|| j7 }| js�| jt }t| j�dk r�d}| j� � D ]4\}}z|| j � |�| 7 }W ql t y� Y ql0 qlt �d� t||�}t �d|� ||7 }n||7 }zt�| j�j}W n: t�y } z t �dt|� � W Y d}~dS d}~0 0 t �d |� d |� �� ||k �r�| j�r^t �d � | �� n | jd d � t|�} t|�} | � | | ��dS )zJPre-commit check for sufficient free space to actually perform the commit.� � i r zAcheck_free_space: few segments, not requiring a full free segmentzBcheck_free_space: calculated working space for compact as %d bytesz.Failed to check free space before committing: Nz!check_free_space: required bytes z , free bytes z@Not enough free space to initialize repository at this location.Tra ) rH r� �lenr� r� r� rP r� �MAX_OBJECT_SIZEr rF � segment_sizert rf r �minr� � disk_usagerD �freerc rg r� rN �errorr� rh r rA ) r; Zrequired_free_spaceZ hints_sizeZfull_segment_sizeZcompact_working_spacer� r( Z free_spaceZos_errorZformatted_requiredZformatted_freer, r, r- r� � s@ zRepository.check_free_spacec C s$ | j r t�dt| j�t| j �� d S )Nz!Storage quota: %s out of %s used.)rQ rf �infor rR rX r, r, r- r� � s �z Repository.log_storage_quotac s� �j st�d� dS �j}��� }�j}g �d ��fdd� }t�d|d � tt�j �dd d d �}t�j � � �D �]�\� }�j � � �s�t� d � � �j � = |� � qp�j �� �}d | | } | |ks�t�d� | d |� |� � qp|�� d� t�d� |� | d |� �j j� dd�D �] \} } } } | tk�r4�q�j�| �}|� | fk}| tk�r�|�r�z�j j| | dd�\}} W n. tj�y� |� �j �| | �\}} Y n0 || f�j| < |�|d� || d 7 < |� d 8 < �q| tk�r@|�s@z�j| �� � W n ttf�y Y n0 � jt| ��j j j 8 _n�| t k�r|�s| �jv}|�pzt � fdd��j| D ��}|du �p�� |k}|�s�|�r z�j j | dd�\}}W n, tj�y� |� �j � | �\}}Y n0 �j | |7 < |�|d� n8t�dt!| �� ||||�j�| �� �j| �s�j| = �q|� dk�sRJ d����"� � |� � qp|�#� |dd� �j �$� �j}t�%dt&|| �� t�d� dS ) zBCompact sparse segments by copying data into new segments z nothing to do: compact emptyNTc s� � j j| d�}� j�|d� � j| tjj7 < t� d| r@dnd|� �D ]@}t� d|� � j� |�}|dksxJ d��� j � |� � j|= qLg �d S )N�� intermediater z+complete_xfer: wrote %scommit at segment %dz intermediate r� z)complete_xfer: deleting unused segment %d�<Corrupted segment reference count - corrupted index or hints) rF r� r� r� r� r� r� r� rf r �pop�delete_segment)r, r� �count)r; �unusedr, r- � complete_xfer� s z2Repository.compact_segments.<locals>.complete_xferz'Compaction started (threshold is %i%%).rn zCompacting segments %3.0f%%r zrepository.compact_segments��totalr� �step�msgidz3segment %d not found, but listed in compaction datag �?z>not compacting segment %d (maybe freeable: %2.2f%% [%d bytes])g Y@r zNcompacting segment %d with usage count %d (maybe freeable: %2.2f%% [%d bytes]))� include_data)� raise_fullc 3 s | ]}|� k V qd S r6 r, )r� Zshadowed�r� r, r- r� : s z.Repository.compact_segments.<locals>.<genexpr>zIdropping DEL for id %s - seg %d, iti %r, knisi %r, spe %r, dins %r, si %rr- Fr+ z+compaction freed about %s repository space.zcompaction completed.)T)'r� rf r rR r� r� r r# r� r rF �segment_existsrg �showr% r� � iter_objects� TAG_COMMITrH r� �TAG_PUT� write_putr� � SegmentFullrI r� �KeyErrorr� �put_header_fmtr� � TAG_DELETE�any� write_deleter �append�finish�clear_empty_dirsr* r )r; r� Zquota_use_beforer� r� r2 �piZfreeable_spacer% Zfreeable_ratio�tagr� �offsetr} Zin_indexZis_index_objectZ new_segmentZkey_not_in_shadow_indexZshadowed_put_existsZdelete_is_not_stabler� Zquota_use_afterr, )r� r; r1 r- r� � s� � � � � " � zRepository.compact_segmentsc C s� | j }d | _ | j|dd� z�tdd� | j�� D ��}t|ddd�}t| j�� �D ]L\}\}}|�|� |d urx||krxqP||kr� q�| j�|�} | � || � qP|� � | � � W || _ | � � n|| _ | � � 0 d S )NF)r c s s | ] }d V qdS �r Nr, �r� �_r, r, r- r� � � z-Repository.replay_segments.<locals>.<genexpr>zReplaying segments %3.0f%%zrepository.replay_segments)r4 r� r6 ) rO r� �sumrF r� r � enumerater; r< � _update_indexrG r� r� ) r; r� r� Zremember_exclusive� segment_countrI �ir� r� �objectsr, r, r- r� z s, � �zRepository.replay_segmentsc C s� d| j |< |D �]l\}}}}|tkr�zJ| j| \}} | j| |7 < | j | d8 < | j�|g ��|� W n ty� Y n0 ||f| j|< | j | d7 < | j|7 _q|t k�r@z| j� |�\}}W n ty� Y n\0 | j � |��r|| j | d8 < | j j |||dd�}| j| |7 < | j�|g ��|� q|tk�rNqqd|� d|� �} |du �rt| �| ��q|| � q| j | dk�r�| j �|�| j|< dS )z2some code shared between replay_segments and checkr r F�� read_datazUnexpected tag z in segment N)r� r> rH r� rI r� rF rA rR rC r. rF r: rp r= r5 r% ) r; r� rU �reportrJ r� rK r� �srN r� r, r, r- rR � s> zRepository._update_indexc C s� z| j �|�}W n ty0 | j�|� Y dS 0 | j| dkrN|| j|< dS d| j|< | j j|dd�D ]X\}}}}|tkr�| j� |d�||fkr�| j| |7 < qh|t krh| j| |7 < qhdS )zNRebuild sparse bytes count for a single segment relative to the current index.Nr FrV )r� r� ) rF r% rt r� r. r� r< r> rH r� rC )r; r� r% rJ r� rK r� r, r, r- r � s zRepository._rebuild_sparser c s� | j r|rt| jd ��d� � fdd�}t�d� | jr<J �z"| �� }| �|�}t�d|� W n> t y� } z&| j � � }d}t�d|� W Y d}~n d}~0 0 |du r�t�d � | � � }|du r�t�d � | j � � }|du r�|d � dS |r�| j �|� | j � � }t�d |� t�d |� | �d� tdd� | j �� D ��} t�d| � t|�} |�r`| �r`J �| �rjdnd} | �r�| jjdddd�} t�d| d � n"d} | j�dd� | �| j| j� t�� } t| dddd �}d}t| j �� �D �]\}\}}|�|� || k�r �q�||k�r�q�t�d |� zt | j � |��}W nZ t �y� } z@|t |�� g }|�r~| j � ||� t | j � |��}W Y d}~n d}~0 0 | �s�| �!|||� | �r�t�� | | k�r�t�d |� | j�"ddt |�� | �| j| j� �q$�q�t�d |� | j�dd� | �| j| j� |�#� |�r`|du �r`|d |� �� |d | j _$| j �%� | �sdt�d!� |�rV|�sVt&|�t&| j'�k�r�|d"� |d#t&|�� |d$t&| j'�� n t�d%� d&}d'}| j'�(� D ]2\}}|�)||�}||k�r�||t*|�||� �q�|�(� D ]D\}}|| j'v �r(�q| j'�)||�}||k�r||t*|�||� �q|�rd| �+� | �,� � �r�|�r�t�d(| � n t�-d)| � n t�d*| � � �p�|S )+z�Check repository consistency This method verifies all segment checksums and makes sure the index is consistent with the data stored in the segments. r� Fc s d� t j| g|�R � d S )NT)rf r) )r� �args�Z error_foundr, r- � report_error� s z&Repository.check.<locals>.report_errorzStarting repository checkz&Read committed index of transaction %dNz#Failed to read committed index (%s)z No segments transaction foundz1No index transaction found, trying latest segmentz'This repository contains no valid data.z Segment transaction is %sz Determined transaction is %sc s s | ] }d V qdS rL r, rM r, r, r- r� � rO z#Repository.check.<locals>.<genexpr>zFound %d segmentsr Zfullr �last_segment_checkedr� r� zskipping to segments >= %dr zChecking segments %3.1f%%r� zrepository.checkr3 zchecking segment file %s...z:finished partial segment check, last segment checked is %dz$finished segment check at segment %dz Adding commit tag to segment z Starting repository index checkz Index object count mismatch.zcommitted index: %d objectszrebuilt index: %d objectszIndex object count match.z5ID: %-64s rebuilt index: %-16s committed index: %-16sz <not found>z8Finished %s repository check, errors found and repaired.z+Finished %s repository check, errors found.z0Finished %s repository check, no problems found.).rP r� rD rf r* rJ r� r� r r� rF r� r� r� rb r� rP r� r_ r� r� Z remove_optionr� �time� monotonicr rQ r; r r< r r� �recover_segmentrR r� rG r� r� r# rH � iteritemsr� r r� r� r) )r; Zrepairr� Z max_durationr\ r� Z current_indexr� r� rS r �moder] Zt_startrI r� rT r� rU r� Z line_formatZ not_foundr� �valueZ current_valuer, r[ r- �check� s� " � & zRepository.checkc c s� | j j|d�D ]�\}}|dur*||kr* q�zL| j j||p:ddd�D ]0\}}}}|durb||krb qt|||||fV qBW q ty� } z$t�d||t| �f � W Y d} ~ qd} ~ 0 0 qdS )a Very low level scan over all segment file entries. It does NOT care about what's committed and what not. It does NOT care whether an object might be deleted or superseded later. It just yields anything it finds in the segment files. This is intended as a last-resort way to get access to all repo contents of damaged repos, when there is uncommitted, but valuable data in there... When segment or segment+offset is given, limit processing to this location only. r9 Nr T)r� rK r7 z6Segment %d (%s) has IntegrityError(s) [%s] - skipping.)rF r� r< r rf r) r� ) r; r� rK Zcurrent_segmentr� rJ r� Zcurrent_offsetr} r� r, r, r- �scan_low_levelR s � �zRepository.scan_low_levelc C s, |r| j �| j �� � d| _d| _d| _dS )z NF)rF rb r� rH rJ rS )r; rb r, r, r- rh k s zRepository._rollbackc C s | j dd� d S )NFra )rh rX r, r, r- r� t s zRepository.rollbackc C s | j s| �| �� �| _ t| j �S r6 )rH r� r� r# rX r, r, r- �__len__x s zRepository.__len__c C s | j s| �| �� �| _ || j v S r6 )rH r� r� )r; r< r, r, r- � __contains__} s zRepository.__contains__c C s4 | j s| �| �� �| _ dd� t| j j|d�|�D �S )zd list <limit> IDs starting from after id <marker> - in index (pseudo-random) order. c S s g | ] \}}|�qS r, r, )r� �id_rN r, r, r- � <listcomp>� rO z#Repository.list.<locals>.<listcomp>)�marker)rH r� r� r ra )r; �limitrj r, r, r- r � s zRepository.listc C s� |dur|dk rt d��| js2| �� }| �|�| _|du }|rBdn| j| \}}g }| j�|�D ]�\}} | jj||ddd�} zt| �\} } } }W n tt fy� Y q`Y n0 |dkr�d}q|| t kr||| f| j� | �kr||� | � t |�|kr|| S q|q`|S )a� list <limit> IDs starting from after id <marker> - in on-disk order, so that a client fetching data in this order does linear reads and reuses stuff from disk cache. We rely on repository.check() has run already (either now or some time before) and that: - if we are called from a borg check command, self.index is a valid, fresh, in-sync repo index. - if we are called from elsewhere, either self.index or the on-disk index is valid and in-sync. - the repository segments are valid (no CRC errors). if we encounter CRC errors in segment entry headers, rest of segment is skipped. Nr z$please use limit > 0 or limit = None)r r F)rW r7 r )r� rH r� r� rF r� r< �next� StopIterationr r> r� rF r# )r; rk rj r� Zat_startZ start_segmentZ start_offset�resultr� r� Z obj_iteratorrJ r< rK r� r, r, r- �scan� s, zRepository.scanc C s^ | j s| �| �� �| _ z | j | \}}| j�|||�W S tyX | �|| j�d �Y n0 d S r6 )rH r� r� rF rp rA r@ rD )r; r< r� rK r, r, r- r� � s zRepository.getc c s |D ]}| � |�V qd S r6 )r� )r; �idsZ is_preloadedrh r, r, r- �get_many� s zRepository.get_manyc C s� | j s| �| �� � z| j| \}}W n ty8 Y n0 | �|||� | j�||�\}}| jt |�| jj j 7 _| j � |d� | j | d7 < ||f| j|< | jr�| j| jkr�| �t| j�t| j��| _| j�dS )z�put a repo object Note: when doing calls with wait=False this gets async and caller must deal with async results / exceptions later. r r N)rJ r� r� rH rA �_deleterF r? rR r# rB r� r� r� rQ rB r rS )r; r< r} �waitr� rK r, r, r- �put� s" �zRepository.putc C s^ | j s| �| �� � z| j�|�\}}W n" tyJ | �|| j�d�Y n0 | �|||� dS )z�delete a repo object Note: when doing calls with wait=False this gets async and caller must deal with async results / exceptions later. N) rJ r� r� rH r. rA r@ rD rr )r; r< rs r� rK r, r, r- �delete� s zRepository.deletec C s� | j �|g ��|� | j| d8 < | jj|||dd�}| j| |7 < | j�|�\}}| j| |7 < | j�|d� d S )Nr FrV r )rI r� rF r� rF rp r� rE )r; r< r� rK r� r, r, r- rr � s zRepository._deletec C s dS )aC Get one async result (only applies to remote repositories). async commands (== calls with wait=False, e.g. delete and put) have no results, but may raise exceptions. These async exceptions must get collected later via async_response() calls. Repeat the call until it returns None. The previous calls might either return one (non-None) result or raise an exception. If wait=True is given and there are outstanding responses, it will wait for them to arrive. With wait=False, it will only return already received responses. Nr, )r; rs r, r, r- �async_response� s zRepository.async_responsec C s dS )z>Preload objects (only applies to remote repositories) Nr, )r; rp r, r, r- �preload s zRepository.preload)FFNTFNTF)NT)FTr� F)T)T)N)FFr )NN)NN)NN)F)T)T)T)Cr( r) r* r+ r r. r/ r0 r1 r2 r3 r4 r r5 r@ rA rB r: rY r] r` rj �propertyrk � staticmethodrr rz rV r� r� r� r� r� r� r� r� r� r� r� r^ rW r� r� r� r� r� r� r� r� r� rR r rd re rh r� rf rg r ro r� rq rt ru rr rv rw r, r, r, r- r& 5 s� E � # # 2 IG9 ) + r& c @ s� e Zd ZG dd� de�Ze�d�Zejdks0J �e�d�Z e jdksHJ �e�d�Z e jdks`J �e�d �Z e jd ksxJ �e � de �Ze � ee��e ZdDd d �Zdd� Zdd� Zeefdd�Zeefdd�ZdEdd�Zdd� Zd d � Z d d � Z d d!� Z d"d#� Z dFd$d%�Z d&d'� Z!d(d)� Z"d*d+� Z#d,d-� Z$d.d/� Z%d0d1� Z&d2d3� Z'dGd6d7�Z(d8d9� Z)dHd:d;�Z*dId<d=�Z+dJd>d?�Z,dKd@dA�Z-dLdBdC�Z.dS )Mr� c @ s e Zd ZdZdS )zLoggedIO.SegmentFullz2raised when a segment is full, before opening nextNr' r, r, r, r- r@ s r@ z<IIB� z<IIB32s�) z<IB� z<Ir! �Z c C s> || _ t|| jd�| _d| _|| _|| _d| _d | _d| _ d S )N)Zdisposer ) rD r � _close_fd�fdsr� rk r� rK � _write_fd� _fds_cleaned)r; rD rk r� Zcapacityr, r, r- r: s zLoggedIO.__init__c C s | � � | j�� d | _d S r6 )� close_segmentr r rX r, r, r- rW % s zLoggedIO.closec C s& |\}}t |�� ddd� |�� d S )Nr ZDONTNEED)r r rW )r; �ts_fd�tsrq r, r, r- r~ * s zLoggedIO._close_fdc s � �fdd�t �|�D �}|S )z�Returns generator yielding required segment dirs in data_dir as `os.DirEntry` objects. Start and end are inclusive. c 3 sB | ]:}|� � r|j�� r�t|j� kr2� krn q|V qd S r6 )�is_dirr r� r� �r� �f�� end_index� start_indexr, r- r� 3 s 0�z,LoggedIO.get_segment_dirs.<locals>.<genexpr>�rC �scandir)r; �data_dirr� r� � segment_dirsr, r� r- �get_segment_dirs/ s �zLoggedIO.get_segment_dirsc s � �fdd�t �|�D �}|S )z�Returns generator yielding required segment files in segment_dir as `os.DirEntry` objects. Start and end are inclusive. c 3 sB | ]:}|� � r|j�� r�t|j� kr2� krn q|V qd S r6 )�is_filer r� r� r� r� r, r- r� > s 0�z-LoggedIO.get_segment_files.<locals>.<genexpr>r� )r; � segment_dirr� r� Z segment_filesr, r� r- �get_segment_files: s �zLoggedIO.get_segment_filesNFc c s� |d u r|st nt}|| j }tj�| jd�}|sB| j||d�}n| j||d�}t|dd� |d�}|D ]T}|s~| j||d�}n| j||d�}t|dd� |d�}|D ]}t |j �|jfV q�qfd S )Nr} )r� )r� c S s t | j�S r6 �r� r )�dirr, r, r- �<lambda>N rO z+LoggedIO.segment_iterator.<locals>.<lambda>)r� �reversec S s t | j�S r6 r� r r, r, r- r� T rO ) �MIN_SEGMENT_INDEX�MAX_SEGMENT_INDEXr� rC rD ro r� r� r� r� r ) r; r� r� Zstart_segment_dirZ data_path�dirsr� �filesr r, r, r- r� E s zLoggedIO.segment_iteratorc C s | j dd�D ]\}}| S d S )NT�r� )r� �r; r� r� r, r, r- r� Z s zLoggedIO.get_latest_segmentc C s, | j dd�D ]\}}| �|�r | S q dS )z+Return the last committed segment. Tr� N)r� �is_committed_segmentr� r, r, r- r� _ s z$LoggedIO.get_segments_transaction_idc C s^ | � � |d | _d}| jdd�D ](\}}||krF| �|� |d7 }q" qLq"t�d||� dS )z:Delete segment files left by aborted transactions r r Tr� zICleaned up %d uncommitted segment files (== everything after segment %d).N)r� r� r� r/ rf r )r; r� r0 r� r� r, r, r- rb g s �zLoggedIO.cleanupc C sF z| � |�}W n ty" Y dS 0 t| �|�d���}z|�| jj tj� W nN t y� } z6|j t j kr�W Y d}~W d � dS |�W Y d}~n d}~0 0 |� | jj�| j kr�W d � dS W d � n1 s�0 Y d}zt|�\}}}} W n. t�y Y dS t�y& Y �qBY n0 |tk�r8d}q�|r�dS q�|S )z4Check if segment ends with a COMMIT_TAG tag Frm NT)r< r r^ �segment_filename�seekr� r� rC �SEEK_ENDrc rd �EINVALrp �COMMITrl rm r= ) r; r� �iteratorrq r� Z seen_commitrJ r� rK rN r, r, r- r� v s4 . z LoggedIO.is_committed_segmentc C s" t j�| jdt|| j �t|��S )Nr} )rC rD ro r� r� �r; r� r, r, r- r� � s zLoggedIO.segment_filenamec C s� |s,|s| j r,| j | jkr,|r$| j�| �� | js�| j| j dkr�tj� | jdt | j| j ��}tj� |�s�t� |� t tj� | jd�� t| �| j�dd�| _| j�t� t| _ | j| jv r�| j| j= | jS )Nr r} Tr� )rK rk r@ r� r� r� r� rC rD ro r� r� r� r r r� r� �MAGIC� MAGIC_LENr )r; �no_new�want_newr8 �dirnamer, r, r- � get_write_fd� s zLoggedIO.get_write_fdc sn t �� � � ��fdd�}� �fdd�}|� z�j� \}}W n tyV |� }Y n0 �j��� |f� |S )Nc s" t ����d�} � | f�j�< | S )Nrm )r^ r� r r ��nowr� r; r, r- �open_fd� s z LoggedIO.get_fd.<locals>.open_fdc sP � �j td krL� �_ t�j�� �D ]$\} }|\}}� | tkr&�j| = q&d S )Nr� )r� Z FD_MAX_AGEr r r )�kr� r� rq )r� r; r, r- � clean_old� s z"LoggedIO.get_fd.<locals>.clean_old)r^ r_ r rA Zupd)r; r� r� r� r� rq r, r� r- �get_fd� s zLoggedIO.get_fdc C s6 | j d }| _ |d ur2| jd7 _d| _|�� d S )Nr r )r� r� rK rW )r; rq r, r, r- r� � s zLoggedIO.close_segmentc C s< || j v r| j |= zt| �|�� W n ty6 Y n0 d S r6 )r r r� rt r� r, r, r- r/ � s zLoggedIO.delete_segmentc C sR t j�| jd�}| �|�}|D ]&}zt �|� W q tyB Y q 0 q t|� dS )zDDelete empty segment dirs, i.e those with no segment files. r} N)rC rD ro r� �rmdirrc r )r; r� r� r� r, r, r- rH � s zLoggedIO.clear_empty_dirsc C s" | � |�}tj�|�o tj�|�S r6 )r� rC rD r� r� r� r, r, r- r: � s zLoggedIO.segment_existsc C s t j�| �|��S r6 )rC rD r� r� r� r, r, r- r% � s zLoggedIO.segment_sizec C s | � |�}|�d� |�t�S )Nr )r� r� rp r� )r; r� rq r, r, r- r� � s zLoggedIO.get_segment_magicr Tc c s� | � |�}|�|� |dkrD|�t�tkr@td|� dd� d���t}|�| jj�}|r�| j|| j|||t t t f|d�\}}} } |r�|| || fV n|| ||fV ||7 }| � |�}|�|� |�| jj�}qRdS )a7 Return object iterator for *segment*. If read_data is False then include_data must be False as well. Integrity checks are skipped: all data obtained from the iterator must be considered informational. The iterator returns four-tuples of (tag, key, offset, data|size). r z Invalid segment magic [segment z , offset �]rV N) r� r� rp r� r� r r� r� �_readr> rC r= ) r; r� rK r7 rW rq �headerr� rJ r� r} r, r, r- r< � s& � zLoggedIO.iter_objectsc C s� t �d| � || jv r | j|= tj�|�t| jj k rrt |dd��}|� t � W d � n1 sd0 Y d S t |dd���P}t |d���"}t j |�� dt jd���}t|�}|}z�|� t � t|�| jjk�rh| j�|d | jj� �\} } } | tk�s:| tk�s:| | jjk �s:| t|�k�s:t|d| � �d@ | k�rH|d d � }q�|� |d | � � || d � }q�W ~|�� n ~|�� 0 W d � n1 �s�0 Y W d � n1 �s�0 Y W d � n1 �s�0 Y d S ) Nzattempting to recover Tr� rm r )�accessr! � �� r )rf r* r rC rD r� r� r� r� r r� r� r^ �mmapr Z ACCESS_READ� memoryviewr# r� r$ � MAX_TAG_IDr! r� ) r; r� r� rq Zdst_fdZsrc_fdZmmr} �d�crcr� rJ r, r, r- r` " s: ( " �� �zLoggedIO.recover_segmentc C s� || j kr| jr| j�� | �|�}|�|� |�| jj�}| �|| j|||t f|�\}}} } || krvt d� ||���|r~| S |S )z� Read entry from *segment* at *offset* with *id*. If read_data is False the size of the entry is returned instead and integrity checks are skipped. The return value should thus be considered informational. zJInvalid segment entry header, is not for wanted id [segment {}, offset {}]) r� r� �syncr� r� rp rB r� r� r> r �format) r; r� rK r< rW rq r� r� rJ r� r} r, r, r- rp A s "�z LoggedIO.readc C s( t |�tksJ d��z|�|�}W n: tjy\ } z td�||| ��d �W Y d } ~ n d } ~ 0 0 || ju rv|\} } } } n"|| ju r�|\} } } d } nt d��| t kr�td�| ||���| |j k r�td�| ||���| |j }|�rv|� |�}t |�|k�rtd�|||t |����t|tt|�dd � ��d@ | k�rBtd �||���| d u �r| ttfv �r|d d � |d d � } }n�| d u �r�| ttfv �r�|� d �} |d 8 }t | �d k�r�td �||d t | ����|�� }|�|tj�| }d }||k�rtd �||||���| |v�r td �||���| | | |fS )Nz7Exceeding MAX_TAG_ID will break backwards compatibilityz8Invalid segment entry header [segment {}, offset {}]: {}z$_read called with unsupported formatz?Invalid segment entry size {} - too big [segment {}, offset {}]zAInvalid segment entry size {} - too small [segment {}, offset {}]zPSegment entry data short read [segment {}, offset {}]: expected {}, got {} bytesr! r� z7Segment entry checksum mismatch [segment {}, offset {}]r� zOSegment entry key short read [segment {}, offset {}]: expected {}, got {} byteszPSegment entry data short seek [segment {}, offset {}]: expected {}, got {} byteszPInvalid segment entry header, did not get acceptable tag [segment {}, offset {}])�maxr� r� �structr) r r� rB r� � TypeErrorr$ r� rp r# r! r� r> rC �tellr� rC �SEEK_CUR)r; rq �fmtr� r� rK Zacceptable_tagsrW Z hdr_tupler� r� r� rJ r� �lengthr} ZoldposZseekedr, r, r- r� S sn �� � � �$� � � �zLoggedIO._readc C s� t |�}|tkr&td|� dt� d���| j|tjk|d�}|| jj }| j}| j � |t �}| j � t |t |t |���d@ �} |�d�| |||f�� | j|7 _| j|fS )Nz More than allowed put data [z > r� �r� r8 r� rO )r# Z MAX_DATA_SIZEr r� r � MANIFEST_IDrB r� rK �header_no_crc_fmtr r> �crc_fmtr! r� ro r� ) r; r< r} r8 � data_sizerq r� rK r� r� r, r, r- r? � s zLoggedIO.write_putc C sv | j |tjk|d�}| j�| jjt�}| j�t |t |��d@ �}|� d� |||f�� | j | jj7 _ | j | jjfS )Nr� r� rO )r� r r� r� r rB r� rC r� r! r� ro rK r� )r; r< r8 rq r� r� r, r, r- rE � s zLoggedIO.write_deletec C sh | j | |d�}|r |�� | j�| jjt�}| j�t|�d@ �}|� d� ||f�� | � � | j d S )N)r� r� r� rO r ) r� r� r� r r� r� r= r� r! r� ro r� r� )r; r, rq r� r� r, r, r- r� � s zLoggedIO.write_commit)r} )NF)FFF)r FT)T)T)F)F)F)/r( r) r* r� r@ r� �Structr� r� rB r� r� r r= Z_commitr! r� r: rW r~ ZMIN_SEGMENT_DIR_INDEXZMAX_SEGMENT_DIR_INDEXr� r� r� r� r� r� r� rb r� r� r� r� r� r/ rH r: r% r� r< r` rp r� r? rE r� r, r, r, r- r� sJ % 7 r� r{ )Drd r� rC r� rs r� r^ Zbinasciir r � collectionsr Z configparserr � functoolsr � itertoolsr Z constantsZ hashindexr Zhelpersr r r r r r r r r r r r r Zlockingr r r rf r Zlrucacher �platformr r r r Zalgorithms.checksumsr! Zcrypto.file_integrityr" r# r( r� r# r� r� r> rC r= r� r� r r& r� rB r� r, r, r, r- �<module> sh ^ &