�
�c@s�dd
kl
Z
lZlZlZlZ
ddklZ
ddkZddk	Z	ddk
Z
ddkZddkZddk
Z
ddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddklZ
ddkZddk Z ddk!Z!ddk"Z"ddk#Z#ddk$Z$ei%Z%dei&f
d��YZ'd�Z(d�Z)d	�Z*dS(
i�(tbinthextnullidtnullrevtshort(
t
_N(
treleasetlocalrepositorycBs�eZ
edd
df�Zedi��Zedd�Zed��Z	ed��Z
ed��Zd	�Zd
�Z
d�Zd�Zd
�Zed�ZdZhd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Z d�Z!d�Z"d�Z#d �Z$d!�Z%d"�Z&d#�Z'ed$�Z(eed%�Z)d&�Z*ed'�Z+d(d)�Z,d*�Z-d+�Z.d,�Z/d-�Z0d.�Z1d/�Z2d0�Z3d1�Z4d2�Z5d3�Z6d4�Z7e8d5�Z9e8d6�Z:d7�Z;d8eeeeehd9�Z<ed:�Z=d;�Z>ed<�Z?d=eeeeed>�Z@d?�ZAd@�ZBedA�ZCdB�ZDdC�ZEedD�ZFeeedE�ZGdF�ZHdG�ZIeeedH�ZJeeedI�ZKeeedJ�ZLeedK�ZMeedL�ZNdM�ZOdN�ZPdO�ZQdP�ZRedQ�ZSdR�ZTdS�ZUedT�ZVdU�ZWgedV�ZXRS(Wtlookuptchangegroupsubsett	branchmapsrevlogv1 store fncache sharedic	Cs*ti
i|�
tii|�|_tii|id
�|_||_t	i
|i�|_
t	i
|i�|_|
|_|
i
�|_y3|ii|id�|i�
ti|i�
Wntj
o



n
Xtii|i�p/

|o

tii|�p
ti|�
n

ti|i�
dg
}|iiddt�os
titii|id��
|id�
|iiddt�o
|id�
n

|i
d	d
�id�
n

|i
dd
�}x|D]}|id|�
q�W|i�
q�
titd�|��n�
|o
titd�|��n�
t�}y%t|i
d�i�i ��}Wn/tj
o#

}
|i!t!i"jo
�q�
n
Xx.||i#D]}titd�|��q�W|i|_$y^tii|i
d�i��}tii|�p
titd�|��n

||_$Wn/tj
o#

}
|i!t!i"jo
�qj
n
Xt%i%||i$t	i
�|_%|i%i|_&|i%i
|_'|i%i|_(|i%i)|i
_)d|_+d|_,d|_-d|_.d|_/d|_0h|_1h|_2d|_3|_4|_5dS(Ns.hgthgrctrevlogv1tformattusestoretstoret
usefncachetfncaches
00changelog.it
at9 dummy changelog to prevent using the old repo layouttrequirest
ws%s
srepository %s not foundsrepository %s already existssrequirement '%s' not supportedt
sharedpaths1.hg/sharedpath points to nonexistent directory %s(6trepot
repositoryt__init__tostpathtrealpathtroottjointorigroottutiltopenertwopenertbaseuitcopytuit
readconfigt
extensionstloadalltIOErrortisdirtexiststmkdirt
configbooltTruetappendtwritetcloseterrort	RepoErrorRtsettreadt
splitlinesterrnotENOENTt	supportedRRtspathtsopenertsjoint
createmodetNonet_tagst	_tagtypestbranchcachet
_ubranchcachet_branchcachetipt
nodetagscachet
filterpatst_datafilterst	_transreft_lockreft	_wlockref(	tselfR#Rtcreatetrequirementstreqfilet
rtinstt
s((s&/sys/lib/python/mercurial/localrepo.pyRs�



	


	









	











	

%






!











	
		
	
	
	
	
	
c
Csjti|i
�}
d
tijo5
tid
}|i|i�o
|
id�
qW
n

|
i|i
_|
S(Nt
HG_PENDINGs00changelog.i.a(	t	changelogR;Rtenviront
startswithRtreadpendingtversiont
defversion(RJt
ct
p((s&/sys/lib/python/mercurial/localrepo.pyRRms






c

Csti|i
�S(
N(tmanifestR;(
RJ((s&/sys/lib/python/mercurial/localrepo.pyRZwsc

Csti|i
|i|i�S(
N(tdirstateR!R%R(
RJ((s&/sys/lib/python/mercurial/localrepo.pyR[{scCs.|
djo
t
i|�Sn

t
i||
�S(
N(R>tcontextt
workingctxt	changectx(RJtchangeid((s&/sys/lib/python/mercurial/localrepo.pyt__getitem__s



c


CstS(
N(
R.(
RJ((s&/sys/lib/python/mercurial/localrepo.pyt__nonzero__�s
c

Cs
t|i
�S(
N(tlenRR(
RJ((s&/sys/lib/python/mercurial/localrepo.pyt__len__�s
c
cs&xtt
|��D]}
|
V
qWdS(
N(txrangeRb(RJt
i((s&/sys/lib/python/mercurial/localrepo.pyt__iter__�s

c

Csd
|iS(Nsfile:(
R(
RJ((s&/sys/lib/python/mercurial/localrepo.pyturl�s
cKsti|i
||
||�S(
N(thookR%(RJtnametthrowtargs((s&/sys/lib/python/mercurial/localrepo.pyRh�s
s:
cs`t|
t
�o
|
}|
f
}
n
d
i|
�}x;�iD]0}	|	|jo
titd�|	��q<
q<Wx9|
D]1}
�iddtdt	��d|
d|�
qwW��fd�}d
}|o�
y�i
d	d
�}
Wn%tj
o



�i
d	d�}
n
X|
i�}||
|
d|�
x3|
D]+}
�iddt	��d|
d|�
q/
WdSn

y�idd
�}
Wn%tj
o



�idd�}
n
X|
i�}||
|
ti|�
d�ijo
�idg
�
n

ti�id
dg
�}�i|||d|d|�}x3|
D]+}
�iddt	��d|
d|�
q-W|S(Nts%r cannot be used in a tag nametpretagRjtnodettagtlocalcs�|id
d�
|o"
|ddjo
|i
d�
n

x�|
D]�}|o

||�p
|}�ioF
|�ijo6
�ii|t�}|i
dt|�|f�
n

|i
dt��|f�
q@W|i�
dS(Niii�s

s%s %s
(tseekR0R@R?tgetRR
R1(tfptnamestmungetprevtagsRit
mtold(RJRn(s&/sys/lib/python/mercurial/localrepo.pyt	writetags�s







!
!
t	localtagssr+Rs.hgtagssrb+tabtextratmatch(t
isinstancetstrRttag_disallowedR tAbortRRhR.R
R!R)R5R>twfiletencodingt	fromlocalR[taddtmatch_texactRtcommit(RJRtRntmessageRptusertdateR|tallcharsRXRiRyRvRsRwttagnode((RJRns&/sys/lib/python/mercurial/localrepo.pyt_tag�sN








!
$







)





!
)c
Cskx>|i�d
 D],}d|jo
t
itd���q
qW|i�
|i|
|||||�
dS(sZtag a revision with one or more symbolic names.

        names is a list of strings or, when adding a single tag, names may be a
        string.

        if local is True, the tags are stored in a per-repository file.
        otherwise, they are stored in the .hgtags file, and a new
        changeset is committed with the change.

        keyword arguments:

        local: whether to store tags in non-version-controlled file
        (default False)

        message: commit message to use if committing

        user: name of user to use if committing

        date: date tuple to use if committingis.hgtagssCworking copy of .hgtags is changed (please commit .hgtags manually)N(tstatusR R�RttagsR�(RJRtRnR�RpR�R�t
x((s&/sys/lib/python/mercurial/localrepo.pyRo�s




c

Cs3|id
jo
|i�\|_|_n

|iS(sreturn a mapping of tag to nodeN(R?R>t	_findtagsR@(
RJ((s&/sys/lib/python/mercurial/localrepo.pyR��s
c
	Cs�h}
h}ti
|i||
|�
ti|i||
|�
h}xD|
i�D]6\}\}}|tjo
||ti|�<qQ
qQW|ii	�|d
<t
g}|i�D]"\}}|ti|�|fq�~�}||fS(su
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.ttip(ttags_tfindglobaltagsR%t
readlocaltagst	iteritemsRR�ttolocalRRR�tdict(	RJtalltagsttagtypesR�RiRnthistt_[1]tvalue((s&/sys/lib/python/mercurial/localrepo.pyR��s










8
cCs|i�
|i
i|
�S(
s�
        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@Rr(RJttagname((s&/sys/lib/python/mercurial/localrepo.pyttagtype
s	
c
Cs�g}
x\|i�i
�D]H\}}y|ii|�}Wn



d
}n
X|
i|||f�
qWg}t|
�D]\}}}|||fqv~S(s)return a list of tags ordered by revisioni�(R�R�RRtrevR/tsorted(RJt
lt
tt
nRNR�((s&/sys/lib/python/mercurial/localrepo.pyttagslist&
s







cCsi|ipL
h|_x@|i
�i�D](\}}|ii|g�i|�
q&Wn

|ii|
g�S(
s&return the tags associated with a node(RDR�R�t
setdefaultR/Rr(RJRnR�R�((s&/sys/lib/python/mercurial/localrepo.pytnodetags1
s

	

$
cCs\t|�d
}||jo;
|i
|
|d
|d
�
|i|
|ii�|�
n

|
S(Ni
(Rbt_updatebranchcachet_writebranchcacheRRR�(RJtpartialtlrevttiprev((s&/sys/lib/python/mercurial/localrepo.pyt_branchtags9
s




 c
Cs
|ii
�}
|idj	o
|i|
jo
|iSn

|i}|
|_|idjo

h|_n
|ii�
|djp
||iijo
|i�\}}}n
|ii|�}|i	}|i
||�
||_	x0|i�D]"\}}||iti
|�<q�iS(
N(RRR�RAR>RCtcleartnodemapt_readbranchcacheR�RBR�R�R�R�(RJR�toldtipR�tlastR�t
kt
v((s&/sys/lib/python/mercurial/localrepo.pyR
B
s$

 
	
	




 

		


c
Cs�h}
x�|i�i
�D]�\}}d}xVtt|�d
dd�D]8}||}d|ii|�djo
|}PqH
qHW|djo
|d}n

||
|<qW|
S(smreturn a dict where branch names map to the tipmost head of
        the branch, open heads come before closedi
i�R1iN(R
R�R>trangeRbRRR5(RJtbttbntheadstheadRet
h((s&/sys/lib/python/mercurial/localrepo.pyt
branchtags^
s







	



c

Cs�h}
y2|id
�}|i
�id�}|i�
Wn&ttfj
o



httfSn
Xy�|id�idd�\}}t	|�t
|�}}|t|�jp
||i�|jo
t
d��n

xY|D]Q}|p
q�n

|idd�\}}|
i|i�g�it	|��
q�WWnhtj
o




�nT
tj
oG

}	
|iio
|iit|	�d�
n

htt}
}}n
X|
||fS(Nsbranchheads.caches

it
 i
s'invalidating branch cache (tip differs)(R!R5tsplitR1R)tOSErrorRRtpopRtintRbRnt
ValueErrorR�tstripR/tKeyboardInterruptt	ExceptionR%t	debugflagtwarnR(
RJR�t
ftlinesR�R�R�RntlabelRO((s&/sys/lib/python/mercurial/localrepo.pyR�p
s0







!

*



-







c	Cs�y�|id
ddt
�
}|idt|�|f�
xH|
i�D]:\}}x+|D]#}|idt|�|f�
qXWqEW|i�
Wnttfj
o



n
XdS(Nsbranchheads.cacheRt
atomictemps%s %s
(R!R.R0R
R�trenameR)R�(RJtbranchesR�R�R�R�tnodesRn((s&/sys/lib/python/mercurial/localrepo.pyR��s






%


c
Cs�h}xFt||�D]5}||}|i
|i�g�i|i��
qWx1
|i�D]#
\}}|
i
|g�}	|	i|�
t|	�d
jo
q\n

g}
x�|o�
|i�}||	jo
q�n

|t	g}|	D]}
|||
i
�q��i�}|ii||�}g}|	D]}||jo
||q,

q,
~}	|
i
d|�
q�
W|	i|
�
|	|
|<q\WdS(Nii(RdR�tbranchR/RnR�textendRbR�tminR�RRt	reachabletinsert(RJR�tstarttendtnewbranchesRNRXR�tnewnodestbheadst	newbheadstlatestR�tbhtminbhrevR�t_[2]t
b((s&/sys/lib/python/mercurial/localrepo.pyR��s,



)












;

2



cCs�t|
t
�o
|ii|
�SnV
|
d
jo
|ii�dSn4
|
djo
tSn
|
djo
|ii�Sn

|ii|
�}|o
|Sn

|
|i	�jo
|i	�|
Sn

|
|i
�jo
|i
�|
Sn

|ii|
�}|o
|Sn

|
|ii�jo#
ti
td�t|
���n

y't|
�djo
t|
�}
n

Wn


n
Xtitd�|
��dS(Nt
.itnullR�s*working directory has unknown parent '%s'!isunknown revision '%s'(R~R�RRRnR[tparentsRR�t_matchR�R�t
_partialmatchR2R�RRRbR
R3(RJtkeyR�((s&/sys/lib/python/mercurial/localrepo.pyR�s6




























c


CstS(
N(
R.(
RJ((s&/sys/lib/python/mercurial/localrepo.pyRp�s
cCsti
i|i
|
�S(
N(RRR(RJR�((s&/sys/lib/python/mercurial/localrepo.pyR�s
cCsti
i|i|
�S(
N(RRRR(RJR�((s&/sys/lib/python/mercurial/localrepo.pytwjoin�s
cCsti
i|iti|
��S(
N(RRRRR tpconvert(RJR�((s&/sys/lib/python/mercurial/localrepo.pytrjoin�s
cCs2|
d
djo
|
d}
n

ti|i
|
�S(Nit
/i
(tfilelogR;(RJR�((s&/sys/lib/python/mercurial/localrepo.pytfile�s


cCs||
S(
N((RJR_((s&/sys/lib/python/mercurial/localrepo.pyR^�s
cCs||
i�S(
s.get list of changectxs for parents of changeid(
R�(RJR_((s&/sys/lib/python/mercurial/localrepo.pyR��scCsti
||
||�S(
sechangeid can be a changeset revision, node, or tag.
           fileid can be a file revision or node.(R\tfilectx(RJRR_tfileid((s&/sys/lib/python/mercurial/localrepo.pyR��sc


Cs
|ii
�S(
N(R[tgetcwd(
RJ((s&/sys/lib/python/mercurial/localrepo.pyR��s
cCs|ii
|
|�S(
N(R[tpathto(RJR�tcwd((s&/sys/lib/python/mercurial/localrepo.pyR��s
RNcCs|i|
|�S(
N(
R"(RJR�tmode((s&/sys/lib/python/mercurial/localrepo.pyR��s
cCsti
i|i|
��S(
N(RRtislinkR�(RJR�((s&/sys/lib/python/mercurial/localrepo.pyt_link�s
cs�|
|ijo

g}x
|i
i|
�D]�}}|d
jo
q)n

ti|id|g
�}d}|}	xN|ii�D]=\}
}|i	|
�o!
|}|t
|
�i�}	Pq�
q�W|p

d�}n

ti
|�dp
|��f
d�}n

|i|||	f�
q)W||i|
<n

xt|i|
D]e\}}}||�oI
|i
itd�||f�
|||d|i
d|d	|�}Pq;

q;
W|S(
Nt
!Rlc[sti
||
�S((R tfilter(RPRXtkwargs((s&/sys/lib/python/mercurial/localrepo.pyt<lambda>sics
�||
�S(((RPRXR�(
toldfn(s&/sys/lib/python/mercurial/localrepo.pyR�ssfiltering %s through %s
R%Rtfilename(RER%tconfigitemsR�R}RR>RFR�RTRbtlstriptinspectt
getargspecR/tdebugR(RJR�R�tdataR�tpattcmdtmftfntparamsRitfilterfn((
R�s&/sys/lib/python/mercurial/localrepo.pyt_filter�s:













	









 
$
	cCs||i|
<dS(
N(
RF(RJRiR�((s&/sys/lib/python/mercurial/localrepo.pyt
adddatafilters
cCsW|i|
�o
t
i|i|
��}n
|i|
d
�i�}|id|
|�S(NRNtencode(R�RtreadlinkR�R"R5R
(RJR�R�((s&/sys/lib/python/mercurial/localrepo.pytwreads


cCs�|id
|
|�}yt
i|i|
��
Wntj
o



n
Xd|jo
|ii||
�
nG
|i|
d�i|�
d|jo 
ti	|i|
�t
t�
n

dS(NtdecodeR�RR�(R
RtunlinkR�R�R"tsymlinkR0R t	set_flagstFalseR.(RJR�R�tflags((s&/sys/lib/python/mercurial/localrepo.pytwwrite"s










cCs|id
|
|�S(NR

(
R
(RJR�R�((s&/sys/lib/python/mercurial/localrepo.pyt
wwritedata/s
c
	Cs�|io

|i�p
d}
|
o
|
i�o
|
i�Sn

tii|id
��o
ti	t
d���n

y|id�i�}Wnt
j
o




d}n
X|idd�i|�
|idd�i|ii��
|id
�|id�f|id�|id	�f|id�|id
�fg}ti|ii|i|id
�t|�|ii�}
ti|
�|_|
S(Ntjournals'journal already exists - run hg recoverR[Rlsjournal.dirstateRsjournal.branchtundos
undo.dirstatesundo.branch(RGR>trunningtnestRRR+R<R2R3RR!R5R)R0R[R�RttransactionR%R�R;t
aftertransRR=tweakreftref(RJttrtdstrenames((s&/sys/lib/python/mercurial/localrepo.pyR
2s(








"

!


	


c
Cs�|i�}
z�t
ii|id
��oM
|iitd��
ti	|i
|id
�|ii�
|i�
t
Sn
|iitd��
tSWd|
i�
XdS(NR
s%rolling back interrupted transaction
s%no interrupted transaction available
(tlockRRR+R<R%R�RR
trollbackR;R�t
invalidateR.R
R(RJR
((s&/sys/lib/python/mercurial/localrepo.pytrecoverMs




%



c

CsZ
d}
}z;
|i
�}
|i�}tii|id
��o�|iit	d��
t
i|i|id
�|ii
�
ti|id�|id��
y)|id�i�}|ii|�
Wn?tj
o3



|ii
t	d�ti|ii���
n
X|i�
|ii�
|i�
n
|ii
t	d��
Wdt||
�
XdS(NR
srolling back last transaction
s
undo.dirstateR[sundo.branchs=Named branch could not be reset, current branch still is: %s
s"no rollback information available
(R>twlockR
RRR+R<R%R�RR
R
R;R�R R�RR!R5R[t	setbranchR)R�R�R�R
t	destroyedR(RJR!
R
R�((s&/sys/lib/python/mercurial/localrepo.pyR
[s&







%
"









c
Csrx5d
i�D]'}
|
|i
jo
t||
�
q

q
Wd|_d|_d|_d|_d|_d|_	dS(Nschangelog manifest(
R�t__dict__tdelattrR>R?R@RDRARBRC(RJR((s&/sys/lib/python/mercurial/localrepo.pyR
ss




	
	
	
	
	
c	Cs�yti|
d
|d|�
}Wn|t
ij
om

}
|p
�n

|iitd�||if�
ti|
t|iiddd��|d|�
}n
X|o
|�
n

|S(Nitdescs"waiting for lock on %s held by %r
R%ttimeoutt600(	R
R2tLockHeldR%R�RtlockerR�tconfig(RJtlocknametwaitt	releasefnt	acquirefnR&
R�RO((s&/sys/lib/python/mercurial/localrepo.pyt_lock~s






$



cCs�|io

|i�}|dj	o
|io
|i�
|Sn

|i|id
�|
d|itd�|i�}t	i
|�|_|S(s�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.)R
s
repository %sN(RHR>theldR
R0
R<R
RRR
R
(RJR-
R�((s&/sys/lib/python/mercurial/localrepo.pyR
�s






cCs�|io

|i�}|dj	o
|io
|i�
|Sn

|i|id
�|
|ii|iit	d�|i
�}ti|�|_|S(s�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.R!
sworking directory of %sN(
RIR>R1
R
R0
RR[R0R
RRR
R
(RJR-
R�((s&/sys/lib/python/mercurial/localrepo.pyR!
�s








c	Cs�|
i�}|
i
�}|i|�}	|i|t�}
|i|t�}}h}
|
i�}|o6

|d
|jo%

|d
}|i|�}|}|oC
|tjp

|djo%
||jo
||}|
}q�
q�n

|pa
|iit	d�||f�
x>|di
�D](}||jo
||i�}Pq

q
Wn

|iit	d�||t|�f�
||
d<t|�|
d<t|}
}nY
|tjoK
|	i
|
|�}||
jo
|t}
}q�|jo

t}q�

|tjp
|	i|
|�p
|
o-
|i|�
|	i||
|||
|�Sn

|
|jo-
|i|�|
i�jo
|i|�
n

|
S(sK
        commit an individual file as part of a larger transaction
        is( %s: searching for copy revision for %s
R�s %s: copy %s:%s
R$tcopyrevN(RR�R�RrRtrenamedR>R%R�Rt	ancestorstfilenodeR
tancestortcmpR/R�R
(RJtfctxt	manifest1t	manifest2tlinkrevR
t
changelisttfnamettexttflogtfparent1tfparent2t	fparent2otmetaR$tcfnametcrevt
newfparentR6
tfparentancestor((s&/sys/lib/python/mercurial/localrepo.pyt_filecommit�sP






















)











'


 )
RlcCs�d
�}|p
ti
|id�}n

|p
g}	|	i|_||_n

|i�}
zo|ii�\}}|d}
|oG
|t
jo:
|o3
|i�p

|i�o
t
itd���n

|id|d|�}|o
|di|d�
n

g}xE|
iD]:}||�o'
|
i|�i�o
|i|�
q

q
W|o)
d|djo
|didd�
n

|o

|i�o

t|d|d	|d
�}x�i�D]�}|djp
||jp
||
ijo
q�n

||djo
||td
��
n

||	joG
|d}xa|D]}|i|�o
PqA
qAW||td��
q�
||ijo
||td��
q�
q�Wn

|oi
|id�oX
|t
joK
|dp
|d	p
|d
o)
|di�|di�jo
dSn

ti|�}xI|dD]=}||jo*
||djo
t
itd���q1
q1Wti|||f|
||||�}|o
||||�|_n

|o�
|
ii�}xa|D]Y}|i itd�|�
|
i|�i!|i||�}||d|f||<q�Wt"i#||�
n

|i$|t%�}x*|d|d	D]}|ii&|�
qlWx"|d
D]}|ii'|�
q�W|ii(|�
|i)�
|SWd|
i*�
XdS(s�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.
        cSsti
d
||
f��dS(Ns%s: %s(R R�(R�tmsg((s&/sys/lib/python/mercurial/localrepo.pytfail�s
RlsBcannot partially commit a merge (do not specify files or patterns)R}tcleaniis.hgsubstatei
iR�isfile not found!R�sno match under directory!sfile not tracked!R1t
us+unresolved merge conflicts (see hg resolve)scommitting subrepository %s
N(+R�talwaysRR/tdirtbadR!
R[R�R>RtfilestanypatsR R�RR�R�tsubstatetsubtdirtyR�R4RTRrR�tmerge_t
mergestateR\R]t_textR$R%R�tsubrepot
writestatet	commitctxR.tnormaltforgett
setparentstresetR(RJR>
R�R�R}tforceteditorR|RJ
tvdirsR!
tp1tp2twctxtchangestsubsRPtmatchedR�t
dR

tmstcctxtstatetsrtret((s&/sys/lib/python/mercurial/localrepo.pyR��s�		















#



 

*









	

&
"
!










!







cs�d
}}|
i
�}|
i�|
i�}}|i�i�}|i�}	|
i�}
|i�|o

|i�p
d
}}�iddt	d|d|�
�i
�}z��i�}ti
|�}
h}g}t��}x�t|
i�|
i��D]�}�ii|d�
yF|
|}�i|||	||
|�||<|i||i��
Wq�tfj
o<



|o!
�iitd�|�
�q�
|i|�
q�q�i|�
g}t|�D]+}||jp

||	jo
||q�
q�~}g}|D]}||jo
||q
q~}x|D]
}||=q>W�ii||
||i�|i�||f�}�ii �
�ii||||
i!�|
|i"�|i"�|
|
i#�|
i$�i��}�f
d�}�id	dt	d
t|�d|d|d|�
�ii%|
�
|i&�
�i'o
�i(�
n

�idd
t|�d|d|�
|SWd
~|i)�
Xd
S(stAdd a new revision to current repository.

        Revision information is passed via the context argument.
        Rlt	precommitRjtparent1tparent2s

strouble committing %s!
c
s�ii
�o

�ip
dS(
Rl(RRtwritependingR((
RJ(s&/sys/lib/python/mercurial/localrepo.pyR��stpretxncommitRntpendingR�N(*R>tremovedRb
Rc
RZR$R�R
RhR.R
R
R
tproxyRbR�tmodifiedtaddedR%tnoteRH
R4R
R�R)R�RR/tupdateR�tmanifestnodeRRtdelayupdatetdescriptionRnR�R|tfinalizeR1RAR�R(RJtctxR2R
R
Rt
Rb
Rc
tm1tm2R�txp1txp2ttrptnewtchangedR;
R�R8
R�R�tdroptmnR�RY((
RJs&/sys/lib/python/mercurial/localrepo.pyRZ
Zsf





'




















E
2







!

$






%

c

Csti
|i|hh�
d
S(s�Inform the repository that nodes have been destroyed.
        Intended for use by strip and rollback, so there's a common
        place for anything that has to be done after destroying history.N(R�R�R%(
RJ((s&/sys/lib/python/mercurial/localrepo.pyR#
�scCs||i|
�S(
s�
        walk recursively through the directory tree or a given
        changeset, finding all files matched by the match
        function
        (
twalk(RJR}Rn((s&/sys/lib/python/mercurial/localrepo.pyR��sR�csB�f
d
�}t|
t
i�o

|
�n
�|
�t|t
i�o

|}n
�|}|i�dj}	|	o
��dj}
�p
ti�i�i���|||}}}
|	o'
|i��i�jo
|i	�
n

|
p
��fd�}|�_
n

|	oS

�ii�|||
�}|\}}}}}}}}|
o

|o

g}x|t
|�D]n}|�jp=
|i|��i|�jp
�|i||i��o
|i|�
qr

|i|�
qr
W|o
||7}n

|oc
yF�it�}z%x|D]}�ii|�
qWWd|i�
XWqctij
o



qc
Xqg
qk
n

|
p�
|��}|	oy
|�d�}x9|||D])}d||<|i||i|��
q�WxJ|D]}||jo
||=q�
q�Wn!
ggg}}}||�}ggg}}}x�|D]�}||jo�
|i|�|i|�jp>
||||jo:
||p
�|i||i��o
|i|�
n
|o
|i|�
n

||=q9
|i|�
q9W|i�}n

|||||||f}g}|D]}||i�q$~
|S(s�return status of files between two nodes or node and working directory

        If node1 is None, use the first dirstate parent instead.
        If node2 is None, compare node1 with working directory.
        c
sE|i�i
�}
x,|
i�D]}�|�p
|
|=q
qW|
S(
N(RZR$tkeys(R~
R

R
(
R}(s&/sys/lib/python/mercurial/localrepo.pyt	mfmatches�s






R�cs;|�jo*
�ii
d
�ii|�|
f�
n

dS(Ns%s: %s
(R%R�R[R�(R�RI
(tctx1RJ(s&/sys/lib/python/mercurial/localrepo.pyRO
�s


N(R~R\R^R�R>R�RM
RR�RZRO
R[R�R�R
R7
R�R/R!
R
R[
RR2t	LockErrorR4R�tsort(RJtnode1tnode2R}tignoredRK
tunknownR�tctx2tworkingt
parentworkingtlistignoredt	listcleantlistunknownRO
RPR7
Rv
Rw
Rt
tdeletedtfixupR�R!
tmf1tmf2R
RNR�R�((RJR�R}s&/sys/lib/python/mercurial/localrepo.pyR��s�








"
!







,

























)





%
cCs�|i�}zd
g}xS
|
D]K
}|i
|�}yti|�}Wn1


|iitd
�|�
|i|�
qn
X|idjo$
|iitd�||f�
n

t	i
|i�p
t	i|i�p+
|iitd�|�
|i|�
q
|i
|djo
|iitd�|�
q
|i
|djo
|i
i|�
q
|i
i|�
qW|SWd|i�
XdS(Ns%s does not exist!
i��se%s: files over 10MB may cause memory and performance problems
(use 'hg revert %s' to unadd the file)
s:%s not added: only files and symlinks supported currently
tamns%s already tracked!
RN(R!
R�RtlstatR%R�RR/tst_sizetstattS_ISREGtst_modetS_ISLNKR[tnormallookupR�R(RJtlistR!
trejectedR�RYtst((s&/sys/lib/python/mercurial/localrepo.pyR�#s4














&







cCsu|i�}zWxP|
D]H}|i
|d
jo
|iitd�|�
q
|i
i|�
qWWd|i�
XdS(NRs%s not added!
(R!
R[R%R�RR\
R(RJR�R!
R�((s&/sys/lib/python/mercurial/localrepo.pyR\
Bs




c	CsB
|oa
x^|
D]R}yti
|i|��
Wqtj
o#

}
|itijo
�q`
q
XqWn

|i�}z�x�|
D]�}|o:
tii	|i|��o
|i
itd
�|�
q~
|i
|djo
|i
i|�
q~
||i
jo
|i
itd�|�
q~
|i
i|�
q~WWd|i�
XdS(Ns%s still exists!
Rs%s not tracked!
(R R
R�R�R7R8R!
RRR+R%R�RR[R\
tremoveR(RJR�R
R�ROR!
((s&/sys/lib/python/mercurial/localrepo.pyR�Ms(










#




c	Cs*
g}|ii
�D]:}|tjo'
||ii|ii|�d
�q
q~}|i�}z�x�|
D]�}|i|djo
|iit	d�|�
qm
||d
jo
|d
p
|d}|i
|�i||�}|i|||i|��
|ii
|�
qmWWd|i�
XdS(NiRNs%s not removed!
i
(R[R�RRZR5RRR!
R%R�RR�R
R
R[
R(	RJR�R�RYt	manifestsR!
R�RwR�((s&/sys/lib/python/mercurial/localrepo.pytundeletecs

P




&


cCs�|i|�}t
ii|�p
t
ii|�p
|iitd
�|�
n�
t
ii|�p
t
ii|�p
|iitd�|�
nZ
|i	�}z?|i
|djo
|i
i|�
n

|i
i|
|�
Wd|i
�
XdS(Ns%s does not exist!
s1copy failed: %s is not a file or a symbolic link
s?r(R�RRR+R�R%R�RtisfileR!
R[R�R$R(RJtsourcetdestRYR!
((s&/sys/lib/python/mercurial/localrepo.pyR$ss

&

&





cCsq|ii
|
�}g}|D] }||ii|�|fq~}g}t|�D]\}}||qW~S(
N(RRR�R�R�(RJR�R�R�R�R�RNR�((s&/sys/lib/python/mercurial/localrepo.pyR��s
4
cCs�|
djo
|di
�}
n

|i�}|
|jo
gSn

||
}|i�
|dj	o 
|ii|g
|�d
}n

|pF
g}|D].}d|ii|�djo
||q�
q�~}n

|S(NiR1i(R>R�R
treverseRRtnodesbetweenR5(RJR�R�tclosedR�R�R�R�((s&/sys/lib/python/mercurial/localrepo.pytbranchheads�s











 


5
cCs�|
p
|ii
�g
}
n

g}x~|
D]v}|}xg|ii|�}|d
tjp
|dtjo&
|i|||d|d
f�
Pn

|d}q9q*W|S(Ni
i(RRR�R�RR/(RJR�R�R�R�RY((s&/sys/lib/python/mercurial/localrepo.pyR��s







"
!


c
Cs�g}x�|
D]�\}}|gd
}}}d}xm||jo_
|tjoR
|i
i|�d
}	||jo
|i|�
|d}n

|	}|d7}q6
W|i|�
q
W|S(Nii
i(RRRR�R/(
RJtpairsRNttoptbottomR�R�ReR�RY((s&/sys/lib/python/mercurial/localrepo.pytbetween�s










cCs|i|
|||�d
S(s�Return list of roots of the subsets of missing nodes from remote

        If base dict is specified, assume that these nodes and their parents
        exist on the remote side and that no child of a node of base exists
        in both remote and self.
        Furthermore base will be updated to include the nodes that exists
        in self and remote but no children exists in self and remote.
        If a list of heads is specified, return only nodes which are heads
        or ancestors of these heads.

        All the ancestors of base are in self and in remote.
        All the descendants of the list returned are missing in self.
        (and so we know that the rest of the nodes are missing in remote, see
        outgoing)
        i
(
tfindcommonincoming(RJtremotetbaseR�R_
((s&/sys/lib/python/mercurial/localrepo.pytfindincoming�scCs�|ii
}g}t�}t�}t�}	|djo

h}n

|p
|
i�}n

|ii�tjoK
d
|t<|tg
jo
tg
tg
t|�fSn

tg
ggfSn

|ii	t
d��
g}
x6|D].}||jo
|
i|�
q�
d
||<q�W|
}|
p
|i�ggfSn

t|
�}d}
|
i
|
�}
x|
o

g}x0|
o(
|
id�}|d|jo
qi
n

|iit
d�t|d�t|d
�f�
|dtjo
n�
||	jo
|iit
d��
qi
nz

|d
oj
|d
|joY
|iit
d�t|d�t|d
�f�
|i|dd!�
|	i|�
n

|d
|jo�
|d
|jo�
|d|joJ
|d|jo9
|iit
d	�t|d
��
|i|d
�
n

x4|dd
!D]!}||jo
d
||<q

q
Wn

xM|dd
!D]>}||jo+
||jo
|i|�
|i|�
qA
qAW|i|d�
qi

W|o�
|
d
7}
|iit
d�|
ditt|��f�
x�tdt|�d
�D]l}xc|
i
|||d
!�D]G}|iit
d�t|d�t|d
�f�
|
i|�
qWq�Y

qY

WxV
|oN

g}|
d
7}
x7
t||
i|��D]
\}}|i|d
�
|d}d
}x�D]�}|iit
d�|t|�t|�f�
||jo�
|dj
o;
|iit
d�t|��
|i|�
d
||<n@
|iit
d�t|�t|�f�
|i||f�
Pn

||d}}q�W|}q�Wqq
WxB|D]:}||jo'
tit
d�t|d
 ���q�
q�W|i�tg
jo:
|o
|iit
d��
q\
tit
d���n

|iit
d�dig}|D]}|t|�q~�d�
|iit
d�|
�
|i�t|�|fS(scReturn a tuple (common, missing roots, heads) used to identify
        missing nodes from remote.

        If base dict is specified, assume that these nodes and their parents
        exist on the remote side and that no child of a node of base exists
        in both remote and self.
        Furthermore base will be updated to include the nodes that exists
        in self and remote but no children exists in self and remote.
        If a list of heads is specified, return only nodes which are heads
        or ancestors of these heads.

        All the ancestors of base are in self and in remote.
        i
ssearching for changes
isexamining %s:%s
sbranch already found
sfound incomplete branch %s:%s
iisfound new changeset %s
isrequest %d: %s
R�i
sreceived %s:%s
snarrowing %d:%d %s
sfound new branch changeset %s
s narrowed branch search to %s:%s
salready have changeset s!warning: repository is unrelated
srepository is unrelateds!found new changesets starting at s

s%d total queries
N(RRR�R4R>R�R�RR�R%R�RR/R�R�R�R�RR�RtmapRdRbtzipR�R2R3R�R R�(RJR�R�R�R_
Rwtsearchtfetchtseent
seenbranchR�R�treqtreqcntRNR�RYR�t	newsearchR�R�ReR�((s&/sys/lib/python/mercurial/localrepo.pyR��s�

	
	
	

























"








"

"
"















 



"











/



















	
?c
Cs�|djo#
h}|i
|
||d
|�

n

|iitd�ditt|i���d�
t	|i
i�}|it
�
|i�}xc|o[
|id�}||jo;
|i|�
x+|i
i|�D]}|i|�
q�Wq�
q�
Wg}	t	�}
x�|D]�}|i
i|�\}}||jo
||jo
|	i|�
n

|o@
||jo
|
i|�
n

||jo
|
i|�
q�
q


q

W|o
|	t|
�fSn
|	SdS(s�Return list of nodes that are roots of subsets not in remote

        If base dict is specified, assume that these nodes and their parents
        exist on the remote side.
        If a list of heads is specified, return only nodes which are heads
        or ancestors of these heads, and return a second element which
        contains all remote heads which get new children.
        R_
scommon changesets up to R�s

iN(R>R�R%R�RRR�RR�R4RRR�R�RR�R�R/R�R�(
RJR�R�R�R_
tremainR�R�RYtsubsett
updated_headsRb
Rc
((s&/sys/lib/python/mercurial/localrepo.pytfindoutgoing[s<	


	
-










	











c		Cs6
|i�}z
|i
|
d
|d|�\}}}|tg
jo
|iitd��
n

|p
|iitd��
dSn

|djo
|
id�o

|}n

|djo
|
i|d�}n?
|
id�p
t	i
td���n

|
i||d�}|i|d|
i
��SWd|i�
XdS(	NR�R_
srequesting all changes
sno changes found
iR	tpullsWPartial pull cannot be done because other repository doesn't support changegroupsubset.(R
R�RR%R�RR>tcapabletchangegroupR R�R	taddchangegroupRgR(	RJR�R�R_
R
tcommonR�trheadstcg((s&/sys/lib/python/mercurial/localrepo.pyR��s$













cCs:|
id
�o
|i
|
||�Sn

|i|
||�S(Ntunbundle(R�t
push_unbundletpush_addchangegroup(RJR�R_
trevs((s&/sys/lib/python/mercurial/localrepo.pytpush�s	

c
s�h}|
i�}�i
|
||d
|�
}�i|
||�\}}�dj	o"
�ii|��\}	}
�n
|�ii�}
����fd�}|
p
�iitd��
d	Sn�
|p�
|t	g
joM

|
i
d�o

h}�p
�i�}nQ
xM�D]E}
�|
i�}||jo
||i
|
�
q

|
g
||<q
W|
i�}x�|D]�}||jo
||}n
g}||}g}|D](}�|i�|jo
||q�
q�~}|p
qn
n

||||�p
d
Sqn

qn
Wq+
|�||�p
dSq+
n

|o
�iitd��
qP
n

�djo
�i|i�d�}n
�i|�d�}||fS(NR_
c
	s�d
}�o#
t|�t|
�jo

d}n

g}|D]}|�i
i||�q<~}tt|g��t|�@}|p
tSn

x�|
D]�}|�i
ijoc
�i
i|��}	g}
�D]}||	jo
|
|q�
q�~
}|p
|i|�
q

q�
|i|�
q�Wt|�t|
�jo

d}n

|og
|
p,
�ii	t
d��|d
i��
n
�ii	t
d��
�iit
d��
t
Sn

tS(s�
            check whether there are more local heads than remote heads on
            a specific branch.

            lheads: local branch heads
            rheads: remote branch heads
            updatelh: outgoing local branch heads
            ii
s,abort: push creates new remote branch '%s'!
s&abort: push creates new remote heads!
s0(did you forget to merge? use push -f to force)
(RbRRR�R4tsumR.R�R�R%R�RR�R�R
(
tlheadsR�tupdatelhR�R�R�tupdatelheadstnewheadsRNR&
R�R�R�(R�RJR�(s&/sys/lib/python/mercurial/localrepo.pytcheckbranch�s4
!


)




2







sno changes found
i
R
isnote: unsynced remote changes!
R�(Ni
(Ni(Ni(R�R�R�R>RRR�R%R�RRR�R
R�R/R�t_changegroupR�R	(RJR�R_
R�R�tremote_headstincRy
R�tmsng_cltbasesR�tlocalhdsR�R�t	remotehdstlhR�R�R�tupdR�R�((R�RJR�s&/sys/lib/python/mercurial/localrepo.pytprepush�sX





".


















+







cCsy|
i�}z[|i
|
||�}|d
dj	o)
|\}}|
i|d|i��Sn

|dSWd|i�
XdS(NiR�i
(R
R�R>R�RgR(RJR�R_
R�R
Rm
R�R�((s&/sys/lib/python/mercurial/localrepo.pyR�#s






cCse|i|
||�}|d
dj	o7
|\}}|o

dg
}n

|
i||d�Sn

|dS(NiR_
R�i
(R�R>R�(RJR�R_
R�Rm
R�R�((s&/sys/lib/python/mercurial/localrepo.pyR�.s




cCs�|ii
p

|d
jo$
|iitd�t|
��
n

|iioE
|iitd��
x,|
D] }|iidt|��
qhWn

dS(Ntbundles%d changesets found
slist of changesets:
s%s
(R%tverboseR�RRbR�R�R
(RJR�R�Rn((s&/sys/lib/python/mercurial/localrepo.pytchangegroupinfo;s

$




cs��djo�
|i
�
�i�}|i
�
||jof
g}xI|
D]A}x8�ii|�D]$}|tjo
|i|�
q`
q`WqGW�i|��Sq�
n

�id
dt	d��
�i��i
|
|�\�}
}�i���
t�}	x$|
D]}|	i
�i|��
q

W|	it�
t|	�}	|	o1
�i
d|	�\�}
}
d}
t���n

t���i�h�h��it��d}
d}
d��d����fd�������fd���f
d	�����fd
������fd���f
d���f
d
������������������fd�}ti|��S(stThis function generates a changegroup consisting of all the nodes
        that are descendents of any of the bases, and ancestors of any of
        the heads.

        It is fairly complex as determining which filenodes and which
        manifest nodes need to be included for the changeset to be complete
        is non-trivial.

        Another wrinkle is doing the reverse, figuring out which changeset in
        the changegroup a particular filenode or manifestnode belongs to.

        The caller can specify some nodes that must be included in the
        changegroup using the extranodes argument.  It should be a dict
        where the keys are the filenames (or 1 for the manifest), and the
        values are lists of (node, linknode) tuples, where node is a wanted
        node and linknode is the changelog node that should be transmitted as
        the linkrev.
        tpreoutgoingRjR�i
c


Ss|S(
N((
R�((s&/sys/lib/python/mercurial/localrepo.pytidentity�s
c
Ss
t|
�}|i
d
|i�

x�|D]�}g}|i|�D]}|tjo
||q@
q@~}x~|ov
|i�}||
joY
|
i|�
g}	|i|�D]}|tjo
|	|q�
q�~	}|i|�
qj
qj
Wq&Wx|
D]}|i|d�
q�S(NR�(	R�R�R�R�RR�R�R�R>(
trevlogthassettmsngsetthaslstRnR�RYt	parentlstR�R�((s&/sys/lib/python/mercurial/localrepo.pyt
prune_parents�s



;







;


c
s���fd
�}
|
S(Nc
sL�i|�}
x"|
d
D]}�i
||�
qW�i
|
d|�
dS(Nii(R5R�(tclnodeRXR�(tmsng_mnfst_settchangedfilesettcl(s&/sys/lib/python/mercurial/localrepo.pytcollect_manifests_and_files�s



((R�R�(R�R�(
R�s&/sys/lib/python/mercurial/localrepo.pytmanifest_and_file_collector�scsmt�}xM�D]E}
�i
�i�i|
���}|�jo
|i|
�
q
qW��|��
dS(
N(R4RnR;
R�R�(t
has_mnfst_setR�tlinknode(R�R�t
has_cl_setR�tmnfst(s&/sys/lib/python/mercurial/localrepo.pytprune_manifests�s
	
!



c

s�|S(
N((
t	mnfstnode(
R�(s&/sys/lib/python/mercurial/localrepo.pytlookup_manifest_link�s
c
s(d
g
������fd�}
|
S(Nic
s 
�i|�}
|
�d
jo
�i
|�}x�|i�D][\}}�i|d�}|dj	o0
�|}�i|h�}|i||�
q<
q<Wnp
�i|�}x]�D]U}|i|d�}|dj	o0
�|}�i|h�}|i||�
q�
q�W|
d�d
<dS(Nii
(R�t	readdeltaR�RrR>R�R5(R�RNtdeltamfR�tfnodeR�tndsetRw(tnext_revR�tchangedfilestmsng_filenode_setR�(s&/sys/lib/python/mercurial/localrepo.pytcollect_msng_filenodes�s&










((R�R
(R�RR�(R�R�s&/sys/lib/python/mercurial/localrepo.pytfilenode_collector�s
	"csw�|}t�}xM|D]E}�i
|
i|
i|���}|�jo
|i|�
q
qW�|
||�
dS(
N(R4RnR;
R�R�(R�t
filerevlogR�R�R�R�(R�RR�R�(s&/sys/lib/python/mercurial/localrepo.pytprune_filenodess


	
!



c
s�|��f
d
�}
|
S(Nc

s�|S(
N((
R�(
R�(s&/sys/lib/python/mercurial/localrepo.pytlookup_filenode_links
((R=
R(
R(
R�s&/sys/lib/python/mercurial/localrepo.pytlookup_filenode_link_funcs

csW�p

|�jo
dSn

x3�|D]'\}}||
jo
||
|<q(
q(WdS(
N((RiR�RnR�(
t
extranodes(s&/sys/lib/python/mercurial/localrepo.pytadd_extra_nodess




c3sSh}�i���|��}
x|
D]}|V
q(W��
�d
��
�i
�}|id�i�

�i|��|��}
x|
D]}|V
q�Wd}�i�
�oF
xC�D]7}t|t�o
q�n

�i|h�
d
||<q�Wn

x
t	|�D]

}�i
|�}t|�p
ti
td�|��n

|�jo2
�||�
�|�|�
�|i
�}n
g}t|�djo^
tit|��V
|V
|id|i�

|i|�|��}
x|
D]}|V
q�n

|�jo
�|=q

q
Wti�V
�o'
�iddt�d�d��
n

dS(Ni
R�sempty or missing revlog for %sitoutgoingRnR�(tgroupR�R�R�R>R�R~R�R�R�R�RbR R�RR�tchunkheadert
closechunkRhR
(R�R
tchnktmsng_mnfst_lstR=
Rtmsng_filenode_lst(RR�R�R�RRR�RR�R�Rtmsng_cl_lstR�R�RRJ(s&/sys/lib/python/mercurial/localrepo.pytgengroup#s`


	





	


















	






N(R>R�R�RRR�RR/R�RhR.R�R�R4Ry
tdiscardR�RZtindexRbR tchunkbuffer(RJR�R�R�RtallheadsR�R�RYt
knownheadstjunkR((R�R�R�RJRR�R�RR�R�R�RRR�R�RRRs&/sys/lib/python/mercurial/localrepo.pyR	CsX












	
	





		
		
/
<GcCs|i|
|i
�|�S(
N(R	R�(RJt	basenodesR�((s&/sys/lib/python/mercurial/localrepo.pyR�lsc
s��id
dt
d��
�i��i|
��tg}�D]}|�i|�q?~���i���
d���f
d���f
d���f
d����������fd�}ti|��S(	s$
Generate a changegroup of all nodes that we have that a recipient
        doesn't.

        This is much easier than the previous function as we can assume that
        the recipient has any changenode we aren't sending them.

        common is the set of common nodes between remote and selfR�RjR�c


Ss|S(
N((
R�((s&/sys/lib/python/mercurial/localrepo.pyR��s
c
3s=x6|D].}
|i|
��jo
|i
|
�V
q
qWdS(
N(R;
Rn(tlogRN(
trevset(s&/sys/lib/python/mercurial/localrepo.pyt
gennodelst�s


c
s��fd
�}
|
S(Nc
s$�i|�}
�i
|
d
�
dS(Ni(R5Ry
(R�RX(R�R�(s&/sys/lib/python/mercurial/localrepo.pytcollect_changed_files�s

((R�R(
R�(
R�s&/sys/lib/python/mercurial/localrepo.pytchanged_file_collector�s
c
s��fd
�}
|
S(Nc

s�i�i
�i|���S(
N(RnR;
R�(
R�(R�R�(s&/sys/lib/python/mercurial/localrepo.pyt
lookuprevlink�s
((R�R(
R�(
R�s&/sys/lib/python/mercurial/localrepo.pytlookuprevlink_func�s
c3sh
t�}x(�i
���|��D]}
|
V
q%W�i}�|�}x%|i
|�|��D]}
|
V
qbWx�t|�D]�}�i|�}t|�p
titd
�|��n

�|�}t	|�}|oK
t
it|��V
|V
�|�}x#|i
||�D]}
|
V
q
Wq~
q~Wt
i�V
�o'
�i
ddt�d�d��
n

dS(Nsempty or missing revlog for %sR	RniR�(R4R
RZR�R�RbR R�RR�R�RRRhR
(R�R
R�tnodeiterR=
RR(R�RRJR�R�R�RR(s&/sys/lib/python/mercurial/localrepo.pyR�s6	


		


	













(	RhR.RRtfindmissingR4R�R�R R(RJR�R�R�R�R((	RR�RRJRRR�R�R�s&/sys/lib/python/mercurial/localrepo.pyR�ps		

0
	$cs���fd
�}�f
d�}|
p
dSn

�iddt
d|d|�
d}}}	�i��i�
t�i��}
�i�}z~ti|�}�i	i
td��
t��}
ti
|
�}�i|||�djo!
|o
titd	���n

t��}||
}�i	i
td
��
ti
|
�}�ii|||�
�i	i
td��
x�ti|
�}|p
Pn

�i	itd�|�
�i|�}t|�}ti
|
�}|i|||�djo
titd
���n

|	t|�|7}	|d7}qx
t�i��}d}|
o%
||
jo
td�||
}n

�i	i
td�||	||f�
|djoP
��fd�}�iddt
dt�i|
��d|d|d|�
n

�i|�
|i�
Wd~X|djo�
�i	itd��
�i�
�iddt�i|
��d|d|�
xIt|
|�D]4}�iddt�i|��d|d|�
q~Wn

||
jo
||
dSn

||
dSdS(s
add changegroup to repo.

        return values:
        - nothing changed or no source: 0
        - more heads than before: 1+added heads (2..n)
        - less heads than before: -1-removed heads (-2..-n)
        - number of heads stays the same: 1
        c

s*�ii
td
�t|��
t��S(Nsadd changeset %s
(R%R�RRRb(
R�(R�RJ(s&/sys/lib/python/mercurial/localrepo.pytcsmap�s
 
c

s
�i|�S(
N(
R�(
R�(
R�(s&/sys/lib/python/mercurial/localrepo.pytrevmap�s
itprechangegroupRjR�Rgsadding changesets
s!received changelog group is emptysadding manifests
sadding file changes
sadding %s revisions
s#received file revlog group is emptyi
Rls (%+d heads)s2added %d changesets with %d changes to %d files%s
c
s�i�o

�i
p
dS(
Rl(Rq
R((RJR�(s&/sys/lib/python/mercurial/localrepo.pyR��stpretxnchangegroupRnRs
Nsupdating the branch cache
R�tincoming(RhR.RRR{
RbR�R
R
Ru
R%R�RR�t	chunkitertaddgroupR>R R�RZtgetchunkR�R�R
RnR}
R1R�Rd(RJR�tsrctypeRgtemptyokR"R#t
changesetsRP
t	revisionstoldheadsR
R�tclstartR'tclendR�tflt
oR�R�RYRe((R�RJs&/sys/lib/python/mercurial/localrepo.pyR��sz	
	







$






























!


!


cCs�|
i�}|i
�}yt|�}Wn+tj
o



titd
�|��n
X|djo
titd���nM
|djo
titd���n'
|djo
titd���n

|i	i
td��
|i
�}y%tt|id	d��\}}Wn1tt
fj
o



titd
�|��n
X|i	i
td
�|ti|�f�
ti�}x�|�D]�|i
�}y(|idd�\}	}
t|
�}
Wn1tt
fj
o



titd
�|��n
X|i	itd�|	ti|
�f�
|iti|	�d
�}x*ti|d|
�
D]}|i|�
qMW|i�
q�Wti�|}
|
dj
o

d}
n

|i	i
td�ti|�|
ti||
�f�
|i�
t|i��dS(Ns'Unexpected response from remote server:i
soperation forbidden by serveris$locking the remote repository failedis%the server sent an unknown error codesstreaming all changes
R�s!%d files to transfer, %s of data
t
sadding %s (%s)
Rtlimitg�MbP?s(transferred %s in %.1f seconds (%s/sec)
(t
stream_outtreadlineR�R�R2t
ResponseErrorRR R�R%R�R�R�t	TypeErrort	bytecountttimeRdR�R;Rt	decodedirt
filechunkiterR0R1R
RbR�(RJR�RsR�trespttotal_filesttotal_bytesR�ReRitsizetofptchunktelapsed((s&/sys/lib/python/mercurial/localrepo.pyt	stream_ins\



















%














)













cCs@|o)
|o!
|
id
�o
|i
|
�Sn

|i|
|�S(s�clone remote repository.

        keyword arguments:
        heads: list of revs to clone (forces use of pull)
        stream: use streaming clone if possibletstream(R�RDR�(RJR�R�RE((s&/sys/lib/python/mercurial/localrepo.pytcloneMs

(Yt__name__t
__module__R4tcapabilitiesR�R9R>Rt
propertycacheRRRZR[R`RaRcRfRgR
RhR�R�RoR�R�R�R�R�R�R
R�R�R�R�RRpRR�R�R�R^R�R�R�R�R�R�R
R
R	
R
R
R
R 
R
R
R0
R.R
R!
RH
R�RZ
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�RDRF(((s&/sys/lib/python/mercurial/localrepo.pyRs�

T
					>			!	
																						
							K
dD		
i						�0
	p		
	�	Di	0c
s:g}
|D]}|
t|�q~
��f
d
�}|S(Ncs+x$�D]\}}
ti
||
�
qWdS(
N(R R�(tsrcR�(
trenamefiles(s&/sys/lib/python/mercurial/localrepo.pyRcs

(
ttuple(RP
R�R�R((
RLs&/sys/lib/python/mercurial/localrepo.pyR
as
'
cCst|t
id
|
�|�S(NR�(RR tdrop_scheme(R%RRK((s&/sys/lib/python/mercurial/localrepo.pytinstancehs
c


CstS(
N(
R.(
R((s&/sys/lib/python/mercurial/localrepo.pytislocalks
(+RnRR
RRRti18nRRR�RX
RRR[R�RZR\R
R
RR�R R'RhR2R}R�tmergeRU
R�R�RR
R�R7RR:R�RJRRR
RORP(((s&/sys/lib/python/mercurial/localrepo.pys<module>s.(

$
<
0
0




H
	����T