HEX
Server: Apache
System: Linux pdx1-shared-a1-38 6.6.104-grsec-jammy+ #3 SMP Tue Sep 16 00:28:11 UTC 2025 x86_64
User: mmickelson (3396398)
PHP: 8.1.31
Disabled: NONE
$ pwd: /usr/lib/python3/dist-packages/mercurial/__pycache__/
Upload Files
File: //usr/lib/python3/dist-packages/mercurial/__pycache__/hg.cpython-310.pyc
o

�]Lb���@s�ddlmZddlZddlZddlZddlZddlZddlZddlm	Z	ddl
mZmZm
Z
ddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZ m!Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z*m+Z+m,Z,m-Z-m.Z/m0Z1ddl2m3Z4dd	l5m6Z6m7Z7m8Z8ej9Z9d
Z:dd�Z;d
d�Z<ee+e;eee'e(d�Z=dd�Z>dd�Z?dVdd�Z@gZA	dWdd�ZB					dXdd�Z3dYdd�ZCdd �ZDd!d"�ZE					dZd#d$�ZFd%d&�ZGd'd(�ZHd[d)d*�ZId[d+d,�ZJd-d.�ZK				d\d/d0�ZLd1d2�ZM										d]d3d4�ZNd^d5d6�ZOd[d7d8�ZPd_d9d:�ZQeQZRd`d;d<�ZSeSZTe jUe jVe jWe jXhZYd_d=d>�ZZ			dad?d@�ZdAdB�Z[		d_dCdD�Z\d[dEdF�Z]d[dGdH�Z^dIdJ�Z_dKdL�Z`d[dMdN�Zad[dOdP�Z.dQdR�ZbgdS�ZcGdTdU�dUed�ZedS)b�)�absolute_importN�)�_)�hex�sha1nodeconstants�short)�getattr)�	bookmarks�
bundlerepo�cmdutil�destutil�	discovery�error�exchange�
extensions�graphmod�httppeer�	localrepo�lock�
logcmdutil�logexchange�merge�
mergestate�
narrowspec�phases�requirements�scmutil�sshpeer�statichttprepo�ui�	unionrepo�url�util�verify�vfs)�
repository)�hashutil�
stringutil�urlutil�	bookmarksc
Cs�t�t�|��}z
t�|�}t�|j�}Wn&tt	fy1}zt
�td�|t
�|�f��d}~wty;d}Ynw|r@tpAtS)Nsinvalid path %s: %sF)r"�
expandpathr(�urllocalpath�os�stat�S_ISREG�st_mode�	TypeError�
ValueErrorr�Abortrr'�forcebytestr�OSErrorr
r)�path�st�isfile�e�r9�./usr/lib/python3/dist-packages/mercurial/hg.py�_localFs
���r;cs|��}|\}}|s |s �pd}�r�d}||fSd}||fS�r't���ng�|�d�sB|r7t�td�����|���dfS|���}|�di��	��Wd�n1sYwY���fdd�}	|D]}
|	|
�swt�
td�|
��qh|r�|	|�s���|���dfS)Nrs	branchmaps"remote branch lookup not supportedcsP|dkr�s
t�td����j��}|�vr&��dd�t�|�D��dSdS)N�.sdirstate branch not accessiblecss�|]}t|�VqdS�N)r)�.0�rr9r9r:�	<genexpr>ys�z1addbranchrevs.<locals>.primary.<locals>.<genexpr>TF)rr2r�dirstate�branch�extend�reversed)rB��	branchmap�lrepo�revsr9r:�primaryss
zaddbranchrevs.<locals>.primarysunknown branch '%s')�peer�list�capablerr2r�append�commandexecutor�callcommand�result�RepoLookupError)rG�other�branchesrHrJ�
hashbranch�x�yr8rIrBr9rEr:�
addbranchrevs[s:�



��
rW)�bundlesunion�fileshttpshttps�sshsstatic-httpcCsVt�|�}|jp	d}t�|�ptd}z||�WSty*t�|d�s&�|YSw)NrYsinstance)r(r!�scheme�schemes�getr0r"�safehasattr)r5�ur[�thingr9r9r:�_peerlookup�s


�racCs8t|t�rzt|��|�WStyYdSw|��S)z7return true if repo (or path pointing to repo) is localF)�
isinstance�bytesra�islocal�AttributeError�local��repor9r9r:rd�s
�rdTcCs8tj|ddd�}|��rt�|��d�Stj|||d�S)z0open path with open if local, url.open if remoteF)�
parsequery�
parsefragmentsrb)�
sendaccept)r(r!rdr"�	posixfile�	localpath�open)rr5rk�pathurlr9r9r:�openpath�srpFc

Cst|�j|||||d�}t|d|�}|pgD]}|||�q|�dd�t�d��D}t�|�D]6\}	}
|�dd|	�t|
dd�}|ret�d	|	��
}|||�Wd�n1sXwY|�dd
|	|�q/Wd�n1spwY|�dd|�|��s�tD]}|||�q�|S)�1return a repository object for the specified path��intents�
createoptsrs	extensions- executing reposetup hooks
z
all reposetups  - running reposetup for %s
�	reposetupNzreposetup %rs  > reposetup for %s took %s
s> all reposetup took %s
)	ra�instancer�logr"�timedcmrrf�wirepeersetupfuncs)
rr5�create�
presetupfuncsrsrt�obj�f�allreposetupstats�name�module�hook�statsr9r9r:�_peerorrepo�s4
������
r��cCsDt||||||d�}|��}|st�td�|p|����|�d�S)rq)r{rsrtsrepository '%s' is not localsvisible)r�rfrr2rr!�filtered)rr5rzr{rsrtrJrhr9r9r:r%�s	��
r%cCs t||�}t|||||d���S)z/return a repository peer for the specified pathrr)�remoteuir�rJ)�uiorrepo�optsr5rzrsrt�ruir9r9r:rJ�s

��rJcCs(t�|�j}|s
dStj�tj�|��S)a9return default destination of clone if none is given

    >>> defaultdest(b'foo')
    'foo'
    >>> defaultdest(b'/foo/bar')
    'bar'
    >>> defaultdest(b'/')
    ''
    >>> defaultdest(b'')
    ''
    >>> defaultdest(b'http://example.org/')
    ''
    >>> defaultdest(b'http://example.org/foo/')
    'foo'
    r�)r(r!r5r,�basename�normpath)�sourcer5r9r9r:�defaultdest�sr�cCs^|j|jkrdSt�|d�r|jr|jS|j�|j�d}t�|�\}}t	|j
|�}||_|S)z}Returns repository object for source repository of a shared repo.

    If repo is not a shared repository, returns None.
    Nssrcrepor)�
sharedpathr5r"r^�srcrepor$�splitr(�parseurlr%r)rhr��srcurlrSr�r9r9r:�sharedreposource
sr�cCs�t|�st�td���|st|�}nt�||�d}t|t�r7t�||�\}}}t	||�}	t
|	|	|d�\}
}n|��}	d}t�}|rG|�
t�t	||d|	||d�d�}
t|	|
|d�t	||�}
t|
||d�|
S)	zcreate a shared repositorys!can only share local repositoriesrNT)s
sharedrepossharedrelativesshareditems�rzrt)�defaultpath)�checkout)rdrr2rr�r(�get_clone_pathrbrcr%rWrf�set�add�sharedbookmarks�	postshare�_postshareupdate)rr��dest�updater	r��relative�
origsourcerSr��revr��shareditemsr?r9r9r:�shares6



��
r�cCs�t�|j�}t�|j�}|�d�sdSd}|�d�r|�d�}|dd��"}|�d�}|�d�|�|�|�d�|�|�Wd�dS1sIwYdS)z�copies the source repo config and prepend it in current repo .hg/hgrc
    on unshare. This is only done if the share was perfomed using share safe
    method where we share config of source in shares�hgrcNr�swbs## Config copied from shared source
�
)�vfsmodr$r�r5�exists�read�write)rh�srcvfs�dstvfs�
currentconfig�fp�sourceconfigr9r9r:�_prependsourcehgrcMs






"�r�c	Cs|���Pt|||j�}|pt���3tj|jvrt|�|j�	d�}t�
||d�|j�tj�|j�tj
�t�|�Wd�n1sHwYWd�n1sWwYt|j|jdd�}|d}|j}t|�D]	}|�|���qpt�|�|S)aconvert a shared repository to a normal one

    Copy the store data to the repo and remove the sharedpath data.

    Returns a new repository object representing the unshared repository.

    The passed repository object is not usable after this function is
    called.
    s
sharedpaths.oldNF)rzr<)r�	copystorer5r"�nullcontextmanagerr�SHARESAFE_REQUIREMENTr�r$�join�rename�discard�SHARED_REQUIREMENT�RELATIVE_SHARED_REQUIREMENTr�writereporequirementsr%�baseui�root�substate�sorted�sub�unsharer�poisonrepository)rrh�destlock�	sharefile�newrepo�c�subs�sr9r9r:r�cs(
���
r�cCsz|p|j�dd�}|rd}|j�dt�||��tj|jvr;|���t	�
|�Wd�dS1s4wYdSdS)aACalled after a new shared repo is created.

    The new repo only has a requirements file and pointer to the source.
    This function configures additional shared data.

    Extensions can wrap this function and write additional entries to
    destrepo/.hg/shared to indicate additional pieces of data to be shared.
    �paths�defaults[paths]
default = %s
r�N)r�configr$r�r"�tonativeeolr�NARROW_REQUIREMENT�wlockr�copytoworkingcopy)�
sourcerepo�destrepor��default�templater9r9r:r��s	
"��r�c	Csp|sdS|j�td��|dur|}|ddfD]}|durqz|�|�}Wn
tjy0Yqwt||�dS)z�Maybe perform a working directory update after a shared repo is created.

    ``update`` can be a boolean or a revision to update to.
    Nsupdating working directory
Tr��tip)r�statusr�lookuprrQ�_update)rhr�r��test�uprevr9r9r:r��s
�r�cCsZd}z�d}|rtd�ntd�}|j|td�d���}d}|��}t�|j�}	t�|�}
|j��D]G}|r9|�d�r9q/t	j
�|�}|rK|
�|�sK|
�
|�|	�|�rv|�d�rbt	j
�|d	�}
t�|
|
�}t�|	�|�|
�|�||�\}}||7}q/|r�|�d
|�n|�d|�Wd�|WSWd�|WS1s�wY|WSt|��)zGcopy files from store of srcrepo in destpath

    returns destlock
    Nslinkingscopyingsfiles)�unitr�
phaserootssdataslockslinked %d files
scopied %d files
)r�makeprogress�
publishingr�r$r��store�copylist�endswithr,r5�dirnamer��mkdirr�rr"�	copyfiles�debug�release)rr��destpathr��hardlink�topic�progress�num�
srcpublishingr�r�r}�dstbase�lockfile�nr9r9r:r��sJ



��
��
��r�c
Cs�d}
|r:|�d�st�td���g}|D]#}|���}
|�|
�dd|i����Wd�n1s2wYq|}
tj	�
|�}zt�|d�Wnt
ya}
z
|
jtjkrW�WYd}
~
nd}
~
wwt�|�}tj	�|�}t�|d|��-tj	�|�r�|�td�|�n|�td�|�t||||d	|d|	d
�Wd�n1s�wYt|�r�t�t�|��}n|}t||d�}t|||dd|d�}tj|||
d
�t||�|t |||�fS)aPerform a clone using a shared repo.

    The store for the repository will be located at <sharepath>/.hg. The
    specified revisions will be cloned or pulled from "source". A shared repo
    will be created at "dest" and a working copy will be created if "update" is
    True.
    N�lookup�Xsrc repository does not support revision lookup and so doesn't support clone by revision�keyFs%s.locks-(sharing from existing pooled repository %s)
s((sharing from new pooled repository %s)
T)r��pullrHr��stream)r5)r�r�r	r�)�heads)!rLrr2rrNrMrOrPr,r5r�r"�makedirr4�errno�EEXISTr�r$r�rr�r��clonerd�abspathr(r+r%r�rr�r�rJ)r�peeropts�	sharepathr��srcpeerr�r�r�r�r�rH�
remoterevsr?r8�pooldir�poolvfsr�r��	sharerepor�r9r9r:�clonewithshare�s�
��	
�����	���

�
�����
r�cCsP|j�|�}tj�||�}tj�|�r&tj�|�st�|�t�||�dSdS)z8copy a cache from srcrepo to destcachedir (if it exists)N)�cachevfsr�r,r5r�r�r"�copyfile)r��dstcachedir�fname�srcfname�dstfnamer9r9r:�
_copycachePs
�rc
2Csd
t|t�rt�|||�}
|
\}}}t|||�}n|��}d|p gf}|��}}d}}}}d}�z�t||||�\}}|durQt|�}|rP|�t	d�|�nt�||�d}t�
|�}t�
|�}|slt�t	d���t
j|dd�}|��r�|��s�t�t	d�|��|��r�t�t	d�|��i}d	}|
dur�t�|
�d}|dur�t�|�d}|r�|r�|
s�d
h}
d|d<|r�d|d<|�d
�r�d|d<t�d�r�|�t	d��n|�t	d��|	p�i}	|	�d�}|	�d�}|�r�t|��r�d}|dk�rCz8|���}|�dddi���}Wd�n	1�swY|tjk�r(tj� |t!|��}n|�t	d��Wn/tj"�yB|�t	d��Ynw|dk�rWtj� |t!t#�$|��%���}n	t�&t	d�|��|�rl|�t	d��d}|�r�t'||||||||||d�
Wt(|||�|du�r�t)�*|d�|du�r�|�+�|�r�|�,�du�r�|�+�SSS|�,�}|} t|��r�t-�.t�
|��} t|��r�tj�/|��r�tj�0tj� |d��}!|!}n|}d	}"|�r�|�1��r�t|��r�t2�3|��s�|�o�|}"|�r�d	}"|"�rz|j4d	d�}Wn
tj5�yd	}"Ynw|"�rr|j6ddd d!�t�
|�}#t7�8|||�}$t7j9||#|$d"�t7�:||#�}%|%�;�}|%�4�}d#d$l<m=}&|&�>||%�t|||�}t?�@|�|�,�_At?�@|�|�,�_B|%jC|�,�_C|j6d%d |jDjEd&��nzt|�px|||d|d'�}Wn tF�y�}'z|'jGtGjHk�r�d}t�&t	d�|���d}'~'ww|�r�|�d��s�t�&t	d(���g}(|D]%})|���}|(�I|�dd|)i����Wd�n	1�s�wY�q�|(}|d}nd}|�,�}*|*�ri|�r#|*�;��(|*�4��|*�J|
|�t�K|*�Wd�n	1�swYWd�n	1�swYt�| �}+t|+�},|*jL�Md)d*|,d �|�s@|�r>d	}nd}d+di}-|*jL�N|-d ��tOjP|*||||
||d,�Wd�n	1�scwYn!|�r�|�rvt�&t	d-���tOjQ||||jR�S�d.�nt�&t	d/���d}|�,�}%|%�r�tTjUd0}.t�| �}+d|+_Vt|+�},|%j�Wd1t-�X|.|,��|%jL�Md)d*|,d �|�Yd2d3��r�tZ�[|%|�|�r�|du�r�|���}|�dd|i���}Wd�n	1�s�wYd}/d}0|du�r-t\|�d4k�r||%v�r|}/n(t]�^|%|��rt]�_|%|��`�}/n|du�r-z|%�a|�}/Wntj"�y,Ynw|/du�r�z1|%jb�rA|%�a|%jb�}/|%jb}n|%jRd5}/d5}|%|/�c�}1|1d*k�rZt	d6|�}0nt	d7�||1f}0Wn"td�y�z|%�ed*�}/Wntj"�y�|%�ad8�}/YnwYnw|0�s�|%|/�c�}1t	d9�|1}0|%jL�|0�tf|%|/�||%jRv�r�tg�h|%|�|du�r�t(|�|du�r�t(|�|%�4��|%jitjjkd:�Wd�n	1�s�wYWt(|||�|du�r�t)�*|d�|du�r�|�+�|�r|�,�du�r|�+�||fSt(|||�|du�rt)�*|d�|du�r!|�+�|�r0|�,�du�r1|�+�www);a�Make a copy of an existing repository.

    Create a copy of an existing repository in a new directory.  The
    source and destination are URLs, as passed to the repository
    function.  Returns a pair of repository peers, the source and
    newly created destination.

    The location of the source is added to the new repository's
    .hg/hgrc file, as the default to be used for future pulls and
    pushes.

    If an exception is raised, the partly cloned/updated destination
    repository will be deleted.

    Arguments:

    source: repository object or URL

    dest: URL of destination repository to create (defaults to base
    name of source repository)

    pull: always pull from source repository, even in local case or if the
    server prefers streaming

    stream: stream raw data uncompressed from repository (fast over
    LAN, slow over WAN)

    revs: revision to clone up to (implies pull=True)

    update: update working directory after clone completes, if
    destination is local repository (True means update to default rev,
    anything else is treated as a revision)

    branch: branches to clone

    shareopts: dict of options to control auto sharing behavior. The "pool" key
    activates auto sharing mode and defines the directory for stores. The
    "mode" key determines how to construct the directory name of the shared
    repository. "identity" means the name is derived from the node of the first
    changeset in the repository. "remote" means the name is derived from the
    remote's path/URL. Defaults to "identity."

    storeincludepats and storeexcludepats: sets of file patterns to include and
    exclude in the repository copy, respectively. If not defined, all files
    will be included (a "full" clone). Otherwise a "narrow" clone containing
    only the requested files will be performed. If ``storeincludepats`` is not
    defined but ``storeexcludepats`` is, ``storeincludepats`` is assumed to be
    ``path:.``. If both are empty sets, no files will be cloned.
    Nsdestination directory: %s
rs#empty destination path is not validT)r*sdestination '%s' already existssdestination '%s' is not emptyFspath:.snarrowfilessshallowfilestores	lfs-serveslfsse(remote is using large file support (lfs), but it is explicitly disabled in the local configuration)
sT(remote is using large file support (lfs); lfs will be enabled for this repository)
spoolsmodesidentityr�r��0s7(not using pooled storage: remote appears to be empty)
sA(not using pooled storage: unable to resolve identity of remote)
sremotesunknown share naming mode: %ss1(pooled storage not supported for narrow clones)
)r�r�r�r�s.hg)�waitspreoutgoingsclone)�throwr�)rr)�streamclone�outgoing)r��noder�r�r�r�)�uisquietbookmarkmove)r��streamclonerequested�includepats�excludepats�depths2narrow clone not available for remote destinations)rHr	s)clone from remote to remote not supportedsclonedr�sexperimentalsremotenames��@supdating to bookmark %s
s%updating to bookmark %s on branch %s
r�supdating to branch %s
)�caches)lrbrcr(r�rJr!rWr�r�rr+r�
InputErrorr�r$�lexists�isdir�listdirr�validatepatternsrLr�
disabled_helpr]rdrNrOrPr�nullidr,r5r�rrQr&�sha1�digestr2r�r��shutil�rmtree�closerfr"r�r��realpath�cancopyr�	hassecretr�	LockErrorr�r�clone_requirements�createrepository�makelocalrepositoryr��r	�
local_copy�weakref�ref�_lockref�	_wlockrefrA�
nodeconstants�nullhexr4r�r�rM�
setnarrowpatsr�r�	setconfig�configoverriderr��push�
_bookmarks�keys�uimod�samplehgrcs�passwdr�r��
configboolr�pullremotenames�lenr�isrevsymbol�	revsymbolrr��_activebookmarkrB�KeyError�	branchtipr�r	�activate�updatecaches�
repositorymod�CACHES_POST_CLONE)2rr�r�r�r�rHr�r�rB�	shareopts�storeincludepats�storeexcludepatsr�srcr�rSr��srclockr��	destwlock�cleandir�destpeerr��destvfsrt�narrow�	sharepool�
sharenamemoder�r8�rootnoder�r��hgdir�copy�destrootpath�	dest_reqsr�r	�instr�r�rfr_�
defaulturl�	overridesr�r�r��bnr9r9r:r�Zs�
A
�


�
�



����



����������
�
���


���

�����
�

�
�
�����	
�����	
��
���
����



����

�


�����



��

�


�r�cCs8|r|��rdS|j�td�|j|j|j|jf�dS)NsI%d files updated, %d files merged, %d files removed, %d files unresolved
)�isemptyrr�r�updatedcount�mergedcount�removedcount�unresolvedcount)rhr��
quietemptyr9r9r:�
_showstats/s����r_cCs(|j�dd�tj||d|ddg|d�S)z�Update the working directory to node.

    When overwrite is set, changes are clobbered, merged else

    returns stats (see pydoc mercurial.merge.applyupdates)sBprefer merge.update() or merge.clean_update() over hg.updaterepo()s5.7Fsworking copysdestination)�branchmerge�force�labels�updatecheck)r�
deprecwarn�mergemodr�)rhr�	overwritercr9r9r:�
updaterepo@s��rgcCs>tj|||d�}t|||�|jr|j�td��|jdkS)z$update the working directory to node�rcs1use 'hg resolve' to retry unresolved file merges
r)rer�r_r]rr�r)rhrr^rcr�r9r9r:r�Ts

r�cCs0t�||�}|jdksJ�|rt|||�dS)zAforcibly switch the working directory to node, clobbering changesrF)re�clean_updater]r_)rhr�
show_statsr^r�r9r9r:�cleanas
rkcCs�|dur|�dd�}|tvrtj}|tvrtd|tf��|����d}d}|dur8tj||d�}|\}}}d}|r@t||�}	n|tj	krOt
j|dd�tj}t
|||d	�}	|	s�|r�||d
��krcnmt�||g|d
���r�|�|jd�}
|�td�|
�nP|�|jd
�}
|�td�|
�t�|�n:||jvr�||jkr�|�|d�}
|�td�|
�t�||�n|r�|jr�|�|jd
�}
|�td�|
�t�|�|r�t�||�Wd�|	SWd�|	S1s�wY|	S)aUpdate the working directory with extra care for non-file components

    This takes care of non-file components below:

    :bookmark: might be advanced or (in)activated

    This takes arguments below:

    :checkout: to which revision the working directory is updated
    :brev: a name, which might be a bookmark to be activated after updating
    :clean: whether changes in the working directory can be discarded
    :updatecheck: how to deal with a dirty working directory

    Valid values for updatecheck are the UPDATECHECK_* constants
    defined in the merge module. Passing `None` will result in using the
    configured default.

     * ABORT: abort if the working directory is dirty
     * NONE: don't check (merge working directory changes into destination)
     * LINEAR: check that update is linear before merging working directory
               changes into destination
     * NO_CONFLICT: check that the update does not result in file merges

    This returns whether conflict is detected at updating or not.
    Nscommandssupdate.checkz,Invalid updatecheck value %r (can accept %r)F)rkT)rrhr<sbookmarks.activesupdating bookmark %s
r)s(leaving bookmark %s)
s(activating bookmark %s)
)r��_VALID_UPDATECHECKSre�UPDATECHECK_LINEARr1r�r�
destupdate�_clean�UPDATECHECK_ABORTr�
bailifchanged�UPDATECHECK_NONEr�rr	r��labelr=r�r�
deactivater3r@�statusotherdests)rrhr��brevrkrc�movemarkfrom�warndest�updata�ret�br9r9r:�
updatetotallyusf��






�)�
�)�)r|cCsX|��}tj|||d�}t||�|jr|j�td��n
|r'|j�td��|jdkS)zWBranch merge with node, resolving changes. Return true if any
    unresolved conflicts.)rarbsRuse 'hg resolve' to retry unresolved file merges or 'hg merge --abort' to abandon
s'(branch merge, don't forget to commit)
r)rhrerr_r]rr�r)�ctxra�remindrbrhr�r9r9r:r�s
��
rcCsrtj�|�}|��r|j��}n|d��}|j�td�|dd��t	�
||�}|jdks2J�t||�dS)Nr<s(aborting the merge, updating back to %s
�r)
�
mergestatemodrr��active�localctxrrr�rrerir]r_)rrh�msrr�r9r9r:�
abortmerge�sr�c
s�t�|||g�}t|�}t|�dkr!td�}	|	t|�;}	t�|	��|d}
t�|
j|�	d��\}}|durbt�
|�}|��rCt|�}nt�
|�}|�
�rQtjj}
ntj}
|
d|j|f�|_t|�}t|||���j}zc|�td�t�|��t|�||�	d��\}}|r��fd	d
�|D�}t�||�||�	d�|�	d��\�}}|s�|�td
��|�W|�S|�d�tj|�||d�}|�||�|��W|�n|�w|�dS)z�
    Helper for incoming / gincoming.
    displaychlist gets called with
        (remoterepo, incomingchangesetlist, displayer) parameters,
    and is supposed to contain only code that can't be unified.
    rs<for now, incoming supports only a single source, %d providedr�branchN�%s/%s�comparing with %s
�revcsg|]}��|��qSr9)r��r>r��rRr9r:�
<listcomp>sz_incoming.<locals>.<listcomp>rX�forcesno changes found
sincoming��buffered)r(�get_pull_pathsrKr:rrr2r��rawlocr]r!�isabsrcrdr,r5r��	posixpathrJrr��hidepasswordrWr
�getremotechanges�pagerr�changesetdisplayer)�
displaychlist�subreporecurserrhr�r�r��subpath�srcs�msgr5rS�pr��	cleanupfnrHr��chlist�	displayerr9r�r:�	_incoming�sR





�
��
r�c	s6����fdd�}��fdd�}t||����|d�S)NcsHd}��d�r"�d}t|j�D]}|�|�}t||������}q|S�Nrssubrepos)r]r�r�r��min�incoming)rzr}r�r��r�rhr�rr9r:r�+�

z incoming.<locals>.subreporecursecs�t���}��d�r|��d}|D]1}|dur||krdS�fdd�|j�|�D�}��d�r8t|�dkr8q|d7}|�||�qdS)N�newest_firstrc�g|]	}|�jkr|�qSr9�r�r>r�rgr9r:r�<sz-incoming.<locals>.display.<locals>.<listcomp>�	no_merges�r)r�getlimitr]�reverse�	changelog�parentsr:�show)rRr�r��limit�countr�r�)r�rhr9r:�display4s



��zincoming.<locals>.display�r�)r�)rrhr�r�r�r�r�r9r�r:r�*s
	�r�cszt�}g}t��||�D]�}|jp|j}|durEt�|�}|��r&t|�}nt�|�}	|	��r4t	j
j}
ntj}
|
d|	j
|f�|	_
t|	�}|j
|�d�pMgf}|�td�t�|��t��||�d��\}}
|rv�fdd�t��|�D�}t�||�}z&tj�|||�d�d�}|j}|�|�|s�t��j�|j�|�|�Wq|���t |�}�j!}|j"|j#d	�||fS)
Nr�r�r�r�csg|]}�|���qSr9)rr�rgr9r:r�_sz_outgoing.<locals>.<listcomp>r�)ra)�key)$r�r(�get_push_paths�pushloc�locr!r�rcrdr,r5r�r�rBr]r�rr�rWr�revrangerJr
�findcommonoutgoing�missingr�r�nochangesfoundr�excludedrMrrKr��sortr�)rrh�destsr�r��out�othersr5r�r�r�rSrHr�rR�outgoing�o�
outgoing_revs�clr9rgr:�	_outgoingIsH



�
r�cCsHd}|�d�r"|d}t|j�D]}|�|�}t||�|||��}q|Sr�)r]r�r�r�r�r�)rrhr�r�rzr}r�r�r9r9r:�_outgoing_recurseur�r�c
#s��t�|�}|�d�}|�d�r|��|dur$|s$|D]}|VqdSd}�j}|D])}|dur8||kr8dS�fdd�|�|�D�}	|rMt|	�dkrMq+|d7}|Vq+dS)	z5apply revision filtering/ordering option for outgoingr�r�Nrcr�r9r�r�rgr9r:r��sz$_outgoing_filter.<locals>.<listcomp>r�r)rr�r]r�r�r�r:)
rhrHr�r��	no_mergesr?r�r�r�r�r9rgr:�_outgoing_filters(�


�r�c	Cs |�d�rt�g|�t|||||d�\}}d}zm|rbd}|�d�rBt�|||�}|�d�tj|||dd�}	t�||||	tj	�n |�d�t�|||�}	t
|||�D]	}
|	�||
�qT|	��|D]}t
�|||||�t|t||||��}qd|W|D]}|��q~S|D]}|��q�w)Nsgraphr�rrr
Tr�)r]r�checkunsupportedgraphflagsr��	graphrevsr�r��displaygraphr�
asciiedgesr�r�rr�
outgoinghooksr�r�)rrhr�r�r�r�r�rz�revdagr�r��othr9r9r:r��s<


��


�
�r�cCs�tj||d�}|�dt�|j|��d��}|rq|j�t	d��|D]O}||}z2|j
D],}z
|j|dd���p8|}Wq+tj
yW}z|j�d||f�WYd}~q+d}~wwWq!typ|j�t	d	�t|����Yq!w|S)
z&verify the consistency of a repository)�levelsfilelog(%s)s.hgsubstateschecking subrepo links
F)�allowcreates%d: %s
Ns&.hgsubstate is corrupt in revision %s
)�	verifymodr#rHr"�pathtor��getcwdrr�rr�r�r�	RepoError�warn�	Exceptionrr)rhr�rzrHr�r}r�r8r9r9r:r#�s4�
� ���
���r#c	Cs�t�|d�r|j��}|j}n|��}dD]}|�|�p!|�d|�}|r,|�d||d�q|�dd�}|r=|�dd|d�dD]}|�|�D]\}}|�|||d�qFq?|�dd	�}|rg|�dd	t�	|�d�|S)
z*build a remote ui from ui or repo and optssbaseui)rZs	remotecmdrscopiedrXsmainreporoot)sauthshostfingerprintsshostsecuritys
http_proxyswebscacerts)
r"r^r�rRrr]r�r0�configitemsr*)	rGr��dstr��vr?�sectr��valr9r9r:r��s(
��r�))�spaths
00changelog.i)r�r�)r�sobsstore)spathr)c@s0eZdZdZdd�Zdd�Zdd�Zdd	�Zd
S)�cachedlocalrepoz6Holds a localrepository that can be cached and reused.cCs2t|tj�sJ�||_|��\|_|_|j|_dS)z�Create a new cached repo from an existing repo.

        We assume the passed in repo was recently created. If the
        repo has changed between when it was created and when it was
        turned into a cache, it may not refresh properly.
        N)	rbr�localrepository�_repo�
_repostate�_state�mtime�
filtername�_filtername)�selfrhr9r9r:�__init__szcachedlocalrepo.__init__cCsj|��\}}||jkr|jdfSt|jj|j���}|jr%|�|j�|_n|��|_||_||_	|jdfS)aRefresh (if necessary) and return a repository.

        If the cached instance is out of date, it will be recreated
        automatically and returned.

        Returns a tuple of the repo and a boolean indicating whether a new
        repo instance was created.
        FT)
r�r�r�r%r�r!r�r��
unfilteredr�)r��stater�rhr9r9r:�fetchs



zcachedlocalrepo.fetchc	Cs�g}d}tD]:\}}t|j|�}tj�||�}zt�|�}Wnty,t�|�}Ynw|�|tj	|j
f�t||tj	�}qt|�|fS)N���)
�foirr�r,r5r�r-r4rM�ST_MTIME�st_size�max�tuple)r�r��maxmtime�attrr�prefixr�r6r9r9r:r�-s�zcachedlocalrepo._repostatecCsJt|jj|jj�}|jr|�|j�}n|��}t|�}|j|_|j	|_	|S)z�Obtain a copy of this class instance.

        A new localrepository instance is obtained. The new instance should be
        completely independent of the original.
        )
r%r�r��origrootr�r�r�r�r�r�)r�rhr�r9r9r:rR<szcachedlocalrepo.copyN)�__name__�
__module__�__qualname__�__doc__r�r�r�rRr9r9r9r:r�sr�)T)FNNN)r�FNNN)FNN)NTTNFr=)FNTF)
NFNTFNNNNN)F)FN)TF)FTN)f�
__future__rr�r,r�rr-r)�i18nrrrrr�pycompatrr'r	r
rrr
rrrrrrrrrrrerr�rrrrrrrr5r r!r"r#r�r$r��
interfacesr%rB�utilsr&r'r(r�r�r;rWr\rardrpryr�rJr�r�r�r�r�r�r�r�r�rr�r_rgr�r�rkrorprrrm�UPDATECHECK_NO_CONFLICTrlr|r�r�r�r�r�r�r�r�r��objectr�r9r9r9r:�<module>s�x-�



�
�

�0
0
/
�m
�
X




�
R
�
�
?
,


!"!
@ Telegram