|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/hgext/remotefilelog/__pycache__/ |
Upload File : |
o
�]Lb�+ � @ 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�st| |�j||||d�D ]}|V qd S t|�dkr(|�� V d S t�||j�}|�|d �d }|� d|� t
� t|�d �D ] } || || d }
} || �} |� || |
| �D ]}|V q`qG|�� V d S )N��unitsr r )
�
isinstancer �super�group�len�closer � sortnodes�parents�insertr �xrange� nodechunk)
�cls�self�nodelist�rlog�lookupr �reorder�c�p�i�prev�curr�linknode� r) �C/usr/lib/python3/dist-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 �
commonrevs�clnodes�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 y |\}}}}} }
Y nw t�| j�rO| j� t� tj�r;tj�� d� � jr9t j
ddd��g S | � |�} | t krOt
� 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>\ s z2shallowcg1packer.generatefiles.<locals>.<listcomp>)�
ValueErrorr r- r. r r �bundlerepository�file� _cgfilesposr �Abort�shouldaddfilegroups�NoFiles�listr r, �
generatefiles) r � changedfiles�argsr4 � linknodesr0 r3 �mfdictsr2 �fnodes�clrevs� filestosendr5 r; r* rF F s6 � �
�
���z shallowcg1packer.generatefilesc C s� | j }t�|�s
tS |dks|dkrtS |dkr+|j�dd�}|dkr%tS |dkr+tS | jp/g }|dks8|d krItj |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�ui�config�
LocalFiles� _bundlecapsr
�BUNDLE2_CAPABLITY�warnr rD )r r3 r< �cfg�capsr) r) r* rC c s$
z$shallowcg1packer.shouldaddfilegroupsc s^ t |tj�stt| ��|||�S | j}g }|D ]}|j|j|d�}|�� |vr,|� |� q|S )N)�fileid)
r r r r, �pruner. �filectx�filename�linkrev�append)r r �missingr0 r< �results�fnode�fctxr5 r) r* rY � s
�
�zshallowcg1packer.prunec c s� � d}||j kr|�|�}t�t|��}n|�||�}|�|�\}}|�|�} | �|||||| �}
|
|7 }
t|
�t|� } t �
| �V |
V |V d S )N� ) �nullid�rawdatar
�trivialdiffheaderr �revdiffr �flags�builddeltaheaderr � chunkheader) r �revlog�node�prevnoder( �prefix�delta�p1�p2rg �meta�lr) r) r* r � s �
zshallowcg1packer.nodechunk�NN)
�__name__�
__module__� __qualname__r/ r rF rC rY r �
__classcell__r) r) r5 r* r, 8 s
r, c
O s� t �|�s| ||||g|�R i |��S |j}zd|dkri|�d�}d } d }
|p'g D ]+} | �d�r?| td�d � } | r>| �d�} q(| �d�rS| td�d � } | rS| �d�}
q(| sX|
rdt�|jdd | |
�|_nt� � |_| ||||g|�R i |��W ||_S ||_w )NrN �
bundlecapss includepattern=� s excludepattern=rb )
r r- r8 �get�
startswithr �splitr �root�always)
�origr< �outgoing�versionr3 rH r4 �originalrx �includepattern�excludepattern�cap�rawr) r) r* �makechangegroup� s4
�
� �
r� c % s t ���s| �||||g|�R i |��S d}t� } i �g ��jjtd�|d�}
|�� } | s/n\| d } �j�d| � |
�� �� | �sU��
| �}
|� � }|
� |||� q'd } |�
|�}|s`n |d }|�| |f< ��| |f� | | vr~|d7 }| �| � qX|d u r�t�td���q(t� � � ���fd d
�}d}g }�D ]/\} }�| |f }|d |d |d g}|D ]}|�jks�| |f�v r�q�|�| t|�f� q�q��j�|� ��rw��d�\} }| |f� v r�q�|d7 }|t��d kr�t�td
�����
| �}
�| |f }|\ }}}}}}} } } || || |��sq�|
�|�} t�| |�} t| t ��s+t | �} t � | �\}!} d|!v �rJ|!d }"t |!d �}#|| ||"|#��sJq�||fD ]}$|$�jk�r`|| || |$��s`�qN�qN|
�| |!||||� � �| |f� d}�s�|
� � t��|fS )Nr s files)�totalTs filenames adding %s revisions
r s# received file revlog group is emptyc sN |�j kr%||f� vr%||f�vrdS ��d| |f� ��d||f� dS dS )NTr F)rc r )r: rk �depf�depnode�� processed�queuer< �
revisiondatasr) r* � available s z&addchangegroupfiles.<locals>.availabler � s circular node dependencys copys copyrev) r r- �setrP � makeprogressr �
filelogheader�debug� incrementr8 r@ � deltaiter�addgroup�
deltachunkr] �addr rB rc r � fileservice�prefetch�popr rd r
�patchr �bytes� parsemetar �complete)%r r< r3 �revmap�trp�
expectedfilesrH r4 �newfiles�visited�progress� chunkdatar: �fl�deltas�chain� revisiondatar� � skipcount�
prefetchfilesrk �
dependents� dependentro rp r( � deltabasern rg �sidedata� proto_flags�base�textrq �copyfrom�copynoder$ r) r� r* �addchangegroupfiles� s�
��+
�
�
��1 r� rs )�
__future__r �mercurial.i18nr �mercurial.noder r � mercurialr r r r r
r � r
r r rD rR rO r+ �cgpackerr, r� r� r) r) r) r* �<module> s
j