| Server IP : 108.167.183.253 / Your IP : 216.73.216.79 Web Server : Apache System : Linux gator4209.hostgator.com 5.14.0-687.39.1.el9_8.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Aug 18 06:09:16 EDT 2026 x86_64 User : raghunath ( 2558) PHP Version : 8.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/hgext/fastannotate/__pycache__/ |
Upload File : |
a
�+�b� � @ s� d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
mZmZ d dlmZ ddlmZ d d
� Zd d � Zd
d� Zdd� Zdd� Zdd� Zdd� Zejdd� �Z d!dd�Z dd � Z d d � Z d d � Z dS )"� )�absolute_importN)�_)�open)�error�
extensions�hg�pycompat�util�wireprotov1peer�wireprotov1server)�urlutil� )�contextc C s" | � dd�}|s t�td���|S )z)get the mainbranch, and enforce it is set� fastannotates
mainbranchsF fastannotate.mainbranch is required for both the client and the server)�configr ZAbortr )�ui�master� r �A/usr/lib64/python3.9/site-packages/hgext/fastannotate/protocol.py�
_getmaster s ��r c C s | ||�}|� d� |S )N� getannotate)�append)Zorig�repo�proto�resultr r r �
_capabilities/ s
r c
C s` d}| j �ddd�}t�| |���(}|r�t| j �}znz|�|�sL|�||� W nF ty� |�� z|�||� W n ty� |�� Y n0 Y n0 W |� � n
|� � 0 |j
|k�r<|j |j fD ]v}t
j�|�s�q�t|d��} | �� }
W d � n1 s�0 Y t| jjd �} || d � } |d| t|
�|
f 7 }q�W d � n1 �sR0 Y |S )N� r s serverbuildondemandTs rb� /s %s %d %s)r Z
configboolr �annotatecontextr �
isuptodateZannotate� ExceptionZrebuild�close�lastnodeZ
revmappathZ linelogpath�os�path�existsr �read�len�vfs�base)
r r r$ r" r Z
buildondemand�actxr �p�f�contentZ
vfsbaselen�relpathr r r � _getannotate5 s6 �
& 8r/ c C s" dt jv rd S t �dd�t� d S )Nr s
path lastnode)r ZcommandsZwireprotocommandr/ r r r r �_registerwireprotocommand` s
�r0 c C s t � t�tdt� d S )Ns
_capabilities)r0 r Z wrapfunctionr r �r r r r �
serveruisetuph s r2 c C s� i }d}t | �d }d}d }}||k r�| ||d � }|dkr�|dkr�| |d |d t|� � ||< |t|�7 }d}d }}q�|dkr�d}n"|dkr�||7 }n|dkr�||7 }|d7 }q |S )Nr r
r � )r' �int)Zpayloadr �i�l�stateZvfspath�sizeZchr r r �_parseresponsep s*
r9 c s G � fdd�d|j �}||_ d S )Nc s e Zd Zejd� fdd� �ZdS )z#peersetup.<locals>.fastannotatepeerNc s6 | � d�s � �td�� dS ||p$dd�}|tfS d S )Nr s* remote peer cannot provide annotate cache
)NNr �s paths lastnode)Zcapable�warnr r9 )�selfr$ r" �argsr1 r r � getannotate� s
z/peersetup.<locals>.fastannotatepeer.getannotate)N)�__name__�
__module__� __qualname__r
Z batchabler> r r1 r r �fastannotatepeer� s rB �� __class__)r �peerrB r r1 r � peersetup� s
rF c c s\ | j }|�ddd�}t�d| ||�}|d }t�|i |�}z|V W |�� n
|�� 0 d S )Nr s
remotepaths defaultr )r r r Zget_unique_pull_pathr rE r! )r r Z
remotedest�rZ
remotepathrE r r r � annotatepeer� s rH c
C s� |sdS |du rFt | �� }t| |||�W d � S 1 s<0 Y |du rRi }| j}g }|�� ��}|�dt|� � |D ]"}|�|�d||�|�d��� q~|D ]�}|� � } dd� t
� | �D �} t | �D ]�}
|
�
d�r�d|
d v � r�|�d
|
� q�| |
} |j�r |�d t| �|
f � | j�tj�|
�� | �|
d ��} | �| � W d � q�1 �sb0 Y q�q�W d � n1 �s�0 Y dS )
z1download annotate cache from the server for pathsNs" fastannotate: requesting %d files
r r: c S s i | ]\}}t �|�|�qS r )r Zpconvert)�.0r+ �vr r r �
<dictcomp>� r z clientfetch.<locals>.<dictcomp>s
fastannotate/s /../r s( fastannotate: ignored malicious path %s
s% fastannotate: writing %d bytes to %s
s wb)rH � clientfetchr Zcommandexecutor�debugr' r Z callcommand�getr r Z iteritems�sorted�
startswithZ debugflagr( �makedirsr# r$ �dirname�write)
r �paths� lastnodemaprE r �resultsZbatcherr+ r rG r$ r- r, r r r rL � sN
, �� ��
��rL c C sl | j �ddd�}|dkr |S g }|D ]B}z t| �|��|krF|�|� W q$ tyd |�|� Y q$0 q$|S )z�return a subset of paths whose history is long and need to fetch linelog
from the server. works with remotefilelog and non-remotefilelog repos.
r s clientfetchthreshold�
r )r Z configintr' �filer r )r rT Z thresholdr r$ r r r �_filterfetchpaths� s rY c C s G dd� d|j �}||_ d S )Nc @ s e Zd Zddd�ZdS )z(localreposetup.<locals>.fastannotaterepoNc
S s� t | j�}g }i }ztt| |�D ]R}t�| |��2}|j|dd�sR|�|� |j||< W d � q 1 sf0 Y q |r�t| |||� W n4 t y� } z | j�
d| � W Y d }~n
d }~0 0 d S )NF)�stricts" fastannotate: prefetch failed: %r
) r r rY r r r r r" rL r rM ) r< rT rE r ZneedupdatepathsrU r$ r* �exr r r �prefetchfastannotate� s
*z=localreposetup.<locals>.fastannotaterepo.prefetchfastannotate)N)r? r@ rA r\ r r r r �fastannotaterepo� s r] rC )r r r] r r r �localreposetup� s r^ c C s2 t � |�� rt| |� ttjvr.tj�t� d S )N)r0 �localr^ rF r Zwirepeersetupfuncsr )r r r r r �clientreposetup� s
r` )NN)!Z
__future__r �
contextlibr# Zmercurial.i18nr Zmercurial.pycompatr Z mercurialr r r r r r
r Zmercurial.utilsr � r r r r/ r0 r2 r9 rF �contextmanagerrH rL rY r^ r` r r r r �<module> s( $ +
0