|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/mercurial/__pycache__/ |
Upload File : |
o
�]Lb�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.�Zwdbd/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�dcdPdQ�Z�dRdS� Z�dbdTdU�Z�dVdW� Z�dXdY� Z�dZd[� Z�d\d]� Z�dcd^d_�Z�d`da� Z�dS )d� )�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 ty Y nw tt| ��||�S �N)�
unfiltered�__dict__�sname�KeyError�superr@ �__get__��self�repo�type�unfi�� __class__� �5/usr/lib/python3/dist-packages/mercurial/localrepo.pyrG m s �z_basefilecache.__get__c s t t| ��|�� |�S rA )rF r@ �setrB )rI rJ �valuerM rO rP rQ x s z_basefilecache.setrA )�__name__�
__module__� __qualname__�__doc__rG rQ �
__classcell__rO rO rM rP r@ j s r@ c �( e Zd ZdZ� fdd�Zdd� Z� ZS )�
repofilecachez3filecache for files in .hg but outside of .hg/storec �, t t| �j|� |D ] }t�|df� q
d S )N� plain)rF rY �__init__� _cachedfiles�add�rI �paths�pathrM rO rP r\ � �zrepofilecache.__init__c C s |j �|�S rA )r6 �join�rI �obj�fnamerO rO rP rc � � zrepofilecache.join�rS rT rU rV r\ rc rW rO rO rM rP rY | � rY c rX )�
storecachez filecache for files in the storec rZ )N� )rF rj r\ r] r^ r_ rM rO rP r\ � rb zstorecache.__init__c C s
|� |�S rA )�sjoinrd rO rO rP rc � �
zstorecache.joinrh rO rO rM rP rj � ri rj c rX )�changelogcachezfilecache for the changelogc �& t t| ��� t�d� t�d� d S )N��
00changelog.irk )�
00changelog.nrk )rF rn r\ r] r^ �rI rM rO rP r\ � �
zchangelogcache.__init__c C �6 | � |d�g}|jjj�dd�r|�| � |d�� |S )Nrq � persistent-nodemapFrr �rc r0 �opener�options�get�append�rI re r` rO rO rP �
tracked_paths� � z changelogcache.tracked_paths�rS rT rU rV r\ r} rW rO rO rM rP rn � ri rn c rX )�manifestlogcachez filecache for the manifestlogc ro )N)� 00manifest.irk )� 00manifest.nrk )rF r� r\ r] r^ rs rM rO rP r\ � rt zmanifestlogcache.__init__c C ru )Nr� rv Fr� rw r| rO rO rP r} � r~ z manifestlogcache.tracked_pathsr rO rO rM rP r� � ri r� c rX )�mixedrepostorecachez2filecache for a mix files in .hg/store and outsidec s t t| �j|� t�|� d S rA )rF r� r\ r] �update)rI �pathsandlocationsrM rO rP r\ � s z mixedrepostorecache.__init__c C s< |\}}|dkr|j �|�S |dkrt�d| ��|�|�S )Nr[ rk s unexpected location: %s)r6 rc r �ProgrammingErrorrl )rI re �fnameandlocationrf �locationrO rO rP rc � s �
zmixedrepostorecache.joinrh rO rO rM rP r� � s r� c C s$ | � � j�|d�}|s
dS |jdfS )z{check if a repo has already cached "name" filecache-ed property
This returns (cachedobj-or-None, iscached) tuple.
N�NFT)rB �
_filecacherz re )rJ �name�
cacheentryrO rO rP � isfilecached� s
r� c s" e Zd ZdZd� fdd� Z� ZS )�unfilteredpropertycachez0propertycache that apply to unfiltered repo onlyNc s, |� � }||u rtt| ��|�S t|| j�S rA )rB rF r� rG r r� rH rM rO rP rG � s z unfilteredpropertycache.__get__rA )rS rT rU rV rG rW rO rO rM rP r� � s r� c @ � e Zd ZdZdd� ZdS )�filteredpropertycachez1propertycache that must take filtering in accountc C s t �|| j|� d S rA )�object� __setattr__r� )rI re rR rO rO rP �
cachevalue� � z filteredpropertycache.cachevalueN)rS rT rU rV r� rO rO rO rP r� � s r� c C s |t | �� �v S )z?check if a repo has an unfilteredpropertycache value for <name>)�varsrB )rJ r� rO rO rP �hasunfilteredcache� � 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 )rJ �args�kwargs��origrO rP �wrapper� s z!unfilteredmethod.<locals>.wrapper)� functools�wraps)r� r� rO r� rP �unfilteredmethod� s r� > � known� lookup� unbundle� branchmap� getbundle� pushkeys 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)rI �peerrO rO rP r\ � s
z localcommandexecutor.__init__c C � | S rA rO rs rO rO rP � __enter__ � z localcommandexecutor.__enter__c C � | � � d S rA )�close)rI �exctype�excvalue�exctbrO rO rP �__exit__ rg z localcommandexecutor.__exit__c C s� | j rt�d��| jrt�d��t| jt�|��}tj� � }z |di t�
|���}W n t y@ t� |t
�� dd � � Y |S w |�|� |S )Ns1 callcommand() cannot be used after sendcommands()s* callcommand() cannot be used after close()r rO )r� r r� r� r r� r' �sysstr�futures�Future� strkwargs� Exception�future_set_exception_info�sys�exc_info�
set_result)rI �commandr� �fn�f�resultrO rO rP � callcommand
s$ ��
�
z localcommandexecutor.callcommandc C �
d| _ d S �NT)r� rs rO rO rP � sendcommands$ rm z!localcommandexecutor.sendcommandsc C r� r� )r� rs rO rO rP r� ' rm zlocalcommandexecutor.closeN) rS rT rU r\ r� r� r� r� r� rO rO rO rP 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 rt�� }|�d�| _|j| _|jr(t �
|�}|� d| � |� |�| _
d S )N� serveds exp-wanted-sidedata=)rF r� r\ �
moderncaps�copy�filtered�_repo�ui�_wanted_sidedatar � format_remote_wanted_sidedatar^ �_restrictcapabilities�_caps)rI rJ �caps� formattedrM rO rP r\ / s
zlocalpeer.__init__c C �
| j �� S rA )r� �urlrs rO rO rP r� ? rm z
localpeer.urlc C � | j S rA )r� rs rO rO rP �localB � zlocalpeer.localc C r� rA rO rs rO rO rP r� E r� zlocalpeer.peerc C � dS r� rO rs rO rO rP �canpushH r� zlocalpeer.canpushc C s | j �� d S rA )r� r� rs rO rO rP r� K � zlocalpeer.closec C r� rA )r� r
rs rO rO rP r
R rm zlocalpeer.branchmapc C r� rA )r� rs rO rO rP � capabilitiesU r� zlocalpeer.capabilitiesc C s | j �tj�S rA )r� �tryreadr �CB_MANIFEST_FILErs rO rO rP � clonebundlesX r� zlocalpeer.clonebundlesc C �$ d||t �|�t �|�t �|�f S )z+Used to test argument passing over the wire� %s %s %s %s %s�r' �bytestr�rI �one�two�three�four�fiverO rO rP �
debugwireargs[ � �zlocalpeer.debugwireargsc K sT t j| j|f||||d�|��d }t�|�}t �|�r#t�| j|�S t �d|d �S )N)�heads�common�
bundlecaps�remote_sidedatar � 01)
r �getbundlechunksr� r5 � chunkbuffer�bundle2requestedr � getunbundlerr� r ) rI �sourcer� r� r� r� r� �chunks�cbrO rO rP � getbundlee s" ����
zlocalpeer.getbundlec C r� rA )r� r� rs rO rO rP r� � rm zlocalpeer.headsc C � | j �|�S rA )r� �known�rI �nodesrO rO rP r� � rg zlocalpeer.knownc C r� rA )r� �listkeys)rI � namespacerO rO rP r� � rg zlocalpeer.listkeysc C r� rA )r� �lookup�rI �keyrO rO rP r� � rg zlocalpeer.lookupc C s | j �||||�S rA )r� r& )rI r� r� �old�newrO rO rP r& � � zlocalpeer.pushkeyc C s t �td���)Ns. cannot perform stream clone against local peer)r �Abortr rs rO rO rP �
stream_out� r� zlocalpeer.stream_outc
C s� zfz*t �| j|d�}t �| j||d|�}t�|d�r(t�|�� �}t �
| j|�}|W W S t yf } z/t |dd�}|rat �
| jj�}|D ]} |�| � qDt�|�� �}t �
| j|�}
t �| j|
� � d}~ww tjy~ } z t�td�t�|���d}~ww )zPapply a bundle on a repo
This function handles the repo locking itself.Ns pushs getchunks�_bundle2salvagedoutputrO s push failed:)r �
readbundler� �unbundler� r5 � safehasattrr� � getchunksr r� r� r �bundle20�addpart�
processbundler � PushRaced�
ResponseErrorr r; � forcebytestr) rI �bundler� r� �ret�stream�exc�output�bundler�out�brO rO rP r � s4 �����zlocalpeer.unbundlec C � t | �S rA )r� rs rO rO rP �commandexecutor� � zlocalpeer.commandexecutorrA �NNN)NNNN)rS rT rU rV r\ r� r� r� r� r� r
r� r� r� r� r� r� r� r� r& r r r rW rO rO rM rP r� + s2
� )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� )rF r r\ �
legacycaps)rI rJ rM rO rP r\ � � zlocallegacypeer.__init__c C r� rA )r� �between)rI �pairsrO rO rP r � rg zlocallegacypeer.betweenc C r� rA )r� �branchesr� rO rO rP r! � rg zlocallegacypeer.branchesc C s* t j| j|| j�� d�}t�| j|d|�S �N)� missingroots� ancestorsofr� )r �outgoingr� r� r �makechangegroup)rI r� r� r% rO rO rP r � s �zlocallegacypeer.changegroupc C s$ t j| j||d�}t�| j|d|�S r" )r r% r� r r& )rI �basesr� r� r% rO rO rP �changegroupsubset� s �z!locallegacypeer.changegroupsubset)
rS rT rU rV r\ r r! r r( rW rO rO rM rP r � s r c C sX | � d��d�}tj|v rt�| �|��}tj|dd�}|� � s*t
� 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 �normpathrc �vfsmodr6 �existsr � RepoErrorr �base)�hgvfsr* �
sharedpath� sharedvfsrO rO rP �
_getsharedvfs� s
��r8 c
C sX z t | �d��� �}W |S ty+ } z|r |jtjks � t � }W Y d}~|S d}~ww )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)rQ r, �
splitlines�IOError�errno�ENOENT)r6 � allowmissingr* �erO rO rP �
_readrequires s
���r@ c ! C s< | � � }| j |_ tj|ddd�}|�d�}tj|dd�}d}d}|�� sfz|�� W n2 tyC } z
| jtjkr9� W Y d} ~ n d} ~ w t y\ } zt
� t d�|t
�| �f ��d} ~ ww t
�t d�| ��t|d�}
tj|
v pttj|
v }d} |r�t||
�}t�|�d ��} nt�|�d ��} t d
�} tj|
v r�|r�tjt|d�vr�|�d d �}
|�d d
�}|dv r�ddlm} |�||||
||
� ni|dkr�t
j t d�| d��t
j t d�| | d��|
t| d�O }
nI|�r,t|d�}tj|v �r,|�d d�}|�d d�}
|dv �rddlm} |�||| |
||
� n|dk�r!t
j t d�| d��t
j t d�| | d��t ||||
|��rFt ||||
� t � |� t � |� dd� t � |�D �}t!|�}t"|
|� t#||
� t$� }|�rs|j%}|�d �}|�&t'j(� n|j%}|�d �}|�d �}t)|
|d d � �}|j*|_*|j} t+||
|�| _,tj-|
v �s�tj.|
v �r�|�&t'j/� |�0t'j1� tj|dd�}|j*|_*tj|dd�}|j*|_*g }i }t2D ]+\} } | � |||
||||| | 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��
expandpathr+ � .hg�� 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-allowrG 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 � h | ]\}}|j �qS rO �rS ��.0�n�mrO rO rP � <setcomp>� � z&makelocalrepository.<locals>.<setcomp>� cache� wcachec S s t j| dd�S )NTrD )r1 r6 )r4 rO rO rP �<lambda>� s z%makelocalrepository.<locals>.<lambda>)r� �intentsr* �features�wdirvfsr5 r0 �storevfs� storeoptions�cachevfs� wcachevfs�extensionmodulenames�
extrastate� baseclassess unable to construct type for %ss derivedrepo:%s<%s>� ,)
�baseuir� �origrootrY r5 r* �supportedrequirementsr6 r0 r\ r] rX rW );r� r1 r6 rc �isdir�stat�OSErrorr< r= �
ValueErrorr r r r; r r3 r@ r. �SHARED_REQUIREMENTr/ r8 �SHARESAFE_REQUIREMENT�
configbool�config� rH �downgrade_share_to_non_safe�upgrade_share_to_safe�loadhgrc�
afterhgrcloadr �loadall�
populateui�gathersupportedrequirements� ensurerequirementsrecognized� ensurerequirementscompatiblerQ r4 r^ r8 �REPO_FEATURE_SHARED_STORAGE� makestore�
createmode�resolvestorevfsoptionsry �REVLOGV2_REQUIREMENT�CHANGELOGV2_REQUIREMENT�REPO_FEATURE_SIDE_DATA�discard�REPO_FEATURE_STREAM_CLONE�REPO_INTERFACES�
isinstancerK r� r{ r' r� �sorted�tuple)!rb ra rW r� rY �hgpathr5 �sharedr7 r? r* rZ rK �
mismatch_warn�mismatch_configrH �sourcerequiresr^ rd rX �
storebasepath� cachepath�
wcachepathr0 r\ r] r' r_ �ifacer� �typr� �clsrO rO rP �makelocalrepository s^
�����
�
���� �����
�
�
�����
� � ���r� c C s� t �� sdS d}tj|v r(|r(z| j|�d�|jd� d}W n ty' Y nw z| j|�d�|jd� d}W n ty@ Y nw z| j|�d�|jd� d}W |S ty[ Y |S w )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( �
use_repo_hgrcr. rj �
readconfigrc r4 r; )r� rY r5 r* r7 r rO rO rP rp O s0 � � ��rp c C s^ dgdgdgd�}t |�� �D ] \}}||vrq|D ]}| �d|�s+| jd|ddd� qqd 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
extensionsrk s autoload)r� N)r� �items� hasconfig� setconfig)r� rY r5 r* �autoextensions� requirement�namesr� rO rO rP rq y s
� ���rq c C s� t tj�}dd� t�| �D �}tD ] }|j|v r || |� qtjD ]"}tj| }|�� rC|� � rC|�
d| � |� � dkrC|�
t j
� q!|S )z6Determine the complete set of recognized requirements.c S rL rO rM rN rO rO rP rR � rS z.gathersupportedrequirements.<locals>.<setcomp>� exp-compression-%s� zstd)rQ �localrepository�_basesupportedr �featuresetupfuncsrT r5 � compengines� available� revlogheaderr^ r� r. �REVLOG_COMPRESSION_ZSTD)r� � supported�modulesr� r� �enginerO rO rP rt � s
�
�rt c C sr t � }| D ] }||v r q|r|dd� �� s t�td���|�|� q|r7tjtd�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 informationrJ N)rQ �isalnumr �RequirementErrorr r^ rc r� )r* r� �missingr� rO rO rP ru � s" ����ru c C s& t j|v rtjst�td���dS 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/ �enabledr r3 r )r� r* rO rO rP rv � s
����rv c C sD t j| v r t j| v rt j| v }t�|||�S t�||�S t�||�S )z,Construct a storage object for a repository.)r. �STORE_REQUIREMENT�FNCACHE_REQUIREMENT�DOTENCODE_REQUIREMENT�storemod� fncachestore� encodedstore�
basicstore)r* ra �vfstype� dotencoderO rO rP rx � s
rx c C s� i }t j|v r d|d< | �dd�}|dur||d< t j|v s#t j|v r-|�t| ||�� nd|d< t j|v r<d|d< |S | �d d
�}d }||v rLd |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{ r� � resolverevlogstorevfsoptions�COPIESSDC_REQUIREMENTrl )r� r* rX ry �manifestcachesize�
writecopiesto�copiesextramoderO rO rP rz � s$
�rz c C s� i }i |d< t j|v rd|d< t j|v rd|d< t j|v r!d|d< t j|v r*d|d< | �dd�}|d ur8||d< | �d
d �}||d < | �d
d
�}||d< | �d
d�}d}|r\| �d
d�}|d u rft�| � }||d< ||d< | � dd�} d| kr|| |d< | � dd�}
|
d ur�|
|d< | �dd�} t
| � dd��} | � dd�}
| |d< | |d < |
|d < t j |v }||d < |r�d|d< d }|r�t
j}| �dd |�}|d ur�||d < |D ]}|j}|d �s�|d!�r�|�d"d#�d# |d$< q�| �d
d%�|d&< |d& d u�rd|d& k�rd'k�sn td(�}t�||d& ��| �d
d)�|d*< |d* d u�r?d|d* k�r1d+k�s?n td,�}t�||d* ��t j|v �rId|d-< | �dd.��rTd|d.< t j|v �r�| � d
d/�}|d0v�r�| �d
d/�}td1�}| �|| � | j�s�| �td2�| � |}td3�}td4�}tj�s�|d5k�r�d6| d7 }| �|� | j�s�d8| 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�r d6| d7 }| �|� | j�s d8| d9 }| �|� |d:k�r(tj||d;��| �d
dA��r3d|dB< | �dCd<��r>d|dD< |S )Ez+Resolve opener options specific to revlogs.s flagprocessorsT� revlogv1� revlogv2s changelogv2s generaldeltar� 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
lazydeltabaser� 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)rG � warnrI 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 detailsr� s warning: r* � (s )
rI rJ rv 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� rk r. �
gddeltaconfig� configbytes�floatrl �SPARSEREVLOG_REQUIREMENT� revlogconst� SPARSE_REVLOG_MAX_CHAIN_LENGTH�
startswith�splitr r r �NARROW_REQUIREMENT�NODEMAP_REQUIREMENT�config_default�warn�quietr+ �HAS_FAST_PERSISTENT_NODEMAP�DIRSTATE_V2_REQUIREMENTr �HAS_FAST_DIRSTATE_V2)r� r* rX ry �chunkcachesize�deltabothparents� issue6528� lazydelta�
lazydeltabase� chainspan�mmapindexthreshold�withsparseread�srdensitythres� srmingapsize� sparserevlog� maxchainlen�r�prefix�msg� slow_path�defaultrK rO rO rP r� s
� �
�
� �
����
��
r� c K � t S )z6Produce a type conforming to ``ilocalrepositorymain``.)r� )r� rO rO rP �makemain� s r� c @ r� )�revlogfilestoragez File storage when using revlogs.c C s$ |� d�r |dd � }t�| j|�S �N� /r )r� r �svfs�rI ra rO rO rP �file� s
zrevlogfilestorage.fileN�rS rT rU rV r� rO rO rO rP r� � � r� c @ r� )�revlognarrowfilestoragez1File storage when using revlogs and narrow files.c C s( |� d�r |dd � }t�| j|| j�S r� )r� r �
narrowfilelogr� �_storenarrowmatchr� rO rO rP r� � s
z revlognarrowfilestorage.fileNr� rO rO rO rP r� � r� r� c K s* |� tj� |� tj� tj| v rtS tS )z=Produce a type conforming to ``ilocalrepositoryfilestorage``.)r^ r8 � REPO_FEATURE_REVLOG_FILE_STORAGEr r. r� r� r� )r* rX r� rO rO rP �makefilestorage� s
r c C r� rA )r� rO rO rO rP rV � � rV c C r� rA )r rO rO rO rP rV � r c @ s� e Zd ZdZejejejejej ej
ej ej ej
ejejejejejejejejejejhZh d�Z d�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�� Znd�d�d��Zod�d�� Zpd�d�� Zqe@d�d�� �Zrd�d�� Zsd�d�d��Zte@d�d�� �Zud�d�� Zve@d�d�d���Zwd�d�� Zxd�d�� Zyd�d�� Zzd�d�d��Z{d�d�� Z|e@d�d�� �Z}d�d�� Z~d�d�� Zd�d�dÄZ�d�d�dńZ�d�dDŽ Z�d�dɄ Z�d�d˄ Z�e@ � > d�d�d΄�Z�e@d�d�dЄ�Z�e@d�d҄ �Z�e@d�dԄ �Z� � > > > >d�d�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 ( r� 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.
> � bisect.stater� � cache/� dirstater9 Nc C s� || _ || _|| _|| _|j| _|| _|j| _|| _t | _
| j
j | _ || _ || _
| | _|
| _| | _| | _d| _| j�dd�sE| j�dd�rN| �| jj�| j_g | _t�| j� | jj| _| jj| _| jj| _ | j�dd�st| 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.
Nr� � all-warnings� check-lockss vfsFr� )<rb r� rc �wvfsr4 r� r6 ra r* r �
nodeconstants�nullidr� r6 r0 r\ r] rX �
filternamerk � _getvfsward�audit�_phasedefaultsr �setup�spathr� rc rl r5 r � _getsvfsward�_dirstatevalidatewarnedr
�BranchMapCache�
_branchcaches�_revbranchcache� _filterpats� _datafilters� _transref�_lockref� _wlockrefr� �filteredrevcache�
_postdsstatusr! r� �_sparsesignaturecache�_sparsematchercacher) � extrafilter�_extrafilterid�filecopiesmoder. r� rQ r� �_sidedata_computers� sidedatamod�set_sidedata_spec_for_repo)rI rb r� rc rY r5 r* rd r6 r0 r\ r] rX rW rO rO rP r\ ' sf D
�
�
zlocalrepository.__init__c s t ����d� ��fdd� }|S )zbuild a ward for self.vfsNc s �� |d�}�� }|d u st �|d�rt �|d�sd S |dv r!d S � �|j�r2� t|j�d d � � � �d�rDd}|jj|� dd d
� d }t� fd d
�|D ��rf|�|j �d u rd|jjd� ddd
� |S |�|j
�d u r��j D ]
}� �|�r{ d S qq|jjd� ddd
� |S )N��modes _wlockref� _lockref�N� rs rbr r s2 accessing cache with vfs instead of cachevfs: "%s"� s cache-vfs)�
stacklevelrl )s journal.s undo.s
strip-backup/r c 3 s � | ]}� � |�V qd S rA )r� )rO r� �ra rO rP � <genexpr>� � � z@localrepository._getvfsward.<locals>.checkvfs.<locals>.<genexpr>� write with no lock: "%s"r s write with no wlock: "%s") r5 r r� ra �lenr� � develwarn�any� _currentlockr r �_wlockfreeprefix)ra r% r rJ r� �vfs_path_prefixesr� ��origfunc�rrefrI r+ rP �checkvfs� sF
�
�
��
��z-localrepository._getvfsward.<locals>.checkvfsrA ��weakref�ref)rI r6 r8 rO r5 rP r � s
-zlocalrepository._getvfswardc s t �| ��d� �fdd� }|S )zbuild a ward for self.svfsNc s� � | |d�}�� }|d u st �|d�sd S |dv rd S | �|j�r,| t|j�d d � } |�|j�d u r>|jjd| dd� |S )Nr$ r& r' r r. � )r* ) r5 r r� r6 r/ r2 r r� r0 )ra r% r rJ �r6 r7 rO rP � checksvfs� s �z/localrepository._getsvfsward.<locals>.checksvfsrA r9 )rI r6 r> rO r= rP r � s
z localrepository._getsvfswardc C r� rA )� _writecachesrs rO rO rP r� rg zlocalrepository.closec C s | j r
| j �� d S d S rA )r �writers rO rO rP r? s �z localrepository._writecachesc C s\ | j �dd�r t|�}t�tj| dd��}|�dt�|� � | j �dd�r,|�t j
� |S )Nr� s bundle2-advertises client)�roles bundle2=s narrow) r� rk rQ r �
encodecaps� getrepocapsr^ �urlreq�quoter7 � NARROWCAP)rI r� �capsblobrO rO rP r� s � z%localrepository._restrictcapabilitiesc C s t j| j| jd�S )N)�callback�r$ � pathauditorr� � _checknestedrs rO rO rP �auditor s zlocalrepository.auditorc C s t j| j| jddd�S )NFT)rH �realfs�cachedrI rs rO rO rP � nofsauditor& s �zlocalrepository.nofsauditorc C s� |� | j�sdS |t| j�d d� }t�|�}| d }t�|�}|rKd�|�}||jv rE||kr3dS |�|�}|� |t|�d d� �S |�
� |s#dS )z/Determine if path is a legal nested repository.Fr Nr� T) r� r� r/ r5 �pconvert� splitpathrc �substate�sub� checknested�pop)rI ra �subpath� normsubpath�ctx�partsr� rS rO rO rP rK . s
�
z localrepository._checknestedc C r rA )r� rs rO rO rP r� T r zlocalrepository.peerc C r� )zaReturn unfiltered version of the repository
Intended to be overwritten by filtered repo.rO rs rO rO rP rB W s zlocalrepository.unfilteredc C s< | j durd|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) �newtyperB rN )rI r� �visibilityexceptionsr� rO rO rP r� ] s zlocalrepository.filtered)� bookmarksr[ )s bookmarks.currentr[ )r] rk rp c C s | � � t�| �S rA )�_refreshchangelogr �bmstorers rO rO rP �
_bookmarkso s 7
zlocalrepository._bookmarksc C s( dt | �v r| �� du r| `dS dS dS )z7make sure the in memory changelog match the on-disk one� changelogN)r� �currenttransactionra rs rO rO rP r^ � s �z!localrepository._refreshchangelogc C s | j jS rA )r` �activers rO rO rP �_activebookmark� � z localrepository._activebookmark�
phaserootsrq c C s t �| | j�S rA )r% �
phasecacher
rs rO rO rP � _phasecache� � zlocalrepository._phasecaches obsstorec C s t �| j| �S rA )r# rx r� rs rO rO rP �obsstore� ri zlocalrepository.obsstorec C s, | j �� | jjt�| j�t�| j d�d�S )N� changelog)�concurrencychecker)
r �prefetch_parentsr0 ra r4 �mayhavependingr� �
revlogchecker� get_checkerr� )rJ rO rO rP ra � s
�zlocalrepository.changelogc C s | j �| | j�S rA )r0 � manifestlogr� rs rO rO rP rq � r� zlocalrepository.manifestlogr c C s | � � S rA )�
_makedirstaters rO rO rP r � re 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/ �matcherrO rs rO rP rV � �
z/localrepository._makedirstate.<locals>.<lambda>)�use_tracked_hint)
r. r� �DIRSTATE_TRACKED_HINT_V1r* r r6 r� r� �_dirstatevalidater )rI �
sparsematchfn�v2_req�th�use_dirstate_v2ru rO rs rP rr � s
�z localrepository._makedirstatec C sR z | j �|� |W S tjy( | js#d| _| j�td�t|� � | j Y S w )NTs- warning: ignoring unknown working parent %s!
)
ra �revr � LookupErrorr r� r� r r r �rI �noderO rO rP rw � s ��
�z!localrepository._dirstatevalidatec C s
t �| �S )zdmatcher patterns for this repository's narrowspec
A tuple of (includes, excludes).
)r" �loadrs rO rO rP �
narrowpats� s
zlocalrepository.narrowpatsc C s0 t j| jvr
t�� S | j\}}tj| j||d�S �N)�include�exclude) r. r� r* �matchmod�alwaysr� r" r r� �rI r� r� rO rO rP r� � s
z!localrepository._storenarrowmatchc C s: t j| jvr
t�� S t�| � | j\}}tj| j ||d�S r� )
r. r� r* r� r� r" �checkworkingcopynarrowspecr� r r� r� rO rO rP � _narrowmatch� s
z localrepository._narrowmatchFc C sP |r%|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�files� unionmatcher�intersectmatchers)rI r � includeexact�em�nmrO rO rP � narrowmatch s zlocalrepository.narrowmatchc C s t �| ||� | jdd� d S )NT��clearfilecache)r" �save�
invalidate)rI � newincludes� newexcludesrO rO rP �
setnarrowpats s z localrepository.setnarrowpatsc C s( dt | jjft t | jjf| jt | jfiS )N� null)r r r rs rO rO rP �_quick_access_changeid_null s �z+localrepository._quick_access_changeid_nullc C s� | j �� }| �� j}| j�� D ]=}|| jkrq|j�|�}|d u r"q||f}|||< |||< |� |�D ]}|t
kr:q3|� |�}||f}|||< |||< q3q| j� � }|| jkr]|| |d< |S )N� .)
r� r� rB ra r �parentsr �index�get_rev�
parentrevsr r �p1) rI �quick�clr r| �pairr� rP �p1noderO rO rP �_quick_access_changeid_wc$ s.
�
z)localrepository._quick_access_changeid_wcc C s dt | �v r | jd= d S d S )Nr� )r� rC rs rO rO rP �!_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) �
filter_has_wcr� r� rs rO rO rP �_quick_access_changeidH s z&localrepository._quick_access_changeidc s@ |d u r t �� �S t|t j�r|S t|t�r'� fdd�tj|�t� ��� D �S � j �
|�}|d ur>|\}}t j � ||dd�S |dkrT� j �
� }� j �|�}t � � ||�S z�t|t�rc� j �|�}|}nz|dkru� j�� }� �� j �|�}nht|�� jjkr�z
|}� j �|�}W nU tjy� t|�}� ty� � �� r�|� �� j�� v r�t d�}t� |t |� ��t|�}� w t|�d� jj kr�t |�}� j �|�}nt� d |t�!t"|��f ��t � � ||�W S tj#tjfy� t�$t d
�t�!|� �� t%tf�y t�&t d �t�!|� �� tj'�y t �� � Y S w ) Nc s g | ] }|� j jvr� | �qS rO )ra � filteredrevs)rO �irs rO rP �
<listcomp>] s
�z/localrepository.__getitem__.<locals>.<listcomp>F)�maybe_filtered� tipr� s* working directory has unknown parent '%s'!r� s$ unsupported changeid '%s' of type %ss filtered revision '%s'� unknown revision '%s')(r �
workingctxr� �basectx�slicer' �xrange�indicesr/ r� rz � changectxra �tipr| �intr r r� rB r �nodelenr �FilteredLookupErrorr r} r� r� r r r r r� r� rK �FilteredIndexError�FilteredRepoLookupError�
IndexError�RepoLookupError�WdirUnsupported)rI �changeid� quick_accessr| r r� rO rs rP � __getitem__S sv
�
�������zlocalrepository.__getitem__c C s& z| | W dS t jy Y dS w )z!True if the given changeid existsTF)r r� )rI r� rO rO rP � __contains__� s �z localrepository.__contains__c C r� r� rO rs rO rO rP � __nonzero__� r� zlocalrepository.__nonzero__c C s | � � }t|j�S rA )rB r/ ra )rI rL rO rO rP �__len__� s
zlocalrepository.__len__c C s
t | j�S rA )�iterra rs rO rO rP �__iter__� rm 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- �spectreer, � makematcher)rI �exprr� �treerO rO rP �revs� s
zlocalrepository.revsc g s( � | j |g|�R � D ]}| | V q
dS )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� )rI r� r� r� rO rO rP rQ � s � �zlocalrepository.setc C s� |dgkr t �tg�S |dgkr"| j�d�}|dur"t �|d g�S |r5t j| j|t �| �|d�}|| �S t 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, �basesetr r� rz �matchanyr� �lookupfn)rI �specs�userr� �
quick_datarQ rO rO rP �anyrevs� s
��zlocalrepository.anyrevsc C s
d| j S )Ns file:r� rs rO rO rP r� � rm 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� )rI r� �throwr� rO rO rP 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�tagslistrs rO rO rP r\ s z6localrepository._tagscache.<locals>.tagscache.__init__N)rS rT rU r\ rO rO rO rP � tagscache� s r� )r� � _findtagsr2 r� )rI r� �cacherO rO rP �
_tagscache� s zlocalrepository._tagscachec
C sn i }| j jr
| �� \}}n| jj}| j j}t�|�D ]\}}z
||� |||< W q tj t
fy4 Y qw |S )z return a mapping of tag to node) ra r� r� r� r2 r| r' � iteritemsr r} rh )rI �tr2 �ttr| �k�vrO rO rP r2 s �zlocalrepository.tagsc C s� t �| j| �}dd� |D �}t �| j| ||� i }t�|�D ]\}\}}|| jkr0||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 globalrO )rO �tagrO rO rP �
<dictcomp>1 s z-localrepository._findtags.<locals>.<dictcomp>r� c S s i | ]
\}}t �|�|�qS rO )r �tolocal)rO r� rR rO rO rP r� > s
��) �tagsmod�findglobaltagsr� �
readlocaltagsr' r� r r r� ra r� )rI �alltagsr� r2 r� r �histrO rO rP 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� rz )rI �tagnamerO rO rP �tagtypeD s zlocalrepository.tagtypec C sZ | j js)g }t�| �� �D ]\}}|�| j�|�||f� q
dd� t|�D �| j _| j jS )z)return a list of tags ordered by revisionc S s g | ] \}}}||f�qS rO rO )rO r� r� rP rO rO rP r� U s z,localrepository.tagslist.<locals>.<listcomp>) r� r� r' r� r2 r{ ra r| r� )rI �lr� rP rO rO rP r� O s zlocalrepository.tagslistc C sf | j js+i }t�| j j�D ]
\}}|�|g ��|� q
t�|�D ]}|�� q || j _| j j� |g �S )z&return the tags associated with a node)
r� r� r' r� r2 �
setdefaultr{ �
itervalues�sortrz )rI r r� r� rP r2 rO rO rP �nodetagsY s
zlocalrepository.nodetagsc C r� )z;return the list of bookmarks pointing to the specified node)r` r� r~ rO rO rP �
nodebookmarksd � z localrepository.nodebookmarksc C s
| j | S )zkreturns a dictionary {branch: [branchheads]} with branchheads
ordered by increasing revision number)r rs rO rO rP r
h s
zlocalrepository.branchmapc C s | j s t�| �� �| _ | j S rA )r r
�revbranchcacherB rs rO rO rP r� m s z localrepository.revbranchcachec C s | � � �||� d S rA )r� �setdata)rI r| �changelogrevisionrO rO rP �register_changesets r� z"localrepository.register_changesetc C s> z| � � �|�W S ty |st�td�| �� Y dS w )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
� branchtiprE r r� r )rI �branch�
ignoremissingrO rO rP r� v s �zlocalrepository.branchtipc C s. t �| |��� }|d u rt�td�| ��|S )Nr� )r. � revsymbolr r r� r )rI r� r rO rO rP r� � s zlocalrepository.lookupc C s" | � � �|�r |S t�| |��� S rA )r
� hasbranchr. r� r� r� rO rO rP � lookupbranch� s z localrepository.lookupbranchc C sJ | j }|jj}|j}g }|D ]}||�}|d u p||v }|�|� q|S rA )ra r� r� r� r{ ) rI r� r� r� r� r� rP r� �resprO rO rP r� � s zlocalrepository.knownc C r� rA rO rs rO rO rP r� � r� zlocalrepository.localc C s | j jdddd�S )N� phasess publishT)� untrusted)r� rk rs rO rO rP �
publishing� s zlocalrepository.publishingc C s( | � � sdS | �� s dS | �d�jj S )NFT� visible)r� r� r� ra r� rs rO rO rP �cancopy� s
zlocalrepository.cancopyc C s | j | jkrdS dS )z2the type of shared repository (None if not shared)rF N)r6 ra rs rO rO rP r� � s zlocalrepository.sharedc G s | j j| j|g|�R � S rA )r6 �reljoinr� )rI r� �insidefrO rO rP �wjoin� r zlocalrepository.wjoinc C s* |d u r| j }| d �||� | �� d S rA )r �
setparentsr� )rI r� �p2rO rO rP r � 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)rI ra r� �fileidr� rO rO rP r � s
�zlocalrepository.filectxc C r� rA )r �getcwdrs rO rO rP r � rm zlocalrepository.getcwdc C s | j �||�S rA )r �pathto)rI r� �cwdrO rO rP r � r� zlocalrepository.pathtoc C s� || j vrmg }| j�|�D ]Z\}}|dkrq
t�| jd|g�}d }|}t�| j�D ]\}} |� |�r@| }|t
|�d � � � } nq)|sJdd� }d|_ t�
|�d s_|}
|
fdd�}d|
j |_ |�|||f� q
|| j |< | j | S ) N� !rk c [ s t �| |�S rA )r: �filter)�s�cr� rO rO rP rV � � z-localrepository._loadfilter.<locals>.<lambda>�
commandfilterr� c [ s
|| |�S rA rO )r
r �oldfnr� rO rO rP rV � rt zcompat-)r r� � configitemsr� r r� r' r� r r� r/ �lstriprS �
getargspecr{ ) rI r r� �pat�cmd�mfr� �paramsr� �filterfnr rO rO rP � _loadfilter� s0
�
zlocalrepository._loadfilterc C sV |D ]&\}}}||�r(| j �d||pt�|j�f � |||| j | |d�} |S q|S )Ns filtering %s through %s
)r� rJ �filename)r� �debugr' �sysbytesrS )rI �
filterpatsr �datar r� r rO rO rP �_filter� s ���zlocalrepository._filterc C �
| � d�S )Ns encode�r rs rO rO rP �_encodefilterpats� �
z!localrepository._encodefilterpatsc C r! )Ns decoder" rs rO rO rP �_decodefilterpats� r$ z!localrepository._decodefilterpatsc C s || j |< d S rA )r )rI r� r rO rO rP �
adddatafilter� r� z localrepository.adddatafilterc C s6 | j �|�r
| j �|�}n| j �|�}| �| j||�S rA )r �islink�readlinkr, r r# �rI r r rO rO rP �wread� s zlocalrepository.wreadc K s� | � | j||�}d|v r| j�||� t|�S | jj||fd|i|�� d|v r4| j�|dd� t|�S | j�|dd� t|�S )z�write ``data`` into ``filename`` in the working directory
This returns length of written (maybe decoded) data.
� l�backgroundclose� xFT)r r% r �symlinkr@ �setflagsr/ )rI r r �flagsr, r� rO rO rP �wwrite s �����zlocalrepository.wwritec C s | � | j||�S rA )r r% r) rO rO rP �
wwritedata s zlocalrepository.wwritedatac C s( | j r| � � }nd}|r|�� r|S dS )z4return the current transaction or None if non existsN)r �running)rI �trrO rO rP rb s
z"localrepository.currenttransactionc
sL �j �dd�s�j �dd�r���j�d u rt�d����� ��d ur)�j� d�S �j� d�r:tj
t d�t d�d ��d
t � � t
�
� f }tt�|��� �}d | }�jd d
� |d� ��� � dd� ��� D �}|rm|}n�j j}�j�jd�}t����dd� ��j �dd�} � dkr�| r��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 )/Nr� r r s transaction requires locking)r� � journals abandoned transaction founds( run 'hg recover' to clean up transactionrJ s %.40f#%fs TXN:s
pretxnopenT)r� �txnname�txnidc S s g | ] \}}||t |�f�qS rO ��undoname�rO r6 �xrO rO rP r� 9 � z/localrepository.transaction.<locals>.<listcomp>)r[ rF c S � d S rA rO )r; rO rO rP rV b r z-localrepository.transaction.<locals>.<lambda>r� s hook-track-tags� stripc s� �� }|d us J �t �|j|� �}|j�� }t �|j||�}t �|j|||�}|rOd| jd< |jdddd��}t �||� W d � d S 1 sHw Y d S d S )N� 1s tag_moveds changes/tags.changes� wT)�
atomictemp) r� � fnoderevsr� ra �headrevs�difftags�hookargsr6 � writediff)�tr2rJ � oldfnodes�newheads� newfnodes�changes� changesfile)�oldheads�reporefrO rP � tracktagsj s
�"��z.localrepository.transaction.<locals>.tracktagsc s~ �| � �� }|dus
J �d}|j j|� }|r9|j j|� d }|�dd�}|�dd�r.d}nd}t�|| � ||� t�|j d �rmt�j d
�
� �D ]#\}\}} �j � � }
|
�
t�||| �� |j dd d it�|
��� qIt�|j d
�r�|�� j} �j d D ]/\} \}} | D ]&}
�j � � }
t| �|
��}|
�
t�||| �� |j
dd d it�|
��� q�q~|j dd d it��j ��� dS )zwill run pre-closing hooksN)r� s single-head-per-branchr s account-closed-headsFs public-changes-onlys immutabler� � pretxnclose-bookmarkr] r� T� pretxnclose-phaser� � pretxnclose)rP )rQ )rR )r� rk �configsuboptionsrz r. �enforcesingleheadr �hashookr� rK r� rE r� r� r �preparehookargsr' r� rB ra r r r% )rG rJ �
singleheadopt�
singlehead�
singleheadsub�
accountclosedr
r� r r r� r� r� r| r )�descrN r4 rO rO rP �validate} sf �
� �
���
����
��
�z-localrepository.transaction.<locals>.validatec s\ � � }|d u r d S |r|j �d � d S t��d� t��d� |j �d d� |jdd� d S )N� journal.narrowspec� journal.narrowspec.dirstate� journal.dirstateTr� )r r@ r" �
restorebackup�restorewcbackupr� )r4 �successrJ )rN rI rO rP � releasefn� s z.localrepository.transaction.<locals>.releasefn� undo)� validatorrc �checkambigfilesr� � origrepolens
obsmarkersr� r] s txnids txnnames changess
flush-fncachec s6 | j � � ��fdd�}�� }|dusJ �|�|� dS )z@To be run if transaction is successful, will schedule a hook runc s0 �� }|d us J �t �|jd�r?t�jd �� �}|D ]#\}\}}�j�� }|�t �
|||�� |j d ddit � |��� qt �|jd�r�|�
� j}t�jd dd� d �}|D ]/\} \}}| D ]&}
�j�� }t|�|
��} |�t�
| ||�� |j d ddit � |��� q`qX|j
d
ddit � � ��� d S )N� txnclose-bookmarkr] r� F� txnclose-phaser� c S s | d d S )Nr rO )r� rO rO rP rV
r zUlocalrepository.transaction.<locals>.txnclosehook.<locals>.hookfunc.<locals>.<lambda>)r� � txnclose)rh )ri )rj )r rU r� r� rK r� rE r� r� r rV r' r� rB ra r r r% ) �unused_successrJ � bmchangesr� r r r� r� �phasemvr� r| r )rE rN r4 rO rP �hookfunc� sN
���
�
����
��
�zClocalrepository.transaction.<locals>.txnclosehook.<locals>.hookfuncN)rE �
_afterlock)rG rn rJ )rN r4 )rE rP � txnclosehook� s
# z1localrepository.transaction.<locals>.txnclosehooks
txnclose-hooks -warm-cachec s4 � � }|dus J �|j dddit�| j��� dS )z#To be run if transaction is abortedN� txnabortr� F)rq )r r' r� rE )rG rJ �rN rO rP � txnaborthook%
s ��
�z1localrepository.transaction.<locals>.txnaborthooks
txnabort-hooks refresh-filecachestats)-r� rk r2 r r r� rb �nestr� r2 r3 r �random�timer r9 �sha1�digestr �
_writejournal�
_journalfilesr� r6 r: r; ra rC r3 �
aftertransr0 ry r] r/ rK rQ rE � addfinalizer@ � addpostclose�_buildcacheupdater�addabort�_refreshfilecachestatsr r. �registersummarycallback)rI r[ �report�idbase�har7 �renames�rp�vfsmap�shouldtracktagsr\ rc rp rs rO )r[ rM rN rI r4 rO rP r3 " s~ �
�
"�
@�
/ zlocalrepository.transactionc C sH | j df| j df| jdf| jdf| jdf| jdft�| �df| j dffS ) Nr5 r] r^ r_ � journal.branch� journal.desc� journal.bookmarks� journal.phaseroots)r� r6 r � bookmarksvfsrs rO rO rP rz 5
s �z localrepository._journalfilesc C s dd� | � � D �S )Nc S s g | ]
\}}|t |�f�qS rO r8 r: rO rO rP r� B
s z-localrepository.undofiles.<locals>.<listcomp>)rz rs rO rO rP � undofilesA
r 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 ) Nr_ r^ r] r� r� s %d
%s
r� r] r� rf )r �
savebackupr" � savewcbackupr6 r@ r � fromlocalr� r/ r r� r� r� )rI r[ r� rO rO rP ry D
s �
�z localrepository._writejournalc C s� | � � �A | j�d�r4| j�td�� | j| jd�}tj| j|d| jj t
d� | � � W d � dS | j� td�� W d � dS 1 sHw Y d S )Nr5 s% rolling back interrupted transaction
)rk r[ �rf Ts% no interrupted transaction available
F) r r� r2 r� �statusr r6 r3 �rollbackr� r] r� )rI r� rO rO rP �recoverS
s&
���$�zlocalrepository.recoverc
C s� d } }}z3| � � }| �� }| j�d�r)t�| d�}| �|||�W t|||� S | j�t d�� W t|||� dS t|||� w )Nrd s rollbacks" no rollback information available
r )
�wlockr r� r2 r � _rollback�releaser� r� r )rI �dryrun�forcer� r �dsguardrO rO rP r� h
s � zlocalrepository.rollbackc sp | j }z=| j�d��� }t|d �|d d }}}t|�dkr$|d }|d } |r7|jr7td�| ||f }
ntd�| |f }
W n tyO td�}
d }Y nw |si| d | d
kri|d krit j
td �td
�d��|� |
� |rrdS | j �
� } | �� | j| jd�} tj| j| d|jtd� t�| �}
|
�d�r�|
jdddd� | j�d�r�| jjdddd� | �� | jjj� t � fdd�| D ��}|�r2|� � t � | d� t � | d� | j � d d � z| j�d �}| j �!t"�#|�� W n t�y |�td �| j �$� � Y nw t%d d � | d �
� D ��} t| �dk�r#|� td!�| � n |� td"�| � t&j'�(| � | �)� dS )#Ns undo.descr r r) r� 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 forcerJ )r[ rk rd r� s undo.bookmarksr] T)�
checkambigs undo.phaserootsrf c 3 s � | ]}� |� V qd S rA rO �rO �p��has_noderO rP r, �
r- 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 rO )r| r� rO rO rP r� �
� 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� r� r] r r� r2 �renamer� ra r� r� r1 r� r" r` ra � setbranchr r� r� r� �
mergestatemodr �clean� destroyed)rI r� r� r� r� r� �oldlenr[ �detail�oldtipr� r� r� r� �
parentgoner� rO r� rP 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 us J �|� | � d S rA )� updatecaches)r4 rJ rr rO rP �updater�
s z3localrepository._buildcacheupdater.<locals>.updaterr9 )rI �newtransactionr� rO rr rP r~ �
s
z"localrepository._buildcacheupdaterc C s� |dur|j �d�dkrdS | �� }|r+d}| j�|d� tj}|dkr'tj}tj}n|du r2tj}tj |v r^|du sD|j
d t | �k r^| j� d� | �
d ��� | �
d
��� | j�| � tj|v rj| jj|d � tj|v rv| jj|d � tj|v r�|�� }|jD ]}|�|� q�|�� tj|v r�| d �� D ]}|� � q�tj |v r�t � | j||j� � � tj!|v r�| �"� tj#|v r�| �
d ��"� tj$|v r�t%j&�'� D ]} | �
| �}
|
�� �|
� q�dS 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-clonerg s updating the branch cache
r� s
served.hidden)r3 r� )(rE rz rB r� �
deprecwarnr8 �
CACHES_ALL�CACHES_POST_CLONE�CACHES_DEFAULT�CACHE_BRANCHMAP_SERVEDrK r/ r r� r
r �
write_delayed�CACHE_CHANGELOG_CACHEra �
update_caches�CACHE_MANIFESTLOG_CACHErq �CACHE_REV_BRANCHr� �
branchinfor@ �CACHE_FULL_MANIFESTr� �manifest�CACHE_FILE_NODE_TAGSr� rB r� �CACHE_TAGS_DEFAULTr2 �CACHE_TAGS_SERVED�CACHE_BRANCHMAP_ALLr) � filtertable�keys) rI r4 �full�cachesrL r� �rbcr� rX �filtr� rO rO rP r� �
sV �
�z localrepository.updatecachesc C s4 dt | �v r
| jd= | j�� | �� | j�� d S )Nr� )r� rC r �clear�invalidatevolatilesetsr rs rO rO rP �invalidatecaches7 s
z localrepository.invalidatecachesc C s | j �� t�| � | �� d S rA )r r� r# �clearobscachesr� rs rO rO rP r� A s
z&localrepository.invalidatevolatilesetsc C sP t | d�r&| jjD ]}zt| j|� W q ty Y q w t| �� d� dS 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 )rI r� rO rO rP �invalidatedirstateF s
��z"localrepository.invalidatedirstatec C s� | � � }t| j�� �D ]*}|dkrq |dkr | �� r | jjr q |r%| j|= zt||� W q ty5 Y q w | � � | �� sE| j
� � dS 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 rk N) rB �listr� r� rb ra �_delayedr
r� r� r0 )rI r� rB r� rO rO rP 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� rs rO rO rP �
invalidateall{ s z localrepository.invalidateallc C s> | j �� D ]\}}t�|�}|dks|| jvrq|�� qdS )z>Reload stats of cached files so that they are flagged as validr N)r� r� r' r� rC �refresh)rI r4 r� �cerO rO rP 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)rc � acquirefnr[ �
signalsafe)r� r� rk �lockmod�trylock) rI r6 �lockname�waitrc r� r[ �timeout� warntimeoutr� r� rO rO rP �_lock� s$ � zlocalrepository._lockc C sD | j | jfD ]}|o |� }|r|jr|j�|� dS 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 �held� postreleaser{ )rI rH r; r� rO rO rP ro � 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� rc r� r[ )
r2 r r r� r� r� r rc r: r; )rI r� r� rO rO rP r � s � zlocalrepository.lockc s� � j r� � � nd}|dur|jr|�� |S |r4� j�dd�s&� j�dd�r4� �� j�dur4� 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.Nr� r r s "wlock" acquired after "lock"c s4 � j �� r � j �� n� j �d � � jd �� d S )Nr )r �pendingparentchanger� r@ r� r� rO rs rO rP �unlock� s
z%localrepository.wlock.<locals>.unlocks wlocks working directory of %s)r r� r r� rk r2 r r0 r� r6 r� r rc r: r; )rI r� r� r� rO rs rP r� � s, � � � zlocalrepository.wlockc C s( |du rdS |� }|du s|j sdS |S )z3Returns the lock if it's held, or None if it's not.N)r� )rI �lockrefr� rO rO rP r2 � s z localrepository._currentlockc C s | � | j�S )z4Returns the wlock if it's held, or None if it's not.)r2 r rs rO rO rP � currentwlock� r� z localrepository.currentwlockc C s� |� � s|�� rkt|j|j |j �}|�� D ]U}| j�|�}|dks,||v s,||j v r-q||j
v r9||t d�� | j �
|�sF|�� �|�r^|d }|D ] }|�|�rU nqL||t d�� q|| jvrj||t d�� qdS dS )z2check for commit arguments that aren't committabler� s file not found!r� s no match under directory!s file not tracked!N)�isexactr� rQ �modified�added�removedr� r � normalizerR �deletedr r re r� �hasdirr� ) rI �wctxr r� �fail�matchedr� �dr rO rO rP �checkcommitpatterns s*
��
��z#localrepository.checkcommitpatternsrk c
s( |du ri }dd� }|st �� }|s||_��� ��a ��� ��K �d } t| �� �dk}
|s<|
r<|�� s<t�t d����j
||d�} |rL| j � | j
� tj�j| | ||d�\} }
}|sd��| || |� t��| ||||�}tj���}t�|� |�� r��j�dd �s��j�d
� |� � W d � W d � dS |
r�|� � r�t�t d ���|r�|�|| �|_ ||j k}�� |j �}| r�t �!��}t"|
�D ](}| �#|�}�j�
t d �|t�$|�� � |�%|j ||�}|| d
|f||< q�t�&�|� �j'�� \}}t(|�|�j)k�r
t(|��pd� �z9�j*dd� �d� ��+d�� ��,|d��t-�.�||g�� |�/�� |� � W d � n 1 �sDw Y W n |�rc�j�0t d�| � �j�0t d�� � W d � n 1 �sow Y W d � n 1 �sw 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 ��)Ns %s: %s)r �
InputError)r� r� rO rO rP r� - r 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 rk s precommitT)r� �parent1�parent2r� s! note: commit message saved in %s
sH note: use 'hg commit --logfile .hg/last-message.txt --edit' to reuse it
c s* �j ���r�jdt��� �d� d S d S )Nr� )r r� r� )ra �hasnoder r �rk ��hookp1�hookp2r rI rO rP �
commithook� s
��z*localrepository.commit.<locals>.commithook)2r� r� �badr� r r/ r� r r r r� r� �extendr� r1 � precommitr� r� r �workingcommitctxr� r r, r �checkunresolved�isemptyrk r �resetr� �_text�savecommitmessager. � getuipathfnr� rS �
subrelpathr �
writestater r r r r3 � commitctxr r� �
markcommittedr@ ro )rI �textr� �dater r� �editor�extrar� r� �merger� �subs�
commitsubs�newstate�cctx�ms�edited�msgfn�uipathfnr
rS �srr� r r� rO r� rP r s� ��� � �
� � *
�� $�
��
���� �� \
zlocalrepository.commitc C s t j| |||d�S )N)r �origctx)r r )rI rX r r rO rO rP r � s zlocalrepository.commitctxc C s dt | �v r
| j�� dS 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.
rh N)r� rh r@ rs rO rO rP 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)rh �
filterunknownr@ r� r� rs rO rO rP r� � s
zlocalrepository.destroyedr� c C s | | � ||||||�S )z3a convenience method that calls node1.status(node2))r� )rI �node1�node2r �ignoredr� �unknown� listsubreposrO rO rP 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 r{ )rI �psrO rO rP �addpostdsstatus� s z localrepository.addpostdsstatusc C r� )zAUsed by workingctx to get the list of post-dirstate-status hooks.�r rs rO rO rP � postdsstatus� s z localrepository.postdsstatusc C s | j dd�= dS )z7Used by workingctx to clear post-dirstate-status hooks.Nr rs rO rO rP �clearpostdsstatus� r� z!localrepository.clearpostdsstatusc sJ |d u r| j � t� �� �}� fdd�|D �S | j �|�}t|| j jdd�S )Nc s g | ]}� � |��qS rO )r )rO r| �r� rO rP r�
rS z)localrepository.heads.<locals>.<listcomp>T)r� �reverse)ra �reversedrC r� r� r| )rI �startrC r� rO r rP r�
s zlocalrepository.headsc sv |du r
| d � � }| �� }|�|�sg S tt|j||d���}|dur9t| 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)�closedr� c s g | ]}|� v r|�qS rO rO )rO �h��fbheadsrO rP r�
s z/localrepository.branchheads.<locals>.<listcomp>) r� r
r� r� r" � branchheadsrQ ra � nodesbetween)rI r� r# r$ r! �bheadsrO r& rP r(
s
zlocalrepository.branchheadsc C sv |s| j �� g}g }|D ],}|} | j �|�}|d | jks%|d | jkr3|�|||d |d f� n|d }qq |S )NTr r )ra r� r� r r{ )rI r� r rP r� r� rO rO rP r!
s �zlocalrepository.branchesc
C s� g }|D ]@\}}|g d}}}d}||kr?|| j kr?| j�|�d } ||kr0|�|� |d }| }|d7 }||kr?|| j ks|�|� q|S )Nr r r� )r ra r� r{ )
rI r r� �top�bottomrP r� r� r� r� rO rO rP r .
s
� zlocalrepository.betweenc C r� )z�Extensions can override this function if additional checks have
to be performed before pushing, or call it if they override push
command.
NrO )rI �pushoprO rO rP � checkpushA
r 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 �hooksrs rO rO rP �prepushoutgoinghooksG
s z$localrepository.prepushoutgoinghooksc
s z1�� � }i }|d ur|�|j� t�|�}�|d< � |d< �|d< �|d< �jdddi|�� W n, tjy] } z �j� t
d�| � |j rR�j� t
d �|j � W Y d }~d
S d }~ww �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 rI rO rP �runhookb
s
�z(localrepository.pushkey.<locals>.runhook)r1 )rb r� rE r' r� r r � HookAbortr� � write_errr rK r r& �pushro ) rI r� r� r r r4 rE r r3 rO r2 rP r& N
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� r r& r� )rI r� r7 rO rO rP r� o
s
zlocalrepository.listkeysc C r� )z+used to test argument passing over the wirer� r� r� rO rO rP r� v
r� z localrepository.debugwireargsc C sL | � dd�}z |�|� W |�� n|�� w | �|jt| j�d d � �S )Ns last-message.txts wbr )r6 r@ r� r r� r/ r� )rI r �fprO rO rP r �
s
z!localrepository.savecommitmessagec C s& t j| jvrd S | j�t�|�� d S rA )r8 r} rX r� r^ r' r� )rI �categoryrO rO rP �register_wanted_sidedata�
s z(localrepository.register_wanted_sidedatac C s� |t jvrtd�}t�|| ��t�|�}|| j�|g �v }|r-|s-td�}t�|| ��|r<|s<td�}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'.)
r� � ALL_KINDSr r r� r' r� r! rz r� ) rI �kindr9 r� �computerr0 �replacer� �already_registeredrO rO rP �register_sidedata_computer�
s"
��z*localrepository.register_sidedata_computerrA r� )FN)Fr )FF)NFN)T)rk NNNFNN)r� NNFFFF)NNF)�rS rT rU rV r. � BOOKMARKS_IN_STORE_REQUIREMENTr| r� rv r� r� r� r� �INTERNAL_PHASE_REQUIREMENTr� r/ r� r{ ri rj r� r� r� r� r� r3 r\ r r r� r? r� �propertyrL rO rK r� rB r� r� r` r^ rd rj rh rj rn ra r� rq rY r rr rw r" �FILENAMEr� r� r� r� r� r� r� r� r� r� r� r� r� r� �__bool__r� r� r� rQ r� r� r r� r� r2 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* r1 r2 rb r3 rz r� ry r� r� r� r~ r� r� r� r� r� r� r� r� ro r r� r2 r� r� r r r� r� r� r r r r� r( r! r r. r0 r& r� r� r r: r@ rO rO rO rP r� � s� �
� 3
&
�
4
O
$
\ Q
$
) �
!
�
!
�r� c s dd� | D �� � fdd�}|S )Nc S s g | ]}t |��qS rO )r� )rO r� rO rO rP r� �
r� z aftertrans.<locals>.<listcomp>c s` � D ]+\} }}| � |� z| �||� W q ty- } z
|jtjkr#� W Y d }~qd }~ww d S rA )� tryunlinkr� rg r< r= )r6 �src�destr �� renamefilesrO rP �a�
s
����zaftertrans.<locals>.arO )r� rK rO rI rP r{ �
s r{ c C s6 t j�| �\}}|�d�sJ �t j�||�ddd��S )Nr5 rd r )�osra r� r� rc r> )r� r4 r� rO rO rP r9 �
s r9 c C s* t �|�}|rt| ||d� t| ||d�S )N��
createopts)rW )r< � urllocalpath�createrepositoryr� )r� ra �createrW rN � localpathrO rO rP �instance�
s
rS c C r� r� rO r+ rO rO rP �islocal�
r� rT 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.
� backendr� s new-repo-backend)�dictrl �r� rN rO rO rP �defaultcreateopts�
s rX c C sd t � }|js|S t| |d�}t| |�D ] }|tjv r |�|� q|jD ] }|tjvr/|�|� q#|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
rM )rQ r* rX �newreporequirementsr. �WORKING_DIR_REQUIREMENTSr^ )r� rN �srcrepo�target_requirementsr� rO rO rP �clone_requirements�
s
�
�r] c C sl d|vr t �d��|d dkrt �td�|d ��tjh}| �dd�rB|�tj� | �dd�rB|�tj � | �dd�rB|�tj
� | � dd �}|D ]}|t j
v r`t j
| }|�� r`|�� r` nqJt jtd
�d �d d
� |D �� td�d��|dkr�|�d� n |dkr�|�d| � t�| �r�|�tj� | �dd�r�|�tj� | �dd�r�|�tj� | �dd�r�|�tj� |�tj� | �dd�r�|�tj� | �dd�}|dkr�|�tj� | �dd�}|dkr�|�tj� |�tj� | �dd �r�|�tj � |� d ��r
|�tj � |� d ��r|�d � | �dd ��r"|�tj � | �dd ��r/|�tj � | �dd!��r<|�tj!� d"|v �r�t"|d" j#�}tj!|v�rQ|}n%t"� } |D ]}
|
tj$v �r`�qV|
|v �rg�qV| �|
� �qV|| 8 }||O }|� d#��r�|�tj%� n|�tj&� | �dd$��r�| �'dd%�} td&�} td'�}
| d(k�r�| j(| | |
d� |S |�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.
rU sF backend key not present in createopts; was defaultcreateopts() called?r� sC unable to determine repository requirements for storage backend: %sr� s usestores
usefncaches dotencodes revlog-compressionsI compression engines %s defined by format.revlog-compression not available� , c s s � | ]}d | V qdS )s "%s"NrO )rO r? rO rO rP r, s � z&newreporequirements.<locals>.<genexpr>s; run "hg debuginstall" to list available compression enginesrJ r� s revlog-compression-zstds zlibr� r� s use-dirstate-v2s" exp-use-copies-side-data-changesetr� r� s exp-use-changelog-v2s* enable-unstable-format-and-corrupt-my-datar� 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 r� r r r. r� rk r^ r� r� r� �
configlistr5 r� r� r� rc r. � gdinitconfigr� r� r� r| r� r� rl r~ r{ rB rz r� rA r� rj rQ r* rZ r/ ri r� r� rv )r� rN r* r� �
compenginer� � changelogv2�revlogv2�source_requirements�to_drop�req�versionr� rK rO rO rP rY �
s� � ���
�����
�rY c C s� t � }tj|vrEtj|v r| �td�� |�tj� tj|v s$tj|v r+t �
td���tj |v rE| � 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 disabledr� r` sr ignoring enabled 'format.use-share-safe' config because it is incompatible with disabled 'format.usestore' config
)
rQ r. r� rA r� r r^ ri r/ r r rj r� )r� r* �droppedr� rO rO rP �checkrequirementscompat~ s0
��
��
�
rm 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.
> � shallowfilestorer� rU ra r_ � shareditemsrb c s i | ] \}}|� vr||�qS rO rO )rO r� r� �r� rO rP r� � r< z)filterknowncreateopts.<locals>.<dictcomp>)r� rW rO rp rP �filterknowncreateopts� s
rq c
C s. |dur|durd}t �|��i }n6t| |d�}t| |�}t|t�s't �d��|r;t jtd�d�t |�� td�d��t
| |d�}|t | |�8 }t j
|d d d
�}t �
|�d ��}|�� ret �td �| ��d
|v r�|d
j}|�d�r�ztj�||j�}t�|�}W n ttfy� } z t jtd�t�| �d��d} ~ ww |�� s�|� � |j d d� d
|vr�|� d� |� d� t j |v }
|
r�d
|vr�|� d� |�!dd� t"�#|�\} } t"�$|| � | r�d
|vr�t j
|�d�d d�}
t"�$|
| � d
|v r�|�%d|� |�d��rd�t |d ��d }|�%d|� dS 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 requirementsrM s- filterknowncreateopts() did not return a dictsB unable to create repository because of unknown creation option: %sr^ s# is a required extension not loaded?rJ TrA rC s repository %s already existsra rb s cannot calculate relative path)�
notindexedrT rU rF rq s9 �� dummy changelog to prevent using the old repo layoutrD r) ro r* s shared)&r r� rX rq r� rV r r rc r� rY rm r1 r6 r2 r3 r6 rz rL ra �relpathr4 r5 rP r; rh r; r �makedirs�makedir�mkdirr. r� r{ r. �filterrequirements�
writerequiresr@ )r� ra rN r* r� � unknownoptsrY r5 r6 r? � has_store�wcreq�storereqrZ r� rO rO rP rP � s~
�� ��
���
� �rP 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 |dkr
t �| |�S t�d��)Nr� s/ repo instances should not be used after unshare)r� �__getattribute__r r� )rI �itemrO rO rP r} M s
�z=poisonrepository.<locals>.poisonedrepository.__getattribute__c S r= rA rO rs rO rO rP r� U r� z2poisonrepository.<locals>.poisonedrepository.closeN)rS rT rU r} r� rO rO rO rP �poisonedrepositoryL s r rN N)r� r� r� )rJ r rO rO rP �poisonrepositoryB s r� rA )NN)��
__future__r r< r� rL ru r� rv r: �i18nr r r r r r r r' r
r rm 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 r� r1 r2 r� r3 r4 r5 r6 r1 r7 �
interfacesr8 �
interfaceutil�utilsr9 r: r; r< � revlogutilsr= ro r> r� r? r" r� �urlerrrD rQ r] � filecacher@ rY rj rn r� r� r� �
propertycacher� r� r� r� r� �unionr � implementer�ipeercommandexecutorr� r� �
ipeercommandsr� r� �ipeerlegacycommandsr r� r8 r@ r� rp rq rt ru rv rx rz r� r� �ilocalrepositoryfilestorager� r� r �ilocalrepositorymainr� r� r{ r9 rS rT rX r] rY rm rq rP r� rO rO rO rP �<module> s� �/
-
%
:* ' %
�
I
+
~