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
|
# (C) 2005 Canonical
# 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
"""Plugin to force-reweave the inventory of a branch.
This makes sure that the inventory weave's DAG of ancestry is correct so that
attempts to fetch the branch over http, or certain merge operations cope
correctly.
This is most likely needed if you have used fetch-ghosts from bzrlib to
resolve ghosts after a baz (or otherwise) import and you get bizarre behaviour
when either exporting over http or when merging from other translated branches.
"""
from bzrlib.commands import Command
from bzrlib.weavefile import write_weave_v5 as w5
import bzrlib.branch
import bzrlib.progress
import os
class cmd_fix(Command):
"""Force-reweave the inventory in this branch.
The branch URL *MUST* be on the local filesystem."""
takes_args = ['branch_dir?']
def run(self, branch_dir="."):
branch = bzrlib.branch.Branch.open(branch_dir)
branch.lock_write()
try:
self._do_reweave(branch, branch_dir)
finally:
branch.unlock()
@staticmethod
def _do_reweave(branch, branch_dir):
inventory_weave = branch._get_inventory_weave()
new_weave = bzrlib.weave.Weave()
pending = list(inventory_weave.iter_names())
total = len(pending)
progress = bzrlib.progress.ProgressBar()
while pending:
index = pending.pop(0)
done = total - len(pending)
progress.update('re-weaving', done, total)
rev = branch.get_revision(index)
parents = []
for parent in rev.parent_ids:
if parent in inventory_weave:
parents.append(parent)
unavailable = [p for p in parents if p not in new_weave]
if len(unavailable) == 0:
new_weave.add(index, parents, inventory_weave.get(index))
else:
pending.append(index)
progress.update('Writing weave')
out_file_name = os.path.join(branch_dir, ".bzr", "inventory.weave")
f = open(out_file_name+".tmp", "w")
w5(new_weave, f)
f.close()
os.rename(out_file_name+".tmp", out_file_name)
progress.clear()
|