�
�c@sldd
kl
Z

ddkZddkZddkZd�Zed�Zdef
d��YZ	d�Z
dS(i�(
t
_Nc
s�f
d
�}
|
S(Nc
s9|id
jo
t
itd���n

�||
|�S(Nis;cannot use transaction when it is already committed/aborted(tcountterrortAbortR(tselftargstkwds(
tfunc(s(/sys/lib/python/mercurial/transaction.pyt_actives

	

((RR((
Rs(/sys/lib/python/mercurial/transaction.pytactives
c
Cs�x�|D]�\}}}|p
|o?
y||d
�i|�
Wq�


|
t
d�|�
�q�Xq
y ||�i}ti|�
Wqtj
o#

}	
|	itijo
�q�
q
XqWti|�
dS(Nt
asfailed to truncate %s
(ttruncateRtnametostunlinktIOErrorterrnotENOENT(
tjournaltreporttopenertentriesRt
ft
otignoretfntinst((s(/sys/lib/python/mercurial/transaction.pyt	_playbacks












ttransactioncBs�eZ
ddd�Zd
�Zed��Zed��Zedd��Zed��Z	edd��Z
ed��Zd�Zed	��Z
ed
��Zd�ZRS(
cCs�d|_
d
|_|
|_||_||_g|_h|_||_
g|_t	|i
d�|_
|dj	o
ti|i
|d@�
n

dS(Ni
t
wi�(
tNoneRR
RRtafterRtmapt_queuetopentfileR
tchmod(RRRRRt
createmode((s(/sys/lib/python/mercurial/transaction.pyt__init__,s
		
	
	
	
	
	
	
	


c


Cs7|io)
|i
o
|i�
n

|ii�
n

dS(
N(RRt_abortR#tclose(
R((s(/sys/lib/python/mercurial/transaction.pyt__del__<s



c

Cs|ii
g�
dS(
N(R!tappend(
R((s(/sys/lib/python/mercurial/transaction.pyt
startgroupAsc
Cs||ii
�}
d
ig}|
D]}|d|d|dfq ~�}|ii|
�
|ii|�
|ii�
dS(Nts%s%d
ii
(R!tpoptjoinRtextendR#twritetflush(Rt
qt_[1]t
xt
d((s(/sys/lib/python/mercurial/transaction.pytendgroupEs

<


cCs�|
|ijo
dSn

|i
o%
|i
d
i|
||f�
dSn

|ii|
||f�
t|i�d|i|
<|iid|
|f�
|ii�
dS(Ni�i
s%s%d
(R R!R*RtlenR#R0R1(RR#toffsettdata((s(/sys/lib/python/mercurial/transaction.pytaddMs




cCs*|
|ijo
|i
|i|
Sn

dS(
N(R RR(RR#((s(/sys/lib/python/mercurial/transaction.pytfind[s

cCsn|
|ijo
t
|
��n

|i|
}|
||f|i|<|iid
|
|f�
|ii�
dS(sn
        replace can only replace already committed entries
        that are not pending in the queue
        s%s%d
N(R tKeyErrorRR#R0R1(RR#R8R9tindex((s(/sys/lib/python/mercurial/transaction.pytreplaceas





c

Cs|id
7_|S(Ni
(
R
(
R((s(/sys/lib/python/mercurial/transaction.pytnestos
c

Cs
|id
jS(Ni(
R
(
R((s(/sys/lib/python/mercurial/transaction.pytrunningts
c

Csr|id
8_|idjo
dSn

|i
i�
g|_|io
|i�
n
ti|i�
d|_dS(scommit the transactioni
iN(	R
R#R(RRR
RRR(
R((s(/sys/lib/python/mercurial/transaction.pyR(ws




	



c


Cs|i�
d
S(s�abort the transaction (generally called on error, or when the
        transaction is not explicitly committed before going out of
        scope)N(
R'(
R((s(/sys/lib/python/mercurial/transaction.pytabort�sc

Cs�d
|_|i
i�
|ip
dSn

|itd��
zZy9t|i|i|i|it	�
|itd��
Wn


|itd��
n
XWdd|_XdS(Nistransaction abort!
srollback completed
s(rollback failed - please run hg recover
(R
R#R(RRRRRRtFalseR(
R((s(/sys/lib/python/mercurial/transaction.pyR'�s
	



"


N(t__name__t
__module__RR&R)R	R+R6R:R;R>R?R@R(RAR'(((s(/sys/lib/python/mercurial/transaction.pyR+s
	



	cCskg}xKt|
�i
�D]7}|id
�\}}|i|t|�df�
qWt|
|||�
dS(Nt
(R"t	readlinestsplitR*tintRR(RR#RRt
lRR((s(/sys/lib/python/mercurial/transaction.pytrollback�s


 (ti18nRR
RRR	tTrueRtobjectRRJ(((s(/sys/lib/python/mercurial/transaction.pys<module>s

	s