~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/merge.py

Change the use of run_bzr to run_bzr_captured in blackbox tests - inspired by David Clymers patch to change run_bzr usage to runbzr

Show diffs side-by-side

added added

removed removed

Lines of Context:
19
19
import tempfile
20
20
import shutil
21
21
import errno
 
22
from fetch import greedy_fetch
22
23
 
23
24
import bzrlib.osutils
24
25
import bzrlib.revision
25
26
from bzrlib.merge_core import merge_flex, ApplyMerge3, BackupBeforeChange
26
27
from bzrlib.changeset import generate_changeset, ExceptionConflictHandler
27
 
from bzrlib.changeset import Inventory, Diff3Merge, ReplaceContents
 
28
from bzrlib.changeset import Inventory, Diff3Merge
28
29
from bzrlib.branch import Branch
29
30
from bzrlib.errors import BzrCommandError, UnrelatedBranches, NoCommonAncestor
30
31
from bzrlib.errors import NoCommits
31
32
from bzrlib.delta import compare_trees
32
 
from bzrlib.trace import mutter, warning, note
33
 
from bzrlib.fetch import greedy_fetch, fetch
 
33
from bzrlib.trace import mutter, warning
 
34
from bzrlib.fetch import greedy_fetch
34
35
from bzrlib.revision import is_ancestor
35
 
from bzrlib.osutils import rename
36
 
from bzrlib.revision import common_ancestor, MultipleRevisionSources
37
 
from bzrlib.errors import NoSuchRevision
38
 
 
39
 
# TODO: build_working_dir can be built on something simpler than merge()
40
 
 
41
 
# FIXME: merge() parameters seem oriented towards the command line
42
 
# NOTABUG: merge is a helper for commandline functions.  merge_inner is the
43
 
#          the core functionality.
44
36
 
45
37
# comments from abentley on irc: merge happens in two stages, each
46
38
# of which generates a changeset object
55
47
    conflict that are not explicitly handled cause an exception and
56
48
    terminate the merge.
57
49
    """
58
 
    def __init__(self, this_tree, base_tree, other_tree, ignore_zero=False):
 
50
    def __init__(self, ignore_zero=False):
59
51
        ExceptionConflictHandler.__init__(self)
60
52
        self.conflicts = 0
61
53
        self.ignore_zero = ignore_zero
62
 
        self.this_tree = this_tree
63
 
        self.base_tree = base_tree
64
 
        self.other_tree = other_tree
65
54
 
66
55
    def copy(self, source, dest):
67
56
        """Copy the text and mode of a file
95
84
            last_new_name = name
96
85
        new_name = last_new_name+suffix
97
86
        try:
98
 
            rename(name, new_name)
 
87
            os.rename(name, new_name)
99
88
            return new_name
100
89
        except OSError, e:
101
90
            if e.errno != errno.EEXIST and e.errno != errno.ENOTEMPTY:
119
108
        self.add_suffix(this_path, ".THIS")
120
109
        self.dump(base_lines, this_path+".BASE")
121
110
        self.dump(other_lines, this_path+".OTHER")
122
 
        rename(new_file, this_path)
 
111
        os.rename(new_file, this_path)
123
112
        self.conflict("Diff3 conflict encountered in %s" % this_path)
124
113
 
125
114
    def new_contents_conflict(self, filename, other_contents):
139
128
            % filename)
140
129
        return "skip"
141
130
 
142
 
    def rem_contents_conflict(self, filename, this_contents, base_contents):
143
 
        base_contents(filename+".BASE", self, False)
144
 
        this_contents(filename+".THIS", self, False)
145
 
        return ReplaceContents(this_contents, None)
146
 
 
147
 
    def rem_contents_conflict(self, filename, this_contents, base_contents):
148
 
        base_contents(filename+".BASE", self, False)
149
 
        this_contents(filename+".THIS", self, False)
150
 
        self.conflict("Other branch deleted locally modified file %s" %
151
 
                      filename)
152
 
        return ReplaceContents(this_contents, None)
153
 
 
154
 
    def abs_this_path(self, file_id):
155
 
        """Return the absolute path for a file_id in the this tree."""
156
 
        relpath = self.this_tree.id2path(file_id)
157
 
        return self.this_tree.tree.abspath(relpath)
158
 
 
159
 
    def add_missing_parents(self, file_id, tree):
160
 
        """If some of the parents for file_id are missing, add them."""
161
 
        entry = tree.tree.inventory[file_id]
162
 
        if entry.parent_id not in self.this_tree:
163
 
            return self.create_all_missing(entry.parent_id, tree)
164
 
        else:
165
 
            return self.abs_this_path(entry.parent_id)
166
 
 
167
 
    def create_all_missing(self, file_id, tree):
168
 
        """Add contents for a file_id and all its parents to a tree."""
169
 
        entry = tree.tree.inventory[file_id]
170
 
        if entry.parent_id is not None and entry.parent_id not in self.this_tree:
171
 
            abspath = self.create_all_missing(entry.parent_id, tree)
172
 
        else:
173
 
            abspath = self.abs_this_path(entry.parent_id)
174
 
        entry_path = os.path.join(abspath, entry.name)
175
 
        if not os.path.isdir(entry_path):
176
 
            self.create(file_id, entry_path, tree)
177
 
        return entry_path
178
 
 
179
 
    def create(self, file_id, path, tree, reverse=False):
180
 
        """Uses tree data to create a filesystem object for the file_id"""
181
 
        from merge_core import get_id_contents
182
 
        get_id_contents(file_id, tree)(path, self, reverse)
183
 
 
184
 
    def missing_for_merge(self, file_id, other_path):
185
 
        """The file_id doesn't exist in THIS, but does in OTHER and BASE"""
186
 
        self.conflict("Other branch modified locally deleted file %s" %
187
 
                      other_path)
188
 
        parent_dir = self.add_missing_parents(file_id, self.other_tree)
189
 
        stem = os.path.join(parent_dir, os.path.basename(other_path))
190
 
        self.create(file_id, stem+".OTHER", self.other_tree)
191
 
        self.create(file_id, stem+".BASE", self.base_tree)
192
 
 
193
131
    def finalize(self):
194
132
        if not self.ignore_zero:
195
 
            note("%d conflicts encountered.\n" % self.conflicts)
 
133
            print "%d conflicts encountered.\n" % self.conflicts
196
134
            
197
135
def get_tree(treespec, temp_root, label, local_branch=None):
198
136
    location, revno = treespec
199
 
    branch = Branch.open_containing(location)
 
137
    branch = Branch.open(location)
200
138
    if revno is None:
201
139
        revision = None
202
140
    elif revno == -1:
203
 
        revision = branch.last_revision()
 
141
        revision = branch.last_patch()
204
142
    else:
205
143
        revision = branch.get_rev_id(revno)
206
144
    return branch, get_revid_tree(branch, revision, temp_root, label,
234
172
        self.tree = tree
235
173
        self.tempdir = tempdir
236
174
        os.mkdir(os.path.join(self.tempdir, "texts"))
237
 
        os.mkdir(os.path.join(self.tempdir, "symlinks"))
238
175
        self.cached = {}
239
176
 
240
177
    def __iter__(self):
249
186
    def get_file_sha1(self, id):
250
187
        return self.tree.get_file_sha1(id)
251
188
 
252
 
    def is_executable(self, id):
253
 
        return self.tree.is_executable(id)
254
 
 
255
189
    def id2path(self, file_id):
256
190
        return self.tree.id2path(file_id)
257
191
 
274
208
        if self.root is not None:
275
209
            return self.tree.abspath(self.tree.id2path(id))
276
210
        else:
277
 
            kind = self.tree.inventory[id].kind
278
 
            if kind in ("directory", "root_directory"):
 
211
            if self.tree.inventory[id].kind in ("directory", "root_directory"):
279
212
                return self.tempdir
280
213
            if not self.cached.has_key(id):
281
 
                if kind == "file":
282
 
                    path = os.path.join(self.tempdir, "texts", id)
283
 
                    outfile = file(path, "wb")
284
 
                    outfile.write(self.tree.get_file(id).read())
285
 
                    assert(bzrlib.osutils.lexists(path))
286
 
                    if self.tree.is_executable(id):
287
 
                        os.chmod(path, 0755)
288
 
                else:
289
 
                    assert kind == "symlink"
290
 
                    path = os.path.join(self.tempdir, "symlinks", id)
291
 
                    target = self.tree.get_symlink_target(id)
292
 
                    os.symlink(target, path)
 
214
                path = os.path.join(self.tempdir, "texts", id)
 
215
                outfile = file(path, "wb")
 
216
                outfile.write(self.tree.get_file(id).read())
 
217
                assert(os.path.exists(path))
293
218
                self.cached[id] = path
294
219
            return self.cached[id]
295
220
 
296
221
 
297
 
def build_working_dir(to_dir):
298
 
    """Build a working directory in an empty directory.
299
 
 
300
 
    to_dir is a directory containing branch metadata but no working files,
301
 
    typically constructed by cloning an existing branch. 
302
 
 
303
 
    This is split out as a special idiomatic case of merge.  It could
304
 
    eventually be done by just building the tree directly calling into 
305
 
    lower-level code (e.g. constructing a changeset).
306
 
    """
307
 
    merge((to_dir, -1), (to_dir, 0), this_dir=to_dir,
308
 
          check_clean=False, ignore_zero=True)
309
 
 
310
222
 
311
223
def merge(other_revision, base_revision,
312
224
          check_clean=True, ignore_zero=False,
323
235
    check_clean
324
236
        If true, this_dir must have no uncommitted changes before the
325
237
        merge begins.
326
 
    ignore_zero - If true, suppress the "zero conflicts" message when 
327
 
        there are no conflicts; should be set when doing something we expect
328
 
        to complete perfectly.
329
 
 
330
 
    All available ancestors of other_revision and base_revision are
 
238
    all available ancestors of other_revision and base_revision are
331
239
    automatically pulled into the branch.
332
240
    """
 
241
    from bzrlib.revision import common_ancestor, MultipleRevisionSources
 
242
    from bzrlib.errors import NoSuchRevision
333
243
    tempdir = tempfile.mkdtemp(prefix="bzr-")
334
244
    try:
335
245
        if this_dir is None:
336
246
            this_dir = '.'
337
247
        this_branch = Branch.open_containing(this_dir)
338
 
        this_rev_id = this_branch.last_revision()
 
248
        this_rev_id = this_branch.last_patch()
339
249
        if this_rev_id is None:
340
250
            raise BzrCommandError("This branch has no commits")
341
251
        if check_clean:
346
256
        other_branch, other_tree = get_tree(other_revision, tempdir, "other",
347
257
                                            this_branch)
348
258
        if other_revision[1] == -1:
349
 
            other_rev_id = other_branch.last_revision()
 
259
            other_rev_id = other_branch.last_patch()
350
260
            if other_rev_id is None:
351
261
                raise NoCommits(other_branch)
352
262
            other_basis = other_rev_id
355
265
            other_basis = other_rev_id
356
266
        else:
357
267
            other_rev_id = None
358
 
            other_basis = other_branch.last_revision()
 
268
            other_basis = other_branch.last_patch()
359
269
            if other_basis is None:
360
270
                raise NoCommits(other_branch)
361
271
        if base_revision == [None, None]:
370
280
        else:
371
281
            base_branch, base_tree = get_tree(base_revision, tempdir, "base")
372
282
            if base_revision[1] == -1:
373
 
                base_rev_id = base_branch.last_revision()
 
283
                base_rev_id = base_branch.last_patch()
374
284
            elif base_revision[1] is None:
375
285
                base_rev_id = None
376
286
            else:
377
287
                base_rev_id = base_branch.get_rev_id(base_revision[1])
378
 
            fetch(from_branch=base_branch, to_branch=this_branch)
 
288
            multi_source = MultipleRevisionSources(this_branch, base_branch)
379
289
            base_is_ancestor = is_ancestor(this_rev_id, base_rev_id,
380
 
                                           this_branch)
 
290
                                           multi_source)
381
291
        if file_list is None:
382
292
            interesting_ids = None
383
293
        else:
412
322
             source_file.interesting = source_file.id in interesting_ids
413
323
 
414
324
 
 
325
def generate_cset_optimized(tree_a, tree_b, interesting_ids=None):
 
326
    """Generate a changeset.  If interesting_ids is supplied, only changes
 
327
    to those files will be shown.  Metadata changes are stripped.
 
328
    """ 
 
329
    cset =  generate_changeset(tree_a, tree_b, interesting_ids)
 
330
    for entry in cset.entries.itervalues():
 
331
        entry.metadata_change = None
 
332
    return cset
 
333
 
 
334
 
415
335
def merge_inner(this_branch, other_tree, base_tree, tempdir, 
416
336
                ignore_zero=False, merge_type=ApplyMerge3, backup_files=False,
417
337
                interesting_ids=None):
428
348
        return tree.tree.inventory
429
349
 
430
350
    inv_changes = merge_flex(this_tree, base_tree, other_tree,
431
 
                             generate_changeset, get_inventory,
432
 
                             MergeConflictHandler(this_tree, base_tree,
433
 
                             other_tree, ignore_zero=ignore_zero),
 
351
                             generate_cset_optimized, get_inventory,
 
352
                             MergeConflictHandler(ignore_zero=ignore_zero),
434
353
                             merge_factory=merge_factory, 
435
354
                             interesting_ids=interesting_ids)
436
355