�
�c	@s�dd
kl
Z
lZlZ
ddklZ
ddkZddkZddkZddk	Z	d�Z
d�Zd�Zde
f
d��YZd	�Zd
eif
d��YZdS(i�(tbinthextnullid(
t
_Nc

Cs:|id
d�idd�idd�}|idd�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((s&/sys/lib/python/mercurial/changelog.pyt_string_escapes*
c
CsZh}
xM|id
�D]<}|o/
|i
d�idd�\}}||
|<q
qW|
S(NRt
string_escapet
:i
(tsplittdecode(Rtextrat
lt
kt
v((s&/sys/lib/python/mercurial/changelog.pytdecodeextras



!

c
CsHg}
t|�D]!}|
t
d
|||f�q~
}di|�S(Ns%s:%sR(tsortedRtjoin(t
dt_[1]Rtitems((s&/sys/lib/python/mercurial/changelog.pytencodeextra"s;
tappendercBs\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:||_|
|_
|
i�|_ti|
�i|_dS(
N(tdatatfpttelltoffsettutiltfstattst_sizetsize(tselfRtbuf((s&/sys/lib/python/mercurial/changelog.pyt__init__*s
	
	

c

Cs|it
d
i|i��S(Nt(RtlenRR(
R ((s&/sys/lib/python/mercurial/changelog.pytend0s
c


Cs|iS(
N(
R(
R ((s&/sys/lib/python/mercurial/changelog.pyR2s
c


CsdS(
N((
R ((s&/sys/lib/python/mercurial/changelog.pytflush4s
c


Cs|ii
�
dS(
N(Rtclose(
R ((s&/sys/lib/python/mercurial/changelog.pyR'6s
icCs�|d
jo

|
|_nE
|djo
|i|
7_n%
|djo
|i
�|
|_n

|i|ijo
|ii|i�
n

dS(s,virtual file offset spans real file and dataii
iN(RR%RRtseek(R Rtwhence((s&/sys/lib/python/mercurial/changelog.pyR(9s










i�cCs�d
}|i|i
joR
|ii|
�}|}|it|�7_|
djo
|
t|�8}
qk
n

|
djot
|i|i
}|iidd
i|i��
|id3|id|||
!}|it|�7_||7}n

|S(s5only trick here is reads that span real file and dataR#ii
(RRRtreadR$RtinsertR(R tcounttrett
stdoff((s&/sys/lib/python/mercurial/changelog.pyR*Ds
















cCs/|ii
t|
��
|it|
�7_dS(
N(RtappendtstrRR$(R R.((s&/sys/lib/python/mercurial/changelog.pytwriteVs

(t__name__t
__module__t__doc__R"R%RR&R'R(R*R2(((s&/sys/lib/python/mercurial/changelog.pyR's
					csd
����fd�}|S(Nt
rcs\|�jo
�||
�Sn

�o!
�|d
|
idd��Sn

t
�||
���S(Ns.at
at
w(RR(tnametmode(ttargettopenertdivertR!(s&/sys/lib/python/mercurial/changelog.pyt
o[s





!((R<R;R=R!R>((R=R<R!R;s&/sys/lib/python/mercurial/changelog.pytdelayopenerZs
t	changelogcBsYeZ
d�Zd
�Zd�Zd�Zd�Zdd�Zd�Z	dhd�Z
RS(	cCs5tii
||
d
�
|
|_t|_t|_dS(Ns
00changelog.i(trevlogR"t_realopenertFalset_delayedt_divert(R R<((s&/sys/lib/python/mercurial/changelog.pyR"es

	
	
c

CsOt|_
t|�d
j|_g|_t|i|i|i|i�|_dS(s2delay visibility of index updates to other readersiN(	tTrueRDR$REt	_delaybufR?RBt	indexfileR<(
R ((s&/sys/lib/python/mercurial/changelog.pytdelayupdateks
	

	

cCs�t|_
|i|_|io1
|i|id
�i}ti||d �
nP
|i	oE
|i|id�}|i
di|i	��
|i�
g|_	n

|i
|
�
dS(sfinalize index updatess.ai�R7R#N(RCRDRBR<RERHR9RtrenameRGR2RR'tcheckinlinesize(R ttrt
nR((s&/sys/lib/python/mercurial/changelog.pytfinalizess	











cCs=ti|i
|
�}|i|_|i|_|i|_dS(
N(RAR<tindextnodemapt_chunkcache(R tfileR6((s&/sys/lib/python/mercurial/changelog.pytreadpending�s



c
Cs�|iow
|i
|i�}
|i
|id
d�}|i|
i��
|idi|i��
|i�
g|_t|_n

|io
tSn

t	S(sDcreate a file containing the unfinalized state for pretxnchangegroups.aR8R#(
RGRBRHR2R*RR'RFRERC(R tfp1tfp2((s&/sys/lib/python/mercurial/changelog.pytwritepending�s




	



cCs(|ip
t
i
i||
|�
n

dS(
N(RDRARK(R RLR((s&/sys/lib/python/mercurial/changelog.pyRK�s


c
Csy
|i|
�}|p#
t
d
dgd
hdd<fSn

|id�}ti||d�}|| id�}t|d�}ti|d�}|did	d�}t|�d
joC
t|i	d��}	yt
|d�}
Wn



d}
n
Xh}n5
|\}	}
}t|	�t
|
�}	}
t|�}|id�p
d|d<n

|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 metadatas, 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#itdefaulttbranchs

is

i
t
 i(ii(
trevisionRROtencodingttolocalR
RR$tfloattpoptintRtget(
R tnodeRtlasttdescR
tmanifesttusert
extra_datattimettimezoneRtfiles((s&/sys/lib/python/mercurial/changelog.pyR*�s.


#



















c
Cs�|i�}|p
t
itd
���n

d|jo#
t
itd�t|���n

dig}
|i�D]}|
|i�qs~
�id�}ti	|�ti	|�}}|o
dt
i|�}n
dt
i�}|	o!
|	i
d�d	jo
|	d=n

|	o 
t|	�}	d||	f}n

t|
�||gt|�d|g}di|�}
|i|
|t|�||�S(
Nsempty usernames

susername %s contains a newlines%d %dRXRWR#s%s %s(sdefaultR#(tstripterrortRevlogErrorRtreprRt
splitlinestrstripR[t	fromlocalRt	parsedatetmakedateR`RR
RtaddrevisionR$(R RdRiRcttransactiontp1tp2RetdateRRR
t
parseddateR((s&/sys/lib/python/mercurial/changelog.pytadd�s&




?






)

N(R3R4R"RIRNRSRVtNoneRKR*Ry(((s&/sys/lib/python/mercurial/changelog.pyR@ds
						)(RaRR
Rti18nRRRkRAR[RRRtobjectRR?R@(((s&/sys/lib/python/mercurial/changelog.pys<module>s

0			3