| 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 dlZd dlmZ d dlmZmZ d dlm Z m
Z
m Z m Z m
Z
mZmZmZ d dlmZ ddlmZmZmZmZmZmZmZmZm Z m Z d d
� Z d d � Z d
d� Z dd� Z!dd� Z"dd� Z#dS )� )�absolute_importN)�_)�hex�nullrev)�encoding�error� localrepo�match�pycompat�scmutil�sparse�util)�procutil� )
�connectionpool� constants� contentstore�datapack�fileserverclient� historypack�
metadatastore�
remotefilectx�
remotefilelog� shallowutilc C sZ t j�| jjjd�}t j�|�s*t �|� tj | || j
dd�}t j | || j
dd�}||fS )z:In-repo stores, like .hg/store/data; can not be discarded.s dataF�Zshared)
�os�path�join�svfsZvfs�base�exists�makedirsr �remotefilelogcontentstore�namer �remotefilelogmetadatastore)�repoZ localpath� localcontent�
localmetadata� r( �E/usr/lib64/python3.9/site-packages/hgext/remotefilelog/shallowrepo.py�makelocalstores' s
�
�r* c C sZ t �| j�}tj| || jdd�}tj| || jdd�}|| _| j �
|� | j �
|� ||fS )z?Typically machine-wide, cache of remote data; can be discarded.Tr ) r Z getcachepath�uir r" r# r r$ Z sharedstore�shareddatastores�append�sharedhistorystores)r% Z cachepath� cachecontent�
cachemetadatar( r( r) �makecachestores7 s
�
� r1 c C s8 t � | �| _t�| j| j|�}t�| j| j|�}||fS )z-These stores fetch data from a remote server.)r � fileservicer Zremotecontentstorer+ r Zremotemetadatastore)r% r/ r0 �
remotecontent�remotemetadatar( r( r) �makeremotestoresI s
�
�r5 c C s\ t �| tj�}t�| j|�}t�| j|�}| j �
|� | j �
|� t � | jd||� ||fS )z5Packs are more efficient (to read from) cache stores.� filestore)
r Zgetcachepackpathr ZFILEPACK_CATEGORYr Z
datapackstorer+ r Zhistorypackstorer, r- r. �reportpackmetrics)r% Zpackpath�packcontentstore�packmetadatastorer( r( r) �makepackstoresV s
�r: c C s� g | _ g | _t| �\}}t| �\}}t| �\}}t| ||�\}}tj|||||d�| _tj |||||d�| _|} |}
| j
� | j| j| |
� t �
| jd||� dS )zBUnion stores iterate the other stores and return the first result.)Z
writestorer6 N)r, r. r: r1 r* r5 r Zunioncontentstorer Zunionmetadatastorer2 Zsetstorer r7 r+ ) r% r8 r9 r/ r0 r& r' r3 r4 ZfileservicedatawriteZfileservicehistorywriter( r( r) �makeunionstorese sB ����
�r; c s� G � �fdd�d� j ���� _ t�� � _t� � � j�ddd �� _� j�ddd �� _t �
� d�slt � � �� _ � jsx� jr�t�� j dd � j� j�� _d S )Nc s� e Zd Zejdd� �Zej�fdd��Z�fdd�Z� �fdd�Z� �fd d
�Z e
j d� �fd
d� �Z d�fdd� Z
d�fdd� Zd�fdd� Z� �fdd�Z� ZS )z#wraprepo.<locals>.shallowrepositoryc S s | j �dd�S )N�
remotefilelogs reponame)r+ �config��selfr( r( r) r# � s z(wraprepo.<locals>.shallowrepository.namec s, � j �dd� j �dd��}|s(t�d��|S )Nr< s fallbackpaths pathss defaults> no remotefilelog server configured - is your .hg/hgrc trusted?)r+ r= r ZAbort)r? r �r% r( r) � fallbackpath� s ��z0wraprepo.<locals>.shallowrepository.fallbackpathc s. |rt j� |d�}n
t �� �}|�� r*dS |S )z�
A wrapper that allows the remotefilelog to invoke sparsematch() if
this is a sparse repository, or returns None if this is not a
sparse repository.
)�revsN)r Zmatcher�always)r? rB �kwargs�retr@ r( r) �maybesparsematch� s
z4wraprepo.<locals>.shallowrepository.maybesparsematchc sF |d dkr|dd � }| � |�r2t�| j|| �S t�| ��|�S d S )Nr � /r )� shallowmatchr r �super�file)r? �f�� __class__�shallowrepositoryr( r) rJ � s
z(wraprepo.<locals>.shallowrepository.filec sF | � |�r$tj| |g|�R i |��S t�| �j|g|�R i |��S d S �N)rH r rI �filectx)r? r �argsrD rL r( r) rP � s
���z+wraprepo.<locals>.shallowrepository.filectxFNc sz |� � sd|�� �� }g }|�� |�� D ].}|�|| j�}|| jkr(|�|t|�f� q(| j �
|� t �| �j |||d�S )z{Add a new revision to current repository.
Revision information is passed via the context argument.
)r �origctx)
� manifestnode�p1ZmanifestZmodifiedZadded�getZnullidr- r r2 �prefetchrI � commitctx)r? �ctxr rR Zm1�filesrK Zfparent1rL r( r) rW � s
�z-wraprepo.<locals>.shallowrepository.commitctxc sl t �� d� jdg}|r |�d� |r0|d|g7 }i }� j�dd�rN� jj|d< t j|tj fdd i|�� d
S ) z0Runs prefetch in background with optional repacks -Rs prefetchs --repacks -rs devels remotefilelog.bg-waitZ record_waitZ ensurestartFN)
r Z hgexecutable�origrootr- r+ Z
configbool�atexitZ runbgcommandr �environ)r? rB r Zrepack�pats�opts�cmdrD r@ r( r) �backgroundprefetch� s
���z6wraprepo.<locals>.shallowrepository.backgroundprefetchc sT � � � jddddtd�� j �� | �||||� W d � n1 sF0 Y dS )z|Prefetches all the necessary file revisions for the given revs
Optionally runs repack in background
s prefetchlockTNs prefetching in %s)�_lockr r rZ � _prefetch)r? rB r r] r^ r@ r( r) rV � s �z,wraprepo.<locals>.shallowrepository.prefetchc s" | j }|rF��d|�}|d urJ|tkrJt��d||��}|rJ|d }n�}�j}|�d�} |d ur�|�| �� �� }
tt �
|
��} nt� } | � � } | � � }
t� }|� t� t
|�}| jjtd�|d�}|�d� t|�D ]�}�| }|r�t�|||�� ��|��|�� }| �|�}| �|�\}}||v �rD||v �rD|| �� }
n || �� }
t �
|
�}|�rr� fdd�|D �}��r��fd d�|D �}||v�r�|
�|� n
| �|� |� |� |�� q�| �| � |
�| � |�� |
�r�d
d � |
D �}�j j |d d
� | �r dd � | D �}�j � |� d S )Ns outgoing(%s)s first(reverse(::%s) - %ld)r � s prefetching)�totalc 3 s | ]}� |d �r|V qdS �r Nr( ��.0Zpf)�mr( r) � <genexpr>0 rc z@wraprepo.<locals>.shallowrepository._prefetch.<locals>.<genexpr>c 3 s | ]}� |d �r|V qdS re r( rf )� sparsematchr( r) ri 2 rc c S s g | ]\}}|t |�f�qS r( �r �rg r Zfnoder( r( r) �
<listcomp>A rc zAwraprepo.<locals>.shallowrepository._prefetch.<locals>.<listcomp>T)�forcec S s g | ]\}}|t |�f�qS r( rk rl r( r( r) rm F rc ) rA rB r �listZ manifestlogZ
getstoragerS �read�setr
Z iteritems�copy�add�lenr+ Z makeprogressr �update�sortedr r rF �revZ
parentrevsZreadfastZ increment�difference_updateZcompleter2 rV )r? rB r r] r^ rA Z localrevsZ
serverbaseZmflZmfrevlogZmfdict�skiprY Z serverfilesZvisitedZrevcountZprogressrw rX ZmfnodeZmfrevrT Zp2�diff�resultsr@ )rh rj r) rb � sn ��
z-wraprepo.<locals>.shallowrepository._prefetchc s t �| ��� | j�� d S rO )rI �closer r> rL r( r) r| I s z)wraprepo.<locals>.shallowrepository.close)FN)NFNN)NNN)NNN)�__name__�
__module__� __qualname__r
Z
propertycacher# rA rF rJ rP r ZunfilteredmethodrW r` rV rb r| �
__classcell__r( �r% rN )rM r) rN � s
�OrN r< s includepatterns excludepatternr rc )
rM r rC rH r; r+ Z
configlistZincludepatternZexcludepatternr
Z safehasattrr �rootr@ r( r� r) �wraprepo� s" ?
�� �r� )$Z
__future__r r Zmercurial.i18nr Zmercurial.noder r Z mercurialr r r r r
r r r
Zmercurial.utilsr � r r r r r r r r r r r* r1 r5 r: r; r� r( r( r( r) �<module> s (
0
)