1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
# Copyright (C) 2004, 2005 by Martin Pool
# Copyright (C) 2005 by Canonical Ltd
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
def upgrade(branch):
"""
Upgrade branch to current format.
This causes objects to be rewritten into the current format.
If they change, their SHA-1 will of course change, which might
break any later signatures, or backreferences that check the
SHA-1.
TODO: Check non-mainline revisions.
"""
import sys
from bzrlib.trace import mutter
from bzrlib.errors import BzrCheckError
from bzrlib.progress import ProgressBar
branch.lock_write()
try:
pb = ProgressBar(show_spinner=True)
last_rev_id = None
history = branch.revision_history()
revno = 0
revcount = len(history)
updated_revisions = []
# Set to True in the case that the previous revision entry
# was updated, since this will affect future revision entries
updated_previous_revision = False
for rev_id in history:
revno += 1
pb.update('upgrading revision', revno, revcount)
rev = branch.get_revision(rev_id)
if rev.revision_id != rev_id:
raise BzrCheckError('wrong internal revision id in revision {%s}'
% rev_id)
last_rev_id = rev_id
# if set to true, revision must be written out
updated = False
if rev.inventory_sha1 is None:
rev.inventory_sha1 = branch.get_inventory_sha1(rev.inventory_id)
updated = True
mutter(" set inventory_sha1 on {%s}" % rev_id)
for prr in rev.parents:
actual_sha1 = branch.get_revision_sha1(prr.revision_id)
if (updated_previous_revision
or prr.revision_sha1 is None):
if prr.revision_sha1 != actual_sha1:
prr.revision_sha1 = actual_sha1
updated = True
elif actual_sha1 != prr.revision_sha1:
raise BzrCheckError("parent {%s} of {%s} sha1 mismatch: "
"%s vs %s"
% (prr.revision_id, rev_id,
actual_sha1, prr.revision_sha1))
if updated:
updated_previous_revision = True
# We had to update this revision entries hashes
# Now we need to write out a new value
# This is a little bit invasive, since we are *rewriting* a
# revision entry. I'm not supremely happy about it, but
# there should be *some* way of making old entries have
# the full meta information.
import tempfile, os, errno
from bzrlib.xml import pack_xml
rev_tmp = tempfile.TemporaryFile()
pack_xml(rev, rev_tmp)
rev_tmp.seek(0)
tmpfd, tmp_path = tempfile.mkstemp(prefix=rev_id, suffix='.gz',
dir=branch.controlfilename('revision-store'))
os.close(tmpfd)
def special_rename(p1, p2):
if sys.platform == 'win32':
try:
os.remove(p2)
except OSError, e:
if e.errno != errno.ENOENT:
raise
os.rename(p1, p2)
try:
# TODO: We may need to handle the case where the old revision
# entry was not compressed (and thus did not end with .gz)
# Remove the old revision entry out of the way
rev_path = branch.controlfilename(['revision-store', rev_id+'.gz'])
special_rename(rev_path, tmp_path)
branch.revision_store.add(rev_tmp, rev_id) # Add the new one
os.remove(tmp_path) # Remove the old name
mutter(' Updated revision entry {%s}' % rev_id)
except:
# On any exception, restore the old entry
special_rename(tmp_path, rev_path)
raise
rev_tmp.close()
updated_revisions.append(rev_id)
else:
updated_previous_revision = False
finally:
branch.unlock()
pb.clear()
if updated_revisions:
print '%d revisions updated to current format' % len(updated_revisions)
|