/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
Upload File
HOME
a �+�b�I � @ s d dl mZ d dlZddlmZ ddlmZmZ ddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZ ddlmZmZmZ d)d d �Zd d � Zd d� Z dd� Z d*dd�Z d+dd�Z dd� Z dd� Z!dd� Z"G d d � d e#�Z$d,d d �Z%d d!� Z&d"d#� Z'd-d%d&�Z(d'd(� Z)dS ).� )�absolute_importN� )�_)�hex�short) �bundle2� changegroup� discovery�error�exchange�obsolete�obsutil�pathutil�phases�pycompat� requirements�scmutil�util)�hashutil� stringutil�urlutilTc C s� d}| j }|�|�s |�|� | �d||�} tdd� | D ��} t�d�| ���� } d|t |�t | dd� �|f } t � | �} d}| d kr�d }|r�d }n|r�d }nd }t j| ||d�}| |dd�}tj| j| d| |||||d� S )z8create a bundle with the specified revisions as a backups strip-backups %ln::%lnc s s | ]}|� � V qd S �N)r ��.0�c� r �6/usr/lib64/python3.9/site-packages/mercurial/repair.py� <genexpr>4 � z backupbundle.<locals>.<genexpr>r s %s/%s-%s-%s.hgN� s 01s HG20s BZs HG10BZs HG10UN)Z missingrootsZ ancestorsofT)s cg.versions obsolescences phases� strip)� compression)�vfs�isdir�mkdir�set�sortedr Zsha1�join�digestr r r Z localversionr �outgoingr Zwritenewbundle�ui)�repo�bases�heads�node�suffix�compress� obsolescenceZ backupdirr" Z allcommitsZ allhashesZ totalhash�nameZ cgversion�compZ bundletyper) Z contentoptsr r r � backupbundle( sL � ��r4 c C s6 t � }t�|t| ��D ]}|�| | �� � qt|�S )z+find out the filelogs affected by the strip)r% r Zxrange�len�update�filesr& )r+ �striprevr7 �xr r r � _collectfiles[ s r: c s � � |�\}}� fdd�|D �S )Nc s g | ]}� � |��qS r )Zlinkrev�r �r��revlogr r � <listcomp>g r z"_collectrevlog.<locals>.<listcomp>)Z getstrippoint)r> r8 r Z brokensetr r= r �_collectrevloge s r@ c C sH t � }t| �D ]}|�t||�� q|D ]}|�t| �|�|�� q(|S )z<return the changesets which will be broken by the truncation)r% �manifestrevlogsr6 r@ �file)r+ r7 r8 �sr> �fnamer r r �_collectbrokencsetsj s rE � backupc $ sp �� � d urt�d��|dv r"d}��� ���� �j}�j �j� t|t �rT|g}� fdd�|D �}t |�}t �|�}t �||�} t |��t | �} � j|d d�D ]V} t�fdd �� �| �D ��rΈ�| � | �vr�| �| � | �� �| �� | �| � q�� fd d�| D �} | �r,t � �| ��} | �| � � fd d�| D �} � fd d��D �}d }��j�dd��rtt��|����r��fdd�t�j�D �}t���\�}d }|d }|�r�t�|||�}d }| �r�t �| | |dddd�}| � � ��h �z�� d���}t |j � � �}|�!|j"� |�#� � �$||� t%�|||� |D ]}��&|��$||� �q>|�'� |�(� }|D ]j\}}||v �r��ql�j)|ddd��}|�*|� W d � n1 �s�0 Y |dk�rl�j+�,|� �qlt-�j|� �`��.� �j/�0�� W d � n1 �s0 Y |�r| �1t2d�� |�3|d�}t4�5| |||�} �jj6�s`�j�7� nt8�9� } | �~ d|�:|� } d} t| t;j<��s�d t=�>| � } �� | ��$}t;j?�| |d| d � W d � n1 �s�0 Y W d � n1 �s�0 Y |�@� �� d ��4}��fd d�|D �} �j�A�|| � W d � n1 �sJ0 Y ��B� D ]p\}!}"z|!�C|"� W nV tD�y� }# z<|#jEtEjFk�r�| �Gt2d �|!�:|"�tH�I|#�f � W Y d }#~#n d }#~#0 0 �q\W nb |�r�| �Gt2d!�|�:|� � |�r,| �Gt2d"�|�:|� � | �Gt2d#�|�:|� � � Y n0 |�rD|�C|� W d � n1 �sZ0 Y ��J� |S )$Ns& cannot strip from inside a transaction)s noner Fc s g | ]}� � |��qS r )�rev)r r. ��clr r r? � r zstrip.<locals>.<listcomp>r )�startc 3 s | ]}|� v V qd S r r )r �p)�tostripr r r � r zstrip.<locals>.<genexpr>c s g | ]}� � |��qS r �r. r; rH r r r? � r c s g | ]}� � |��qS r rM r; rH r r r? � r c s g | ]}� � |��qS r rM r; rH r r r? � r r s devels strip-obsmarkersc s g | ]\}}|� v r|�qS r r )r �i�m)� obsmarkersr r r? � s ���s temp)r0 r1 r � aT)Z checkambigr s adding branch s rbs bundle:s strip %s)�source�urls repairc s g | ]}|�� � � f�qS r rM �r rO �� newbmtargetr+ r r r? r s error removing %s: %s s+ strip failed, backup bundle stored in '%s' s1 strip failed, unrecovered changes stored in '%s' sG (fix the problem, then recover the changesets with "hg unbundle '%s'") )K�currenttransactionr ZProgrammingError� unfilteredZ destroyingr" � _bookmarks� changelog� isinstance�bytes�minr: rE r% �revs�anyZ parentrevs�add�difference_update� descendantsr* Z configboolr Zexclusivemarkers� enumerate�obsstore�_bookmarkmovements�_createstripbackupr4 Zuninterruptible� transactionZ _offsetmap�keysr6 Z _newfilesZ startgroup�strip� stripmanifestrB ZendgroupZ readjournal�svfs�truncate�storeZ markremoved�deleteobsmarkersZinvalidatevolatilesetsZ _phasecacheZ filterunknownZnoter �openr Z readbundle�verboseZsilentr Znullcontextmanagerr' r Z unbundle20r Z hidepasswordZ applybundle�close� applychangesZ undofiles�unlink�OSError�errno�ENOENT�warnr Z forcebytestrZ destroyed)$r* r+ �nodelist�backup�topicr" Z striplistr8 r7 ZsaverevsZ saveheadsr< rc Z savebases� stripbasesZ stripobsidx�updatebm� backupfiler. Z tmpbundlefile�trZoldfiles�fn�entriesrB Ztroffset�fp�f�genZ maybe_silentZ tmpbundleurlZtxnname� bmchangesZundovfsZundofile�er )rI rW rP r+ rL r rj v s �� * , ��� �F 0���"�������*rj c s� dd� �� d|�D �}|s dS d}|r<|d }t�|||�}t�|�\� }��d��F} t��| tj|� � �fdd�|D �} �j��| | � W d � n1 s�0 Y |S )z/perform a "soft" strip using the archived phasec S s g | ] }|� � �qS r rM r r r r r? 8 r z softstrip.<locals>.<listcomp>s sort(%ln::)Nr r c s g | ]}|�� � � f�qS r rM rU rV r r r? D r ) r% rg rf rh r ZretractboundaryZarchivedrZ rs ) r* r+ ry rz r{ rL r~ r. r} r r� r rV r � softstrip6 s .r� c C sn | j }g }|D ]&}| || �� }||v r|�|� qd }|rf| �d||�}|rb| |�� �� }nd}||fS )Ns max(parents(%ld) - (%ld))� .)rZ rG �appendr_ �firstr. )r+ rL Zbmr} rO rG rW r r r rf I s rf c C sT | j }| j}t| ||�� ||�}| j�td�|�|� � | j�dd|�|�� |S )Ns saved backup bundle to %s s backupbundle) r" r[ r4 r- r* �statusr r' �log)r+ r| r. r{ r" rI r~ r r r rg _ s �rg c s� � � � jj��fdd�|D �}d}t� �|||tj|��}|| }|rtd�t� fdd�|D ���}| � t d�| � dd � � �d |�D �S ) zDreturn list of roots of nodes where descendants are covered by nodesc s h | ] }� |��qS r r �r �n)�torevr r � <setcomp>n r z!safestriproots.<locals>.<setcomp>s5 %ld - ( ::( (roots(%ld):: and not _phase(%s)) -%ld) )s , c 3 s | ]}t � | �� �V qd S r )r r. r� )r+ r r r w r z!safestriproots.<locals>.<genexpr>s9 warning: orphaned descendants detected, not stripping %s c S s g | ] }|� � �qS r rM r r r r r? | r z"safestriproots.<locals>.<listcomp>s roots(%ld)) rY r[ rG r% r_ r Zinternalr' r& rx r )r* r+ �nodesr_ ZrevsetrL ZnotstripZnodestrr )r+ r� r �safestriprootsk s ��r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � stripcallbackz(used as a transaction postclose callbackc C s& || _ || _|| _|pd| _g | _d S )NrF )r* r+ rz r{ ry )�selfr* r+ rz r{ r r r �__init__� s zstripcallback.__init__c C s | j �|� d S r )ry �extend)r� r� r r r �addnodes� s zstripcallback.addnodesc C s2 t | j| j| j�}|r.t| j| j|| j| j� d S r )r� r* r+ ry rj rz r{ )r� r �rootsr r r �__call__� s zstripcallback.__call__N)�__name__� __module__� __qualname__�__doc__r� r� r� r r r r r� s r� c C sp |� � }|s*t| ||�}t| ||||d�S |�d�}|du rXt| |||d�}|�d|� |rb||_|�|� dS )ai like strip, but works inside transaction and won't strip irreverent revs nodelist must explicitly contain all descendants. Otherwise a warning will be printed that some nodes are not stripped. Will do a backup if `backup` is True. The last non-None "topic" will be used as the backup topic name. The default backup topic name is "backup". )rz r{ s �stripN)rX r� rj Z getpostcloser� Z addpostcloser{ r� )r* r+ ry r{ rz r r� �callbackr r r � delayedstrip� s r� c C s t | �D ]}|�||� qd S r )rA rj )r+ r8 r r7 r> r r r rk � s rk c c s` | j �d�V t�| �r\| j�� D ]8\}}}|�d�r"|�d�r"|dd� }| j �|�V q"d S )Nr s meta/s 00manifest.i� i�)Z manifestlogZ getstorager Zistreemanifestrn Z datafiles� startswith�endswith)r+ �tZ unencoded�size�dirr r r rA � s � rA Fc C s� |� � }tj|jvr&| �td�� dS |�� ��� |jj}|j| jd� t |j �}t � }t � }|r�|D ]f}|dd� dkrf|dd� dkrf|� |dd� � |� |� |dd� d }|j� |�rf|� |� qfn�| j td �td �t|�d �} |D ]~} | �| � || } | �� D ]^}||v �r �q|� |� d | } d | } |j� | ��rR|� | � |j� | ��r|� | � �qq�| �� tj|jv �r�t�|�D ]F}d| } d| } |j� | ��r�|� | � |j� | ��r�|� | � �q�t|| �}t|| �}t|| �D ]}| �td�| � �q�t|| �D ]}| �td�| � �q"|�sH|�r�| �td�||f � ||_ d|_|�d��}|�|� W d � n1 �s�0 Y n| �td�� W d � n1 �s�0 Y dS )ztRebuilds the fncache file from repo history. Missing entries will be added. Extra entries will be removed. sE (not rebuilding fncache because repository does not support fncache) N)rx r� s data/���s .is .ds rebuildings changesets)Zunit�totals data/%s.is data/%s.ds meta/%s/00manifest.is meta/%s/00manifest.ds removing %s s adding %s s( %d items added, %d removed from fncache Ts fncaches fncache already up to date )rY r ZFNCACHE_REQUIREMENTrx r �lockrn ZfncacheZ ensureloadedr% r� ra �_existsZ makeprogressr5 r6 r7 ZcompleteZTREEMANIFEST_REQUIREMENTr �dirsr& �write�_dirtyrh )r* r+ Z only_dataZfncZ oldentriesZ newentriesZ seenfilesr� ZdatafZprogressrG �ctxrN �dr� ZaddcountZ removecountrK r r r r �rebuildfncache� s� �� � �� ,r� c C s� |sdS g }| j }d}t|�D ]$\}}||v r8|d7 }q |�|� q | jdddd�}t�|d| j�D ]}|�|� qd|�� |S )a� Delete some obsmarkers from obsstore and return how many were deleted 'indices' is a list of ints which are the indices of the markers to be deleted. Every invocation of this function completely rewrites the obsstore file, skipping the markers we want to be removed. The new temporary file is created, remaining markers are written there and on .close() this file gets atomically renamed to obsstore, thus guaranteeing consistency.Nr r s obsstore� wT)Z atomictemp) Z_allrd r� rl r Z encodemarkersZ_versionr� rr ) re �indices�left�currentr� rN rO Znewobsstorefiler] r r r ro s ro )TT)TrF )TrF )NT)F)*Z __future__r rv Zi18nr r. r r � r r r r r r r r r r r r r Zutilsr r r r4 r: r@ rE rj r� rf rg r� �objectr� r� rk rA r� ro r r r r �<module> s, < � 3 A \