~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/merge.py

  • Committer: Martin Pool
  • Date: 2005-05-15 02:36:04 UTC
  • Revision ID: mbp@sourcefrog.net-20050515023603-7328f6cbabd2b09a
- Merge aaron's merge command

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
from bzrlib.merge_core import merge_flex, ApplyMerge3, BackupBeforeChange
2
 
from bzrlib.changeset import generate_changeset, ExceptionConflictHandler
3
 
from bzrlib.changeset import Inventory, Diff3Merge
4
 
from bzrlib import find_branch
 
1
from merge_core import merge_flex
 
2
from changeset import generate_changeset, ExceptionConflictHandler
 
3
from changeset import Inventory
 
4
from bzrlib import Branch
5
5
import bzrlib.osutils
6
 
from bzrlib.errors import BzrCommandError
7
 
from bzrlib.delta import compare_trees
8
 
from trace import mutter, warning
 
6
from trace import mutter
9
7
import os.path
10
8
import tempfile
11
9
import shutil
12
10
import errno
13
11
 
14
 
 
15
 
# comments from abentley on irc: merge happens in two stages, each
16
 
# of which generates a changeset object
17
 
 
18
 
# stage 1: generate OLD->OTHER,
19
 
# stage 2: use MINE and OLD->OTHER to generate MINE -> RESULT
20
 
 
21
 
class UnrelatedBranches(BzrCommandError):
22
 
    def __init__(self):
23
 
        msg = "Branches have no common ancestor, and no base revision"\
24
 
            " specified."
25
 
        BzrCommandError.__init__(self, msg)
26
 
 
27
 
 
28
12
class MergeConflictHandler(ExceptionConflictHandler):
29
 
    """Handle conflicts encountered while merging.
30
 
 
31
 
    This subclasses ExceptionConflictHandler, so that any types of
32
 
    conflict that are not explicitly handled cause an exception and
33
 
    terminate the merge.
34
 
    """
35
 
    def __init__(self, dir, ignore_zero=False):
36
 
        ExceptionConflictHandler.__init__(self, dir)
37
 
        self.conflicts = 0
38
 
        self.ignore_zero = ignore_zero
39
 
 
 
13
    """Handle conflicts encountered while merging"""
40
14
    def copy(self, source, dest):
41
15
        """Copy the text and mode of a file
42
16
        :param source: The path of the file to copy
61
35
        new_name = last_new_name+suffix
62
36
        try:
63
37
            os.rename(name, new_name)
64
 
            return new_name
65
38
        except OSError, e:
66
39
            if e.errno != errno.EEXIST and e.errno != errno.ENOTEMPTY:
67
40
                raise
68
 
            return self.add_suffix(name, suffix, last_new_name=new_name)
69
 
 
70
 
    def conflict(self, text):
71
 
        warning(text)
72
 
        self.conflicts += 1
73
 
        
 
41
            self.add_suffix(name, suffix, last_new_name=new_name)
74
42
 
75
43
    def merge_conflict(self, new_file, this_path, base_path, other_path):
76
44
        """
85
53
        self.copy(base_path, this_path+".BASE")
86
54
        self.copy(other_path, this_path+".OTHER")
87
55
        os.rename(new_file, this_path)
88
 
        self.conflict("Diff3 conflict encountered in %s" % this_path)
89
 
 
90
 
    def new_contents_conflict(self, filename, other_contents):
91
 
        """Conflicting contents for newly added file."""
92
 
        self.copy(other_contents, filename + ".OTHER")
93
 
        self.conflict("Conflict in newly added file %s" % filename)
94
 
    
95
56
 
96
57
    def target_exists(self, entry, target, old_path):
97
58
        """Handle the case when the target file or dir exists"""
98
 
        moved_path = self.add_suffix(target, ".moved")
99
 
        self.conflict("Moved existing %s to %s" % (target, moved_path))
100
 
 
101
 
    def rmdir_non_empty(self, filename):
102
 
        """Handle the case where the dir to be removed still has contents"""
103
 
        self.conflict("Directory %s not removed because it is not empty"\
104
 
            % filename)
105
 
        return "skip"
106
 
 
107
 
    def finalize(self):
108
 
        if not self.ignore_zero:
109
 
            print "%d conflicts encountered.\n" % self.conflicts
 
59
        self.add_suffix(target, ".moved")
110
60
            
111
 
class SourceFile(object):
 
61
class SourceFile:
112
62
    def __init__(self, path, id, present=None, isdir=None):
113
63
        self.path = path
114
64
        self.id = id
120
70
        return "SourceFile(%s, %s)" % (self.path, self.id)
121
71
 
122
72
def get_tree(treespec, temp_root, label):
123
 
    location, revno = treespec
124
 
    branch = find_branch(location)
 
73
    dir, revno = treespec
 
74
    branch = Branch(dir)
125
75
    if revno is None:
126
76
        base_tree = branch.working_tree()
127
77
    elif revno == -1:
130
80
        base_tree = branch.revision_tree(branch.lookup_revision(revno))
131
81
    temp_path = os.path.join(temp_root, label)
132
82
    os.mkdir(temp_path)
133
 
    return branch, MergeTree(base_tree, temp_path)
 
83
    return MergeTree(base_tree, temp_path)
134
84
 
135
85
 
136
86
def abspath(tree, file_id):
145
95
def inventory_map(tree):
146
96
    inventory = {}
147
97
    for file_id in tree.inventory:
 
98
        if not file_exists(tree, file_id):
 
99
            continue
148
100
        path = abspath(tree, file_id)
149
101
        inventory[path] = SourceFile(path, file_id)
150
102
    return inventory
163
115
        os.mkdir(os.path.join(self.tempdir, "texts"))
164
116
        self.cached = {}
165
117
 
166
 
    def __contains__(self, file_id):
167
 
        return id in self.tree
168
 
 
169
 
    def get_file_sha1(self, id):
170
 
        return self.tree.get_file_sha1(id)
171
 
 
172
118
    def readonly_path(self, id):
173
 
        if id not in self.tree:
174
 
            return None
175
119
        if self.root is not None:
176
120
            return self.tree.abspath(self.tree.id2path(id))
177
121
        else:
185
129
                self.cached[id] = path
186
130
            return self.cached[id]
187
131
 
188
 
 
189
 
 
190
 
def merge(other_revision, base_revision,
191
 
          check_clean=True, ignore_zero=False,
192
 
          this_dir=None, backup_files=False, merge_type=ApplyMerge3,
193
 
          file_list=None):
194
 
    """Merge changes into a tree.
195
 
 
196
 
    base_revision
197
 
        Base for three-way merge.
198
 
    other_revision
199
 
        Other revision for three-way merge.
200
 
    this_dir
201
 
        Directory to merge changes into; '.' by default.
202
 
    check_clean
203
 
        If true, this_dir must have no uncommitted changes before the
204
 
        merge begins.
205
 
    """
 
132
def merge(other_revision, base_revision):
206
133
    tempdir = tempfile.mkdtemp(prefix="bzr-")
207
134
    try:
208
 
        if this_dir is None:
209
 
            this_dir = '.'
210
 
        this_branch = find_branch(this_dir)
211
 
        if check_clean:
212
 
            changes = compare_trees(this_branch.working_tree(), 
213
 
                                    this_branch.basis_tree(), False)
214
 
            if changes.has_changed():
215
 
                raise BzrCommandError("Working tree has uncommitted changes.")
216
 
        other_branch, other_tree = get_tree(other_revision, tempdir, "other")
217
 
        if base_revision == [None, None]:
218
 
            if other_revision[1] == -1:
219
 
                o_revno = None
220
 
            else:
221
 
                o_revno = other_revision[1]
222
 
            base_revno = this_branch.common_ancestor(other_branch, 
223
 
                                                     other_revno=o_revno)[0]
224
 
            if base_revno is None:
225
 
                raise UnrelatedBranches()
226
 
            base_revision = ['.', base_revno]
227
 
        base_branch, base_tree = get_tree(base_revision, tempdir, "base")
228
 
        if file_list is None:
229
 
            interesting_ids = None
230
 
        else:
231
 
            interesting_ids = set()
232
 
            this_tree = this_branch.working_tree()
233
 
            for fname in file_list:
234
 
                path = this_branch.relpath(fname)
235
 
                found_id = False
236
 
                for tree in (this_tree, base_tree.tree, other_tree.tree):
237
 
                    file_id = tree.inventory.path2id(path)
238
 
                    if file_id is not None:
239
 
                        interesting_ids.add(file_id)
240
 
                        found_id = True
241
 
                if not found_id:
242
 
                    raise BzrCommandError("%s is not a source file in any"
243
 
                                          " tree." % fname)
244
 
        merge_inner(this_branch, other_tree, base_tree, tempdir, 
245
 
                    ignore_zero=ignore_zero, backup_files=backup_files, 
246
 
                    merge_type=merge_type, interesting_ids=interesting_ids)
 
135
        this_branch = Branch('.') 
 
136
        other_tree = get_tree(other_revision, tempdir, "other")
 
137
        base_tree = get_tree(base_revision, tempdir, "base")
 
138
        merge_inner(this_branch, other_tree, base_tree, tempdir)
247
139
    finally:
248
140
        shutil.rmtree(tempdir)
249
141
 
250
142
 
251
 
def set_interesting(inventory_a, inventory_b, interesting_ids):
252
 
    """Mark files whose ids are in interesting_ids as interesting
253
 
    """
254
 
    for inventory in (inventory_a, inventory_b):
255
 
        for path, source_file in inventory.iteritems():
256
 
             source_file.interesting = source_file.id in interesting_ids
257
 
 
258
 
 
259
 
def generate_cset_optimized(tree_a, tree_b, inventory_a, inventory_b,
260
 
                            interesting_ids=None):
261
 
    """Generate a changeset.  If interesting_ids is supplied, only changes
262
 
    to those files will be shown.  Metadata changes are stripped.
 
143
def generate_cset_optimized(tree_a, tree_b, inventory_a, inventory_b):
 
144
    """Generate a changeset, using the text_id to mark really-changed files.
 
145
    This permits blazing comparisons when text_ids are present.  It also
 
146
    disables metadata comparison for files with identical texts.
263
147
    """ 
264
 
    if interesting_ids is not None:
265
 
        set_interesting(inventory_a, inventory_b, interesting_ids)
 
148
    for file_id in tree_a.tree.inventory:
 
149
        if file_id not in tree_b.tree.inventory:
 
150
            continue
 
151
        entry_a = tree_a.tree.inventory[file_id]
 
152
        entry_b = tree_b.tree.inventory[file_id]
 
153
        if (entry_a.kind, entry_b.kind) != ("file", "file"):
 
154
            continue
 
155
        if None in (entry_a.text_id, entry_b.text_id):
 
156
            continue
 
157
        if entry_a.text_id != entry_b.text_id:
 
158
            continue
 
159
        inventory_a[abspath(tree_a.tree, file_id)].interesting = False
 
160
        inventory_b[abspath(tree_b.tree, file_id)].interesting = False
266
161
    cset =  generate_changeset(tree_a, tree_b, inventory_a, inventory_b)
267
162
    for entry in cset.entries.itervalues():
268
163
        entry.metadata_change = None
269
164
    return cset
270
165
 
271
166
 
272
 
def merge_inner(this_branch, other_tree, base_tree, tempdir, 
273
 
                ignore_zero=False, merge_type=ApplyMerge3, backup_files=False,
274
 
                interesting_ids=None):
275
 
 
276
 
    def merge_factory(base_file, other_file):
277
 
        contents_change = merge_type(base_file, other_file)
278
 
        if backup_files:
279
 
            contents_change = BackupBeforeChange(contents_change)
280
 
        return contents_change
281
 
    
282
 
    def generate_cset(tree_a, tree_b, inventory_a, inventory_b):
283
 
        return generate_cset_optimized(tree_a, tree_b, inventory_a, inventory_b,
284
 
                                       interesting_ids)
285
 
 
286
 
    this_tree = get_tree((this_branch.base, None), tempdir, "this")[1]
 
167
def merge_inner(this_branch, other_tree, base_tree, tempdir):
 
168
    this_tree = get_tree(('.', None), tempdir, "this")
287
169
 
288
170
    def get_inventory(tree):
289
171
        return tree.inventory
290
172
 
291
173
    inv_changes = merge_flex(this_tree, base_tree, other_tree,
292
 
                             generate_cset, get_inventory,
293
 
                             MergeConflictHandler(base_tree.root,
294
 
                                                  ignore_zero=ignore_zero),
295
 
                             merge_factory=merge_factory)
 
174
                             generate_cset_optimized, get_inventory,
 
175
                             MergeConflictHandler(base_tree.root))
296
176
 
297
177
    adjust_ids = []
298
178
    for id, path in inv_changes.iteritems():
303
183
                assert path.startswith('./')
304
184
            path = path[2:]
305
185
        adjust_ids.append((path, id))
306
 
    if len(adjust_ids) > 0:
307
 
        this_branch.set_inventory(regen_inventory(this_branch, this_tree.root,
308
 
                                                  adjust_ids))
 
186
    this_branch.set_inventory(regen_inventory(this_branch, this_tree.root, adjust_ids))
309
187
 
310
188
 
311
189
def regen_inventory(this_branch, root, new_entries):
348
226
    assert len(new_inventory_list) == len(old_entries) + insertions - deletions
349
227
    new_inventory_list.sort()
350
228
    return new_inventory_list
351
 
 
352
 
merge_types = {     "merge3": (ApplyMerge3, "Native diff3-style merge"), 
353
 
                     "diff3": (Diff3Merge,  "Merge using external diff3")
354
 
              }
355