| Server IP : 104.21.74.243 / Your IP : 216.73.216.47 Web Server : Apache System : Linux infong-es77 4.4.400-icpu-108 #2 SMP Wed Feb 11 10:12:42 UTC 2026 x86_64 User : u67207989 ( 1351568) PHP Version : 8.4.24 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3/dist-packages/breezy/bzr/__pycache__/ |
Upload File : |
a
�*�^�N � @ s� d Z ddlmZ g d�ZddlmZmZmZm Z ddl
m Z ddl m
Z
ddlmZ dd lmZ d
d lmZmZ G d d
� d
e�ZG dd� de�ZG dd� de�ZG dd� de�ZdS )zCReconcilers are able to fix some potential data errors in a branch.� )�absolute_import)�BranchReconciler�KnitReconciler�PackReconciler�VersionedFileRepoReconciler� )�cleanup�errors�revision�ui)�ReconcileResult)�gettext)�mutter)� topo_sort� )�AdapterFactory�ChunkedContentFactoryc @ sj e Zd ZdZddd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� ZdS )r ay Reconciler that reconciles a repository.
The goal of repository reconciliation is to make any derived data
consistent with the core data committed by a user. This can involve
reindexing, or removing unreferenced data if that can interfere with
queries in a given repository.
Currently this consists of an inventory reweave with revision cross-checks.
NFc C s" d| _ d| _d| _|| _|| _dS )z�Construct a RepoReconciler.
:param thorough: perform a thorough check which may take longer but
will correct non-data loss issues such as incorrect
cached data.
r FN)�garbage_inventories�inconsistent_parents�aborted�repo�thorough)�selfr �otherr � r �6/usr/lib/python3/dist-packages/breezy/bzr/reconcile.py�__init__4 s
z$VersionedFileRepoReconciler.__init__c C s� | j �� �t tj�� �J| _| �� t� }| j|_| j |_ | j
|_
|W d � W d � S 1 sf0 Y W d � n1 s�0 Y dS )an Perform reconciliation.
After reconciliation the following attributes document found issues:
* `inconsistent_parents`: The number of revisions in the repository
whose ancestry was being reported incorrectly.
* `garbage_inventories`: The number of inventory objects without
revisions that were garbage collected.
N) r �
lock_writer �
ui_factory�nested_progress_bar�pb�_reconcile_stepsr r r r �r Zretr r r � reconcileA s
�z%VersionedFileRepoReconciler.reconcilec C s | � � dS )�/Perform the steps to reconcile this repository.N)�_reweave_inventory�r r r r r! T s z,VersionedFileRepoReconciler._reconcile_stepsc C s� | j �� }| j�td�� | j j| _| j j| _dd� | j�� D �| _ i | _
d| _ | � t
| j �� | j D ]}| �|� qf| �� | j s�| jr�| js�tj�td�� dS | j�td�dd� | j �� tj�td�� | j �� }| � t
| j
�� d d
� t| j
�D �}| �| j�|d d �| jt|��}|� |� t|�� �d
d� | j D �k�sNt � �| j�td�� | j � � d| _tj�td�� dS )a` Regenerate the inventory weave for the repository from scratch.
This is a smart function: it will only do the reweave if doing it
will correct data issues. The self.thorough flag controls whether
only data-loss causing issues (!self.thorough) or all issues
(self.thorough) are treated as requiring the reweave.
zReading inventory datac S s h | ] }|d �qS ����r ��.0�keyr r r � <setcomp>e � zAVersionedFileRepoReconciler._reweave_inventory.<locals>.<setcomp>r �
Inventory ok.N�Backing up inventoryzBackup inventory created.c S s g | ]
}|f�qS r r )r* �rev_idr r r �
<listcomp>~ r- zBVersionedFileRepoReconciler._reweave_inventory.<locals>.<listcomp>� unorderedTc S s h | ]
}|f�qS r r �r* �revidr r r r, � r- �
Writing weave�Inventory regenerated.) r �get_transactionr �updater
� inventories� inventory� revisions�keys�pending�
_rev_graphr � _setup_steps�len�_graph_revision�_check_garbage_inventoriesr r r r �note�_backup_inventory�_temp_inventoriesr �_change_inv_parents�get_record_stream�_new_inv_parents�set�insert_record_stream�AssertionError�_activate_new_inventory)r � transactionr0 �new_inventories�
revision_keys�streamr r r r% X sL
��
�
�
z.VersionedFileRepoReconciler._reweave_inventoryc C s t dd� | j|d D ��S )z/Lookup ghost-filtered parents for revision_key.c S s g | ]
}|f�qS r r r3 r r r r1 � r- z@VersionedFileRepoReconciler._new_inv_parents.<locals>.<listcomp>r( )�tupler> )r � revision_keyr r r rH � s z,VersionedFileRepoReconciler._new_inv_parentsc c sf |D ]\}||j �}|rB|d |vrB|�d�}t|j ||j|�V nt|j ||�}|V | �d� qdS )z/Adapt a record stream to reconcile the parents.r �chunkedzadding inventoriesN)r+ � get_bytes_asr �sha1r �
_reweave_step)r rP Z get_parentsZall_revision_keys�recordZwanted_parents�chunksZadapted_recordr r r rF � s
�z/VersionedFileRepoReconciler._change_inv_parentsc C s || _ d| _dS )z6Setup the markers we need to control the progress bar.r N)�total�count)r Z new_totalr r r r? � s z(VersionedFileRepoReconciler._setup_stepsc C sT | � d� | j�|�}g }|jD ]$}| �|�r:|�|� q td|� q || j|< dS )z(Load a revision into the revision graph.zloading revisionszfound ghost %sN)rV r Zget_revision_reconcileZ
parent_ids�_parent_is_available�appendr r> )r r0 Zrev�parents�parentr r r rA � s
z+VersionedFileRepoReconciler._graph_revisionc C sV | j s
dS t| j�� �}t| j�� �}|�|�}t|�| _|D ]}td|d � q>dS )z�Check for garbage inventories which we cannot trust
We cant trust them because their pre-requisite file data may not
be present - all we know is that their revision was not installed.
Nz Garbage inventory {%s} found.r( ) r rI r: r< r; �
differencer@ r r )r r9 r; ZgarbagerR r r r rB � s
z6VersionedFileRepoReconciler._check_garbage_inventoriesc C s6 || j v rdS dt| j�|fg��k}|o4| j�|�S )z�True if parent is a fully available revision
A fully available revision has a inventory and a revision object in the
repository.
Tr )r> r@ r: �get_parent_mapr Z has_revision)r r^ Z inv_presentr r r r[ � s
z0VersionedFileRepoReconciler._parent_is_availablec C s& | j �|| j| j� | jd7 _dS )z,Mark a single step of regeneration complete.r N)r r8 rZ rY )r �messager r r rV � s z)VersionedFileRepoReconciler._reweave_step)NF)�__name__�
__module__� __qualname__�__doc__r r# r! r% rH rF r? rA rB r[ rV r r r r r ) s
6 r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
r z�Reconciler that reconciles a knit format repository.
This will detect garbage inventories and remove them in thorough mode.
c C sD | j r@z | �� W n tjy. d| _Y dS 0 | �� | �� dS )r$ TN)r �
_load_indexesr Z
BzrCheckErrorr �
_gc_inventory�_fix_text_parentsr& r r r r! � s z KnitReconciler._reconcile_stepsc C sj | j �� | _| j�td�dd� | j j| _| j�td�dd� | j �� | j j | _ | j�td�dd� dS )z$Load indexes for the reconciliation.zReading indexesr r r N)
r r7 rM r r8 r
r9 r: Z(_check_for_inconsistent_revision_parentsr; r& r r r rf � s
z KnitReconciler._load_indexesc C s0 | j �td�dd� | �� | j �td�dd� | jsJtj�td�� dS | j �td�dd� | j� � tj�td�� | j�
� }| j � | j �
� �}t|�}d d
� |D �}| �t|�� | �| j�|d d �|jt|��}|�|� t|�
� �t|�ks�t� �| j �td
�� | j�� d| _tj�td�� dS )zCRemove inventories that are not referenced from the revision store.zChecking unused inventoriesr r � r. Nr/ zBackup Inventory createdc S s g | ] }|d �qS r' r r) r r r r1 r- z0KnitReconciler._gc_inventory.<locals>.<listcomp>r2 Tr5 r6 )r r8 r
rB r r r rC r rD rE r; r` r< r r? r@ rF r: rG � __getitem__rI rJ rK rL )r rN �graphrO Z revision_idsrP r r r rg � s4
�
z KnitReconciler._gc_inventoryc st | j �� }dd� | j�� D �}tdt|�� | j �� }|�| j j| j �\}}|j
}i }|D ]}i ||d < qZ|� � D ]\\}} |d � |d }
t dd� | d D ��} t dd� | d D ��} |�
� i �}
| | f|
|
< qti }|D ]"}|�
|d g �}|�|d � q�t|�D ]h\}� | j �td�|t|�� |� }t� fd d
�|D ��}� |v �rX|� }ng }| �� |||� �qd S ) a[ Fix bad versionedfile parent entries.
It is possible for the parents entry in a versionedfile entry to be
inconsistent with the values in the revision and inventory.
This method finds entries with such inconsistencies, corrects their
parent lists, and replaces the versionedfile with a corrected version.
c S s g | ] }|d �qS r' r r) r r r r1 r- z4KnitReconciler._fix_text_parents.<locals>.<listcomp>z3Prepopulating revision text cache with %d revisionsr r c S s g | ] }|d �qS r' r �r* r^ r r r r1 , r- c S s g | ] }|d �qS r' r rl r r r r1 - r- zFixing text parentsc 3 s" | ]}|d � kr|d V qdS )r r( Nr r) ��file_idr r � <genexpr>9 s �z3KnitReconciler._fix_text_parents.<locals>.<genexpr>N)r r7 r; r< r r@ Z_get_versioned_file_checkerZcheck_file_version_parents�textsr �
text_index�itemsrQ �
setdefaultr\ � enumerater8 r
rI �_fix_text_parent)r rM ZversionsZ
vf_checkerZ bad_parents�unused_versionsrq Zper_id_bad_parentsr+ Zdetailsr0 Z knit_parentsZcorrect_parentsZ file_detailsZfile_id_versionsZtext_keyZ
versions_listZnum�versions_with_bad_parentsZid_unused_versionsZ
file_versionsr rm r rh sH
�
� �
�z KnitReconciler._fix_text_parentsc s t d|t|�� t dt|�� d| � i �t� }|D ]x}||v rDq4n@||v rZ|| d }n*| jj�||fg�}dd� |||f D �}� fdd�|D ��� |f< |�||f� q4� �fdd �} | jj�|d
d �}
| j�� � | jj� | |
�� | j�|� t���r| j�
� |� d S )
z9Fix bad versionedfile entries in a single versioned file.z$fixing text parent: %r (%d versions)z(%d are unused)s temp:%sr c S s g | ] }|d �qS r' r r) r r r r1 T r- z3KnitReconciler._fix_text_parent.<locals>.<listcomp>c s g | ] }� |f�qS r r rl )� new_file_idr r r1 U s c 3 s@ | D ]6}|� d�}� |jd f}�| }t|||j|�V qd S )NrS r( )rT r+ r rU )rP rW rX Znew_keyr] �rx Z new_parentsr r � fix_parentsY s
z4KnitReconciler._fix_text_parent.<locals>.fix_parentsZ topologicalTN) r r@ rI r rp r` �addrG Z_remove_file_idrJ Z
_move_file_id) r rn rw rv Z all_versionsZ needed_keys�versionr] Zpmaprz rP r ry r ru D s6 �
��
z KnitReconciler._fix_text_parentN) rb rc rd re r! rf rg rh ru r r r r r � s
2r c s2 e Zd ZdZd
� fdd� Zdd� Zdd � Z� ZS ) r ax Reconciler that reconciles a pack based repository.
Garbage inventories do not affect ancestry queries, and removal is
considerably more expensive as there is no separate versioned file for
them, so they are not cleaned. In short it is currently a no-op.
In future this may be a good place to hook in annotation cache checking,
index recreation etc.
NFc s t t| �j|||d� || _d S )N)r r )�superr r �canonicalize_chks)r r r r r~ �� __class__r r r z s �zPackReconciler.__init__c C s� | j s
dS | jj}|�� |�� z�|�� }| j�� }tt|j j
� � ��}t|�r�| j rb| jj
}n| jj}|||d|| j�}|dur�| �|� n
| �|� |tt|j j
� � �� | _W |�� n
|�� 0 dS )r$ Nz
.reconcile)r r �_pack_collectionZ
ensure_loadedZ
lock_namesZ all_packsZall_revision_idsr@ �listZinventory_indexZcombined_indexZiter_all_entriesr~ Z_canonicalize_chks_packZ_reconcile_packr �_discard_and_saver Z
_unlock_names)r Z
collection�packsZ
all_revisionsZtotal_inventoriesZreconcile_methZnew_packr r r r! � s2
�
�
� z PackReconciler._reconcile_stepsc C s6 |D ]}| j j�|� q| j j�� | j j�|� dS )ae Discard some packs from the repository.
This removes them from the memory index, saves the in-memory index
which makes the newly reconciled pack visible and hides the packs to be
discarded, and finally renames the packs being discarded into the
obsolete packs directory.
:param packs: The packs to discard.
N)r r� Z_remove_pack_from_memoryZ_save_pack_namesZ_obsolete_packs)r r� Zpackr r r r� � s
z PackReconciler._discard_and_save)NFF)rb rc rd re r r! r� �
__classcell__r r r r r h s � r c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d
� Zd S )
r z"Reconciler that works on a branch.Fc C s d | _ || _|| _d S �N)�
fixed_historyr �branch)r Za_branchr r r r r � s zBranchReconciler.__init__c C s| | j �� �^ tj�� �4| _t� }| �� |_|W d � W d � S 1 sP0 Y W d � n1 sn0 Y d S r� ) r� r r r r r r r! r� r" r r r r# � s �
zBranchReconciler.reconcilec C s | � � S r� )�_reconcile_revision_historyr& r r r r! � s z!BranchReconciler._reconcile_stepsc C s� | j �� \}}g }| j j�� }z$|�|tjf�D ]}|�|� q0W n tj yV Y n0 |�
� |t |�kr�t j
�td��|t |��� | j �t |�|� dS t j
�td�� dS d S )Nz%Fixing last revision info {0} => {1}Tzrevision_history ok.F)r� Zlast_revision_infoZ
repositoryZ get_graphZiter_lefthand_ancestry�
_mod_revisionZ
NULL_REVISIONr\ r ZRevisionNotPresent�reverser@ r r rC r
�formatZset_last_revision_info)r Z
last_revnoZlast_revision_idZ real_historyrk r4 r r r r� � s* � � �z,BranchReconciler._reconcile_revision_historyN)F)rb rc rd re r r# r! r� r r r r r � s
r N)re Z
__future__r �__all__� r r r
r� r r# r Zi18nr
Ztracer Ztsortr Z
versionedfiler r �objectr r r r r r r r �<module> s . E