| 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/hgext/remotefilelog/__pycache__/ |
Upload File : |
a
�+�b�+ � @ s� d dl mZ d dlmZ d dlmZmZ d dlmZm Z m
Z
m Z m Z m
Z
ddlmZmZmZ d ZdZdZdd d
�ZG d d � d e j�Zd
d� Zdd� ZdS )� )�absolute_import)�_)�bin�hex)�
bundlerepo� changegroup�error�match�mdiff�pycompat� )� constants�
remotefilelog� shallowutil� Nc
c s� t |tj�s4t| |�j||||d�D ]
}|V q$d S t|�dkrN|�� V d S t�||j�}|�|d �d }|� d|� t
� t|�d �D ]>} || || d }
} || �} |� || |
| �D ]
}|V q�q�|�� V d S )N��unitsr r )
�
isinstancer �super�group�len�closer Z sortnodes�parents�insertr Zxrange� nodechunk)
�cls�self�nodelist�rlog�lookupr �reorder�c�p�i�prevZcurr�linknode� r& �G/usr/lib64/python3.9/site-packages/hgext/remotefilelog/shallowbundle.py� shallowgroup s
r( c sN e Zd Z� fdd�Zddd�Z� fdd�Zdd � Z� fd
d �Zd d
� Z� Z S )�shallowcg1packerc s. t �| j�rd}tt| �j||||fi |��S )NF)r � isenabled�_repor r) �generate)r �
commonrevsZclnodes�fastpathlinkrev�source�kwargs�� __class__r& r' r, 9 s
��zshallowcg1packer.generateNc C s t t| ||||d�S )Nr )r( r) )r r r r r r r& r& r' r A s �zshallowcg1packer.groupc s� z|\}}}W n" t y0 |\}}}}} }
Y n0 t�| j�r�| j� t� tj�rvtj�� d� � jrrt j
ddd��g S | � |�} | t kr�t
� fdd�|D ��}tt| �j|g|�R i |��S )Ns foos cannot pull from full bundless use `hg unbundle` instead)�hintc s g | ]}� � |�s|�qS r& )� shallowmatch)�.0�f��repor& r' �
<listcomp>\ � z2shallowcg1packer.generatefiles.<locals>.<listcomp>)�
ValueErrorr r* r+ r r Zbundlerepository�fileZ _cgfilesposr �Abort�shouldaddfilegroups�NoFiles�listr r) �
generatefiles) r Z changedfiles�argsr0 Z linknodesr- r/ Zmfdictsr. ZfnodesZclrevsZ filestosendr1 r7 r' rA F s4 �
�
���z shallowcg1packer.generatefilesc C s� | j }t�|�stS |dks$|dkr(tS |dkrV|j�dd�}|dkrJtS |dkrVtS | jp^g }|dksp|d kr�tj |v r~tS |j�
t d
�� tS t S ) Ns pushs bundles strips
remotefilelogs strip.includefiless locals none� serves pulls pulling from a shallow repo
)
r+ r r* �AllFiles�uiZconfig�
LocalFilesZ _bundlecapsr
ZBUNDLE2_CAPABLITY�warnr r? )r r/ r8 ZcfgZcapsr& r& r' r> c s$
z$shallowcg1packer.shouldaddfilegroupsc s^ t |tj�s tt| ��|||�S | j}g }|D ]*}|j|j|d�}|�� |vr.|� |� q.|S )N)Zfileid)
r r r r) �pruner+ Zfilectx�filenameZlinkrev�append)r r �missingr- r8 �resultsZfnodeZfctxr1 r& r' rH � s
� zshallowcg1packer.prunec c s� d}||j kr(|�|�}t�t|��}n |�||�}|�|�\}}|�|�} | �|||||| �}
|
|7 }
t|
�t|� } t �
| �V |
V |V d S )Nr: ) �nullid�rawdatar
Ztrivialdiffheaderr Zrevdiffr �flagsZbuilddeltaheaderr Z chunkheader) r Zrevlog�nodeZprevnoder% �prefix�delta�p1�p2rO �meta�lr& r& r' r � s
zshallowcg1packer.nodechunk)NN)
�__name__�
__module__� __qualname__r, r rA r> rH r �
__classcell__r& r& r1 r' r) 8 s
r) c
O s t �|�s&| ||||g|�R i |��S |j}z�|dkr�|�d�}d } d }
|pNg D ]V} | �d�r~| td�d � } | r�| �d�} qP| �d�rP| td�d � } | rP| �d�}
qP| s�|
r�t�|jdd | |
�|_n
t� � |_| ||||g|�R i |��W ||_S ||_0 d S )NrC �
bundlecapss includepattern=� s excludepattern=r: )
r r* r4 �get�
startswithr �splitr �root�always)
�origr8 Zoutgoing�versionr/ rB r0 �originalr[ ZincludepatternZexcludepatternZcap�rawr& r& r' �makechangegroup� s4
�
�rf c % s t ���s(| �||||g|�R i |��S d}t� } i �g ��jjtd�|d�}
|�� } | s^�q| d } �j�d| � |
�� �� | �s���
| �}
|� � }|
� |||� qNd }|�
|�}|s�q�|d }|�| |f< ��| |f� | | vr�|d7 }| �| � q�|d u rNt�td���qNt� � � ���fdd �}d}g }�D ]h\} }�| |f }|d |d
|d g}|D ]6}|�jk�sf| |f�v �r��qf|�| t|�f� �qf�q8�j�|� ��r ��d�\} }| |f� v �rԐq�|d7 }|t��d k�r�t�td �����
| �}
�| |f }|\ }}}}}}} } } || || |��s<�q�|
�|�} t�| |�} t| t ��sft | �} t � | �\}!} d
|!v �r�|!d
}"t |!d �}#|| ||"|#��s��q�||fD ]&}$|$�jk�r�|| || |$��s��q��q�|
�| |!||||� � �| |f� d}�q�|
� � t��|fS )Nr s files)�totals filenames adding %s revisions
r s# received file revlog group is emptyc sN |�j krJ||f� vrJ||f�vr&dS ��d| |f� ��d||f� dS dS )NTr F)rM r )r6 rP ZdepfZdepnode�Z processedZqueuer8 Z
revisiondatasr& r' � available s z&addchangegroupfiles.<locals>.availabler � s circular node dependencys copys copyrev) r r* �setrE Z makeprogressr Z
filelogheader�debugZ incrementr4 r< Z deltaiter�addgroupZ
deltachunkrJ �addr r= rM r Z fileserviceZprefetch�popr rN r
Zpatchr �bytesZ parsemetar Zcomplete)%rb r8 r/ ZrevmapZtrpZ
expectedfilesrB r0 ZnewfilesZvisitedZprogressZ chunkdatar6 ZflZdeltas�chainZ revisiondatari Z skipcountZ
prefetchfilesrP Z
dependentsZ dependentrS rT r% Z deltabaserR rO ZsidedataZ proto_flags�base�textrU ZcopyfromZcopynoder" r& rh r' �addchangegroupfiles� s�
�
rt )NN)Z
__future__r Zmercurial.i18nr Zmercurial.noder r Z mercurialr r r r r
r � r
r r r? rF rD r( Zcgpackerr) rf rt r& r& r& r' �<module> s
j