| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/mercurial/__pycache__/ |
Upload File : |
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
\