�
Hq�Qc@s�dd
lm
Z
mZmZ
ddlmZ
ddlZddlZddlZddl	Z	i
dd6Z
d�Zd�Zd�Z
d	�Zd
ef
d��YZd�Zd
ejf
d��YZdS(i����(tbinthextnullid(
t
_Ntdefaulttbranchc

Cs:|jd
d�jdd�jdd�}|jdd�S(	s

    >>> d = {'nl': chr(10), 'bs': chr(92), 'cr': chr(13), 'nul': chr(0)}
    >>> s = "ab%(nl)scd%(bs)s%(bs)sn%(nul)sab%(cr)scd%(bs)s%(nl)s" % d
    >>> s
    'ab\ncd\\\\n\x00ab\rcd\\\n'
    >>> res = _string_escape(s)
    >>> s == res.decode('string_escape')
    True
    s
\s\\s

s\ns

s\rt
s\0(
treplace(
ttext((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyt_string_escapes*
c
Cs�tj
�}
x�|jd
�
D]}|rd|krm|jdd�}|jdd
�}|jdd�}n|jd�
jdd	�\}}||
|<qqW|
S(
s�

    >>> sorted(decodeextra(encodeextra({'foo': 'bar', 'baz': chr(0) + '2'})
    ...                    ).iteritems())
    [('baz', '\x002'), ('branch', 'default'), ('foo', 'bar')]
    >>> sorted(decodeextra(encodeextra({'foo': 'bar',
    ...                                 'baz': chr(92) + chr(0) + '2'})
    ...                    ).iteritems())
    [('baz', '\\\x002'), ('branch', 'default'), ('foo', 'bar')]
    Rs\0s\\s\\
s

tt
string_escapet
:i
(t
_defaultextratcopytsplitRtdecode(Rtextrat
lt
kt
v((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytdecodeextras






!

c
Cs@gt|�
D] }
t
d
|
||
f�
^q
}dj|�
S(Ns%s:%sR(tsortedR	tjoin(t
dRtitems((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytencodeextra2s3
c
Cs5d
jg|j
�D]}
|
j�^q�
jd
�
S(s>strip trailing whitespace and leading and trailing empty liness

(Rt
splitlinestrstriptstrip(tdescR((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyt	stripdesc7stappendercBs\eZ
dZd
�Zd�Zd�Zd�Zd�Zdd�
Zdd	�
Z	d
�Z
RS(s`the changelog index must be updated last on disk, so we use this class
    to delay writes to itcCs:||_|
|_
|
j�|_tj|
�
j|_dS(
N(tdatatfpttelltoffsettutiltfstattst_sizetsize(tselfR"tbuf((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyt__init__>s
	
	

c

Cs|jt
d
j|j�
�
S(NR
(R(tlenRR!(
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytendDs
c


Cs|jS(
N(
R$(
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR#Fs
c


CsdS(
N((
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytflushHs
c


Cs|jj
�
dS(
N(R"tclose(
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR/Js
icCs�|d
kr|
|_n@|dkr6|j|
7_n"|dkrX|j
�|
|_n|j|jkr�|jj|j�

ndS(s,virtual file offset spans real file and dataii
iN(R$R-R(R"tseek(R)R$twhence((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR0Ms






i����cCs�d
}|j|j
krg|jj|
�
}|}|jt|�
7_|
dkrg|
t|�
8}
qgn|
dkr�|j|j
}|jjdd
j|j�
�
|jd3|jd|||
!}|jt|�
7_||7}n|S(s5only trick here is reads that span real file and dataR
ii
(R$R(R"treadR,R!tinsertR(R)tcounttrett
stdoff((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR2Xs















cCs/|jj
t|
�
�

|jt|
�
7_dS(
N(R!tappendtstrR$R,(R)R6((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytwritejs

(t__name__t
__module__t__doc__R+R-R#R.R/R0R2R:(((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR ;s
					csd
��
��fd�
}|S(Nt
rcsR|�kr�||
�S�
r<�|d
|
jdd��St
�||
���S(Ns.at
at
w(RR (tnametmode(R*tdiverttopenerttarget(s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyt
oos





((RDRERCR*RF((R*RCRDREs9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytdelayopenerns
t	changelogcBs�eZ
d�Zd
�Zd�Zddd�Zejd��
Z	d�Z
d�Zd�Zd	�Z
d
�Zd�Zd�Zd
�Zd�Zd�Zd�Zd�Zdd�
Zd�Zddd�Zd�ZRS(cCsitjj
||
d
�
|jr>|jtjM_t|_n|
|_t|_t|_	t
�|_dS(Ns
00changelog.i(trevlogR+t
_initemptytversiontREVLOGGENERALDELTAtFalset
_generaldeltat_realopenert_delayedt_divertt	frozensettfilteredrevs(R)RD((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR+ys

	

	
	
	
c
CsGx@tt
|�
d
dd�D]"}
|
|jkr|j|
�
SqWdS(sfiltered version of revlog.tipi
i����i����N(txrangeR,RStnode(R)t
i((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyttip�s#

c
s;t�j
�
d
kr%tjj��
S�f
d�}
|
�S(s#filtered version of revlog.__iter__ic
3s8x1tt
��
�
D]}|�jkr|V
qqWdS(
N(RTR,RS(
RV(
R)(s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytfilterediter�s


(R,RSRIt__iter__(R)RX((
R)s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRY�s
iccsAx:tt
|�j|
|�D]}||jkr|V
qqWd
S(sfiltered version of revlog.revsN(tsuperRHtrevsRS(R)tstarttstopRV((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR[�s"

c

Cs|j|j
d
�
�

|jS(Ni(trevRUt
_nodecache(
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytnodemap�s
cCs9y |j|
�
}||j
kSWntk
r4


tSXd
S(s"filtered version of revlog.hasnodeN(R^RStKeyErrorRM(R)RURV((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pythasnode�s





c

Cs&|jr|j
�Stt|�j�S(
N(RSt	_headrevsRZRHtheadrevs(
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRd�s
	

c
Os-|jst
�
tt|�j|
|�
dS(
N(RStAssertionErrorRZRHR(R)targstkwargs((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR�s
cCsRtt
|�j|
�
}||jkrNtjt|
�
|jtd
�
��
n|S(sfiltered version of revlog.revsno node(	RZRHR^RSterrortLookupErrorR
t	indexfileR(R)RUR>((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR^�s

'
cCs4|
|jkrt
|
�
�
ntt|�j|
�
S(
sfiltered version of revlog.node(RSt
IndexErrorRZRHRU(R)R^((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRU�s

cCs4|
|jkrt
|
�
�
ntt|�j|
�
S(
s"filtered version of revlog.linkrev(RSRkRZRHtlinkrev(R)R^((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRl�s

cCs4|
|jkrt
|
�
�
ntt|�j|
�
S(
s%filtered version of revlog.parentrevs(RSRkRZRHt
parentrevs(R)R^((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRm�s

cCs4|
|jkrt
|
�
�
ntt|�j|
�
S(
s filtered version of revlog.flags(RSRkRZRHtflags(R)R^((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRn�s

c

CsOt|_
t|�
d
k|_g|_t|j|j|j|j�|_dS(s2delay visibility of index updates to other readersiN(	tTrueRPR,RQt	_delaybufRGRORjRD(
R)((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytdelayupdate�s
	

	

cCs�t|_
|j|_|jr^|j|jd
�
}|j}|j�
tj	||d �
nM|j
r�|j|jd�}|jdj|j
�
�

|j�
g|_
n|j
|
�

dS(sfinalize index updatess.ai����R?R
N(RMRPRORDRQRjRAR/R%trenameRpR:Rtcheckinlinesize(R)ttrtnfilet
nR"((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytfinalize�s	
	

	



	




cCsItj|j
|
�}|j|_|j|_|j|_|j|_dS(
N(RIRDtindexR`R_t_chunkcache(R)tfileR>((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytreadpending�s





c
Cs�|jr|j
|j�
}
|j
|jd
d�}|j|
j��

|jdj|j�
�

|j�
g|_t|_n|jr�tSt	S(sDcreate a file containing the unfinalized state for pretxnchangegroups.aR@R
(
RpRORjR:R2RR/RoRQRM(R)tfp1tfp2((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytwritepending�s	



	
	
cCs&|js"t
j
j||
|�
ndS(
N(RPRIRs(R)RtR"((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRs	
s
	
c
CsM
|j|
�
}|s+t
d
d	gd
tfS|jd�
}tj||d�
}|| jd�
}t|d�
}tj|d�
}|djdd�}t|�
dkr�t	|d�
}	yt
|d�
}
Wntk
r�


d}
n
Xt}n1t	|d�
t
|d�
}	}
t|d�
}|d}|||	|
f|||fS(
s�

        format used:
        nodeid
        : manifest node in ascii
        user
          : user, no 
 or 
 allowed
        time tz extra
 : date (time is int or float, timezone is int)
                        : extra is metadata, encoded and separated by ''
                        : older versions ignore it
        files

       : files modified by the cset, no 
 or 
 allowed
        (.*)            : comment (free text, ideally utf-8)

        changelog v0 doesn't use extra
        R
is

is

i
t
 i(ii(
trevisionRR
RxtencodingttolocalRRR,tfloattintt
ValueErrorR(
R)RURtlastRRtmanifesttuserttdatattimettimezoneRtfiles((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyR2

s(















	!


c
Cs�
tj
|�
tj
|�
}}|j�}|sItjtd
�
�
�
nd|krwtjtd�
t|�
�
�
nt|�
}|r�dtj	|�
}
ndtj
�}
|	r
|	jd�
}|d
kr�|	d=q
|dkr
tjtd�
|�
�
q
n|	r*
t|	�
}	d|
|	f}
nt
|
�
||
gt|�
d|g}dj|�
}
|j|
|t|�
||�S(Nsempty usernames

susername %s contains a newlines%d %dRRR
t
.tnullRWsthe name '%s' is reserveds%s %s(sdefaultR
(R�R�stip(R�t	fromlocalRRhtRevlogErrorRtreprRR%t	parsedatetmakedatetgetRR
RRtaddrevisionR,(R)R�R�Rttransactiontp1tp2R�tdateRt
parseddateRRR((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pytadd3
s0
















)

cCs#tj
|j|
�
d
jd�
�
S(s�return the branch of a revision

        This function exists because creating a changectx object
        just to access this is costly.iR(R�R�R2R�(R)R^((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRX
sN(R;R<R+RWRYtNoneR[R%t
propertycacheR`RbRdRR^RURlRmRnRqRwR{R~RsR2R�R(((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyRHxs*
																'$(RURR
Rti18nRR%RhRIR�R
R	RRRtobjectR RGRH(((s9/usr/lib64/python2.7/site-packages/mercurial/changelog.pyt<module>s

0
				3