| 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Ĥ � @ sL d Z ddlmZ ddlZddlZddlZddlmZmZ ddl m
Z
ddl m Z ddl
mZmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z* dd l+m,Z,mZm-Z-m.Z.m/Z/m0Z0m1Z2m3Z3m4Z4m5Z5m6Z6m7Z7 ej8 i Z9e#�8e9�Z8i Z:e#�;e:�Z;e;d
d d d
� e;d
ddd
� e;d
ddd
� e;d
ddd
� e;d
ddd
� e;d
ddd
� e;d
ddd
� e;d
dej<dgd� e;d
ddd
� e;d
ddd
� e;d
d dd
� e;d
d dd
� e;d
d d d
� e;d
d d d
� e;d
d!dd
� e;d
d"dd
� e;d
d#d d
� e;d
d$d%d
� e;d
d&d'd
� e;d
d(d)d
� e;d
d*d+d
� e;d
d,d-d
� e;d
d.ej<� e;d
d/dd
� e;d
d0dd
� e;d
d1dd
� e;d
d2d d
� e;d
d3d d
� e;d4d5d6d6d7� e;d8d9dd
� e;d8d:d;d
� e;d<d=d d
� d>Z=e;d
d?e=d
� e;d
d@dAd
�f e;d
dBg dC�d
� e;d
dDdEd
� e;d
dFdGd
� e;d
dHdId
� e;d
dJdAd
�f e;d
dKdIgd
� e;d
dLdEd
� e;d
dMdNd
� e;d
dOdId
� dPZ>ej?Z@e@jA�Be,jC� e6jDZDdQdR� ZEdSdT� ZFdUdV� ZGdWdX� ZHdYdZ� ZId[d\� ZJd]d^� ZKd_d`� ZLdadb� ZMdcdd� ZNd�dedf�ZOdgdh� ZPdidj� ZQd�dkdl�ZRd�dmdn�ZSdodp� ZTd�dqdr�ZUd aVdsdt� ZWd�dudv�ZXdwdx� ZYe8dyg e
dz�d6d{�d|d}� �ZZd~d� Z[d�d�� Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbe8d�d�d�de
d��fge
d��d6d{�d�d�� �Zce8d�d�d�de
d��fge
d��d6d{�d�d�� �Zde8d�dd�de
d��fdd�de
d��d�fge
d��d6d{�d�d�� �Zee8d�g e
d��d6d{�d�d�� �Zfe8d�g e
d���d�d�� �Zge8d�g e
d���d�d�� �Zhe8d�g e
d���d�d�� �Zid�d�� Zje8d�d�d�g e
d��e
d��fdd4d e
d��fd�d�de
d��fgejk e
d��e8jld��d�d�� �Zme8d4dd�de
dÃdfdd�de
dŃdfdd�de
dǃdfge
dȃ�d�dʄ �ZndS )�a remotefilelog causes Mercurial to lazilly fetch file contents (EXPERIMENTAL)
This extension is HIGHLY EXPERIMENTAL. There are NO BACKWARDS COMPATIBILITY
GUARANTEES. This means that repositories created with this extension may
only be usable with the exact version of this extension/Mercurial that was
used. The extension attempts to enforce this in order to prevent repository
corruption.
remotefilelog works by fetching file contents lazily and storing them
in a cache on the client rather than in revlogs. This allows enormous
histories to be transferred only partially, making them easier to
operate on.
Configs:
``packs.maxchainlen`` specifies the maximum delta chain length in pack files
``packs.maxpacksize`` specifies the maximum pack file size
``packs.maxpackfilecount`` specifies the maximum number of packs in the
shared cache (trees only for now)
``remotefilelog.backgroundprefetch`` runs prefetch in background when True
``remotefilelog.bgprefetchrevs`` specifies revisions to fetch on commit and
update, and on other commands that use them. Different from pullprefetch.
``remotefilelog.gcrepack`` does garbage collection during repack when True
``remotefilelog.nodettl`` specifies maximum TTL of a node in seconds before
it is garbage collected
``remotefilelog.repackonhggc`` runs repack on hg gc when True
``remotefilelog.prefetchdays`` specifies the maximum age of a commit in
days after which it is no longer prefetched.
``remotefilelog.prefetchdelay`` specifies delay between background
prefetches in seconds after operations that change the working copy parent
``remotefilelog.data.gencountlimit`` constraints the minimum number of data
pack files required to be considered part of a generation. In particular,
minimum number of packs files > gencountlimit.
``remotefilelog.data.generations`` list for specifying the lower bound of
each generation of the data pack files. For example, list ['100MB','1MB']
or ['1MB', '100MB'] will lead to three generations: [0, 1MB), [
1MB, 100MB) and [100MB, infinity).
``remotefilelog.data.maxrepackpacks`` the maximum number of pack files to
include in an incremental data repack.
``remotefilelog.data.repackmaxpacksize`` the maximum size of a pack file for
it to be considered for an incremental data repack.
``remotefilelog.data.repacksizelimit`` the maximum total size of pack files
to include in an incremental data repack.
``remotefilelog.history.gencountlimit`` constraints the minimum number of
history pack files required to be considered part of a generation. In
particular, minimum number of packs files > gencountlimit.
``remotefilelog.history.generations`` list for specifying the lower bound of
each generation of the history pack files. For example, list [
'100MB', '1MB'] or ['1MB', '100MB'] will lead to three generations: [
0, 1MB), [1MB, 100MB) and [100MB, infinity).
``remotefilelog.history.maxrepackpacks`` the maximum number of pack files to
include in an incremental history repack.
``remotefilelog.history.repackmaxpacksize`` the maximum size of a pack file
for it to be considered for an incremental history repack.
``remotefilelog.history.repacksizelimit`` the maximum total size of pack
files to include in an incremental history repack.
``remotefilelog.backgroundrepack`` automatically consolidate packs in the
background
``remotefilelog.cachepath`` path to cache
``remotefilelog.cachegroup`` if set, make cache directory sgid to this
group
``remotefilelog.cacheprocess`` binary to invoke for fetching file data
``remotefilelog.debug`` turn on remotefilelog-specific debug output
``remotefilelog.excludepattern`` pattern of files to exclude from pulls
``remotefilelog.includepattern`` pattern of files to include in pulls
``remotefilelog.fetchwarning``: message to print when too many
single-file fetches occur
``remotefilelog.getfilesstep`` number of files to request in a single RPC
``remotefilelog.getfilestype`` if set to 'threaded' use threads to fetch
files, otherwise use optimistic fetching
``remotefilelog.pullprefetch`` revset for selecting files that should be
eagerly downloaded rather than lazily
``remotefilelog.reponame`` name of the repo. If set, used to partition
data from other repos in a shared store.
``remotefilelog.server`` if true, enable server-side functionality
``remotefilelog.servercachepath`` path for caching blobs on the server
``remotefilelog.serverexpiration`` number of days to keep cached server
blobs
``remotefilelog.validatecache`` if set, check cache entries for corruption
before returning blobs
``remotefilelog.validatecachelog`` if set, check cache entries for
corruption before returning metadata
� )�absolute_importN)�hex�wdirrev)�_)�open)� changegroup� changelog�commands� configitems�context�copies�
debugcommands�dispatch�error�exchange�
extensions�hg� localrepo�match�merge�
mergestate�patch�pycompat� registrar�repair�repoview�revset�scmutil�smartset� streamclone�util� ) � constantsr
�fileserverclient�
remotefilectx�
remotefilelog�remotefilelogserver�repack�
shallowbundle� shallowrepo� shallowstore� shallowutil�shallowverifier�
remotefilelogs debugF)�defaults reponame� s cachepaths
cachegroups cacheprocesss cacheprocess.includepaths
cachelimits 1000 GBs fallbackpath)r- s fallbackrepo)r. �aliass validatecachelogs
validatecaches on� servers servercachepaths serverexpiration� � backgroundrepack� bgprefetchrevs� pullprefetch� backgroundprefetch�
prefetchdelay�x � prefetchdays� s strip.includefiles�alls getfilesstepi' s getfilestypes
optimistics batchsizes fetchwarnings includepatterns excludepattern� gcrepack� repackonhggc� repacks chainorphansbysizeT)r. Z experimentals packss maxpacksizes maxchainleni� s devels remotefilelog.bg-waiti �' s nodettls data.gencountlimit� s data.generations)s 1GB� 100MBs 1MBs data.maxrepackpacks�2 s data.repackmaxpacksizes 4GBs data.repacksizelimitr@ s history.gencountlimits history.generationss history.maxrepackpackss history.repackmaxpacksizes 400MBs history.repacksizelimits ships-with-hg-corec C s� t j�tj� t�tjdt �}|d �dddt
d�f� t�tjdt j � t�tjdt j
� t�tjd t� t�tjd
t� d d � }t�tjd
|� d#dd�}t�d|� t�tjdt� tjt_t�tdtj� t�tdtj� t�tdt� t�td
t � t�t dt � t�t dt � t�t j!dt"� t�t#dt$� t�t%dt&� t�t'dt(� t�t)d t*� t�t j+d t,� t�t j!d t-� t�t.d t/� t�t d t0� t#j1�2d t3� t�t#d!t4� t�t5d"t6� t5j7t5j8d"< dS )$zUWraps user facing Mercurial commands to swap them out with shallow
versions.
s cloner! r/ s shallowNs5 create a shallow clone which uses remote file historys
debugindexs
debugindexdots log� pullc _ s8 t |�r |�d�r t�td���| ||g|�R i |��S )Nr; s( --all is not supported in a shallow repo)� isenabled�getr �Abortr )�orig�ui�repo�args�opts� rK �B/usr/lib64/python3.9/site-packages/hgext/remotefilelog/__init__.py� _manifest& s zuisetup.<locals>._manifests manifestFc S s@ d }zt �d�}W n ty$ Y n0 |r<|�tj� |t_d S )N� lfs)r �find�KeyErrorZ wrapfilelogr% r# Z_lfsmod)ZloadedZlfsmodrK rK rL �
_lfsloaded/ s zuisetup.<locals>._lfsloadedrN s debugdatas _addchangegroupfiless makechangegroups makestores applyupdatess _checkunknownfiless _checklookups _findrenamess _computeforwardmissings
runcommands _collectbrokencsetss filectxs trydiffs verifyr- s getrenamedfns filelog)F)9r Zwirepeersetupfuncs�appendr# Z peersetupr Z wrapcommandr �table� cloneshallowr r
Z
debugindexZ
debugindexdot�log�pullZ afterloaded�debugdatashallowr( Zshallowcg1packerr Zcgpacker� wrapfunctionZaddchangegroupfilesZmakechangegroupr � storewrapperr � exchangepullr � applyupdates�checkunknownfilesr �
workingctx� checklookupr � findrenamesr �computeforwardmissingr �
runcommandr �_collectbrokencsets� changectx�filectx�workingfilectxr �trydiff�_verifyZfileprefetchhooks�add�_fileprefetchhook� getrenamedfnr �
filelogrevset�filelogZsymbols)rG �entryrM rQ rK rK rL �uisetup s` ��
�
�
���rn c s� |� d�rbg � � fdd�}t�td|� dd� ��fdd�}t�td |� dd d �}t�td
|� zF| ||g|�R i |�� W |� d�rֈ D ]}t�|d�r�|j�� q�n,|� d�rԈ D ]}t�|d�r�|j�� q�0 d S )N�shallowc s� t |�s�� �|�� � t|j|�� � t|tj�rL|jjd |�� jf|j_|j �
t j � |�
� � t�|� W d � n1 s�0 Y t| |g|�R i |��S | |g|�R i |��S d S �Nr )rC rR Z
unfiltered� setupclientrG �
isinstancer � __class__� __bases__� requirementsrh r" �SHALLOWREPO_REQUIREMENT�lockr ZwritereporequirementsrZ )rF �selfrI �kwargs)�reposrK rL � pull_shallowa s
�
(z"cloneshallow.<locals>.pull_shallowrB c s � �fdd�}t �� d|� d S )Nc s\ � � � }tj|v rRi }�jr,d��j�|d< �jrBd��j�|d< � jdi |��S | � S d S )N� �includepattern�excludepattern� stream_out_shallow)r )Z capabilitiesr" Z NETWORK_CAP_LEGACY_SSH_GETFILESr} �joinr~ Z _callstream)rF ZcapsrJ ��remoterH rK rL �stream_out_shallow� s
zAcloneshallow.<locals>.setup_streamout.<locals>.stream_out_shallows
stream_out)r rX )rH r� r� rK r� rL �setup_streamout~ s z%cloneshallow.<locals>.setup_streamoutc s � |j |j� | |�S �N)rH r� )rF �op)r� rK rL � stream_wrap� s z!cloneshallow.<locals>.stream_wraps maybeperformlegacystreamcloneFc S s` d|j �dg �v r,dd� |j d D �|j d< |r4dS | ||d�\}}|d urX|�tj� ||fS )N� v2s streamc S s g | ]}|d kr|�qS )r� rK )�.0�crK rK rL �
<listcomp>� s z?cloneshallow.<locals>.canperformstreamclone.<locals>.<listcomp>)FN)�bundle2)Zremotebundle2capsrD rh r" rv )rF Zpullopr� Z supportedru rK rK rL �canperformstreamclone� s � z+cloneshallow.<locals>.canperformstreamclones canperformstreamclones fileservice)F) rD r rX r r r � safehasattr� fileservice�close) rF rG rH rI rJ r{ r� r� �rrK )rz r� rL rT ] s.
�
�
�
rT c O s< t j j}z$dd� t j _| |i |��W |t j _S |t j _0 d S )Nc S s dS )Nr! rK )�xrK rK rL �<lambda>� r/ z"debugdatashallow.<locals>.<lambda>)r% �__len__)rF rI �kwds�oldlenrK rK rL rW � s �rW c C sn |� � s d S | �ddt� | �ddt� | �dd�}t|�}|rL|rLtd��|rZt| |� |rjt�| |� d S )Ns hookss update.prefetchs commit.prefetchr- r1 s+ Cannot be both a server and shallow client.) �localZ setconfig� wcpprefetch�
configboolrC � RuntimeErrorrq r& Z setupserver)rG rH ZisserverenabledZisshallowclientrK rK rL � reposetup� s
r� c C s> t |tj�sd S t�| � t| � t�|� t� |j
�|_
d S r� ) rr r �localrepositoryr& Z onetimesetup�onetimeclientsetupr) Zwraprepor* � wrapstore�store)rG rH rK rK rL rq � s
rq c C s$ | |||�}t j|v r t�|�}|S r� )r" rv r* r� )rF ru �pathZvfstype�srK rK rL rY � s
rY c
K sj t |�rP|�� }g } |�tjg�D ] \}
} } | �|
t||
�f� q"|j�| � | ||||||fi |��S r� ) rC �manifestZ
getactions�
mergestatemodZ
ACTION_GETrR r r� �prefetch)
rF rH �mresult�wctx�mctxZ overwriteZ wantfiledatarJ r� �files�frI �msgrK rK rL r[ � s r[ c O s� t |�r�g }|�|�� �} |�� D ]t\}
\} } }
| r>| |
�s>q"| tjtjtjfv rl|�|
t |�
|
��f� q"| tj kr"| d }|�|t |�
|��f� q"|j �
|� | |||||g|�R i |��S rp )rC �maybesparsematch�revZfilemapr� ZACTION_CREATEDZACTION_DELETED_CHANGEDZACTION_CREATED_MERGErR r �filenodeZACTION_LOCAL_DIR_RENAME_GETr� r� )rF rH r� r� �forcer� rI ry r� � sparsematchr� �mZ
actionargsr� �f2rK rK rL r\ � s" �
r\ c C s` |j }t|�rTg }|jD ].}|D ]$}||v r |�|t|�|��f� q q|j�|� | |||�S r� )�_reporC Z_parentsrR r r� r� r� )rF rx r� Zmtime_boundaryrH Z
prefetchfiles�parentr� rK rK rL r^ s
r^ c
O sh t |�rLg }|d �� }|D ]"} | |v r |�| t|| �f� q |j�|� | ||||g|�R i |��S )N� .)rC r� rR r r� r� )
rF rH Zmatcher�added�removedrI ry r� Zpmfr� rK rK rL r_ s r_ c C s� | |||d�}|j }t|�r�|�� }g }|�|�� �}|rvt� } |D ],}
||
�rD|�|
t||
�f� | �|
� qD| }|j �
|� |S )N)r ) r� rC r� r� r� �setrR r rh r� r� ) rF �a�br �missingrH Zmbr� r� Z
sparsemissingr� rK rK rL r` & s r` c O sR d }|rt |�r|j}z(| ||g|�R i |��W |r<|�� S n|rL|�� 0 d S r� )rC r� r� )rF ZluirH rI ry r� rK rK rL ra < s � �ra c s* t � �r t� fdd�|D ��}| � ||�S )Nc s g | ]}� � |�s|�qS rK )� shallowmatch�r� r� �rH rK rL r� M r/ z'_collectbrokencsets.<locals>.<listcomp>)rC �list)rF rH r� ZstriprevrK r� rL rb K s rb c C sN |d u r|� |�}t|j�r>|j�|�r>tj|j||||d�S | ||||d�S )N)�fileidrc rl )r� rl )r� rC r� r� r$ )rF rx r� r� rl rK rK rL rd R s
�rd c C s8 t |j�r*|j�|�r*tj|j|||d�S | |||d�S )N)r] rl )rl )rC r� r� r$ Zremoteworkingfilectx)rF rx r� rl rK rK rL re \ s
�re c
O s� t |�r�g } |�� }
|| | D ]\}||
v rP| ||��� }|rP| �|t|�f� ||vr | ||��� }|r | �|t|�f� q |j�| � | ||||||||| g |
�R i | ��S r� )rC r� r� rR r r� r� )rF rH �revsZctx1Zctx2Zmodifiedr� r� �copyZ
getfilectxrI ry r� Zmf1�fname�fnoderK rK rL rf e s8 �
� �rf c C s0 |� � }zt�|��� W |�� S |�� 0 d S r� )rw r, Zverify�release)rF rH �levelrw rK rK rL rg � s �rg c sN t rd S da g � d� fdd� }t�tjd|� � fdd�}t�tjd|� d S ) NTc sL t |t�r,� �||||||||| |
f
� |S | ||||||||| |
d�
S d S )N)�
_metatuple)rr �intrR ) rF rx ZrawtextZ transaction�link�p1�p2�node�flagsZ
cachedeltar� �ZpendingfilecommitsrK rL �addrawrevision� s6
���z*onetimeclientsetup.<locals>.addrawrevisions addrawrevisionc s� t |�}| |g|�R i |��}t |�}||kr�� D ]T}|\
}} }
} } }
}}}}|�| �}||kr||�| |
|| |
||||� q2t�d��q2n t dd� � D ��dkr�t�d��� d d �= |S )Ns4 pending multiple integer revisions are not supportedc S s h | ] }|d �qS )� rK )r� r� rK rK rL � <setcomp>� r/ z;onetimeclientsetup.<locals>.changelogadd.<locals>.<setcomp>r! )�lenr� r� r ZProgrammingError)rF rx rI ry r� r� ZnewlenZoldargsrU Zrt�trr� r� r� �nZflr� r� Zlinknoder� rK rL � changelogadd� s$
��
z(onetimeclientsetup.<locals>.changelogadds add)NN)�
clientonetimer rX r% r )rG r� r� rK r� rL r� � s �+� r� c s2 t ��rt���r | �|�S i � � �fdd�}|S )Nc s� |� � | i �v r � | | S z^�| �| �}|�� D ]0}|�� | kr4|�� }|oV|d � | |�� < q4|�� }|ox|d W S tjy� Y dS 0 dS )z�looks up all renames for a file (up to endrev) the first
time the file is given. It indexes on the changerev and only
parses the manifest if linkrev != changerev.
Returns rename info for fn at changerev rev.r N)�
setdefaultrd � ancestorsr� �renamedr� r � LookupError)�fnr� �fctxZancestorr� �ZrcacherH rK rL �
getrenamed� s z getrenamedfn.<locals>.getrenamed)rC r Zusechangesetcentricalgo)rF rH Zendrevr� rK r� rL rj � s
rj c s t |�s| |||�S t�|td��}tj|j|�� |gd|d d�� t� �t� |�s�|D ]<}|| }|�
� }� �
� D ] }||v rt�� |� � � qXqtqXnX� fdd�|d D �} | D ]<}|d �
|�}
�� |
�� � |
�� D ]} �� | �� � q�q�t��fdd�|D ��S ) a ``filelog(pattern)``
Changesets connected to the specified filelog.
For performance reasons, ``filelog()`` does not show every changeset
that affects the requested file(s). See :hg:`help log` for details. For
a slower, more accurate result, use ``file()``.
s filelog requires a patterns relpathN)r. �ctxc 3 s | ]}� |�r|V qd S r� rK r� )r� rK rL � <genexpr>1 r/ z filelogrevset.<locals>.<genexpr>c s g | ]}|� v r|�qS rK rK �r� r� )r� rK rL r� 8 r/ z!filelogrevset.<locals>.<listcomp>)rC r Z getstringr �matchmodr �root�getcwdr� Zpatkindr� rh r� rd Zlinkrevr� r Zbaseset) rF rH Zsubsetr� �patr� r� Zcfilesr� r� r� ZactxrK )r� r� rL rk s, �
rk s gcs hg gc [REPO...])Znorepoc O s� t � }tj| dd�}|r"|�|� g }| j�d�}|r@|�|� |�|� g }|D ]T}z:t� | i |�} |�| � tj| j
dd�}
|
r�|�|
� W qR t j y� Y qR0 qR|D ]} t
| | � q�|D ]} t�| | j� q�dS )z4garbage collect the client and server filelog cachesT)Z
allowemptys PWDN)r� r+ Z getcachepathrh �environrD rR �extendr �peerrG r � RepoError�gcclientr& Zgcserverr� ) rG rI rJ Z
cachepathsZ systemcacheZ repopaths�pwdrz ZrepopathrH Z repocache� cachepathrK rK rL �gc; s.
r� c s~ t j�|d�}t j�|�s0| �td�| � d S t|d�}dd� |�� D �}|�� g }t � }d }d}d} | j
td�dt |�d �}
|D �]r} |
� | � | d
7 } zt
�t j�| ��} W nP t�y } z6| �td �| | f � t�� W Y d } ~ q�W Y d } ~ n
d } ~ 0 0 zt�| i | �}
|
j}W n tj�y8 Y q�Y n0 |�| � t|��sPq�t
�|d ��sr| �td
�| � q�|j� dd�}|j� dd�}|�r�|�r�zt � |� d}W q�W n t t j f�y� Y n0 |j!� |�s�|j"}� fdd�}t j#|||d�}q�|
�$� t �%d�}z4t|d�}|�&dd� |D �� |�� W t �%|� n t �%|� 0 |d u�rf|�'|� n|�sz| �td�� d S )Ns reposs no known cache at %s
s rbc S s h | ]}|d d� �qS )N���rK r� rK rK rL r� i r/ zgcclient.<locals>.<setcomp>Fr s analyzing repositories)Zunit�totalr! s warning: malformed path: %r:%s
s names. repo %s is a misconfigured remotefilelog repo
r- r= r< Tc s t �� | t|��S r� )r# � getcachekeyr �r� r� �ZreponamerK rL �keyfn� s zgcclient.<locals>.keyfn)r� Z lastkeepkeysr? s wbc S s g | ] }d | �qS )� %s
rK r� rK rK rL r� � r/ z gcclient.<locals>.<listcomp>s$ warning: no valid repos in repofile
)(�osr� r� �exists�warnr r � readlinesr� r� Z makeprogressr� �updater Z
expandpath�normpath� TypeError� traceback� print_excr r� r� r r� rR rC r� rG r� � repackmod�incrementalrepack�IOError�RepackAlreadyRunning�nameZ sharedstore�keepsetZcomplete�umask�
writelinesr� )rG r� Z repospathZ reposfilerz Z
validreposZkeepkeysZ sharedcacheZ
filesrepacked�countZprogressr� �er� rH Z repackonhggcZgcrepackr� ZoldumaskrK r� rL r� a s|
�
"
�
r� c
O s� t |�s | ||g|�R i |��S |�d�}|�d�}|r�|r@|rHd|d< |s�|s�t�|d |t�|��}|�� }|r�|�� D ] } tj �
|� | ��s~d} q�q~|r�|� t
d�� | ||g|�R i |��S )N�followr� Tr� r� FsE warning: file log can be slow on large repos - use -f to speed it up
)rC rD r r r � byteskwargsZanypatsr� r� r� �isfileZwjoinr� r )
rF rG rH �patsrJ r r� r r �filerK rK rL rU � s,
��rU c C s$ | � dd�}|dkr d||f }|S )z�Update revset so that only changesets no older than 'prefetchdays' days
are included. The default value is set to 14 days. If 'prefetchdays' is set
to zero or negative value then date restriction is not applied.
r- r9 r s (%s) & date(-%s))� configint)rG r ZdaysrK rK rL � revdatelimit� s r
c C sx | j �dd�}| j�d�}d}t|d��< tj�|�}t�� | |krVt� |d� d}W d � n1 sj0 Y |S )z�Check that enough time has passed since the last background prefetch.
This only relates to prefetches after operations that change the working
copy parent. Default delay between background prefetches is 2 minutes.
r- r7 s lastprefetchF� aNT)
rG r Zvfsr� r r� r� �getmtime�time�utime)rH �timeoutr� ZreadyZmodtimerK rK rL � readytofetch� s "r c sb t ��}| �dd�� t��}|r(� r(|s,dS �j�dd��t| � �� � ��fdd�}��|� dS )z�Prefetches in background revisions specified by bgprefetchrevs revset.
Does background repack if backgroundrepack flag is set in config.
r- r4 Nr3 c s. t ��d�r�jrd S d�_�j� �d� d S )Ns ranprefetchT�r' )r r� Z ranprefetch�backgroundprefetch)Zunused_success��bgprefetchrevs�bgrepackrH rK rL �anon s zwcpprefetch.<locals>.anon)rC �configr rG r� r
Z
_afterlock)rG rH ry ro Zisreadyr rK r rL r� s
r� c O s� | ||g|�R i |��}t |�r�|�dd�}|j�dd�}|j�dd�}|r�|�td�� t�||g�} |d �� }
|r�|j ||d� q�|j
| |
d� |r�t j |d d
� n|r�t j |d d
� |S ) Nr- r5 r3 r6 s prefetching file contents
r� r )�baseT�� incremental)
rC r rG r� �statusr r �revranger� r r� r� �backgroundrepack) rF rG rH r
rJ �result�prefetchrevsetr Z
bgprefetchr� r rK rK rL rV s" rV c O sP ddd�}t �|d�r ||_nt �|d�r8t�|d|� | ||g|�R i |��S )Nc [ s. |s
t � }|�tj� | |f|||d�|��S )N)�heads�common�
bundlecaps)r� rh r" ZBUNDLE2_CAPABLITY)rF �sourcer# r$ r% ry rK rK rL �localgetbundle4 s ���z$exchangepull.<locals>.localgetbundles _callstreams getbundle)NNN)r r� Z
_localrepor rX )rF rH r� rI ry r' rK rK rL rZ 1 s �
rZ c C s� t | �r�g }|D ]r\}}|tks|d u r*q| | }|�� }| �|�� �}|�|�D ].}|rb||�rR||v rR|�|t|| �f� qRq| j� |� d S r� )
rC r r� r� r� �walkrR r r� r� ) rH Z
revmatchesZallfilesr� r r� Zmfr� r� rK rK rL ri F s ri s debugremotefilelog� ds
decompresss decompress the filelog firsts hg debugremotefilelog <path>c K s t j| |fi |��S r� )r
�debugremotefilelog�rG r� rJ rK rK rL r* U s r* s verifyremotefilelogs decompress the filelogs firsts# hg verifyremotefilelogs <directory>c K s t j| |fi |��S r� )r
�verifyremotefilelogr+ rK rK rL r, a s r, s
debugdatapacks longs print the long hashess nodes dump the contents of nodes NODEs hg debugdatapack <paths>c O s t j| g|�R i |��S r� )r
�
debugdatapack)rG �pathsrJ rK rK rL r- m s
r- s debughistorypacks hg debughistorypack <path>c K s t �| |�S r� )r
�debughistorypackr+ rK rK rL r/ z s r/ s debugkeepsets hg debugkeepsetc s � fdd�}t �� |� d S )Nc s t �� j| t|��S r� )r# r� r r r� r� rK rL r� � s zdebugkeepset.<locals>.keyfn)r� r )rG rH rJ r� rK r� rL � debugkeepset s r0 s debugwaitonrepacks hg debugwaitonrepackc K s
t �|�S r� )r
�debugwaitonrepack�rG rH rJ rK rK rL r1 � s r1 s debugwaitonprefetchs hg debugwaitonprefetchc K s
t �|�S r� )r
�debugwaitonprefetchr2 rK rK rL r3 � s r3 c C s� |� d�spddg}| �ddd �}|r2|�d| � | �ddd �}|rR|�d| � d�|�}t| |�}|g|d< |� d �s�d |d < |S )
N� revr� s draft()r- r5 s (%s)r4 � +� base)rD r rR r� r
)rG rJ r r" r rK rK rL �resolveprefetchopts� s
r7 s prefetch� rr4 s prefetch the specified revisionss REVs run repack after prefetch� br6 s' rev that is assumed to already be locals hg prefetch [OPTIONS] [FILE...])Z helpcategoryc O sn t �|�}t|�s t�td���t| |�}t�||� d��}|�
||� d�||� |� d�rjt j |dd� dS )at prefetch file revisions from the server
Prefetchs file revisions for the specified revs and stores them in the
local remotefilelog cache. If no rev is specified, the default rev is
used which is the union of dot, draft, pullprefetch and bgprefetchrev.
File names or patterns can be used to limit which files are downloaded.
Return 0 on success.
s repo is not shallowr4 r6 r> Tr N)
r r rC r rE r r7 r r rD r� r� r )rG rH r
rJ r� rK rK rL r� � s
r� s
backgrounds run in a background processs incrementals do an incremental repack� packsonlys& only repack packs (skip loose objects)s hg repack [OPTIONS]c
O s� |� d�r,tj||� d�|� dd�d� d S d|� d�i}z,|� d�rVtj||d� ntj||d� W n6 tjy� } z |j�d| � W Y d }~n
d }~0 0 d S ) NZ
backgroundr � packsonlyF)r r; r: )�optionsr� )rD r� r r� Z
fullrepackr rG r� )rG rH r
rJ r< �exrK rK rL �repack_� s
�
r> )N)NN)N)N)N)o�__doc__Z
__future__r r� r r� Zmercurial.noder r Zmercurial.i18nr Zmercurial.pycompatr Z mercurialr r r r
r r r
Zhgdebugcommandsr r r r r r r r� r r r� r r r r r r r r r r � r" r# r$ r% r& r' r� r( r) r* r+ r, ZcommandZcmdtableZ configtableZ
configitemZdynamicdefaultZ
_defaultlimitZ
testedwithr� Z repoclassZ_basesupportedrh rv rC rn rT rW r� rq rY r[ r\ r^ r_ r` ra rb rd re rf rg r� r� rj rk r� r� rU r
r r� rV rZ ri r* r, r- r/ r0 r1 r3 r7 ZwalkoptsZCATEGORY_MAINTENANCEr� r> rK rK rK rL �<module> s@ x p 8
�
�QV
/
W
(
%^# ��
��
��
���
�� �