Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
mercurial
/
revlogutils
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: rewrite.cpython-310.pyc
o �]Lb@s � @ s\ d dl Z d dlZd dlZd dlZddlmZ ddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZ ddlmZ ddlmZmZm Z m Z m Z ddl m Z dd lmZm!Z! d0d d �Z"d0d d�Z#d0dd�Z$dd� Z%dd� Z&dd� Z'dd� Z(dd� Z)dd � Z*d d � Z+d d � Z,d1d!d"�Z- d1d#d$�Z.d%d&� Z/d'd(� Z0d)d*� Z1d+d,� Z2 -d2d.d/�Z3dS )3� N� )�nullrev� )�COMP_MODE_PLAIN� ENTRY_DATA_COMPRESSED_LENGTH�ENTRY_DATA_COMPRESSION_MODE�ENTRY_DATA_OFFSET� ENTRY_DATA_UNCOMPRESSED_LENGTH�ENTRY_DELTA_BASE�ENTRY_LINK_REV� ENTRY_NODE_ID�ENTRY_PARENT_1�ENTRY_PARENT_2� ENTRY_SIDEDATA_COMPRESSED_LENGTH� ENTRY_SIDEDATA_COMPRESSION_MODE�ENTRY_SIDEDATA_OFFSET�REVIDX_ISCENSORED�REVLOGV0�REVLOGV1)�_)�error�mdiff�pycompat� revlogutils�util)� storageutil)� constants�deltas� c C s� | j tjks J | j ��ddlm} | �|�}t�d|id�}|j| j| j | j ddd�}| j |_ | j |_ | j |_ | j |_ | �� D ]i}| �|�}| �|�\} } ||krw|�||| �|�| | |tj� |�|�tkrvtd�} td �} tj| | d ��q?| �|�r�| �|�tkr�td �} t�| ��| �|�} n| �|�} |�| || �|�| | || � |�� q?|j | j d d � | j s�|j | j d d � | j�!|j | j � | j s�| j�!|j | j � | �"� | �#� dS )z*censors a revision in a "version 1" revlogr )�revlog� censoredr s tmpcensoredT)�target�radix�postfix� censorables0 censored revision stored as delta; cannot censorsE censoring of revlogs is not fully implemented; please report this bug)�hints: cannot censor due to censored revision having delta storeds store)�locationN)$�_format_versionr r � r �revr �packmeta�openerr! r" � _format_flags� _generaldelta� _parse_index�revs�node�parents�addrawrevision�linkrevr � deltaparentr r r �Abort� iscensored�_chunk�rawdata�flags� addbackup� _indexfile�_inline� _datafile�rename� clearcaches� _loadindex)�rl�tr� censornode� tombstoner � censorrev�newrlr) r0 �p1�p2�m�h�rawtext� rL �?/usr/lib/python3/dist-packages/mercurial/revlogutils/rewrite.py� v1_censor6 sl � � � � � rN c C sF | j tks J | j ��| j tksJ | j ��| �|�h}t| |||� dS )z*censors a revision in a "version 2" revlogN)r' r r r) � _rewrite_v2)r rB rC rD � censor_revsrL rL rM � v2_censor� s rQ c C sF | j tks J | j ��| j tksJ | j ��| j}| j}t�d|id�}t|�}| j| }| jj| }|t d? } | � |�} t j dd��P} t | ||| �} t| || | �} | � �/}|\}}}}}t|t|��D ]}||v rrt| ||||� qct| |||| | � qcW d � n1 s�w Y W d � n1 s�w Y |jddd� dS ) a[ rewrite a revlog to censor some of its content General principle We create new revlog files (index/data/sidedata) to copy the content of the existing data without the censored data. We need to recompute new delta for any revision that used the censored revision as delta base. As the cumulative size of the new delta may be large, we store them in a temporary file until they are stored in their final destination. All data before the censored data can be blindly copied. The rest needs to be copied as we go and the associated index entry needs adjustement. r r � s w+b��modeNT)� transaction� stripping)r' r r �index�_docketr r* �min� entry_sizer �sidedata_cut_offr �unnamedtempfile�_precompute_rewritten_delta�_setup_new_files�range�len�_rewrite_censor�_rewrite_simple�write)r rB rP rD � old_index�docket�first_excl_rev�first_excl_entry� index_cutoff� data_cutoff�sidedata_cutoff� tmp_storage�rewritten_entries� all_files� open_files� old_data_file�old_sidedata_file�new_index_file� new_data_file�new_sidedata_filer) rL rL rM rO � sj �� ���� �� �0rO c C s@ t �| �}i }t|�}| j�� ��}t|t|��D ]u}||v r q|| } | t |vr*q| t dkr9t ddt f||< q| j ||d�} t j | t | �| t �| �| t �| gt| �d| t d@ d�} |j| |||d�} | jj} t �| | �\}} |�� }|�| jd � |�� }| j|||f||< qW d � |S 1 s�w Y |S )u� Compute new delta for revisions whose delta is based on revision that will not survive as is. Return a mapping: {rev → (new_base, data_start, data_end, compression_mode)} r )�_dfN� )r0 rG rH �btext�textlen� cachedeltar9 )�excluded_bases� target_revr )r � deltacomputerrY � _segmentfile� _open_readr_ r` r r r r r8 r � revisioninfor r0 r r r � finddeltainforX �default_compression_header�delta_compression�tellrc �data�base)r rd � excluded_revsrk �dcrl rf �dfhr) �entry�text�info�d� default_comp� comp_mode�start�endrL rL rM r] � sH � �� �$�$r] c s | j }| j�|�� �}| j�|�� ��| j�|�� ��| j�|�� ��| j�|�� ��| j�|�� ��t j |��d� t j ��� d� t j ���d� | j� |�� � | j� |�� � | j� |�� � �|_ � |_ �|_| �� | j|d� tj� �������fdd��}|S )a+ return a context manager to open all the relevant files: - old_data_file, - old_sidedata_file, - new_index_file, - new_data_file, - new_sidedata_file, The old_index_file is not here because it is accessed through the `old_index` object if the caller function. )�nb_bytes)re c 3 sT � t �d���} t �d��|}t �d��g}t �d��R}t �d��=}|�dtj� |�� �ks.J �|�dtj� |�� � ks=J �|�dtj� |�� �ksLJ �| ||||fV W d � n1 s^w Y W d � n1 smw Y W d � n1 s|w Y W d � n1 s�w Y W d � d S W d � d S 1 s�w Y d S )N�rbzr+br )�open�seek�os�SEEK_ENDr� )ro rp rq rr rs �ri rh �new_data_filepath�new_index_filepath�new_sidedata_filepath�old_data_filepath�old_sidedata_filepathrj rL rM �all_files_openerB s> � �� �� �� �� ��"�z*_setup_new_files.<locals>.all_files_opener)rX r+ �join�index_filepath� data_filepath�sidedata_filepathrq rr rs r �copyfile� register_file� index_end�data_end� sidedata_endr? r@ � contextlib�contextmanager)r rh ri rj re �old_index_filepathr� rL r� rM r^ s2 � r^ c C s� |\}}}} } || } | t d@ } | t d? } ||vr2|�| � | t }|�|�}| t }| t }n|| \}}}}|| }|�|� |�|�}| �� }| �|� | t }| �� }d|k rp| t }|�|� |�|�}| �|� | t }| t }||ks�J ||f��t j | ||||| t | t | t | t ||||d� }| j�|� | j�|�} |�| � |�� | j_| �� | j_| �� | j_dS )z@append a normal revision to the index after the rewritten one(s)ru rR r � r9 � data_offset�data_compressed_length�data_uncompressed_length�data_delta_base�link_rev� parent_rev_1� parent_rev_2�node_id�sidedata_offset�sidedata_compressed_length�data_compression_mode�sidedata_compression_modeN)r r� r �readr r r� rc r r r r r r� r r r r rW �append� entry_binaryrX r� r� r� ) r rd rm r) rl rk ro rp rq rr rs r� r9 �old_data_offset� new_data_size�new_datar� � d_comp_moder� r� �new_data_offset� sidedata_size�new_sidedata_offset�old_sidedata_offset� new_sidedatar� � sd_com_mode� new_entry� entry_binrL rL rM rb ^ st � � � rb c C s� |\}}}}} || } t |�} |�� } |�|� | t } | t }| t }tjtj | | | || ||| t ddt t d� }| j � |� | j �|�}|�|� |�� | j_|�� | j_dS )z&rewrite and append a censored revisionr r� N)r` r� rc r r r r r� r r r r rW r� r� rX r� r� )r rd rm r) rD ro rp rq rr rs r� r� r� r� rG rH r� r� rL rL rM ra � sD � � ra c C sF | � dd�d �dd�}t|�dk r td�}|| ; }t�|��|d S )N� .r r � /r s, cannot recognize filelog from filename: '%s')�rsplit�splitr` r r r5 )�path� path_part�msgrL rL rM � _get_filename_from_filelog_index� s r� c C s ddl m} |�| j|�}|S )zAReturns the filelog for the given `path`. Stolen from `engine.py`r )�filelog)r( r� �svfs)�repor� r� �flrL rL rM �_filelog_from_filename� s r� c C s� ddl m} | �| j�du rd}t�|��|jj}|j| }t |�} |d |d | d< | d< |j | dd� � } |� |� |� | � dS )zASwaps p1 and p2 and overwrites the revlog entry for `rev` in `fp`r ��parsersNz*repo needs to be locked to rewrite parents� � � ) �purer� � _currentlock�_lockrefr �ProgrammingError� IndexObject� index_formatrW �list�packr� rc ) r� rA r) �offset�fpr� r� r� r� r� �packedrL rL rM �_write_swapped_parents� s r� c C s� ddl m} | j}t|�dksJ �|j}|jtjkr$d|j }t� |��|j }|d }t d�} |� � �� z�t j|j�|�|j�|�|jd� |j|dd ��S} |jrz|�| �� �} |�� D ] } | |v rx| �| �} t| || | | � |�| | |f � q\n |jj}|D ]} | |j } t| || | | � |�| | |f � q�W d � n1 s�w Y |j� ||� |� � |� � W t � |� nt � |� w W d � d S 1 s�w Y d S ) z� Swaps p1 and p2 for all `to_fix` revisions of filelog `fl` and writes the new version to disk, overwriting the old one with a rename. r r� r z+expected version 1 revlog, got version '%d's .tmp-parents-fixs% repaired revision %d of 'filelog %s' )� checkambigs r+rS N) r� r� �uir` �_revlogr' r r r r� r; r �uninterruptibler r� r+ r� � _checkambigr< �InlinedIndexObjectr� r/ �_calculate_indexr� rc r� r� �sizer> r? r@ � tryunlink)r� r� �to_fixr� r� rA r� � index_file� new_file_path� repaired_msgr� rW r) r� r� rL rL rM �_reorder_filelog_parents sN � �� � � "�r� c s* � �fdd�}� �fdd�}t ||� |�S )Nc � �j �� �S �N)r� r8 rL ��filerevr� rL rM �<lambda>8 � z'_is_revision_affected.<locals>.<lambda>c r� r� )r� � parentrevsrL r� rL rM r� 9 r� )�_is_revision_affected_inner)r� r� �metadata_cache� full_text� parent_revsrL r� rM �_is_revision_affected7 s �r� c C sl z| � }W n t jy Y dS w t|dd� �dk}|dur#|||< |r4|� \}}|tkr4|tkr4dS dS )a� Mercurial currently (5.9rc0) uses `p1 == nullrev and p2 != nullrev` as a special meaning compared to the reverse in the context of filelog-based copytracing. issue6528 exists because new code assumed that parent ordering didn't matter, so this detects if the revision contains metadata (since it's only used for filelog-based copytracing) and its parents are in the "wrong" order.FNr s T)r �CensoredNodeError�bytesr )r� � parents_revsr� r� �raw_text�has_metarG rH rL rL rM r� ? s � r� c s` |j �� �fdd�}� �fdd�}� �fdd�}� �fdd�}� �fdd�}t|||||� |�S )Nc � �� � �S r� )r6 rL �r� rA rL rM r� ^ � z,_is_revision_affected_fast.<locals>.<lambda>c r r� )r4 rL r rL rM r� _ r c r r� )r7 rL r rL rM r� ` r c r r� )r8 rL r rL rM r� a r c r r� )r� rL r rL rM r� b r )r� � _is_revision_affected_fast_inner) r� r� r� r� � is_censored� delta_base�deltar� r� rL r rM �_is_revision_affected_fast\ s �r c C s� | � r d||< dS |� \}}|t ks|t krdS |� } |�| �} | du r+t||||�S |� } t| �s4| S d} t| �| k rCt�td���t�d| d| � �\} }}| dk r]t||||�}|S | ||< | S )aG Optimization fast-path for `_is_revision_affected`. `metadata_cache` is a dict of `{rev: has_metadata}` which allows any revision to check if its base has metadata, saving computation of the full text, instead looking at the current delta. This optimization only works if the revisions are looked at in order.FN� s patch cannot be decodeds >lllr ) r �getr� r` r r5 r �struct�unpack)r r r r� r� r� r� rG rH � delta_parent�parent_has_metadata�chunk� header_lengthr� �_end�_length� is_affectedrL rL rM r n s@ � �r c sh | � td�| � |� �� t|dd��}|�� �d�D ]o}|s q|�dd�\}}t||�� t� fdd�|�d �D ��} t� } | D ]-} t� | �rSd } | �| | |f � q@td �} | t � � � | ��|f; } | �| � | � | � q@| | } | s�td �} | � | | � q|s�t |� t| �� qW d � n1 s�w Y W d � d S W d � d S 1 s�w Y d S )a Fix the revisions given in the `from_report` file, but still checks if the revisions are indeed affected to prevent an unfortunate cyclic situation where we'd swap well-ordered parents again. See the doc for `debug_fix_issue6528` for the format documentation. s loading report file '%s' r� rS � � r c 3 s � | ] }� � t�|��V qd S r� )r) �binascii� unhexlify)�.0�n�r� rL rM � <genexpr>� s � �z _from_report.<locals>.<genexpr>� ,�, found affected revision %d for filelog '%s' s) revision %s of file '%s' is not affected s* no affected revisions were found for '%s' N)rc r r� r� r� r� �setr� �warnr �hexlifyr0 �addr� �sorted) r� r� �context� from_report�dry_run�f�line� filenodes�filenamer� �excludedr� r� rL r rM � _from_report� s: � ��P�r, c # sF � i }t �� ��t|t� ��D ]�\}}|\���}}��}� j�|�s-t�|� jt d���� � |�� � j���sBt��� jt d���� � ���� j���sWt��� jt d���� � ��� �fdd�}�� fdd��� fdd���� fdd�} � ������� fdd�} t |��fd d�| | ||�} | r����||��|f}|V qd S ) z7filter incomind deltas to repaire issue 6528 on the flys unknown parentc s t � t@ �S r� )�boolr rL )r9 rL rM r� � r� z(filter_delta_issue6528.<locals>.<lambda>c r r� )r) rL )r r rL rM r� � r c � � S r� rL rL )�base_revrL rM r� � � c s � �fS r� rL rL )�p1_rev�p2_revrL rM r� � s c sd t ���� ���} t����d g| � �f��}�jd us J ��jr'�jd }n�jd }��||�S )Nr r )r � patchedsizer� r r~ �_writinghandlesr< � buildtext)rw �revinfo�fh)r/ r r{ r9 r0 �p1_node�p2_noder rL rM r� � s � z)filter_delta_issue6528.<locals>.full_textc r. r� rL rL )r rL rM r� r0 N) r r{ � enumerater` rW �has_noder � LookupErrorr" r r) r ) r � deltas_iterr� r) r� �linknode� deltabase�sidedatar r� r� r rL ) r/ r r r{ r9 r0 r8 r1 r9 r2 r rM �filter_delta_issue6528� sf � � � � � �rA Fc s4 ddl m� tj� ��fdd��}|rt| �||� �S g }|� �� t�fdd��j�� D ��}| jtd�td�t |�d �} d } |D ]�\} } | � d �rO| �j @ sPqA| � � t | �} t�| �}t� }i }|�� D ]M}t�|||�}|r�t||�}||kr�td �}t�|�|��}t�|| |f ��|r�d }| �||| f � d} � s��r�|�t�|�|��� qf|�|� qf|r�t|�}�r�|�| |f� qAt �||� qA| r�| � td�� ��r|�rt �dd��}|D ]\} }|� dd� |�| f � q�W d � n1 s�w Y | � � W d � d S 1 �sw Y d S )Nr ��storec 3 s� � � s�r d V d S �� � �( ��� � d V W d � n1 s!w Y W d � d S W d � d S 1 s9w Y d S r� )�wlock�lockrL )r& r� � to_reportrL rM r$ - s � P�z!repair_issue6528.<locals>.contextc 3 s2 � | ]\}}}|� d �r|� j@ r||fV qdS )� .iN)�endswith�FILEFLAGS_FILELOG)r � file_typer� �_srB rL rM r ; s � �� �z#repair_issue6528.<locals>.<genexpr>s looking for affected revisionss filelogs)�unit�totalTrG s) paranoid check failed for '%s' at node %sr Fs! no affected revisions were found �wbrS s %s %s r )!r( rC r� r� r, r� � datafiles� makeprogressr r` rH rI � incrementr� r� r r/ r r� r r! r0 r r5 r r" r# r� r� rc r� r� �complete)r� r� r& rF r% �paranoidr$ �report_entries�files�progress� found_nothingrJ r� r* r� r� r� r� �affected�slowr� r0 r' rL )r& r� rC rF rM �repair_issue6528( s| �� �� � � � � � $�rZ )r r� )FNNF)4r r� r� r r0 r r r r r r r r r r r r r r r r r r �i18nr r( r r r r r �utilsr r rN rQ rO r] r^ rb ra r� r� r� r� r� r� r r r, rA rZ rL rL rL rM �<module> s< H N R5JP3 0 � @(S�
Save
Cancel