| 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 : /usr/lib64/python3.9/site-packages/hgext/narrow/__pycache__/ |
Upload File : |
a
�+�by- � @ s d dl mZ d dlZd dlZd dlmZ d dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZ d dlmZ dZdZdZd Zd
Zd Zd Zd
ZdZ dZ e� e �Z e� e �Z d dd�Z!dd� Z"dd� Z#e�$eeef�dd� �Z%e�$e�dd� �Z&e�$e�dd� �Z'd d � Z(d d � Z)dS )!� )�absolute_importN)�_) �bundle2� changegroup�error�exchange� localrepo�
narrowspec�repair� requirements�scmutil�util�wireprototypes)�
stringutils narrowacls narrow:changespecs narrow:responsespecs narrow:specs includes excludes KILLs DONEs >20s20s20sls >20s20s20s20slc s� |� d�}� fdd�|D �}|s,ttd���t|�} ttt|� dg ���}
ttt|� dg ���} t| � |
| | |||� dd �� d S )N� changegroupc s g | ]}|t �� �v r|�qS � )r Zsupportedoutgoingversions)�.0�v��repor �@/usr/lib64/python3.9/site-packages/hgext/narrow/narrowbundle2.py�
<listcomp>8 s �z3getbundlechangegrouppart_narrow.<locals>.<listcomp>s no common changegroup version� includepats� excludepats�depth)�get�
ValueErrorr �max�sorted�filter�bool�generateellipsesbundle2) �bundlerr �sourceZ
bundlecapsZb2caps�heads�common�kwargsZ
cgversions�version�include�excluder r r � getbundlechangegrouppart_narrow+ s&
�
�r* c C s� t j|j||d�}|d ur<t|�}|dk r<t�td�| ��t|pH|�� �}t|pX|j g�}t
j |||t� ||d�\} }
} |j �
dt|
� � | r�tj|||d|d u| |
d�} | �|| dd �}
| jd
|
d �}|�d |� t�|�r�|�d
d� d S )N)r( r) � s depth must be positive, got %d)r s Found %d relevant revs
T�ZmatcherZellipses�shallow�
ellipsisrootsZ fullnodesF� narrow_widenr ��data� version� treemanifest� 1)r �match�root�intr �Abortr �setr$ �nullidr �_computeellipsis�ui�debug�lenr �
getbundler�generate�newpart�addparamr �istreemanifest)r" r r( r) r' r% r$ r r5 Z
visitnodesZrelevant_nodesr. �packer�cgdata�partr r r r! O s4
� �
r! c s� t |p �jg�}�fdd�|D �}|� � �fdd�}| jt|� d� t��t � |||�\} }
} | r�tj|�|dd| |
d�} | �|| dd �}
| jd
|
d�}|� d |� t
� ��r�|� d d
� d S )Nc s h | ]}� j �|��qS r )� changelogZrev)r �nr r r � <setcomp>� � z9generate_ellipses_bundle2_for_widening.<locals>.<setcomp>c 3 s( � D ]} t V �j�| �V qtV d S �N)�_KILLNODESIGNALrG Znode� _DONESIGNAL)�r�Zdeadrevsr r r �genkills� s z8generate_ellipses_bundle2_for_widening.<locals>.genkillsr0 TFr, r/ r r2 r3 r4 ) r9 r: rA �_CHANGESPECPARTr r; r r? r@ rB r rC )r" r ZoldmatchZnewmatchr' r% ZknownZ knownrevsrP ZnewvisitZnewfullZ newellipsisrD rE rF r rO r �&generate_ellipses_bundle2_for_wideningy s. �
�
rR c C s� t |j�td��� �}t |j�td��� �}t�|� t�|� tj | j
jvrj| j
j� tj � t �
| j
� | j
�||� t�| j
� d S )NrJ )r9 �paramsr �_SPECPART_INCLUDE�
splitlines�_SPECPART_EXCLUDEr �validatepatternsr �NARROW_REQUIREMENTr �addr �writereporequirements�
setnarrowpats�copytoworkingcopy)�op�inpartr r r r r �_handlechangespec_2� s
r_ c C s� |� � }|�d�\}}t|�� �}t|�� �}t�|� t�|� tj| jjvrl| jj� tj� t
� | j� | j� ||� t�
| j� d S )N� )�read�splitr9 rU r rW r rX r rY r rZ r[ r\ )r] r^ r1 Zinc�excr r r r r �_handlenarrowspecs� s
rd c C s� | j }|j}t� }t�|d�}|tkrp|tkrPt�|d�}|�|�rb|�|� nt �
t d�| ��t�|d�}q |r�|j | _
G dd� dt�}tjj �||� � tj| j|t|�ddd�}|r�|j�� | _| j�� || _t�|d �r�|�� d S )
N� � s) unexpected changespec node chunk type: %sc @ s e Zd Zdd� ZdS )z'_handlechangespec.<locals>.dummybmstorec S s d S rK r )�selfr �trZchangesr r r � applychanges� s z4_handlechangespec.<locals>.dummybmstore.applychangesN)�__name__�
__module__� __qualname__ri r r r r � dummybmstore� s rm Ts widen)ZbackupZtopic�setnewnarrowpats) r rG r9 r Z readexactlyrM rL ZhasnoderY r r8 r �
_bookmarks�_bookmarksbackup�dictr �localrepositoryr
�stripr< �listZuninterruptible�_widen_uninterr� __enter__�
_widen_bundler
� safehasattrrn ) r] r^ r ZclZclkillsZ chunksignalZckrm � chgrpfiler r r �_handlechangespec� s4
��
rz c s� | j }| j}| j}| `|j}|�td�� |�|d�}z�t�||||�}|j sV|�
� nt � � }|�x t
|tj�r�|�d��&� t�||� fdd�� W d � q�1 s�0 Y n|�|dd|�|� d� W d � n1 s�0 Y W |�� n
|�� 0 |�� D ]p\} }
z| �|
� W nV t�yt } z<| jtjk�r`|�td �| �|
�t� | �f � W Y d} ~ n
d} ~ 0 0 �q| j � ddd� |�|� dS )
zFChangegroup exchange handler which restores temporarily-stripped nodess adding branch
s rbs stripc s � S rK r r �rh r r �<lambda>" rJ z)handlechangegroup_widen.<locals>.<lambda>Ns bundle:Ts error removing %s: %s
) r r< rw �vfsZnoter �openr Z
readbundle�verboseZsilentr
Znullcontextmanager�
isinstancer Z
unbundle20Z transactionZ
processbundleZapply�join�closeZ undofiles�unlink�OSError�errno�ENOENT�warnr Z forcebytestrru �__exit__) r] r^ r r< ry r} �f�genZ maybe_silentZundovfsZundofile�er r{ r �handlechangegroup_widen s> � 6�$�� r� c sz t j} d| d< d| d< d| d< d| d< d| d< tjd � � fd
d �}|tjd < tjd ��fd d
�}�j|_|tjd < dS )z?Enable narrow repo support in bundle2-related extension points.s booleans narrows plains depths csvs oldincludepatss oldexcludepatss knownr c s\ | d }|j �t�r t�||�}|�dd�rJ|j �dd�rJt| i |�� n� | i |�� d S )Nr+ ZnarrowFs experimentals narrowservebrokenellipses)r< Z has_section�_NARROWACL_SECTIONr Zapplynarrowaclr Z
configboolr* )�argsr& r )�origcgfnr r � wrappedcgfnG s �zsetup.<locals>.wrappedcgfnc sH � | |� t �| d�r t| |� t �| d�rDtjj�| j| j� | `d S )Nrw rp ) r
rx r� r rr ro r9 r rp )r] r^ )�
origcghandlerr r �wrappedcghandlerX s
�z setup.<locals>.wrappedcghandlerN)r ZGETBUNDLE_ARGUMENTSr Zgetbundle2partsmappingr ZparthandlermappingrS )Z
getbundleargsr� r� r )r� r� r �setup: s
r� )NNNN)*Z
__future__r r� �structZmercurial.i18nr Z mercurialr r r r r r r
r r r
r Zmercurial.utilsr r� rQ Z _RESSPECSZ _SPECPARTrT rV rL rM Z_ELIDEDCSHEADERZ_ELIDEDMFHEADER�calcsizeZ
_CSHEADERSIZEZ
_MFHEADERSIZEr* r! rR Z parthandlerr_ rd rz r� r� r r r r �<module> s@ 4
�
$*=
3.