��c@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((s7/sys/lib/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((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pytdecodeextras






!

c
Cs@gt|�D] }
t
d
|
||
f�^q
}dj|�S(Ns%s:%sR(tsortedR	tjoin(t
dRtitems((s7/sys/lib/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((s7/sys/lib/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((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyt__init__>s
	
	

c

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


Cs|jS(
N(
R$(
R)((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyR#Fs
c


CsdS(
N((
R)((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pytflushHs
c


Cs|jj
�
dS(
N(R"tclose(
R)((s7/sys/lib/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((s7/sys/lib/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((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyR2Xs















cCs/|jj
t|
��
|jt|
�7_dS(
N(R!tappendtstrR$R,(R)R6((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pytwritejs

(t__name__t
__module__t__doc__R+R-R#R.R/R0R2R:(((s7/sys/lib/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(s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyt
oos





((RDRERCR*RF((R*RCRDREs7/sys/lib/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((s7/sys/lib/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((s7/sys/lib/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)(s7/sys/lib/python2.7/site-packages/mercurial/changelog.pytfilterediter�s


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

c

Cs|j|j
d
��
|jS(Ni(trevRUt
_nodecache(
R)((s7/sys/lib/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((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pythasnode�s





c

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

c
Os-|jst
�tt|�j|
|�
dS(
N(RStAssertionErrorRZRHR(R)targstkwargs((s7/sys/lib/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>((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyR^�s

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

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

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

cCs4|
|jkrt
|
��ntt|�j|
�S(
s filtered version of revlog.flags(RSRkRZRHtflags(R)R^((s7/sys/lib/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)((s7/sys/lib/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"((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pytfinalize�s	
	

	



	




cCsItj|j
|
�}|j|_|j|_|j|_|j|_dS(
N(RIRDtindexR`R_t_chunkcache(R)tfileR>((s7/sys/lib/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((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pytwritepending�s	



	
	
cCs&|js"t
j
j||
|�
ndS(
N(RPRIRs(R)RtR"((s7/sys/lib/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�|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((s7/sys/lib/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((s7/sys/lib/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^((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyRX
sN(R;R<R+RWRYtNoneR[R%t
propertycacheR`RbRdRR^RURlRmRnRqRwR{R~RsR2R�R(((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyRHxs*
																'$(RURR
Rti18nRR%RhRIR�R
R	RRRtobjectR RGRH(((s7/sys/lib/python2.7/site-packages/mercurial/changelog.pyt<module>s

0
				3