| 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 : /usr/lib64/python3.9/site-packages/mercurial/__pycache__/ |
Upload File : |
a
�+�b�3 � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z m
Z
mZmZmZ ddlmZmZ ddlmZmZmZmZmZmZmZm 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+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2mZm3Z3m4Z4m5Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z=m>Z>m?Z@mAZAmBZBmCZCmDZEmFZF ddlGmHZHmCZI dd lJmKZKmLZLmMZMmNZN dd
lOmPZQmRZSmTZU e'jVZVeCjWZWeCjXZXeY� ZZG d d � d e:j[�Z\G d
d� de\�Z]G dd� de\�Z^G dd� de^�Z_G dd� de^�Z`G dd� de\�Zadd� ZbG dd� deCjc�ZdG dd � d eCjc�Zed d � Zfd d � Zgh d!�Zheh�id"h�ZjeI�keHjl�G d#d$� d$em��ZneI�keHjo�G d%d&� d&eHjp��ZqeI�keHjr�G d'd(� d(eq��ZseY� Ztd)d*� Zud+d,� Zvdbd-d.�Zwdcd/d0�Zxd1d2� Zyd3d4� Zzd5d6� Z{d7d8� Z|d9d:� Z}d;d<� Z~d=d>� Zd?d@� Z�eI�keHj��G dAdB� dBem��Z�eI�keHj��G dCdD� dDem��Z�dEdF� Z�eHj�dGdH� feHj�dIdH� fgZ�eI�keHj��G dJdK� dKem��Z�dLdM� Z�dNdO� Z�dddPdQ�Z�dRdS� Z�dedTdU�Z�dVdW� Z�dXdY� Z�dZd[� Z�d\d]� Z�dfd^d_�Z�d`da� Z�dS )g� )�absolute_importN� )�_)�bin�hex�nullrev�sha1nodeconstants�short)�delattr�getattr),� bookmarks� branchmap�bundle2� bundlecaches� changegroup�color�commit�context�dirstate�
dirstateguard� discovery�encoding�error�exchange�
extensions�filelog�hook�lock�match�
mergestate� mergeutil�
namespaces�
narrowspec�obsolete�pathutil�phases�pushkey�pycompat�rcutil�repoview� requirements�revlog�revset�
revsetlang�scmutil�sparse�store� subrepoutil�tags� transaction�txnutil�util�vfs�wireprototypes)�
repositoryr5 )�hashutil�procutil�
stringutil�urlutil)�concurrency_checker� constants�sidedatac s. e Zd ZdZd� fdd� Z� fdd�Z� ZS )�_basefilecachezHAll filecache usage on repo are done for logic that should be unfilteredNc sH |d u r | S |� � }z|j| j W S ty4 Y n0 tt| ��||�S �N)�
unfiltered�__dict__Zsname�KeyError�superr@ �__get__��self�repo�type�unfi�� __class__� �9/usr/lib64/python3.9/site-packages/mercurial/localrepo.pyrF m s z_basefilecache.__get__c s t t| ��|�� |�S rA )rE r@ �setrB )rH rI �valuerL rN rO rP x s z_basefilecache.set)N)�__name__�
__module__� __qualname__�__doc__rF rP �
__classcell__rN rN rL rO r@ j s r@ c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�
repofilecachez3filecache for files in .hg but outside of .hg/storec s, t t| �j|� |D ]}t�|df� qd S )N� plain)rE rW �__init__� _cachedfiles�add�rH �paths�pathrL rN rO rY s zrepofilecache.__init__c C s |j �|�S rA )r6 �join�rH �obj�fnamerN rN rO r_ � s zrepofilecache.join�rR rS rT rU rY r_ rV rN rN rL rO rW | s rW c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�
storecachez filecache for files in the storec s, t t| �j|� |D ]}t�|df� qd S )N� )rE rd rY rZ r[ r\ rL rN rO rY � s zstorecache.__init__c C s
|� |�S rA )�sjoinr` rN rN rO r_ � s zstorecache.joinrc rN rN rL rO rd � s rd c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�changelogcachezfilecache for the changelogc s& t t| ��� t�d� t�d� d S )N��
00changelog.ire )�
00changelog.nre )rE rg rY rZ r[ �rH rL rN rO rY � s
zchangelogcache.__init__c C s6 | � |d�g}|jjj�dd�r2|�| � |d�� |S )Nri � persistent-nodemapFrj �r_ r0 �opener�options�get�append�rH ra r] rN rN rO �
tracked_paths� s z changelogcache.tracked_paths�rR rS rT rU rY rs rV rN rN rL rO rg � s rg c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�manifestlogcachez filecache for the manifestlogc s& t t| ��� t�d� t�d� d S )N)� 00manifest.ire )� 00manifest.nre )rE ru rY rZ r[ rk rL rN rO rY � s
zmanifestlogcache.__init__c C s6 | � |d�g}|jjj�dd�r2|�| � |d�� |S )Nrv rl Frw rm rr rN rN rO rs � s z manifestlogcache.tracked_pathsrt rN rN rL rO ru � s ru c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�mixedrepostorecachez2filecache for a mix files in .hg/store and outsidec s t t| �j|� t�|� d S rA )rE rx rY rZ �update)rH ZpathsandlocationsrL rN rO rY � s z mixedrepostorecache.__init__c C s@ |\}}|dkr |j �|�S |dkr2t�d| ��|�|�S d S )NrX re s unexpected location: %s)r6 r_ r �ProgrammingErrorrf )rH ra Zfnameandlocationrb �locationrN rN rO r_ � s �zmixedrepostorecache.joinrc rN rN rL rO rx � s rx c C s$ | � � j�|d�}|sdS |jdfS )z{check if a repo has already cached "name" filecache-ed property
This returns (cachedobj-or-None, iscached) tuple.
N�NFT)rB �
_filecacherp ra )rI �nameZ
cacheentryrN rN rO � isfilecached� s r c s" e Zd ZdZd� fdd� Z� ZS )�unfilteredpropertycachez0propertycache that apply to unfiltered repo onlyNc s, |� � }||u r tt| ��|�S t|| j�S rA )rB rE r� rF r r~ rG rL rN rO rF � s z unfilteredpropertycache.__get__)N)rR rS rT rU rF rV rN rN rL rO r� � s r� c @ s e Zd ZdZdd� ZdS )�filteredpropertycachez1propertycache that must take filtering in accountc C s t �|| j|� d S rA )�object� __setattr__r~ )rH ra rQ rN rN rO �
cachevalue� s z filteredpropertycache.cachevalueN)rR rS rT rU r� rN rN rN rO r� � s r� c C s |t | �� �v S )z?check if a repo has an unfilteredpropertycache value for <name>)�varsrB )rI r~ rN rN rO �hasunfilteredcache� s r� c s t �� �� fdd��}|S )z@decorate method that always need to be run on unfiltered versionc s � | � � g|�R i |��S rA )rB )rI �args�kwargs��origrN rO �wrapper� s z!unfilteredmethod.<locals>.wrapper)� functools�wraps)r� r� rN r� rO �unfilteredmethod� s r� > s branchmap� pushkeys lookups unbundles getbundles knowns changegroupsubsetc @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )�localcommandexecutorc C s || _ d| _d| _d S r| )�_peer�_sent�_closed)rH �peerrN rN rO rY � s z localcommandexecutor.__init__c C s | S rA rN rk rN rN rO � __enter__ s z localcommandexecutor.__enter__c C s | � � d S rA )�close)rH �exctypeZexcvalue�exctbrN rN rO �__exit__ s z localcommandexecutor.__exit__c C s� | j rt�d��| jr t�d��t| jt�|��}tj� � }z|f i t�
|���}W n* t y~ t� |t
�� dd � � Y n 0 |�|� |S )Ns1 callcommand() cannot be used after sendcommands()s* callcommand() cannot be used after close()r )r� r rz r� r r� r' �sysstrZfuturesZFuture� strkwargs� ExceptionZfuture_set_exception_info�sys�exc_infoZ
set_result)rH Zcommandr� �fn�f�resultrN rN rO � callcommand
s ��
z localcommandexecutor.callcommandc C s
d| _ d S �NT)r� rk rN rN rO � sendcommands$ s z!localcommandexecutor.sendcommandsc C s
d| _ d S r� )r� rk rN rN rO r� ' s zlocalcommandexecutor.closeN) rR rS rT rY r� r� r� r� r� rN rN rN rO r� � s r� c s� e Zd ZdZd)� fdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z d*dd�Z
d+dd�Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Z� ZS ),� localpeerz8peer for a local repo; reflects only the most recent APINc s` t t| ��� |d u r t�� }|�d�| _|j| _|jrPt �
|�}|� d| � |� |�| _
d S )N� serveds exp-wanted-sidedata=)rE r� rY �
moderncaps�copy�filtered�_repo�ui�_wanted_sidedatar Z format_remote_wanted_sidedatar[ �_restrictcapabilities�_caps)rH rI �caps� formattedrL rN rO rY / s
zlocalpeer.__init__c C s
| j �� S rA )r� �urlrk rN rN rO r� ? s z
localpeer.urlc C s | j S rA )r� rk rN rN rO �localB s zlocalpeer.localc C s | S rA rN rk rN rN rO r� E s zlocalpeer.peerc C s dS r� rN rk rN rN rO �canpushH s zlocalpeer.canpushc C s | j �� d S rA )r� r� rk rN rN rO r� K s zlocalpeer.closec C s
| j �� S rA )r� r
rk rN rN rO r
R s zlocalpeer.branchmapc C s | j S rA )r� rk rN rN rO � capabilitiesU s zlocalpeer.capabilitiesc C s | j �tj�S rA )r� �tryreadr ZCB_MANIFEST_FILErk rN rN rO � clonebundlesX s zlocalpeer.clonebundlesc C s$ d||t �|�t �|�t �|�f S )z+Used to test argument passing over the wire� %s %s %s %s %s�r' �bytestr�rH ZoneZtwoZthreeZfourZfiverN rN rO �
debugwireargs[ s �zlocalpeer.debugwireargsc K sX t j| j|f||||d�|��d }t�|�}t �|�rFt�| j|�S t �d|d �S d S )N)�heads�common�
bundlecaps�remote_sidedatar � 01)
r Zgetbundlechunksr� r5 � chunkbufferZbundle2requestedr � getunbundlerr� r ) rH �sourcer� r� r� r� r� �chunks�cbrN rN rO � getbundlee s" ����
zlocalpeer.getbundlec C s
| j �� S rA )r� r� rk rN rN rO r� � s zlocalpeer.headsc C s | j �|�S rA )r� �known�rH �nodesrN rN rO r� � s zlocalpeer.knownc C s | j �|�S rA )r� �listkeys)rH � namespacerN rN rO r� � s zlocalpeer.listkeysc C s | j �|�S rA )r� �lookup�rH �keyrN rN rO r� � s zlocalpeer.lookupc C s | j �||||�S rA )r� r& )rH r� r� �old�newrN rN rO r& � s zlocalpeer.pushkeyc C s t �td���d S )Ns. cannot perform stream clone against local peer)r �Abortr rk rN rN rO �
stream_out� s zlocalpeer.stream_outc
C s z�zTt �| j|d�}t �| j||d|�}t�|d�rPt�|�� �}t �
| j|�}|W W S t y� } zjt |dd�}|r�t �
| jj�}|D ]} |�| � q�t�|�� �}t �
| j|�}
t �| j|
� � W Y d}~n
d}~0 0 W n> tj�y } z"t�td�t�|���W Y d}~n
d}~0 0 dS )zPapply a bundle on a repo
This function handles the repo locking itself.Ns pushs getchunksZ_bundle2salvagedoutputrN s push failed:)r Z
readbundler� �unbundler� r5 � safehasattrr� Z getchunksr r� r� r Zbundle20ZaddpartZ
processbundler Z PushRacedZ
ResponseErrorr r; � forcebytestr) rH Zbundler� r� �ret�stream�exc�outputZbundler�out�brN rN rO r� � s, �zlocalpeer.unbundlec C s t | �S rA )r� rk rN rN rO �commandexecutor� s zlocalpeer.commandexecutor)N)NNN)NNNN)rR rS rT rU rY r� r� r� r� r� r
r� r� r� r� r� r� r� r� r& r� r� r� rV rN rN rL rO r� + s0
�
)r� c s@ e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd
d � Z� Z S ) �locallegacypeerzcpeer extension which implements legacy methods too; used for tests with
restricted capabilitiesc s t t| �j|td� d S )N)r� )rE r� rY �
legacycaps)rH rI rL rN rO rY � s zlocallegacypeer.__init__c C s | j �|�S rA )r� �between)rH �pairsrN rN rO r� � s zlocallegacypeer.betweenc C s | j �|�S rA )r� �branchesr� rN rN rO r� � s zlocallegacypeer.branchesc C s* t j| j|| j�� d�}t�| j|d|�S �N)Z missingrootsZ ancestorsofr� )r �outgoingr� r� r �makechangegroup)rH r� r� r� rN rN rO r � s �zlocallegacypeer.changegroupc C s$ t j| j||d�}t�| j|d|�S r� )r r� r� r r� )rH �basesr� r� r� rN rN rO �changegroupsubset� s �z!locallegacypeer.changegroupsubset)
rR rS rT rU rY r� r� r r� rV rN rN rL rO r� � s r� c C sX | � d��d�}tj|v r*t�| �|��}tj|dd�}|� � sTt
� t d�|j
��|S )z�returns the vfs object pointing to root of shared source
repo for a shared repository
hgvfs is vfs pointing at .hg/ of current repo (shared one)
requirements is a set of requirements of current repo (shared one)
�
sharedpath�
T)�realpaths1 .hg/sharedpath points to nonexistent directory %s)�read�rstrip�requirementsmod�RELATIVE_SHARED_REQUIREMENTr5 �normpathr_ �vfsmodr6 �existsr � RepoErrorr �base)�hgvfsr* �
sharedpath� sharedvfsrN rN rO �
_getsharedvfs� s
��r� c
C sX zt | �d��� �}W n< tyR } z$|r6|jtjks8� t � }W Y d}~n
d}~0 0 |S )z�reads the require file present at root of this vfs
and return a set of requirements
If allowmissing is True, we suppress ENOENT if raised� requiresN)rP r� �
splitlines�IOError�errno�ENOENT)r6 Z allowmissingr* �erN rN rO �
_readrequires s
r� c ! C sZ | � � }| j |_ tj|ddd�}|�d�}tj|dd�}d}d}|�� s�z |�� W np ty� } z| jtjkrr� W Y d} ~ nHd} ~ 0 t y� } z(t
� t d�|t
�| �f ��W Y d} ~ n
d} ~ 0 0 t
�t d�| ��t|d�}
tj|
v p�tj|
v }d} |�r t||
�}t�|�d ��} nt�|�d ��} t d
�} tj|
v �r�|�r�tjt|d�v�r�|�d d �}
|�d d
�}|dv �r�ddlm} |�||||
||
� n4|dk�r�t
j t d�| d��nt
j t d�| | d��n|
t| d�O }
n�|�rvt|d�}tj|v �rv|�d d�}|�d d�}
|dv �rBddlm} |�||| |
||
� n4|dk�r`t
j t d�| d��nt
j t d�| | d��t ||||
|��r�t ||||
� t � |� t � |� dd� t � |�D �}t!|�}t"|
|� t#||
� t$� }|�r|j%}|�d �}|�&t'j(� n|j%}|�d �}|�d �}t)|
|d d � �}|j*|_*|j} t+||
|�| _,tj-|
v �sbtj.|
v �rz|�&t'j/� |�0t'j1� tj|dd�}|j*|_*tj|dd�}|j*|_*g }i }t2D ]V\} } | � |||
||||| | j,|||||d �} t3| t4��s�t
�5d!| ��|�6| � �q�t7�8d"|j%d#�t9|
��f �} t4| t:|�i �} | | |||||
|||||||d$�
S )%ae Create a local repository object.
Given arguments needed to construct a local repository, this function
performs various early repository loading functionality (such as
reading the ``.hg/requires`` and ``.hg/hgrc`` files), validates that
the repository can be opened, derives a type suitable for representing
that repository, and returns an instance of it.
The returned object conforms to the ``repository.completelocalrepository``
interface.
The repository type is derived by calling a series of factory functions
for each aspect/interface of the final repository. These are defined by
``REPO_INTERFACES``.
Each factory function is called to produce a type implementing a specific
interface. The cumulative list of returned types will be combined into a
new type and that type will be instantiated to represent the local
repository.
The factory functions each receive various state that may be consulted
as part of deriving a type.
Extensions should wrap these factory functions to customize repository type
creation. Note that an extension's wrapped function may be called even if
that extension is not loaded for the repo being constructed. Extensions
should check if their ``__name__`` appears in the
``extensionmodulenames`` set passed to the factory function and no-op if
not.
T�Z
expandpathr� � .hg�Z cacheauditedFNs invalid path %s: %ss repository %s not found� stores? see `hg help config.format.use-share-safe` for more informations shares" safe-mismatch.source-not-safe.warns safe-mismatch.source-not-safe)s downgrade-allow� allows downgrade-abortr )�upgrade� aborts4 share source does not support share-safe requirement��hintsf share-safe mismatch with source.
Unrecognized value '%s' of `share.safe-mismatch.source-not-safe` set.s safe-mismatch.source-safes safe-mismatch.source-safe.warn)s
upgrade-allowr s
upgrade-abortsW version mismatch: source uses share-safe functionality while the current share does notsb share-safe mismatch with source.
Unrecognized value '%s' of `share.safe-mismatch.source-safe` set.c S s h | ]\}}|j �qS rN �rR ��.0�n�mrN rN rO � <setcomp>� re z&makelocalrepository.<locals>.<setcomp>� cache� wcachec S s t j| dd�S )NTr )r� r6 )r� rN rN rO �<lambda>� re z%makelocalrepository.<locals>.<lambda>)r� �intentsr* �features�wdirvfsr� r0 �storevfsZ storeoptions�cachevfs� wcachevfs�extensionmodulenames�
extrastateZ baseclassess unable to construct type for %ss derivedrepo:%s<%s>� ,)
�baseuir� �origrootr r� r* �supportedrequirementsr� r0 r r r r );r� r� r6 r_ �isdir�stat�OSErrorr� r� �
ValueErrorr r� r r; r� r� r� r� �SHARED_REQUIREMENTr� r� �SHARESAFE_REQUIREMENT�
configbool�config� r Zdowngrade_share_to_non_safeZupgrade_share_to_safe�loadhgrc�
afterhgrcloadr ZloadallZ
populateui�gathersupportedrequirements� ensurerequirementsrecognized� ensurerequirementscompatiblerP r� r[ r8 ZREPO_FEATURE_SHARED_STORAGE� makestore�
createmode�resolvestorevfsoptionsro �REVLOGV2_REQUIREMENT�CHANGELOGV2_REQUIREMENT�REPO_FEATURE_SIDE_DATA�discard�REPO_FEATURE_STREAM_CLONE�REPO_INTERFACES�
isinstancerJ rz rq r' r� �sorted�tuple)!r r^ r r� r Zhgpathr� �sharedr� r� r* r r Z
mismatch_warnZmismatch_configr Zsourcerequiresr r r Z
storebasepathZ cachepathZ
wcachepathr0 r r r� r Zifacer� �typr~ �clsrN rN rO �makelocalrepository s\
�
�
�����
�
����
�
�
�����
��� � ���r9 c C s� t �� s dS d}tj|v rP|rPz | j|�d�|jd� d}W n tyN Y n0 z | j|�d�|jd� d}W n ty� Y n0 z | j|�d�|jd� d}W n ty� Y n0 |S )a Load hgrc files/content into a ui instance.
This is called during repository opening to load any additional
config files or settings relevant to the current repository.
Returns a bool indicating whether any additional configs were loaded.
Extensions should monkeypatch this function to modify how per-repo
configs are loaded. For example, an extension may wish to pull in
configs from alternate files or sources.
sharedvfs is vfs object pointing to source repo if the current one is a
shared one
F� hgrc��rootTs hgrc-not-shared)r( Z
use_repo_hgrcr� r! Z
readconfigr_ r� r� )r� r r� r* r� r� rN rN rO r% O s( r% c C s^ dgdgdgd�}t |�� �D ]:\}}||vr0q |D ]"}| �d|�s4| jd|ddd� q4q d S )
aQ Perform additional actions after .hg/hgrc is loaded.
This function is called during repository loading immediately after
the .hg/hgrc file is loaded and before per-repo extensions are loaded.
The function can be used to validate configs, automatically add
options (including extensions) based on requirements, etc.
� git�
largefiles� lfs)r= r> r? s
extensionsre s autoload)r� N)r4 �items� hasconfigZ setconfig)r� r r� r* Zautoextensions� requirement�namesr~ rN rN rO r& y s
� r& c C s� t tj�}dd� t�| �D �}tD ]}|j|v r"|| |� q"tjD ]D}tj| }|�� rB|� � rB|�
d| � |� � dkrB|�
t j
� qB|S )z6Determine the complete set of recognized requirements.c S s h | ]\}}|j �qS rN r r rN rN rO r � re z.gathersupportedrequirements.<locals>.<setcomp>� exp-compression-%s� zstd)rP �localrepository�_basesupportedr �featuresetupfuncsrS r5 � compengines� available� revlogheaderr[ r~ r� ZREVLOG_COMPRESSION_ZSTD)r� � supported�modulesr� r~ �enginerN rN rO r' � s
r' c C sr t � }| D ]:}||v rq
|r,|dd� �� s:t�td���|�|� q
|rntjtd�d�t|�� td�d��dS ) a Validate that a set of local requirements is recognized.
Receives a set of requirements. Raises an ``error.RepoError`` if there
exists any requirement in that set that currently loaded code doesn't
recognize.
Returns a set of supported requirements.
r r s .hg/requires file is corrupts: repository requires features unknown to this Mercurial: %s� sJ see https://mercurial-scm.org/wiki/MissingRequirement for more informationr N)rP �isalnumr ZRequirementErrorr r[ r_ r4 )r* rL �missingrB rN rN rO r( � s ���r( c C s" t j|v r tjs t�td���dS )a� Validates that a set of recognized requirements is mutually compatible.
Some requirements may not be compatible with others or require
config options that aren't enabled. This function is called during
repository opening to ensure that the set of requirements needed
to open a repository is sane and compatible with config options.
Extensions can monkeypatch this function to perform additional
checking.
``error.RepoError`` should be raised on failure.
sf repository is using sparse feature but sparse is not enabled; enable the "sparse" extensions to accessN)r� �SPARSE_REQUIREMENTr/ Zenabledr r� r )r� r* rN rN rO r) � s ����r) c C sD t j| v r8t j| v r,t j| v }t�|||�S t�||�S t�||�S )z,Construct a storage object for a repository.)r� �STORE_REQUIREMENT�FNCACHE_REQUIREMENT�DOTENCODE_REQUIREMENT�storemodZ fncachestoreZ encodedstoreZ
basicstore)r* r^ ZvfstypeZ dotencoderN rN rO r* � s
r* c C s� i }t j|v rd|d< | �dd�}|dur2||d< t j|v sFt j|v rZ|�t| ||�� nd|d< t j|v rvd|d< n | �d d
�}d }||v r�d |d< |S )
z�Resolve the options to pass to the store vfs opener.
The returned dict is used to influence behavior of the storage layer.
T� treemanifest� formats manifestcachesizeNs revlogv0� changeset-sidedatas copies-storage� experimentals copies.write-to)s changeset-onlys
compatibilitys extra) r� �TREEMANIFEST_REQUIREMENT� configint�REVLOGV1_REQUIREMENTr- ry � resolverevlogstorevfsoptions�COPIESSDC_REQUIREMENTr# )r� r* r ro ZmanifestcachesizeZ
writecopiestoZcopiesextramoderN rN rO r, � s&
��
r, c C s� i }i |d< t j|v r d|d< t j|v r0d|d< t j|v rBd|d< t j|v rTd|d< | �dd�}|d urp||d< | �d
d �}||d < | �d
d
�}||d< | �d
d�}d}|r�| �d
d�}|d u r�t�| � }||d< ||d< | � dd�} d| kr�| |d< | � dd�}
|
d u�r|
|d< | �dd�} t
| � dd��} | � dd�}
| |d< | |d < |
|d < t j |v }||d < |�rvd|d< d }|�r�t
j}| �dd |�}|d u�r�||d < |D ]4}|j}|d ��s�|d!��r�|�d"d#�d# |d$< �q�| �d
d%�|d&< |d& d u�r6d|d& k�rd'k�s6n td(�}t�||d& ��| �d
d)�|d*< |d* d u�r�d|d* k�rpd+k�s�n td,�}t�||d* ��t j|v �r�d|d-< | �dd.��r�d|d.< t j|v �r�| � d
d/�}|d0v�r| �d
d/�}td1�}| �|| � | j�s| �td2�| � |}td3�}td4�}tj�s�|d5k�rnd6| d7 }| �|� | j�snd8| d9 }| �|� |d:k�r�tj||d;��d|d<< t j|v �r^| � d
d=�}|d0v�r�| �d
d=�}td>�}| �|| � | j�s�| �td2�| � |}td?�}td@�}t j �s^|d5k�rFd6| d7 }| �|� | j�sFd8| d9 }| �|� |d:k�r^tj||d;��| �d
dA��rtd|dB< | �dCd<��r�d|dD< |S )Ez+Resolve opener options specific to revlogs.s flagprocessorsT� revlogv1� revlogv2s changelogv2s generaldeltarX s chunkcachesizeN� storages# revlog.optimize-delta-parent-choices deltabothparentss revlog.issue6528.fix-incomings issue6528.fix-incomings revlog.reuse-external-deltaFs" revlog.reuse-external-delta-parents lazydeltas
lazydeltabaserZ s maxdeltachainspanr s mmapindexthresholds sparse-reads sparse-read.density-thresholds sparse-read.min-gap-sizes with-sparse-reads sparse-read-density-thresholds sparse-read-min-gap-size�
sparse-revlogs maxchainlens revlog-compression-s exp-compression-� -� s
compengines revlog.zlib.levels
zlib.level� s8 invalid value for `storage.revlog.zlib.level` config: %ds revlog.zstd.levels
zstd.level� s8 invalid value for `storage.revlog.zstd.level` config: %ds enableellipsiss
rust.indexs# revlog.persistent-nodemap.slow-path)r � warnr sM unknown value for config "storage.revlog.persistent-nodemap.slow-path": "%s"
s" falling back to default value: %s
sQ accessing `persistent-nodemap` repository without associated fast implementation.s@ check `hg help config.format.use-persistent-nodemap` for detailsrh s warning: r� � (s )
r r rl s dirstate-v2.slow-paths7 unknown value for config "dirstate-v2.slow-path": "%s"
sJ accessing `dirstate-v2` repository without associated fast implementation.s9 check `hg help config.format.use-dirstate-v2` for detailss revlog.persistent-nodemap.mmaps persistent-nodemap.mmap� devels devel-force-nodemap) r� r] r- r. �GENERALDELTA_REQUIREMENTr\ r" r. Z
gddeltaconfigZ configbytes�floatr# �SPARSEREVLOG_REQUIREMENT� revlogconstZ SPARSE_REVLOG_MAX_CHAIN_LENGTH�
startswith�splitr r r� �NARROW_REQUIREMENT�NODEMAP_REQUIREMENTZconfig_default�warn�quietr+ ZHAS_FAST_PERSISTENT_NODEMAP�DIRSTATE_V2_REQUIREMENTr ZHAS_FAST_DIRSTATE_V2)r� r* r ro ZchunkcachesizeZdeltabothparentsZ issue6528Z lazydeltaZ
lazydeltabaseZ chainspanZmmapindexthresholdZwithsparsereadZsrdensitythresZ srmingapsizeZ sparserevlogZ maxchainlen�r�prefix�msgZ slow_path�defaultr rN rN rO r^ s
� �
�
�
����
��
r^ c K s t S )z6Produce a type conforming to ``ilocalrepositorymain``.)rF )r� rN rN rO �makemain� s rz c @ s e Zd ZdZdd� ZdS )�revlogfilestoragez File storage when using revlogs.c C s$ |� d�r|dd � }t�| j|�S �N� /r )ro r �svfs�rH r^ rN rN rO �file� s
zrevlogfilestorage.fileN�rR rS rT rU r� rN rN rN rO r{ � s r{ c @ s e Zd ZdZdd� ZdS )�revlognarrowfilestoragez1File storage when using revlogs and narrow files.c C s( |� d�r|dd � }t�| j|| j�S r| )ro r Z
narrowfilelogr~ �_storenarrowmatchr rN rN rO r� � s
z revlognarrowfilestorage.fileNr� rN rN rN rO r� � s r� c K s. |� tj� |� tj� tj| v r&tS tS dS )z=Produce a type conforming to ``ilocalrepositoryfilestorage``.N)r[ r8 Z REPO_FEATURE_REVLOG_FILE_STORAGEr1 r� rq r� r{ )r* r r� rN rN rO �makefilestorage� s
r� c C s t S rA )rz rN rN rN rO r � re r c C s t S rA )r� rN rN rN rO r � re c @ s� e Zd ZdZejejejejej ej
ej ej ej
ejejejejejejejejejejhZh d�Zd�dd�Zdd� Zdd � Z d
d � Z d d
� Z dd� Z e dd� �Z!e dd� �Z"dd� Z#dd� Z$dd� Z%d�dd�Z&e'd d d d �d d!� �Z(d"d#� Z)e d$d%� �Z*e+d&d'�d(d)� �Z,e+d*�d+d,� �Z-e.� d-d.� �Z/e0� d/d0� �Z1e2d1�d2d3� �Z3d4d5� Z4d6d7� Z5e+e6j7�d8d9� �Z8e+e6j7�d:d;� �Z9e+e6j7�d<d=� �Z:d�d?d@�Z;dAdB� Z<e=dCdD� �Z>e=dEdF� �Z?e@dGdH� �ZAe dIdJ� �ZBdKdL� ZCdMdN� ZDdOdP� ZEeEZFdQdR� ZGdSdT� ZHdUdV� ZIdWdX� ZJd�dYdZ�ZKd[d\� ZLd�d]d^�ZMeNd_d`� �ZOdadb� ZPdcdd� ZQdedf� ZRdgdh� ZSdidj� ZTdkdl� ZUdmdn� ZVe@dodp� �ZWdqdr� ZXd�dsdt�ZYdudv� ZZdwdx� Z[dydz� Z\d{d|� Z]d}d~� Z^dd�� Z_d�d�� Z`d�d�� Zad�d�d��Zbd�d�d��Zcd�d�� Zdd�d�d��Zed�d�� Zfd�d�� Zge=d�d�� �Zhe=d�d�� �Zid�d�� Zjd�d�� Zkd�d�d��Zld�d�� Zmd�d�� Zn�d d�d��Zod�d�� Zpd�d�� Zqe@d�d�� �Zrd�d�� Zs�dd�d��Zte@d�d�� �Zud�d�� Zve@�dd�d���Zwd�d�� Zxd�d�� Zyd�d�� Zz�dd�d��Z{d�d�� Z|e@d�d�� �Z}d�d�� Z~d�d�� Z�dd�dÄZ��dd�dńZ�d�dDŽ Z�d�dɄ Z�d�d˄ Z�e@�dd�d΄�Z�e@�dd�dЄ�Z�e@d�d҄ �Z�e@d�dԄ �Z��dd�dׄZ�d�dل Z�d�dۄ Z�d�d݄ Z��d d�d߄Z��d
d�d�Z�d�d� Z�d�d� Z�d�d� Z�e=d�d� �Z�d�d� Z�d�d� Z��d d�d�Z�d�d� Z�d�d� Z��d d�d��Z�dS (
rF aQ Main class for representing local repositories.
All local repositories are instances of this class.
Constructed on its own, instances of this class are not usable as
repository objects. To obtain a usable repository object, call
``hg.repository()``, ``localrepo.instance()``, or
``localrepo.makelocalrepository()``. The latter is the lowest-level.
``instance()`` adds support for creating new repositories.
``hg.repository()`` adds more extension integration, including calling
``reposetup()``. Generally speaking, ``hg.repository()`` should be
used.
> r� � dirstates bisect.state� cache/r: Nc C s� || _ || _|| _|| _|j| _|| _|j| _|| _t | _
| j
j | _ || _ || _
| | _|
| _| | _| | _d| _| j�dd�s�| j�dd�r�| �| jj�| j_g | _t�| j� | jj| _| jj| _| jj| _ | j�dd�s�| j�dd��r$t � | jd��r| � | jjj�| jj_n| � | jj�| j_d| _ t!�"� | _#d| _$i | _%i | _&d | _' | _(| _)i | _*i | _+g | _,t-�-� | _.i | _/i | _0t1�2|�| _3d| _4t5j6| jv �r�d| _4t7� | _8i | _9t:�;| � dS )a� Create a new local repository instance.
Most callers should use ``hg.repository()``, ``localrepo.instance()``,
or ``localrepo.makelocalrepository()`` for obtaining a new repository
object.
Arguments:
baseui
``ui.ui`` instance that ``ui`` argument was based off of.
ui
``ui.ui`` instance for use by the repository.
origroot
``bytes`` path to working directory root of this repository.
wdirvfs
``vfs.vfs`` rooted at the working directory.
hgvfs
``vfs.vfs`` rooted at .hg/
requirements
``set`` of bytestrings representing repository opening requirements.
supportedrequirements
``set`` of bytestrings representing repository requirements that we
know how to open. May be a supetset of ``requirements``.
sharedpath
``bytes`` Defining path to storage base directory. Points to a
``.hg/`` directory somewhere.
store
``store.basicstore`` (or derived) instance providing access to
versioned storage.
cachevfs
``vfs.vfs`` used for cache files.
wcachevfs
``vfs.vfs`` used for cache files related to the working copy.
features
``set`` of bytestrings defining features/capabilities of this
instance.
intents
``set`` of system strings indicating what this repo will be used
for.
Nrj � all-warnings� check-lockss vfsFrY )<r r� r �wvfsr� r< r6 r^ r* r �
nodeconstants�nullidrL r� r0 r r r �
filternamer" � _getvfsward�audit�_phasedefaultsr ZsetupZspathr~ r_ rf r5 r� � _getsvfsward�_dirstatevalidatewarnedr
ZBranchMapCache�
_branchcaches�_revbranchcache� _filterpats� _datafilters� _transref�_lockref� _wlockrefr} �filteredrevcache�
_postdsstatusr! rC �_sparsesignaturecacheZ_sparsematchercacher) Z extrafilter�_extrafilteridZfilecopiesmoder� r_ rP r� �_sidedata_computers� sidedatamodZset_sidedata_spec_for_repo)rH r r� r r r� r* r r� r0 r r r r rN rN rO rY ' sf D
�
�
zlocalrepository.__init__c s t ����d� ��fdd� }|S )zbuild a ward for self.vfsNc s �� |d�}�� }|d u s2t �|d�r2t �|d�s6d S |dv rBd S � �|j�rd� t|j�d d � � � �d�r�d}|jj|� dd d
� d }t� fd d
�|D ��r�|�|j �d u r�|jjd� ddd
� nD|�|j
�d u �r�j D ]}� �|�r� d S q�|jjd� ddd
� |S )N��modes _wlockref� _lockref�N� rs rbr r� s2 accessing cache with vfs instead of cachevfs: "%s"� s cache-vfs)�
stacklevelr# )s journal.s undo.s
strip-backup/r� c 3 s | ]}� � |�V qd S rA )ro )r rw �r^ rN rO � <genexpr>� re z@localrepository._getvfsward.<locals>.checkvfs.<locals>.<genexpr>� write with no lock: "%s"r� s write with no wlock: "%s") r5 r� ro r^ �lenr� � develwarn�any� _currentlockr� r� �_wlockfreeprefix)r^ r� r� rI rx Zvfs_path_prefixesrw ��origfunc�rrefrH r� rO �checkvfs� sD �
�
�
�
�z-localrepository._getvfsward.<locals>.checkvfs)N��weakref�ref)rH r� r� rN r� rO r� � s
-zlocalrepository._getvfswardc s t �| ��d� �fdd� }|S )zbuild a ward for self.svfsNc s� � | |d�}�� }|d u s&t �|d�s*d S |dv r6d S | �|j�rX| t|j�d d � } |�|j�d u r||jjd| dd� |S )Nr� r� r� r r� � )r� ) r5 r� ro r� r� r� r� r� r� )r^ r� r� rI �r� r� rN rO � checksvfs� s �z/localrepository._getsvfsward.<locals>.checksvfs)Nr� )rH r� r� rN r� rO r� � s
z localrepository._getsvfswardc C s | � � d S rA )� _writecachesrk rN rN rO r� s zlocalrepository.closec C s | j r| j �� d S rA )r� �writerk rN rN rO r� s z localrepository._writecachesc C s\ | j �dd�r>t|�}t�tj| dd��}|�dt�|� � | j �dd�rX|�t j
� |S )NrZ s bundle2-advertises client)Zroles bundle2=s narrow) r� r" rP r Z
encodecapsZ getrepocapsr[ �urlreq�quoter7 Z NARROWCAP)rH r� ZcapsblobrN rN rO r� s � z%localrepository._restrictcapabilitiesc C s t j| j| jd�S )N)�callback�r$ Z pathauditorr< � _checknestedrk rN rN rO �auditor s zlocalrepository.auditorc C s t j| j| jddd�S )NFT)r� Zrealfs�cachedr� rk rN rN rO � nofsauditor& s �zlocalrepository.nofsauditorc C s� |� | j�sdS |t| j�d d� }t�|�}| d }t�|�}|r�d�|�}||jv r�||krfdS |�|�}|� |t|�d d� �S qB|�
� qBdS )z/Determine if path is a legal nested repository.Fr Nr} T) ro r< r� r5 �pconvertZ splitpathr_ �substate�subZ checknested�pop)rH r^ ZsubpathZ normsubpath�ctx�partsrw r� rN rN rO r� . s
z localrepository._checknestedc C s t | �S rA )r� rk rN rN rO r� T s zlocalrepository.peerc C s | S )zaReturn unfiltered version of the repository
Intended to be overwritten by filtered repo.rN rk rN rN rO rB W s zlocalrepository.unfilteredc C s< | j dur d|vr |d | j }t�| �� j�}|| ||�S )a Return a filtered version of a repository
The `name` parameter is the identifier of the requested view. This
will return a repoview object set "exactly" to the specified view.
This function does not apply recursive filtering to a repository. For
example calling `repo.filtered("served")` will return a repoview using
the "served" view, regardless of the initial view used by `repo`.
In other word, there is always only one level of `repoview` "filtering".
N� %)r� r) ZnewtyperB rM )rH r~ Zvisibilityexceptionsr8 rN rN rO r� ] s zlocalrepository.filtered)� bookmarksrX )s bookmarks.currentrX )r� re rh c C s | � � t�| �S rA )�_refreshchangelogr Zbmstorerk rN rN rO �
_bookmarkso s 7zlocalrepository._bookmarksc C s dt | �v r | �� du r | `dS )z7make sure the in memory changelog match the on-disk one� changelogN)r� �currenttransactionr� rk rN rN rO r� � s z!localrepository._refreshchangelogc C s | j jS rA )r� Zactiverk rN rN rO �_activebookmark� s z localrepository._activebookmark�
phaserootsri c C s t �| | j�S rA )r% Z
phasecacher� rk rN rN rO � _phasecache� s zlocalrepository._phasecaches obsstorec C s t �| j| �S rA )r# r* r� rk rN rN rO �obsstore� s zlocalrepository.obsstorec C s, | j �� | jjt�| j�t�| j d�d�S )N� changelog)Zconcurrencychecker)
r Zprefetch_parentsr0 r� r4 Zmayhavependingr< �
revlogcheckerZ get_checkerr� )rI rN rN rO r� � s
�zlocalrepository.changelogc C s | j �| | j�S rA )r0 � manifestlogr� rk rN rN rO r� � s zlocalrepository.manifestlogr� c C s | � � S rA )�
_makedirstaterk rN rN rO r � s zlocalrepository.dirstatec
sP � fdd�}t j}t j}|� jv }|� jv }tj� j� j� j� j|� j ||d�S )z3Extension point for wrapping the dirstate per-repo.c s
t �� �S rA )r/ ZmatcherrN rk rN rO r � re z/localrepository._makedirstate.<locals>.<lambda>)�use_tracked_hint)
r� ru �DIRSTATE_TRACKED_HINT_V1r* r r6 r� r< �_dirstatevalidater� )rH Z
sparsematchfnZv2_req�thZuse_dirstate_v2r� rN rk rO r� � s
�z localrepository._makedirstatec C sV z| j �|� |W S tjyP | jsFd| _| j�td�t|� � | j Y S 0 d S )NTs- warning: ignoring unknown working parent %s!
)
r� �revr � LookupErrorr� r� rs r r r� �rH �noderN rN rO r� � s ��z!localrepository._dirstatevalidatec C s
t �| �S )zdmatcher patterns for this repository's narrowspec
A tuple of (includes, excludes).
)r" �loadrk rN rN rO �
narrowpats� s zlocalrepository.narrowpatsc C s0 t j| jvrt�� S | j\}}tj| j||d�S �N)�include�exclude) r� rq r* �matchmod�alwaysr� r" r r< �rH r� r� rN rN rO r� � s
z!localrepository._storenarrowmatchc C s: t j| jvrt�� S t�| � | j\}}tj| j ||d�S r� )
r� rq r* r� r� r" Zcheckworkingcopynarrowspecr� r r< r� rN rN rO � _narrowmatch� s
z localrepository._narrowmatchFc C sP |rJ|r<| j �� s<t�|�� �}t�| j |g�}t�||�S t�|| j �S | j S )a matcher corresponding the the repo's narrowspec
If `match` is given, then that will be intersected with the narrow
matcher.
If `includeexact` is True, then any exact matches from `match` will
be included even if they're outside the narrowspec.
)r� r� r� �exact�filesZ unionmatcherZintersectmatchers)rH r Z includeexactZemZnmrN rN rO � narrowmatch s zlocalrepository.narrowmatchc C s t �| ||� | jdd� d S )NT��clearfilecache)r" Zsave�
invalidate)rH Z newincludesZ newexcludesrN rN rO �
setnarrowpats s z localrepository.setnarrowpatsc C s( dt | jjft t | jjf| jt | jfiS )N� null)r r� r� rk rN rN rO �_quick_access_changeid_null s �z+localrepository._quick_access_changeid_nullc C s� | j �� }| �� j}| j�� D ]z}|| jkr.q |j�|�}|d u rDq ||f}|||< |||< |� |�D ]0}|t
krtqf|� |�}||f}|||< |||< qfq | j� � }|| jkr�|| |d< |S )N� .)
r� r� rB r� r �parentsr� �index�get_revZ
parentrevsr r� �p1) rH Zquick�clr� r� Zpairrv r
Zp1noderN rN rO �_quick_access_changeid_wc$ s,
z)localrepository._quick_access_changeid_wcc C s dt | �v r| jd= d S )Nr� )r� rC rk rN rN rO �!_quick_access_changeid_invalidateC s z1localrepository._quick_access_changeid_invalidatec C s | j tjv r| jS | jS )z�an helper dictionnary for __getitem__ calls
This contains a list of symbol we can recognise right away without
further processing.
)r� r) Z
filter_has_wcr� r� rk rN rN rO �_quick_access_changeidH s z&localrepository._quick_access_changeidc sh |d u rt �� �S t|t j�r"|S t|t�rN� fdd�tj|�t� ��� D �S � j �
|�}|d ur||\}}t j � ||dd�S |dkr�� j �
� }� j �|�}t � � ||�S �z8t|t�rʈ j �|�}|}�n
|dkr� j�� }� �� j �|�}n�t|�� jjk�r�z|}� j �|�}W nt tj�y4 t|�}� Y nV t�y� � �� �rz|� �� j�� v �rzt d�}t� |t |� ��t|�}� Y n0 nHt|�d� jj k�r�t |�}� j �|�}n t� d |t�!t"|��f ��t � � ||�W S tj#tjf�y t�$t d
�t�!|� ��Y nN t%tf�yD t�&t d �t�!|� ��Y n tj'�yb t �� � Y S 0 d S ) Nc s g | ]}|� j jvr� | �qS rN )r� � filteredrevs)r �irk rN rO �
<listcomp>] s �z/localrepository.__getitem__.<locals>.<listcomp>F)Zmaybe_filtered� tipr� s* working directory has unknown parent '%s'!re s$ unsupported changeid '%s' of type %ss filtered revision '%s'� unknown revision '%s')(r Z
workingctxr3 Zbasectx�slicer' Zxrange�indicesr� r� rp � changectxr� �tipr� �intr� r r� rB r� Znodelenr ZFilteredLookupErrorr r� r� r� r r� r r rz r� rJ ZFilteredIndexErrorZFilteredRepoLookupError�
IndexError�RepoLookupErrorZWdirUnsupported)rH �changeidZ quick_accessr� r� rx rN rk rO � __getitem__S st
�
��
����zlocalrepository.__getitem__c C s* z| | W dS t jy$ Y dS 0 dS )z!True if the given changeid existsTFN)r r )rH r rN rN rO � __contains__� s
z localrepository.__contains__c C s dS r� rN rk rN rN rO � __nonzero__� s zlocalrepository.__nonzero__c C s | � � }t|j�S rA )rB r� r� )rH rK rN rN rO �__len__� s zlocalrepository.__len__c C s
t | j�S rA )�iterr� rk rN rN rO �__iter__� s zlocalrepository.__iter__c G s t j|g|�R � }t�|�| �S )a� Find revisions matching a revset.
The revset is specified as a string ``expr`` that may contain
%-formatting to escape certain types. See ``revsetlang.formatspec``.
Revset aliases from the configuration are not expanded. To expand
user aliases, consider calling ``scmutil.revrange()`` or
``repo.anyrevs([expr], user=True)``.
Returns a smartset.abstractsmartset, which is a list-like interface
that contains integer revisions.
)r- Zspectreer, Z makematcher)rH �exprr� ZtreerN rN rO �revs� s
zlocalrepository.revsc g s& | j |g|�R � D ]}| | V qdS )aV Find revisions matching a revset and emit changectx instances.
This is a convenience wrapper around ``revs()`` that iterates the
result and is a generator of changectx instances.
Revset aliases from the configuration are not expanded. To expand
user aliases, consider calling ``scmutil.revrange()``.
N)r
)rH r r� rv rN rN rO rP � s zlocalrepository.setc C s| |dgkrt �tg�S |dgkrD| j�d�}|durDt �|d g�S |rdt j| j|t �| �|d�}nt jd||d�}|| �S )a< Find revisions matching one of the given revsets.
Revset aliases from the configuration are not expanded by default. To
expand user aliases, specify ``user=True``. To provide some local
definitions overriding user aliases, set ``localalias`` to
``{name: definitionstring}``.
r� r� Nr )r� �
localalias)r )r, Zbasesetr r� rp Zmatchanyr� Zlookupfn)rH Zspecs�userr Z
quick_datar rN rN rO �anyrevs� s
�zlocalrepository.anyrevsc C s
d| j S )Ns file:r; rk rN rN rO r� � s zlocalrepository.urlc K s t j | j| ||fi |��S )z�Call a hook, passing this repo instance.
This a convenience method to aid invoking hooks. Extensions likely
won't call this unless they have registered a custom hook or are
replacing code that is expected to call a hook.
)r r� )rH r~ �throwr� rN rN rO r � s zlocalrepository.hookc C s* G dd� dt �}|� }| �� \|_|_|S )zMReturns a tagscache object that contains various tags related
caches.c @ s e Zd Zdd� ZdS )z-localrepository._tagscache.<locals>.tagscachec S s d | _ | _d | _| _d S rA )r2 �tagtypes�
nodetagscache�tagslistrk rN rN rO rY s z6localrepository._tagscache.<locals>.tagscache.__init__N)rR rS rT rY rN rN rN rO � tagscache� s r )r� � _findtagsr2 r )rH r �cacherN rN rO �
_tagscache� s zlocalrepository._tagscachec
C sp i }| j jr| �� \}}n| jj}| j j}t�|�D ]6\}}z||� |||< W q4 tj t
fyh Y q40 q4|S )z return a mapping of tag to node) r� r� r r r2 r� r' � iteritemsr r� r )rH �tr2 �ttr� �k�vrN rN rO r2 s zlocalrepository.tagsc C s� t �| j| �}dd� |D �}t �| j| ||� i }t�|�D ]$\}\}}|| jkr<||t�|�< q<| j �
� |d< dd� t�|�D �}||fS )au Do the hard work of finding tags. Return a pair of dicts
(tags, tagtypes) where tags maps tag name to node, and tagtypes
maps tag name to a string like 'global' or 'local'.
Subclasses or extensions are free to add their own tags, but
should be aware that the returned dicts will be retained for the
duration of the localrepo object.c S s i | ]
}|d �qS )s globalrN )r �tagrN rN rO �
<dictcomp>1 re z-localrepository._findtags.<locals>.<dictcomp>r� c S s i | ]\}}t �|�|�qS rN )r �tolocal)r r~ rQ rN rN rO r > s �) �tagsmodZfindglobaltagsr� Z
readlocaltagsr' r r� r r r� r )rH Zalltagsr r2 r~ r� ZhistrN rN rO r s
�zlocalrepository._findtagsc C s | j j�|�S )z�
return the type of the given tag. result can be:
'local' : a local tag
'global' : a global tag
None : tag does not exist
)r r rp )rH ZtagnamerN rN rO �tagtypeD s zlocalrepository.tagtypec C sZ | j jsRg }t�| �� �D ] \}}|�| j�|�||f� qdd� t|�D �| j _| j jS )z)return a list of tags ordered by revisionc S s g | ]\}}}||f�qS rN rN )r rv r r
rN rN rO r� U re z,localrepository.tagslist.<locals>.<listcomp>) r r r' r r2 rq r� r� r4 )rH �lr r
rN rN rO r O s zlocalrepository.tagslistc C sf | j jsVi }t�| j j�D ]\}}|�|g ��|� qt�|�D ] }|�� q@|| j _| j j� |g �S )z&return the tags associated with a node)
r r r' r r2 �
setdefaultrq Z
itervalues�sortrp )rH r� r r r
r2 rN rN rO �nodetagsY s
zlocalrepository.nodetagsc C s | j �|�S )z;return the list of bookmarks pointing to the specified node)r� rC r� rN rN rO �
nodebookmarksd s z localrepository.nodebookmarksc C s
| j | S )zkreturns a dictionary {branch: [branchheads]} with branchheads
ordered by increasing revision number)r� rk rN rN rO r
h s zlocalrepository.branchmapc C s | j st�| �� �| _ | j S rA )r� r
�revbranchcacherB rk rN rN rO r( m s z localrepository.revbranchcachec C s | � � �||� d S rA )r( Zsetdata)rH r� ZchangelogrevisionrN rN rO �register_changesets s z"localrepository.register_changesetc C s@ z| � � �|�W S ty: |s6t�td�| ��n Y n0 dS )z�return the tip node for a given branch
If ignoremissing is True, then this method will not raise an error.
This is helpful for callers that only expect None for a missing branch
(e.g. namespace).
s unknown branch '%s'N)r
� branchtiprD r r r )rH �branchZ
ignoremissingrN rN rO r* v s zlocalrepository.branchtipc C s. t �| |��� }|d u r*t�td�| ��|S )Nr� )r. � revsymbolr� r r r )rH r� r� rN rN rO r� � s zlocalrepository.lookupc C s" | � � �|�r|S t�| |��� S rA )r
� hasbranchr. r, r+ r� rN rN rO � lookupbranch� s z localrepository.lookupbranchc C sJ | j }|jj}|j}g }|D ](}||�}|d u p6||v }|�|� q |S rA )r� r� r� r� rq ) rH r� r� r� r� r� r
rv ZresprN rN rO r� � s zlocalrepository.knownc C s | S rA rN rk rN rN rO r� � s zlocalrepository.localc C s | j jdddd�S )N� phasess publishT)Z untrusted)r� r" rk rN rN rO �
publishing� s zlocalrepository.publishingc C s( | � � s dS | �� sdS | �d�jj S )NFT� visible)r� r0 r� r� r� rk rN rN rO �cancopy� s
zlocalrepository.cancopyc C s | j | jkrdS dS )z2the type of shared repository (None if not shared)r N)r� r^ rk rN rN rO r6 � s zlocalrepository.sharedc G s | j j| j|g|�R � S rA )r6 Zreljoinr< )rH r� ZinsidefrN rN rO �wjoin� s zlocalrepository.wjoinc C s* |d u r| j }| d �||� | �� d S rA )r� �
setparentsr� )rH r� �p2rN rN rO r4 � s zlocalrepository.setparentsc C s t j| ||||d�S )zcchangeid must be a changeset revision, if specified.
fileid can be a file revision or node.)r )r �filectx)rH r^ r Zfileidr rN rN rO r6 � s
�zlocalrepository.filectxc C s
| j �� S rA )r �getcwdrk rN rN rO r7 � s zlocalrepository.getcwdc C s | j �||�S rA )r �pathto)rH r� �cwdrN rN rO r8 � s zlocalrepository.pathtoc C s� || j vr�g }| j�|�D ]�\}}|dkr,qt�| jd|g�}d }|}t�| j�D ].\}} |� |�rR| }|t
|�d � � � } q�qR|s�dd� }d|_ t�
|�d s�|}
|
fdd�}d|
j |_ |�|||f� q|| j |< | j | S ) N� !re c [ s t �| |�S rA )r: �filter)�s�cr� rN rN rO r � re z-localrepository._loadfilter.<locals>.<lambda>Z
commandfilterre c [ s
|| |�S rA rN )r< r= �oldfnr� rN rN rO r � re zcompat-)r� r� Z configitemsr� r r< r' r r� ro r� �lstriprR Z
getargspecrq ) rH r; r# �pat�cmd�mfr� �paramsr~ Zfilterfnr> rN rN rO � _loadfilter� s.
zlocalrepository._loadfilterc C sT |D ]J\}}}||�r| j �d||p.t�|j�f � |||| j | |d�} qPq|S )Ns filtering %s through %s
)r� rI �filename)r� �debugr' ZsysbytesrR )rH Z
filterpatsrE �datarB r� rA rN rN rO �_filter� s ��zlocalrepository._filterc C s
| � d�S )Ns encode�rD rk rN rN rO �_encodefilterpats� s z!localrepository._encodefilterpatsc C s
| � d�S )Ns decoderI rk rN rN rO �_decodefilterpats� s z!localrepository._decodefilterpatsc C s || j |< d S rA )r� )rH r~ r; rN rN rO �
adddatafilter� s z localrepository.adddatafilterc C s6 | j �|�r| j �|�}n | j �|�}| �| j||�S rA )r� �islink�readlinkr� rH rJ �rH rE rG rN rN rO �wread� s zlocalrepository.wreadc K st | � | j||�}d|v r(| j�||� nD| jj||fd|i|�� d|v r\| j�|dd� n| j�|dd� t|�S )z�write ``data`` into ``filename`` in the working directory
This returns length of written (maybe decoded) data.
� l�backgroundclose� xFT)rH rK r� �symlinkr� Zsetflagsr� )rH rE rG �flagsrR r� rN rN rO �wwrite s ���zlocalrepository.wwritec C s | � | j||�S rA )rH rK rO rN rN rO �
wwritedata s zlocalrepository.wwritedatac C s( | j r| � � }nd}|r$|�� r$|S dS )z4return the current transaction or None if non existsN)r� Zrunning)rH �trrN rN rO r� s
z"localrepository.currenttransactionc
sP �j �dd�s �j �dd�r6���j�d u r6t�d����� ��d urR�j� d�S �j� d�rttj
t d�t d�d ��d
t � � t
�
� f }tt�|��� �}d | }�jd d
� |d� ��� � dd� ��� D �}|r�|}n�j j}�j�jd�}t����dd� ��j �dd�} � dk�r8| �r8�j�� ���fdd��� ���fdd�}
��fdd �} tj|�j|dd t |��j j |
| t � d � �t ���j!d < t"� �j!d < g �j!d!< i �j!d"< |�j#d#< � �j#d$< �j!�j#d%< ��$d&�j j%� ��fd'd(�} ��$d)| � ��&d*��'��� �fd+d,�}
��(d-|
� ��&d.�j)� t����_*t+�,��� � �S )/Nrj r� r� s transaction requires locking)r~ � journals abandoned transaction founds( run 'hg recover' to clean up transactionr s %.40f#%fs TXN:s
pretxnopenT)r Ztxnname�txnidc S s g | ]\}}||t |�f�qS rN ��undoname�r r6 �xrN rN rO r� 9 re z/localrepository.transaction.<locals>.<listcomp>)rX r c S s d S rA rN )r^ rN rN rO r b re z-localrepository.transaction.<locals>.<lambda>rZ s hook-track-tags� stripc s� �� }t �|j|� �}|j�� }t �|j||�}t �|j|||�}|r�d| jd< |jdddd�� }t �||� W d � n1 s�0 Y d S )N� 1s tag_moveds changes/tags.changes� wT)Z
atomictemp) r! � fnoderevsr� r� �headrevsZdifftags�hookargsr6 Z writediff)�tr2rI Z oldfnodesZnewheadsZ newfnodes�changesZ changesfile)�oldheads�reporefrN rO � tracktagsj s
�z.localrepository.transaction.<locals>.tracktagsc sp �| � �� }d}|j j|� }|rf|j j|� d }|�dd�}|�dd�rPd}nd}t�|| � ||� t�|j d�r�t�j d �
� �D ]D\}\}} �j � � }
|
�
t�||| �� |jdd
d it�|
��� q�t�|j d ��rP|�� j} �j d
D ]^\} \}} | D ]L}
�j � � }
t| �|
��}|
�
t�||| �� |jdd
d it�|
��� �q q�|jdd
d it��j ��� dS )zwill run pre-closing hooks)rZ s single-head-per-branchr s account-closed-headsFs public-changes-onlys immutabler1 � pretxnclose-bookmarkr� r T� pretxnclose-phaser/ � pretxncloseN)rj )rk )rl )r� r" Zconfigsuboptionsrp r. Zenforcesingleheadr �hashookr4 rf r@ rd r� ry r �preparehookargsr' r� rB r� r r� r% )re rI Z
singleheadoptZ
singleheadZ
singleheadsubZ
accountclosedr� r~ r� r� r� r� r
r� r� )�descrh rX ri rN rO �validate} sb �
� �
���
��� ��
�z-localrepository.transaction.<locals>.validatec sZ � � }|d u rd S |r$|j �d � n2t��d� t��d� |j �d d� |jdd� d S )N� journal.narrowspec� journal.narrowspec.dirstate� journal.dirstateTr� )r r� r" �
restorebackup�restorewcbackupr� )rX �successrI )rh rH rN rO � releasefn� s z.localrepository.transaction.<locals>.releasefn� undo)Z validatorrw �checkambigfilesr~ � origrepolens
obsmarkersr/ r� s txnids txnnames changess
flush-fncachec s* | j � � ��fdd�}�� }|�|� dS )z@To be run if transaction is successful, will schedule a hook runc s �� }t �|jd�rpt�jd �� �}|D ]D\}\}}�j�� }|�t �
|||�� |j d ddit � |��� q*t �|jd��r|�
� j}t�jd dd� d �}|D ]\\} \}}| D ]J}
�j�� }t|�|
��} |�t�
| ||�� |j d ddit � |��� q�q�|j d
ddit � � ��� d S )N� txnclose-bookmarkr� r F� txnclose-phaser/ c S s | d d S )Nr rN )rv rN rN rO r
re zUlocalrepository.transaction.<locals>.txnclosehook.<locals>.hookfunc.<locals>.<lambda>)r� � txnclose)r{ )r| )r} )r rm r� r4 rf r@ rd r� ry r rn r' r� rB r� r r� r% ) �unused_successrI Z bmchangesr~ r� r� r� r� Zphasemvr
r� r� )rd rh rX rN rO �hookfunc� sJ
���
�
���
���zClocalrepository.transaction.<locals>.txnclosehook.<locals>.hookfuncN)rd �
_afterlock)re r rI )rh rX )rd rO � txnclosehook� s #z1localrepository.transaction.<locals>.txnclosehooks
txnclose-hooks -warm-cachec s& � � }|j dddit�| j��� dS )z#To be run if transaction is aborted� txnabortr FN)r� )r r' r� rd )re rI �rh rN rO � txnaborthook%
s ��
�z1localrepository.transaction.<locals>.txnaborthooks
txnabort-hooks refresh-filecachestats)-r� r" r� r� r rz r� Znestr~ r� r� r �random�timer r9 Zsha1�digestr �
_writejournal�
_journalfilesrs r6 r� r� r� rc r3 �
aftertransr0 r+ rZ r� rf rP rd Z addfinalizer� Z addpostclose�_buildcacheupdaterZaddabort�_refreshfilecachestatsr� r. Zregistersummarycallback)rH ro �reportZidbaseZharZ �renamesZrp�vfsmapZshouldtracktagsrp rw r� r� rN )ro rg rh rH rX ri rO r3 " s~ �
�
"�
@�
/ zlocalrepository.transactionc C sH | j df| j df| jdf| jdf| jdf| jdft�| �df| j dffS ) NrY rq rr rs � journal.branch� journal.desc� journal.bookmarks� journal.phaseroots)r~ r6 r � bookmarksvfsrk rN rN rO r� 5
s �z localrepository._journalfilesc C s dd� | � � D �S )Nc S s g | ]\}}|t |�f�qS rN r[ r] rN rN rO r� B
re z-localrepository.undofiles.<locals>.<listcomp>)r� rk rN rN rO � undofilesA
s zlocalrepository.undofilesc C s� | j �d d� t�| d� t�| d� | j�dt�| j �� �� | j�ddt | �|f � t
� | �}|�d|� d�� | j
�d | j
� d
�� d S ) Nrs rr rq r� r� s %d
%s
r� r� r� r� )r Z
savebackupr" Z savewcbackupr6 r� r Z fromlocalr+ r� r r� r� r~ )rH ro r� rN rN rO r� D
s �
�z localrepository._writejournalc C s� | � � �� | j�d�rf| j�td�� | j| jd�}tj| j|d| jj t
d� | � � W d � dS | j� td�� W d � dS W d � n1 s�0 Y d S )NrY s% rolling back interrupted transaction
)re rX �ry Ts% no interrupted transaction available
F) r r~ r� r� �statusr r6 r3 �rollbackrs rZ r� )rH r� rN rN rO �recoverS
s"
��zlocalrepository.recoverc
C s� d } }}zv| � � }| �� }| j�d�rRt�| d�}| �|||�W t|||� S | j�t d�� W t|||� dS W t|||� nt|||� 0 d S )Nrx s rollbacks" no rollback information available
r )
�wlockr r~ r� r � _rollback�releaser� rs r )rH �dryrun�forcer� r �dsguardrN rN rO r� h
s � �zlocalrepository.rollbackc st | j }zz| j�d��� }t|d �|d d }}}t|�dkrH|d }|d } |rn|jrntd�| ||f }
ntd�| |f }
W n ty� td�}
d }Y n0 |s�| d | d
kr�|d kr�t j
td �td
�d��|� |
� |r�dS | j �
� } | �� | j| jd�} tj| j| d|jtd� t�| �}
|
�d��rB|
jdddd� | j�d��rb| jjdddd� | �� | jjj� t � fdd�| D ��}|�rh|� � t � | d� t � | d� | j � d d � z"| j�d �}| j �!t"�#|�� W n, t�y |�td �| j �$� � Y n0 t%d d � | d �
� D ��} t| �dk�rJ|� td!�| � n|� td"�| � t&j'�(| � | �)� dS )#Ns undo.descr r r� re s8 repository tip rolled back to revision %d (undo %s: %s)
s4 repository tip rolled back to revision %d (undo %s)
s! rolling back unknown transaction
r� r� � commits; rollback of last commit while not checked out may lose datas use -f to forcer )rX re rx r� s undo.bookmarksr� T)Z
checkambigs undo.phaserootsr� c 3 s | ]}� |� V qd S rA rN �r �p��has_noderN rO r� �
re z,localrepository._rollback.<locals>.<genexpr>s undo.narrowspecs undo.narrowspec.dirstates
undo.dirstates undo.branchs> named branch could not be reset: current branch is still '%s'
c S s g | ] }|� � �qS rN )r� r� rN rN rO r� �
re z-localrepository._rollback.<locals>.<listcomp>s3 working directory now based on revisions %d and %d
s+ working directory now based on revision %d
)*r� r6 r� r� r r� �verboser r� r r� r� r r� �
destroyingr~ r3 r� rs rZ r r� r� �renamer� r� r� r� r� r� r" rt ru Z setbranchr r r+ r5 �
mergestatemodr �clean� destroyed)rH r� r� r� r� r� Zoldlenro ZdetailZoldtiprx r� r� r� Z
parentgoner+ rN r� rO r� w
s�
����
��
�
�
���
���
� zlocalrepository._rollbackc s t �| �� � fdd�}|S )z�called during transaction to build the callback updating cache
Lives on the repository to help extension who might want to augment
this logic. For this purpose, the created transaction is passed to the
method.
c s � � }|� | � d S rA )� updatecaches)rX rI r� rN rO �updater�
s z3localrepository._buildcacheupdater.<locals>.updaterr� )rH Znewtransactionr� rN r� rO r� �
s
z"localrepository._buildcacheupdaterc C s� |dur |j �d�dkr dS | �� }|rVd}| j�|d� tj}|dkrNtj}tj}n|du rdtj}tj |v r�|du s�|j
d t | �k r�| j� d� | �
d ��� | �
d
��� | j�| � tj|v r�| jj|d � tj|v r�| jj|d � tj|v �r |�� }|jD ]}|�|� �q|�� tj|v �rH| d �� D ]}|� � �q8tj |v �rjt � | j||j� � � tj!|v �r~| �"� tj#|v �r�| �
d ��"� tj$|v �r�t%j&�'� D ] } | �
| �}
|
�� �|
� �q�dS )
a� warm appropriate caches
If this function is called after a transaction closed. The transaction
will be available in the 'tr' argument. This can be used to selectively
update caches relevant to the changes in that transaction.
If 'full' is set, make sure all caches the function knows about have
up-to-date data. Even the ones usually loaded more lazily.
The `full` argument can take a special "post-clone" value. In this case
the cache warming is made after a clone and of the slower cache might
be skipped, namely the `.fnodetags` one. This argument is 5.8 specific
as we plan for a cleaner way to deal with this for 5.9.
Ns sourcer_ za`full` argument for `repo.updatecaches` is deprecated
(use `caches=repository.CACHE_ALL` instead)s 5.9s
post-clonerz s updating the branch cache
r� s
served.hidden)r3 r� )(rd rp rB r� Z
deprecwarnr8 Z
CACHES_ALLZCACHES_POST_CLONEZCACHES_DEFAULTZCACHE_BRANCHMAP_SERVEDrf r� rF r� r
r� Z
write_delayedZCACHE_CHANGELOG_CACHEr� Z
update_cachesZCACHE_MANIFESTLOG_CACHEr� ZCACHE_REV_BRANCHr( Z
branchinfor� ZCACHE_FULL_MANIFESTr� ZmanifestZCACHE_FILE_NODE_TAGSr! rb r
ZCACHE_TAGS_DEFAULTr2 ZCACHE_TAGS_SERVEDZCACHE_BRANCHMAP_ALLr) Z filtertable�keys) rH rX ZfullZcachesrK rx Zrbcrv r� Zfiltr� rN rN rO r� �
sR �
z localrepository.updatecachesc C s4 dt | �v r| jd= | j�� | �� | j�� d S )Nr )r� rC r� �clear�invalidatevolatilesetsr� rk rN rN rO �invalidatecaches7 s
z localrepository.invalidatecachesc C s | j �� t�| � | �� d S rA )r� r� r# Zclearobscachesr� rk rN rN rO r� A s
z&localrepository.invalidatevolatilesetsc C sN t | d�rJ| jjD ](}zt| j|� W q ty8 Y q0 qt| �� d� dS )a� Invalidates the dirstate, causing the next call to dirstate
to check if it was modified since the last time it was read,
rereading it if it has.
This is different to dirstate.invalidate() that it doesn't always
rereads the dirstate. Use dirstate.invalidate() if you want to
explicitly read the dirstate again (i.e. restoring it to a previous
known good state).r N)r� r r} r
�AttributeErrorrB )rH r rN rN rO �invalidatedirstateF s
z"localrepository.invalidatedirstatec C s� | � � }t| j�� �D ]V}|dkr$q|dkr>| �� r>| jjr>q|rJ| j|= zt||� W q tyj Y q0 q| � � | �� s�| j
� � dS )a9 Invalidates both store and non-store parts other than dirstate
If a transaction is running, invalidation of store is omitted,
because discarding in-memory changes might cause inconsistency
(e.g. incomplete fncache causes unintentional failure, but
redundant one doesn't).
r� r� N) rB �listr} r� r� r� Z_delayedr
r� r� r0 )rH r� rB r rN rN rO r� W s( ��� zlocalrepository.invalidatec C s | � � | �� dS )zyFully invalidates both store and non-store parts, causing the
subsequent operation to reread any outside changes.N)r� r� rk rN rN rO �
invalidateall{ s z localrepository.invalidateallc C s> | j �� D ].\}}t�|�}|dks
|| jvr0q
|�� q
dS )z>Reload stats of cached files so that they are flagged as validr N)r} r@ r' r� rC �refresh)rH rX r ZcerN rN rO r� � s
z&localrepository._refreshfilecachestatsc C sX d}d}|r(| j �dd�}| j �dd�}| j �dd�} tj| j |||||||| d� }
|
S )Nr � uis timeouts timeout.warns signal-safe-lock)rw � acquirefnro �
signalsafe)r� r\ r" �lockmodZtrylock) rH r6 �lockname�waitrw r� ro �timeoutZ warntimeoutr� r# rN rN rO �_lock� s$ � zlocalrepository._lockc C sB | j | jfD ](}|o|� }|r |jr |j�|� q>q |d� dS )z�add a callback to be run when the repository is fully unlocked
The callback will be executed when the outermost lock is released
(with wlock being higher level than 'lock').TN)r� r� �heldZ postreleaserq )rH r� r� r# rN rN rO r� � s
zlocalrepository._afterlockTc C sT | � | j�}|dur |�� |S | j| jd|d| jtd�| j d�}t� |�| _|S )a] Lock the repository store (.hg/store) and return a weak reference
to the lock. Use this before modifying the store (e.g. committing or
stripping). If you are opening a transaction, get a lock as well.)
If both 'lock' and 'wlock' must be acquired, ensure you always acquires
'wlock' first to avoid a dead-lock hazard.Ns locks
repository %s)r6 r� r� rw r� ro )
r� r� r r� r~ r� r r r� r� )rH r� r# rN rN rO r � s � zlocalrepository.lockc s� � j r� � � nd}|dur,|jr,|�� |S |rh� j�dd�sL� j�dd�rh� �� j�durh� j�d� � fdd�}� �� j d||� j
t d �� j �}t
�|�� _ |S )
a8 Lock the non-store parts of the repository (everything under
.hg except .hg/store) and return a weak reference to the lock.
Use this before modifying files in .hg.
If both 'lock' and 'wlock' must be acquired, ensure you always acquires
'wlock' first to avoid a dead-lock hazard.Nrj r� r� s "wlock" acquired after "lock"c s4 � j �� r� j �� n � j �d � � jd �� d S )Nr� )r Zpendingparentchanger� r� r} r� rN rk rN rO �unlock� s
z%localrepository.wlock.<locals>.unlocks wlocks working directory of %s)r� r� r r� r" r� r� r� r� r6 r� r r r� r� )rH r� r# r� rN rk rO r� � s, � � � zlocalrepository.wlockc C s( |du r dS |� }|du s |j s$dS |S )z3Returns the lock if it's held, or None if it's not.N)r� )rH Zlockrefr# rN rN rO r� � s z localrepository._currentlockc C s | � | j�S )z4Returns the wlock if it's held, or None if it's not.)r� r� rk rN rN rO � currentwlock� s z localrepository.currentwlockc C s� |� � s|�� r�t|j|j |j �}|�� D ]�}| j�|�}|dks.||v s.||j v rZq.||j
v rr||t d�� | j �
|�s�|�� �|�r�|d }|D ]}|�|�r� q�q�||t d�� q.|| jvr.||t d�� q.dS )z2check for commit arguments that aren't committabler� s file not found!r} s no match under directory!s file not tracked!N)Zisexactrw rP �modifiedZaddedZremovedr� r � normalizer� �deletedr r� r r� Zhasdirro ) rH �wctxr r� �failZmatchedr� �drB rN rN rO �checkcommitpatterns s
z#localrepository.checkcommitpatternsre c
s> |du r i }dd� }|s t �� }|s*||_��� ��� ��� ��� �d } t| �� �dk}
|sx|
rx|�� sxt�t d����j
||d�} |r�| j � | j
� tj�j| | ||d�\} }
}|sȈ�| || |� t��| ||||�}tj���}t�|� |�� �r<�j�dd ��s<�j�d
� |� � W d � W d � dS |
�rZ|� � �rZt�t d ���|�rn|�|| �|_ ||j k}�� |j �}| �r�t �!��}t"|
�D ]R}| �#|�}�j�
t d �|t�$|�� � |�%|j ||�}|| d
|f||< �q�t�&�|� �j'�� \}}t(|�|�j)k�r&t(|��p(d � �zr�j*dd� �d� ��+d��@ ��,|d��t-�.�||g�� |�/�� |� � W d � n1 �s�0 Y W n< |�rֈj�0t d�| � �j�0t d�| � � Y n0 W d � n1 �s�0 Y W d � n1 �s0 Y � ���fdd�}��1|� �S )z�Add a new revision to current repository.
Revision information is gathered from the working directory,
match can be used to filter the committed files. If editor is
supplied, it is called to get a commit message.
Nc S s t �d| |f ��d S )Ns %s: %s)r Z
InputError)r� rx rN rN rO r� - s z$localrepository.commit.<locals>.failr sB cannot partially commit a merge (do not specify files or patterns))r r� )r� r� s allowemptycommits( nothing to commit, clearing merge state
s& cannot commit merge with missing filess committing subrepository %s
r re s precommitT)r �parent1�parent2r� s! note: commit message saved in %s
s6 note: use 'hg commit --logfile %s --edit' to reuse it
c s& �j ���r"�jdt��� �d� d S )Nr� )r� r� r� )r� Zhasnoder r �r~ �Zhookp1Zhookp2r� rH rN rO �
commithook� s �z*localrepository.commit.<locals>.commithook)2r� r� Zbadr� r r� r� r r� r r� r� �extendr� r1 Z precommitr� r� r Zworkingcommitctxr� r r� r ZcheckunresolvedZisemptyr" rF �resetr� Z_text�savecommitmessager. Z getuipathfnr4 r� Z
subrelpathr Z
writestater r r� r r3 � commitctxr ry Z
markcommittedr� r� )rH �textr �dater r� ZeditorZextrar� r� �merger� ZsubsZ
commitsubsZnewstateZcctx�msZeditedZmsg_pathZuipathfnr< r� �srr� r5 r� rN r� rO r s� ��� � �
�
�� $�
,
����H
zlocalrepository.commitc C s t j| |||d�S )N)r �origctx)r r� )rH r� r r� rN rN rO r� � s zlocalrepository.commitctxc C s dt | �v r| j�� dS )a Inform the repository that nodes are about to be destroyed.
Intended for use by strip and rollback, so there's a common
place for anything that has to be done before destroying history.
This is mostly useful for saving state that is in memory and waiting
to be flushed when the current lock is released. Because a call to
destroyed is imminent, the repo will be invalidated causing those
changes to stay in memory (waiting for the next unlock), or vanish
completely.
r� N)r� r� r� rk rN rN rO r� � s zlocalrepository.destroyingc C s* | j �| � | j �� | �� | �� dS )z�Inform the repository that nodes have been destroyed.
Intended for use by strip and rollback, so there's a common
place for anything that has to be done after destroying history.
N)r� Z
filterunknownr� r� r� rk rN rN rO r� � s
zlocalrepository.destroyedr� c C s | | � ||||||�S )z3a convenience method that calls node1.status(node2))r� )rH Znode1Znode2r Zignoredr� �unknownZ listsubreposrN rN rO r� � s �zlocalrepository.statusc C s | j �|� dS )a� Add a callback to run within the wlock, at the point at which status
fixups happen.
On status completion, callback(wctx, status) will be called with the
wlock held, unless the dirstate has changed from underneath or the wlock
couldn't be grabbed.
Callbacks should not capture and use a cached copy of the dirstate --
it might change in the meanwhile. Instead, they should access the
dirstate via wctx.repo().dirstate.
This list is emptied out after each status run -- extensions should
make sure it adds to this list each time dirstate.status is called.
Extensions should also make sure they don't call this for statuses
that don't involve the dirstate.
N)r� rq )rH ZpsrN rN rO �addpostdsstatus� s z localrepository.addpostdsstatusc C s | j S )zAUsed by workingctx to get the list of post-dirstate-status hooks.�r� rk rN rN rO � postdsstatus� s z localrepository.postdsstatusc C s | j dd�= dS )z7Used by workingctx to clear post-dirstate-status hooks.Nr� rk rN rN rO �clearpostdsstatus� s z!localrepository.clearpostdsstatusc sJ |d u r,| j � t� �� �}� fdd�|D �S | j �|�}t|| j jdd�S )Nc s g | ]}� � |��qS rN )r� )r r� �r� rN rO r�
re z)localrepository.heads.<locals>.<listcomp>T)r� �reverse)r� �reversedrc r� r4 r� )rH �startrc r� rN r� rO r�
s zlocalrepository.headsc sv |du r| d � � }| �� }|�|�s*g S tt|j||d���}|durrt| j�|g|�d �� � fdd�|D �}|S )aV return a (possibly filtered) list of heads for the given branch
Heads are returned in topological order, from newest to oldest.
If branch is None, use the dirstate branch.
If start is not None, return only heads reachable from start.
If closed is True, return heads that are marked as closed as well.
N)�closedre c s g | ]}|� v r|�qS rN rN )r �h�ZfbheadsrN rO r�
re z/localrepository.branchheads.<locals>.<listcomp>) r+ r
r- r� r� � branchheadsrP r� Z nodesbetween)rH r+ r� r� r� ZbheadsrN r� rO r�
s
zlocalrepository.branchheadsc C st |s| j �� g}g }|D ]V}|}| j �|�}|d | jksH|d | jkrd|�|||d |d f� q|d }q q|S )Nr r )r� r r� r� rq )rH r� r� r
r r� rN rN rO r� !
s zlocalrepository.branchesc
C s~ g }|D ]p\}}|g d }}}d}||krn|| j krn| j�|�d } ||kr`|�|� |d }| }|d7 }q$|�|� q|S )Nr r re )r� r� r� rq )
rH r� rv �topZbottomr
r# r� r� r� rN rN rO r� /
s
zlocalrepository.betweenc C s dS )z�Extensions can override this function if additional checks have
to be performed before pushing, or call it if they override push
command.
NrN )rH ZpushoprN rN rO � checkpushB
s zlocalrepository.checkpushc C s t �� S )z�Return util.hooks consists of a pushop with repo, remote, outgoing
methods, which are called before pushing changesets.
)r5 Zhooksrk rN rN rO �prepushoutgoinghooksH
s z$localrepository.prepushoutgoinghooksc
s zb�� � }i }|d ur"|�|j� t�|�}�|d< � |d< �|d< �|d< �jdddi|�� W nX tjy� } z>�j� t
d�| � |j r��j� t
d �|j � W Y d }~d
S d }~0 0 �j� d �� f � t
���� ����� �����fd d
�}��|� �S )Nr� r� r� r� �
prepushkeyr Ts pushkey-abort: %s
s (%s)
Fs pushing key for "%s:%s"
c s �j d�� ���d� d S )Nr� )r� r� r� r� r� )r r� �r� r� r� r� r� rH rN rO �runhookc
s �z(localrepository.pushkey.<locals>.runhook)r� )r� ry rd r' r� r r Z HookAbortr� Z write_errr r rF r& �pushr� ) rH r� r� r� r� rX rd r� r� rN r� rO r& O
s*
zlocalrepository.pushkeyc C s@ | j dd|d� | j�d| � t�| |�}| j d||d� |S )Ns prelistkeysT)r r� s listing keys for "%s"
s listkeys)r� �values)r r� rF r& r� )rH r� r� rN rN rO r� p
s
zlocalrepository.listkeysc C s$ d||t �|�t �|�t �|�f S )z+used to test argument passing over the wirer� r� r� rN rN rO r� w
s �z localrepository.debugwireargsc C sL | � dd�}z|�|� W |�� n
|�� 0 | �|jt| j�d d � �S )Ns last-message.txts wbr )r6 r� r� r8 r~ r� r< )rH r� �fprN rN rO r� �
s
z!localrepository.savecommitmessagec C s& t j| jvrd S | j�t�|�� d S rA )r8 r/ r r� r[ r' r� )rH �categoryrN rN rO �register_wanted_sidedata�
s z(localrepository.register_wanted_sidedatac C s� |t jvr td�}t�|| ��t�|�}|| j�|g �v }|rZ|sZtd�}t�|| ��|rx|sxtd�}t�|| ��| j� |i � |||f| j| |< d S )Ns unexpected revlog kind '%s'.s< cannot register a sidedata computer twice for category '%s'.sK cannot replace a sidedata computer that isn't registered for category '%s'.)
rn Z ALL_KINDSr r rz r' r� r� rp r$ ) rH �kindr� r� ZcomputerrU �replacerx Zalready_registeredrN rN rO �register_sidedata_computer�
s"
��z*localrepository.register_sidedata_computer)N)N)NF)FN)F)F)N)NNN)N)F)N)FF)NFN)F)T)T)re NNNFNN)FN)r� NNFFFF)N)NNF)NNN)F)�rR rS rT rU r� � BOOKMARKS_IN_STORE_REQUIREMENTr. r_ r� ru rU rT rk �INTERNAL_PHASE_REQUIREMENTrr r� r] r- r r! rR rm rS r[ rG r� rY r� r� r� r� r� �propertyr� r� r� r� rB r� rx r� r� r� rd r� r� rg r� ru r� rW r r� r� r" ZFILENAMEr� r� r� r� r� r� r� r� r� r� r� r r r �__bool__r r r
rP r r� r r� r r2 r r" r r& r' r
r( r) r* r� r. r� r� r0 r2 r6 r3 r4 r6 r7 r8 rD rH rJ rK rL rP rV rW r� r3 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� r� r� r� r& r� r� r� r� r� rN rN rN rO rF � s� � �
3
&
�
4
O
$
\Q
$
) �
! �
!
�rF c s dd� | D �� � fdd�}|S )Nc S s g | ] }t |��qS rN )r5 )r r rN rN rO r� �
re z aftertrans.<locals>.<listcomp>c sb � D ]X\} }}| � |� z| �||� W q tyZ } z|jtjkrF� W Y d }~qd }~0 0 qd S rA )Z tryunlinkr� r r� r� )r6 �src�destr� �Z renamefilesrN rO �a�
s
zaftertrans.<locals>.arN )r� r� rN r� rO r� �
s r� c C s( t j�| �\}}t j�||�ddd��S )NrY rx r )�osr^ rp r_ r� )r� r� r~ rN rN rO r\ �
s r\ c C s* t �|�}|r t| ||d� t| ||d�S )N��
createopts)r )r< Z urllocalpath�createrepositoryr9 )r� r^ Zcreater r� Z localpathrN rN rO �instance�
s
r� c C s dS r� rN r� rN rN rO �islocal�
s r� c C s( t |pi �}d|vr$| �dd�|d< |S )z�Populate the default creation options for a repository.
A dictionary of explicitly requested creation options can be passed
in. Missing keys will be populated.
� backendrb s new-repo-backend)�dictr# �r� r� rN rN rO �defaultcreateopts�
s r c C sd t � }|js|S t| |d�}t| |�D ]}|tjv r&|�|� q&|jD ]}|tjvrF|�|� qF|S )z�clone the requirements of a local repo for a local clone
The store requirements are unchanged while the working copy requirements
depends on the configuration
r� )rP r* r �newreporequirementsr� �WORKING_DIR_REQUIREMENTSr[ )r� r� ZsrcrepoZtarget_requirementsrv rN rN rO �clone_requirements�
s
r c C s~ d|vrt �d��|d dkr4t �td�|d ��tjh}| �dd�r�|�tj� | �dd�r�|�tj � | �dd�r�|�tj
� | � dd �}|D ],}|t j
v r�t j
| }|�� r�|�� r� q�q�t jtd
�d �d d
� |D �� td�d��|dk�r|�d� n|dk�r|�d| � t�| ��rL|�tj� | �dd��rL|�tj� | �dd��rf|�tj� | �dd��r�|�tj� |�tj� | �dd��r�|�tj� | �dd�}|dk�r�|�tj� | �dd�}|dk�r�|�tj� |�tj� | �dd ��r|�tj � |� d ��r(|�tj � |� d ��r>|�d � | �dd ��rX|�tj � | �dd ��rr|�tj � | �dd!��r�|�tj!� d"|v �r&t"|d" j#�}tj!|v�r�|}nJt"� } |D ].}
|
tj$v �rԐq�|
|v �r�q�| �|
� �q�|| 8 }||O }|� d#��r|�tj%� n |�tj&� | �dd$��rz| �'dd%�} td&�} td'�}
| d(k�rn| j(| | |
d� n |�tj)� |S ))z�Determine the set of requirements for a new local repository.
Extensions can wrap this function to specify custom requirements for
new repositories.
r sF backend key not present in createopts; was defaultcreateopts() called?r` sC unable to determine repository requirements for storage backend: %srX s usestores
usefncaches dotencodes revlog-compressionsI compression engines %s defined by format.revlog-compression not available� , c s s | ]}d | V qdS )s "%s"NrN )r r� rN rN rO r� re z&newreporequirements.<locals>.<genexpr>s; run "hg debuginstall" to list available compression enginesr rE s revlog-compression-zstds zlibrD rc s use-dirstate-v2s" exp-use-copies-side-data-changesetrZ rW s exp-use-changelog-v2s* enable-unstable-format-and-corrupt-my-datara s internal-phase� narrowfilesr? s bookmarks-in-stores use-persistent-nodemap� use-share-safe�
sharedrepo� sharedrelatives use-dirstate-tracked-hints! use-dirstate-tracked-hint.versionz)ignoring unknown tracked key version: %d
z<see `hg help config.format.use-dirstate-tracked-hint-versionr )*r rz r� r r� r] r" r[ rS rT rU Z
configlistr5 rI rJ rK r_ r. Z gdinitconfigrk rm ru r. r_ r[ r# r0 r- r� rp rq r� rr r! rP r* r r� r r\ rs r� )r� r� r* rI Z
compenginerN Z changelogv2Zrevlogv2Zsource_requirementsZto_dropZreq�versionrx r rN rN rO r �
s� � ���
����
r c C s� t � }tj|vr�tj|v r4| �td�� |�tj� tj|v sHtj|v rVt �
td���tj |v r�| � dd�r~td�}| �|� |�tj � |S )z�Checks compatibility of repository requirements enabled and disabled.
Returns a set of requirements which needs to be dropped because dependend
requirements are not enabled. Also warns users about itsv ignoring enabled 'format.bookmarks-in-store' config beacuse it is incompatible with disabled 'format.usestore' config
s\ cannot create shared repository as source was created with 'format.usestore' config disabledrX r sr ignoring enabled 'format.use-share-safe' config because it is incompatible with disabled 'format.usestore' config
)
rP r� rS r� rs r r[ r r� r r� r! rA )r� r* Zdroppedrx rN rN rO �checkrequirementscompat s4
�� ����
�
r
c s h d�� � fdd�|� � D �S )a% Filters a dict of repo creation options against options that are known.
Receives a dict of repo creation options and returns a dict of those
options that we don't know how to handle.
This function is called as part of repository creation. If the
returned dict contains any items, repository creation will not
be allowed, as it means there was a request to create a repository
with options not recognized by loaded code.
Extensions can wrap this function to filter out creation options
they know how to handle.
> r r s shallowfilestore� shareditemsr
r? r c s i | ]\}}|� vr||�qS rN rN )r r r �r� rN rO r � re z)filterknowncreateopts.<locals>.<dictcomp>)r@ r rN r rO �filterknowncreateopts� s
r c
C sJ |dur$|dur d}t �|��i }nlt| |d�}t| |�}t|t�sNt �d��|rvt jtd�d�t |�� td�d��t
| |d�}|t | |�8 }t j
|d d d
�}t �
|�d ��}|�� r�t �td �| ��d
|v �rL|d
j}|�d��rLz tj�||j�}t�|�}W nB ttf�yJ } z$t jtd�t�| �d��W Y d} ~ n
d} ~ 0 0 |�� �s^|� � |j d d� d
|v�r~|� d� |� d� t j |v }
|
�r�d
|v�r�|� d� |�!dd� t"�#|�\} } t"�$|| � | �rd
|v�rt j
|�d�d d�}
t"�$|
| � d
|v �r|�%d|� |�d��rFd�t |d ��d }|�%d|� dS )a7 Create a new repository in a vfs.
``path`` path to the new repo's working directory.
``createopts`` options for the new repository.
``requirement`` predefined set of requirements.
(incompatible with ``createopts``)
The following keys for ``createopts`` are recognized:
backend
The storage backend to use.
lfs
Repository will be created with ``lfs`` requirement. The lfs extension
will automatically be loaded when the repository is accessed.
narrowfiles
Set up repository to support narrow file storage.
sharedrepo
Repository object from which storage should be shared.
sharedrelative
Boolean indicating if the path to the shared repo should be
stored as relative. By default, the pointer to the "parent" repo
is stored as an absolute path.
shareditems
Set of items to share to the new repository (in addition to storage).
shallowfilestore
Indicates that storage for files should be shallow (not all ancestor
revisions are known).
Ns/ cannot specify both createopts and requirementsr� s- filterknowncreateopts() did not return a dictsB unable to create repository because of unknown creation option: %sr s# is a required extension not loaded?r Tr� r� s repository %s already existsr
r s cannot calculate relative path)Z
notindexedr
r r ri s9 �� dummy changelog to prevent using the old repo layoutr r� r r� s shared)&r rz r r r3 r r� r r_ r4 r r
r� r6 r� r� r� rp r� r^ �relpathr� r5 r� r� r r; r� �makedirsZmakedir�mkdirr� rS rq r. ZfilterrequirementsZ
writerequiresr� )r� r^ r� r* rx Z unknownoptsr r� r� r� Z has_storeZwcreqZstorereqr r6 rN rN rO r� � sx
�� ��
�
�
r� c C s* | � � G dd� dt�}t�| d|� dS )z9Poison a repository instance so it can no longer be used.c @ s e Zd Zdd� Zdd� ZdS )z,poisonrepository.<locals>.poisonedrepositoryc S s" |dkrt �| |�S t�d��d S )Nr� s/ repo instances should not be used after unshare)r� �__getattribute__r rz )rH �itemrN rN rO r N s
�z=poisonrepository.<locals>.poisonedrepository.__getattribute__c S s d S rA rN rk rN rN rO r� V s z2poisonrepository.<locals>.poisonedrepository.closeN)rR rS rT r r� rN rN rN rO �poisonedrepositoryM s r rM N)r� r� r� )rI r rN rN rO �poisonrepositoryC s r )N)N)NN)N)NN)�Z
__future__r r� r� r� r� r� r� r� Zi18nr 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 r� r r! r" r# r$ r% r& r( r) r* r� r+ r, r- r. r/ r0 rV r1 r2 r! r3 r4 r5 r6 r� r7 Z
interfacesr8 Z
interfaceutilZutilsr9 r: r; r< Z revlogutilsr= r� r> rn r? r� r� Zurlerrr� rP rZ Z filecacher@ rW rd rg ru rx r Z
propertycacher� r� r� r� r� �unionr� Z implementerZipeercommandexecutorr� r� Z
ipeercommandsr� r� Zipeerlegacycommandsr� rH r� r� r9 r% r& r' r( r) r* r, r^ rz Zilocalrepositoryfilestorager{ r� r� Zilocalrepositorymainr2 rF r� r\ r� r� r r r r
r r� r rN rN rN rO �<module> s� �/
-
%
:
* ' %
�
J
+
~