File: //usr/lib/python3/dist-packages/hgext/remotefilelog/__pycache__/__init__.cpython-310.pyc
o
�]LbĤ � @ 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. � 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.repacksizelimitrA 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�rt�td���| ||g|�R i |��S )Nr; s( --all is not supported in a shallow repo)� isenabled�getr �Abortr )�orig�ui�repo�args�opts� rL �>/usr/lib/python3/dist-packages/hgext/remotefilelog/__init__.py� _manifest& s zuisetup.<locals>._manifests manifestFc S sD d }zt �d�}W n ty Y nw |r |�tj� |t_d S d S )N� lfs)r �find�KeyError� wrapfilelogr% r# �_lfsmod)�loaded�lfsmodrL rL rM �
_lfsloaded/ s �
�zuisetup.<locals>._lfsloadedrO s debugdatas _addchangegroupfiless makechangegroups makestores applyupdatess _checkunknownfiless _checklookups _findrenamess _computeforwardmissings
runcommands _collectbrokencsetss filectxs trydiffs verifyr- s getrenamedfns filelog�F)9r �wirepeersetupfuncs�appendr# � peersetupr � wrapcommandr �table� cloneshallowr r
�
debugindex�
debugindexdot�log�pull� afterloaded�debugdatashallowr( �shallowcg1packerr �cgpacker� wrapfunction�addchangegroupfiles�makechangegroupr � storewrapperr � exchangepullr � applyupdates�checkunknownfilesr �
workingctx� checklookupr � findrenamesr �computeforwardmissingr �
runcommandr �_collectbrokencsets� changectx�filectx�workingfilectxr �trydiff�_verify�fileprefetchhooks�add�_fileprefetchhook� getrenamedfnr �
filelogrevset�filelog�symbols)rH �entryrN rV rL rL rM �uisetup s` ��
�
�
���r� c s� |� d�r1g � � fdd�}t�td|� dd� ��fdd�}t�td |� dd d �}t�td
|� z&| ||g|�R i |�� W |� d�rT� D ]}t�|d�rS|j�� qFd S d S |� d�rm� D ]}t�|d�rl|j�� q_w w )N�shallowc s� t |�sR� �|�� � t|j|�� � t|tj�r&|jjd |�� jf|j_|j �
t j � |�
� �
t�|� W d � n1 sAw Y t| |g|�R i |��S | |g|�R i |��S �Nr )rD rY �
unfiltered� setupclientrH �
isinstancer � __class__� __bases__� requirementsry r" �SHALLOWREPO_REQUIREMENT�lockr �writereporequirementsrj )rG �selfrJ �kwargs)�reposrL rM � pull_shallowa s
�
�z"cloneshallow.<locals>.pull_shallowrC c s � �fdd�}t �� d|� d S )Nc sX � � � }tj|v r)i }�jrd��j�|d< �jr!d��j�|d< � jdi |��S | � S )N� �includepattern�excludepattern� stream_out_shallow)r� )� capabilitiesr" � NETWORK_CAP_LEGACY_SSH_GETFILESr� �joinr� � _callstream)rG �capsrK ��remoterI rL rM �stream_out_shallow� s
zAcloneshallow.<locals>.setup_streamout.<locals>.stream_out_shallows
stream_out)r rf )rI r� r� rL r� rM �setup_streamout~ s z%cloneshallow.<locals>.setup_streamoutc s � |j |j� | |�S �N)rI r� )rG �op)r� rL rM � stream_wrap� s z!cloneshallow.<locals>.stream_wraps maybeperformlegacystreamcloneFc S s` d|j �dg �v rdd� |j d D �|j d< |rdS | ||d�\}}|d ur,|�tj� ||fS )N� v2s streamc S s g | ]}|d kr|�qS )r� rL )�.0�crL rL rM �
<listcomp>� s z?cloneshallow.<locals>.canperformstreamclone.<locals>.<listcomp>)FN)�bundle2)�remotebundle2capsrE ry r" r� )rG �pullopr� � supportedr� rL rL rM �canperformstreamclone� s � z+cloneshallow.<locals>.canperformstreamclones canperformstreamclones fileservicerW ) rE r rf r r r � safehasattr� fileservice�close) rG rH rI rJ rK r� r� r� �rrL )r� r� rM r] ] s:
�
�
��
�
��r] c O s8 t j j}zdd� t j _| |i |��W |t j _S |t j _w )Nc S s dS )Nr! rL )�xrL rL rM �<lambda>� s z"debugdatashallow.<locals>.<lambda>)r% �__len__)rG rJ �kwds�oldlenrL rL rM rc � s
rc c C sr |� � sd S | �ddt� | �ddt� | �dd�}t|�}|r&|r&td��|r-t| |� |r7t�| |� d S d S )Ns hookss update.prefetchs commit.prefetchr- r1 s+ Cannot be both a server and shallow client.) �local� setconfig� wcpprefetch�
configboolrD � RuntimeErrorr� r& � setupserver)rH rI �isserverenabled�isshallowclientrL rL rM � reposetup� s
�r� c C s> t |tj�sd S t�| � t| � t�|� t� |j
�|_
d S r� ) r� r �localrepositoryr& � onetimesetup�onetimeclientsetupr) �wraprepor* � wrapstore�store)rH rI rL rL rM r� � s
r� c C s$ | |||�}t j|v rt�|�}|S r� )r" r� r* r� )rG r� �path�vfstype�srL rL rM ri � s
ri c
K sj t |�r(|�� }g } |�tjg�D ]\}
} } | �|
t||
�f� q|j�| � | ||||||fi |��S r� ) rD �manifest�
getactions�
mergestatemod�
ACTION_GETrY r r� �prefetch)
rG rI �mresult�wctx�mctx� overwrite� wantfiledatarK r� �files�frJ �msgrL rL rM rk � s rk c O s� t |�rRg }|�|�� �} |�� D ]:\}
\} } }
| r | |
�s q| tjtjtjfv r6|�|
t |�
|
��f� q| tj krK| d }|�|t |�
|��f� q|j �
|� | |||||g|�R i |��S r� )rD �maybesparsematch�rev�filemapr� �ACTION_CREATED�ACTION_DELETED_CHANGED�ACTION_CREATED_MERGErY r �filenode�ACTION_LOCAL_DIR_RENAME_GETr� r� )rG rI r� r� �forcer� rJ r� r� � sparsematchr� �m�
actionargsr� �f2rL rL rM rl � s$ �
� rl c C s` |j }t|�r*g }|jD ]}|D ]}||v r"|�|t|�|��f� qq |j�|� | |||�S r� )�_reporD �_parentsrY r r� r� r� )rG r� r� �mtime_boundaryrI �
prefetchfiles�parentr� rL rL rM rn s
�� rn c
O sh t |�r&g }|d �� }|D ]} | |v r |�| t|| �f� q|j�|� | ||||g|�R i |��S )N� .)rD r� rY r r� r� )
rG rI �matcher�added�removedrJ r� r� �pmfr� rL rL rM ro s � ro c C s� | |||d�}|j }t|�rA|�� }g }|�|�� �}|r;t� } |D ]}
||
�r8|�|
t||
�f� | �|
� q"| }|j �
|� |S )N)r ) r� rD r� r� r� �setrY r ry r� r� ) rG �a�br �missingrI �mbr� r� �
sparsemissingr� rL rL rM rp & s
� rp c O sP d }|r t |�r |j}z| ||g|�R i |��W |r |�� S S |r'|�� w w r� )rD r� r� )rG �luirI rJ r� r� rL rL rM rq < s
�
�rq c s* t � �rt� fdd�|D ��}| � ||�S )Nc s g | ] }� � |�s|�qS rL )� shallowmatch�r� r� �rI rL rM r� M s z'_collectbrokencsets.<locals>.<listcomp>)rD �list)rG rI r� �striprevrL r� rM rr K s rr c C sN |d u r |� |�}t|j�r |j�|�r tj|j||||d�S | ||||d�S )N)�fileidrs r} )r� r} )r� rD r� r� r$ )rG r� r� r� r} rL rL rM rt R s
�rt c C s8 t |j�r|j�|�rtj|j|||d�S | |||d�S )N)rm r} )r} )rD r� r� r$ �remoteworkingfilectx)rG r� r� r} rL rL rM ru \ s
�ru c
O s� t |�rEg } |�� }
|| | D ].}||
v r(| ||��� }|r(| �|t|�f� ||vr>| ||��� }|r>| �|t|�f� q|j�| � | ||||||||| g |
�R i | ��S r� )rD r� r� rY r r� r� )rG rI �revs�ctx1�ctx2�modifiedr� r� �copy�
getfilectxrJ r� r� �mf1�fname�fnoderL rL rM rv e s: � �
� �rv c C s, |� � }z t�|��� W |�� S |�� w r� )r� r, �verify�release)rG rI �levelr� rL rL rM rw � s rw c sR t rd S da g � d� fdd� }t�tjd|� � fdd�}t�tjd|� d S ) NTc sH t |t�r� �||||||||| |
f
� |S | ||||||||| |
d�
S )N)�
_metatuple)r� �intrY ) rG r� �rawtext� transaction�link�p1�p2�node�flags�
cachedeltar ��pendingfilecommitsrL rM �addrawrevision� s6
���z*onetimeclientsetup.<locals>.addrawrevisions addrawrevisionc s� t |�}| |g|�R i |��}t |�}||krD� D ])}|\
}} }
} } }
}}}}|�| �}||kr>|�| |
|| |
||||� qt�d��nt dd� � D ��dkrTt�d��� d d �= |S )Ns4 pending multiple integer revisions are not supportedc S s h | ]}|d �qS )� rL )r� r� rL rL rM � <setcomp>� � z;onetimeclientsetup.<locals>.changelogadd.<locals>.<setcomp>r! )�lenr r r �ProgrammingError)rG r� rJ r� r� r �newlen�oldargsr` �rt�trr r r �n�flr� r� �linknoder rL rM � changelogadd� s&
��
�
z(onetimeclientsetup.<locals>.changelogadds add�NN)�
clientonetimer rf r% r )rH r r rL r rM r� � s �+� r� c s2 t ��r t���r| �|�S i � � �fdd�}|S )Nc s� |� � | i �v r� | | S z/�| �| �}|�� D ]}|�� | kr2|�� }|o+|d � | |�� < q|�� }|o<|d W S tjyH Y dS w )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)�
setdefaultrt � ancestorsr� �renamedr� r � LookupError)�fnr� �fctx�ancestorr ��rcacherI rL rM �
getrenamed� s ��z getrenamedfn.<locals>.getrenamed)rD r �usechangesetcentricalgo)rG rI �endrevr' rL r% rM r{ � s
r{ c s t |�s
| |||�S t�|td��}tj|j|�� |gd|d d�� t� �t� |�sL|D ] }|| }|�
� }� �
� D ]}||v rI�� |� � � nq:q,n,� fdd�|d D �} | D ] }|d �
|�}
�� |
�� � |
�� D ] } �� | �� � qmqYt��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� rL r� )r� rL rM � <genexpr>1 s � z filelogrevset.<locals>.<genexpr>c s g | ]}|� v r|�qS rL rL �r� r� )r� rL rM r� 8 � z!filelogrevset.<locals>.<listcomp>)rD r � getstringr �matchmodr �root�getcwdr� �patkindr� ry r� rt �linkrevr r �baseset) rG rI �subsetr� �patr� r* �cfilesr� r� r# �actxrL )r� r� rM r| s4 �
��� �r| s gcs hg gc [REPO...])�norepoc O s� t � }tj| dd�}|r|�|� g }| j�d�}|r |�|� |�|� g }|D ])}z t� | i |�} |�| � tj| j
dd�}
|
rG|�|
� W q) t j yR Y q)w |D ]} t
| | � qU|D ] } t�| | j� q_dS )z4garbage collect the client and server filelog cachesT)�
allowemptys PWDN)r� r+ � getcachepathry �environrE rY �extendr �peerrH r � RepoError�gcclientr& �gcserverr� ) rH rJ rK �
cachepaths� systemcache� repopaths�pwdr� �repopathrI � repocache� cachepathrL rL rM �gc; s4
�� �rI c s^ t j�|d�}t j�|�s| �td�| � d S t|d�}dd� |�� D �}|�� g }t � }d }d}d} | j
td�dt |�d �}
|D ]�} |
� | � | d
7 } z t
�t j�| ��} W n! tyz } z| �td �| | f � t�� W Y d } ~ qCd } ~ ww z t�| i | �}
|
j}W n
tjy� Y qCw |�| � t|�s�qCt
�|d �s�| �td
�| � qC|j� dd�}|j� dd�}|r�|r�z t � |� d}W qC t t j fy� Y nw |j!� |s�|j"}� fdd�}t j#|||d�}qC|
�$� t �%d�}zt|d�}|�&dd� |D �� |�� W t �%|� nt �%|� w |d u�r!|�'|� d S |�s-| �td�� d S d S )Ns reposs no known cache at %s
s rbc S s h | ]}|d d� �qS )N���rL r, rL rL rM r i r- zgcclient.<locals>.<setcomp>Fr s analyzing repositories)�unit�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� ��reponamerL rM �keyfn� s zgcclient.<locals>.keyfn)rQ � lastkeepkeysr@ s wbc S s g | ]}d | �qS )� %s
rL r, rL rL rM r� � r z gcclient.<locals>.<listcomp>s$ warning: no valid repos in repofile
)(�osr� r� �exists�warnr r � readlinesr� r� � makeprogressr �updater �
expandpath�normpath� TypeError� traceback� print_excr r> r� r r? rY rD r� rH r� � repackmod�incrementalrepack�IOError�RepackAlreadyRunning�name� sharedstore�keepset�complete�umask�
writelinesrI )rH rH � repospath� reposfiler� �
validrepos�keepkeys� sharedcache�
filesrepacked�count�progressr� �er> rI � repackonhggc�gcrepackrQ �oldumaskrL rO rM r@ a s�
�
��
�
�
�
�r@ c
O s� t |�s| ||g|�R i |��S |�d�}|�d�}|rX|r |r$d|d< |sX|sXt�|d |t�|��}|�� }|rO|�� D ]} tj �
|� | ��sNd} nq?|rX|� 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
)rD rE r r r � byteskwargs�anypatsr� rT r� �isfile�wjoinrV r )
rG rH rI �patsrK ru r� r rx �filerL rL rM r` � s.
���r` c C s$ | � dd�}|dkrd||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)rH r �daysrL rL rM � revdatelimit� s r~ c C s� | j �dd�}| j�d�}d}t|d��' tj�|�}t�� | |kr3t� |d� d}W d � |S W d � |S 1 s>w 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)
rH r| �vfsr� r rT r� �getmtime�time�utime)rI �timeoutr� �ready�modtimerL rL rM � readytofetch� s
��
��r� c sb t ��}| �dd�� t��}|r� r|sdS �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 �jr d S d�_�j� �d� d S )Ns ranprefetchT�r' )r r� � ranprefetch�backgroundprefetch)�unused_success��bgprefetchrevs�bgrepackrI rL rM �anon s zwcpprefetch.<locals>.anon)rD �configr� rH r� r~ �
_afterlock)rH rI r� r� �isreadyr� rL r� rM r� s
r� c O s� | ||g|�R i |��}t |�r`|�dd�}|j�dd�}|j�dd�}|rW|�td�� t�||g�} |d �� }
|rE|j ||d� |S |j
| |
d� |rUt j |d d
� |S |r`t j |d d
� |S ) Nr- r5 r3 r6 s prefetching file contents
r� r� )�baseT�� incremental)
rD r� rH r� �statusr r �revranger� r� r� r_ �backgroundrepack) rG rH rI rz rK �result�prefetchrevsetr� �
bgprefetchr� r� rL rL rM ra s& ��ra c O sR ddd�}t �|d�r||_n
t �|d�r t�|d|� | ||g|�R i |��S )Nc [ s. |st � }|�tj� | |f|||d�|��S )N)�heads�common�
bundlecaps)r� ry r" �BUNDLE2_CAPABLITY)rG �sourcer� r� r� r� rL rL rM �localgetbundle4 s ���z$exchangepull.<locals>.localgetbundles _callstreams getbundle)NNN)r r� �
_localrepor rf )rG rI r� rJ r� r� rL rL rM rj 1 s
�
rj c C s� t | �rJg }|D ]9\}}|tks|d u rq| | }|�� }| �|�� �}|�|�D ]}|r1||�r@||v r@|�|t|| �f� q)q| j� |� d S d S r� )
rD r r� r� r� �walkrY r r� r� ) rI �
revmatches�allfilesr� r r* �mfr� r� rL rL rM rz F s ���rz s debugremotefilelog� ds
decompresss decompress the filelog firsts hg debugremotefilelog <path>c K � t j| |fi |��S r� )r
�debugremotefilelog�rH r� rK rL rL rM r� U � r� s verifyremotefilelogs decompress the filelogs firsts# hg verifyremotefilelogs <directory>c K r� r� )r
�verifyremotefilelogr� rL rL rM r� a r� 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)rH �pathsrK rL rL rM r� m s
r� s debughistorypacks hg debughistorypack <path>c K s t �| |�S r� )r
�debughistorypackr� rL rL rM r� z s r� s debugkeepsets hg debugkeepsetc s � fdd�}t �� |� d S )Nc s t �� j| t|��S r� )r# rM rc r rN r� rL rM rQ � s zdebugkeepset.<locals>.keyfn)r_ re )rH rI rK rQ rL r� rM � debugkeepset s r� s debugwaitonrepacks hg debugwaitonrepackc K �
t �|�S r� )r
�debugwaitonrepack�rH rI rK rL rL rM r� � �
r� s debugwaitonprefetchs hg debugwaitonprefetchc K r� r� )r
�debugwaitonprefetchr� rL rL rM r� � r� r� c C s� |� d�s8ddg}| �ddd �}|r|�d| � | �ddd �}|r)|�d| � d�|�}t| |�}|g|d< |� d �sAd |d < |S )
N� revr� s draft()r- r5 s (%s)r4 � +� base)rE r� rY r� r~ )rH rK r r� r� rL rL rM �resolveprefetchopts� s
r� s prefetch� rr� s prefetch the specified revisionss REVs run repack after prefetch� br� s' rev that is assumed to already be locals hg prefetch [OPTIONS] [FILE...])� helpcategoryc O sr t �|�}t|�st�td���t| |�}t�||� d��}|�
||� d�||� |� d�r7t j |dd� dS 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 shallowr� r� r> Tr� N)
r rv rD r rF r r� r r� rE r� r_ r� )rH rI rz rK r� rL rL rM 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�rtj||� d�|� dd�d� d S d|� d�i}z|� d�r-tj||d� W d S tj||d� W d S tjyR } z|j�d| � W Y d }~d S d }~ww ) N�
backgroundr� � packsonlyF)r� r� r� )�optionsrS )rE r_ r� r` �
fullrepackrb rH rV )rH rI rz rK r� �exrL rL rM �repack_� s
�
��r� r� r )o�__doc__�
__future__r rT r� r] �mercurial.noder r �mercurial.i18nr �mercurial.pycompatr � mercurialr r r r
r r r
�hgdebugcommandsr 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, �command�cmdtable� configtable�
configitem�dynamicdefault�
_defaultlimit�
testedwithr� � repoclass�_basesupportedry r� rD r� r] rc r� r� ri rk rl rn ro rp rq rr rt ru rv rw r r� r{ r| rI r@ r` r~ r� r� ra rj rz r� r� r� r� r� r� r� r� �walkopts�CATEGORY_MAINTENANCEr� r� rL rL rL rM �<module> sB x p8
�
�QV
/
W (
%^# ��
��
��
���
�� �