Mercurial > hg > mercurial-crew-with-dirclash
comparison mercurial/transaction.py @ 582:df8a5a0098d4
Remove all remaining print statements
-----BEGIN PGP SIGNED MESSAGE-----
Hash: SHA1
Remove all remaining print statements
Convert most prints to ui.warn or ui.write
Pass a write function into transactions
manifest hash: d1b0af7a344fc087a5acfe3ae87b782c20d043e0
-----BEGIN PGP SIGNATURE-----
Version: GnuPG v1.4.0 (GNU/Linux)
iD8DBQFCx1Q3ywK+sNU5EO8RAqSTAJwM5t/m+JOlf2ZXOjuItCSdFiubcwCdFm3G
HoicikSYpTgfCj2pIRfyLjo=
=Loqo
-----END PGP SIGNATURE-----
author | mpm@selenic.com |
---|---|
date | Sat, 02 Jul 2005 18:57:59 -0800 |
parents | fbfbd4e506c3 |
children | 46a8dd3145cc 445970ccf57a |
comparison
equal
deleted
inserted
replaced
581:9db6d5455642 | 582:df8a5a0098d4 |
---|---|
13 | 13 |
14 import os | 14 import os |
15 import util | 15 import util |
16 | 16 |
17 class transaction: | 17 class transaction: |
18 def __init__(self, opener, journal, after = None): | 18 def __init__(self, report, opener, journal, after = None): |
19 self.journal = None | 19 self.journal = None |
20 | 20 |
21 # abort here if the journal already exists | 21 # abort here if the journal already exists |
22 if os.path.exists(journal): | 22 if os.path.exists(journal): |
23 raise "journal already exists - run hg recover" | 23 raise "journal already exists - run hg recover" |
24 | 24 |
25 self.report = report | |
25 self.opener = opener | 26 self.opener = opener |
26 self.after = after | 27 self.after = after |
27 self.entries = [] | 28 self.entries = [] |
28 self.map = {} | 29 self.map = {} |
29 self.journal = journal | 30 self.journal = journal |
55 self.journal = None | 56 self.journal = None |
56 | 57 |
57 def abort(self): | 58 def abort(self): |
58 if not self.entries: return | 59 if not self.entries: return |
59 | 60 |
60 print "transaction abort!" | 61 self.report("transaction abort!\n") |
61 | 62 |
62 for f, o in self.entries: | 63 for f, o in self.entries: |
63 try: | 64 try: |
64 self.opener(f, "a").truncate(o) | 65 self.opener(f, "a").truncate(o) |
65 except: | 66 except: |
66 print "failed to truncate", f | 67 self.report("failed to truncate %s\n" % f) |
67 | 68 |
68 self.entries = [] | 69 self.entries = [] |
69 | 70 |
70 print "rollback completed" | 71 self.report("rollback completed\n") |
71 | 72 |
72 def rollback(opener, file): | 73 def rollback(opener, file): |
73 for l in open(file).readlines(): | 74 for l in open(file).readlines(): |
74 f, o = l.split('\0') | 75 f, o = l.split('\0') |
75 opener(f, "a").truncate(int(o)) | 76 opener(f, "a").truncate(int(o)) |