Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
hgext
/
remotefilelog
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: shallowbundle.cpython-310.pyc
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
Save
Cancel