~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/merge.py

  • Committer: John Arbash Meinel
  • Author(s): Mark Hammond
  • Date: 2008-09-09 17:02:21 UTC
  • mto: This revision was merged to the branch mainline in revision 3697.
  • Revision ID: john@arbash-meinel.com-20080909170221-svim3jw2mrz0amp3
An updated transparent icon for bzr.

Show diffs side-by-side

added added

removed removed

Lines of Context:
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
17
 
18
18
import errno
28
28
    patiencediff,
29
29
    registry,
30
30
    revision as _mod_revision,
31
 
    tree as _mod_tree,
32
31
    tsort,
33
32
    )
34
33
from bzrlib.branch import Branch
55
54
from bzrlib.trace import mutter, warning, note, is_quiet
56
55
from bzrlib.transform import (TransformPreview, TreeTransform,
57
56
                              resolve_conflicts, cook_conflicts,
58
 
                              conflict_pass, FinalPaths, create_from_tree,
 
57
                              conflict_pass, FinalPaths, create_by_entry,
59
58
                              unique_add, ROOT_PARENT)
60
59
from bzrlib.versionedfile import PlanWeaveMerge
61
60
from bzrlib import ui
70
69
 
71
70
class Merger(object):
72
71
    def __init__(self, this_branch, other_tree=None, base_tree=None,
73
 
                 this_tree=None, pb=None, change_reporter=None,
 
72
                 this_tree=None, pb=DummyProgress(), change_reporter=None,
74
73
                 recurse='down', revision_graph=None):
75
74
        object.__init__(self)
76
75
        self.this_branch = this_branch
89
88
        self.interesting_files = None
90
89
        self.show_base = False
91
90
        self.reprocess = False
92
 
        if pb is None:
93
 
            pb = DummyProgress()
94
91
        self._pb = pb
95
92
        self.pp = None
96
93
        self.recurse = recurse
99
96
        self._revision_graph = revision_graph
100
97
        self._base_is_ancestor = None
101
98
        self._base_is_other_ancestor = None
102
 
        self._is_criss_cross = None
103
 
        self._lca_trees = None
104
99
 
105
100
    @property
106
101
    def revision_graph(self):
134
129
                                      _set_base_is_other_ancestor)
135
130
 
136
131
    @staticmethod
137
 
    def from_uncommitted(tree, other_tree, pb=None, base_tree=None):
 
132
    def from_uncommitted(tree, other_tree, pb):
138
133
        """Return a Merger for uncommitted changes in other_tree.
139
134
 
140
135
        :param tree: The tree to merge into
141
136
        :param other_tree: The tree to get uncommitted changes from
142
137
        :param pb: A progress indicator
143
 
        :param base_tree: The basis to use for the merge.  If unspecified,
144
 
            other_tree.basis_tree() will be used.
145
138
        """
146
 
        if base_tree is None:
147
 
            base_tree = other_tree.basis_tree()
148
 
        merger = Merger(tree.branch, other_tree, base_tree, tree, pb)
 
139
        merger = Merger(tree.branch, other_tree, other_tree.basis_tree(), tree,
 
140
                        pb)
149
141
        merger.base_rev_id = merger.base_tree.get_revision_id()
150
142
        merger.other_rev_id = None
151
143
        merger.other_basis = merger.base_rev_id
177
169
 
178
170
    @staticmethod
179
171
    def from_revision_ids(pb, tree, other, base=None, other_branch=None,
180
 
                          base_branch=None, revision_graph=None,
181
 
                          tree_branch=None):
 
172
                          base_branch=None, revision_graph=None):
182
173
        """Return a Merger for revision-ids.
183
174
 
184
 
        :param pb: A progress indicator
185
175
        :param tree: The tree to merge changes into
186
176
        :param other: The revision-id to use as OTHER
187
177
        :param base: The revision-id to use as BASE.  If not specified, will
192
182
            not supplied, other_branch or tree.branch will be used.
193
183
        :param revision_graph: If you have a revision_graph precomputed, pass
194
184
            it in, otherwise it will be created for you.
195
 
        :param tree_branch: The branch associated with tree.  If not supplied,
196
 
            tree.branch will be used.
 
185
        :param pb: A progress indicator
197
186
        """
198
 
        if tree_branch is None:
199
 
            tree_branch = tree.branch
200
 
        merger = Merger(tree_branch, this_tree=tree, pb=pb,
 
187
        merger = Merger(tree.branch, this_tree=tree, pb=pb,
201
188
                        revision_graph=revision_graph)
202
189
        if other_branch is None:
203
190
            other_branch = tree.branch
243
230
 
244
231
        if self.other_rev_id is None:
245
232
            other_basis_tree = self.revision_tree(self.other_basis)
246
 
            if other_basis_tree.has_changes(self.other_tree):
 
233
            changes = other_basis_tree.changes_from(self.other_tree)
 
234
            if changes.has_changed():
247
235
                raise WorkingTreeNotRevision(self.this_tree)
248
236
            other_rev_id = self.other_basis
249
237
            self.other_tree = other_basis_tree
275
263
            basis_tree = self.revision_tree(self.this_tree.last_revision())
276
264
        except errors.NoSuchRevision:
277
265
            basis_tree = self.this_tree.basis_tree()
278
 
        if not self.this_tree.has_changes(basis_tree):
 
266
        changes = self.this_tree.changes_from(basis_tree)
 
267
        if not changes.has_changed():
279
268
            self.this_rev_id = self.this_basis
280
269
 
281
270
    def set_interesting_files(self, file_list):
364
353
                     ensure_null(self.other_basis)]
365
354
        if NULL_REVISION in revisions:
366
355
            self.base_rev_id = NULL_REVISION
367
 
            self.base_tree = self.revision_tree(self.base_rev_id)
368
 
            self._is_criss_cross = False
369
356
        else:
370
 
            lcas = self.revision_graph.find_lca(revisions[0], revisions[1])
371
 
            self._is_criss_cross = False
372
 
            if len(lcas) == 0:
373
 
                self.base_rev_id = NULL_REVISION
374
 
            elif len(lcas) == 1:
375
 
                self.base_rev_id = list(lcas)[0]
376
 
            else: # len(lcas) > 1
377
 
                if len(lcas) > 2:
378
 
                    # find_unique_lca can only handle 2 nodes, so we have to
379
 
                    # start back at the beginning. It is a shame to traverse
380
 
                    # the graph again, but better than re-implementing
381
 
                    # find_unique_lca.
382
 
                    self.base_rev_id = self.revision_graph.find_unique_lca(
383
 
                                            revisions[0], revisions[1])
384
 
                else:
385
 
                    self.base_rev_id = self.revision_graph.find_unique_lca(
386
 
                                            *lcas)
387
 
                self._is_criss_cross = True
 
357
            self.base_rev_id, steps = self.revision_graph.find_unique_lca(
 
358
                revisions[0], revisions[1], count_steps=True)
388
359
            if self.base_rev_id == NULL_REVISION:
389
360
                raise UnrelatedBranches()
390
 
            if self._is_criss_cross:
 
361
            if steps > 1:
391
362
                warning('Warning: criss-cross merge encountered.  See bzr'
392
363
                        ' help criss-cross.')
393
 
                mutter('Criss-cross lcas: %r' % lcas)
394
 
                interesting_revision_ids = [self.base_rev_id]
395
 
                interesting_revision_ids.extend(lcas)
396
 
                interesting_trees = dict((t.get_revision_id(), t)
397
 
                    for t in self.this_branch.repository.revision_trees(
398
 
                        interesting_revision_ids))
399
 
                self._cached_trees.update(interesting_trees)
400
 
                self.base_tree = interesting_trees.pop(self.base_rev_id)
401
 
                sorted_lca_keys = self.revision_graph.find_merge_order(
402
 
                    revisions[0], lcas)
403
 
                self._lca_trees = [interesting_trees[key]
404
 
                                   for key in sorted_lca_keys]
405
 
            else:
406
 
                self.base_tree = self.revision_tree(self.base_rev_id)
 
364
        self.base_tree = self.revision_tree(self.base_rev_id)
407
365
        self.base_is_ancestor = True
408
366
        self.base_is_other_ancestor = True
409
 
        mutter('Base revid: %r' % self.base_rev_id)
410
367
 
411
368
    def set_base(self, base_revision):
412
369
        """Set the base revision to use for the merge.
452
409
        if self.merge_type.supports_cherrypick:
453
410
            kwargs['cherrypick'] = (not self.base_is_ancestor or
454
411
                                    not self.base_is_other_ancestor)
455
 
        if self._is_criss_cross and getattr(self.merge_type,
456
 
                                            'supports_lca_trees', False):
457
 
            kwargs['lca_trees'] = self._lca_trees
458
412
        return self.merge_type(pb=self._pb,
459
413
                               change_reporter=self.change_reporter,
460
414
                               **kwargs)
461
415
 
462
 
    def _do_merge_to(self, merge):
463
 
        if self.other_branch is not None:
464
 
            self.other_branch.update_references(self.this_branch)
465
 
        merge.do_merge()
466
 
        if self.recurse == 'down':
467
 
            for relpath, file_id in self.this_tree.iter_references():
468
 
                sub_tree = self.this_tree.get_nested_tree(file_id, relpath)
469
 
                other_revision = self.other_tree.get_reference_revision(
470
 
                    file_id, relpath)
471
 
                if  other_revision == sub_tree.last_revision():
472
 
                    continue
473
 
                sub_merge = Merger(sub_tree.branch, this_tree=sub_tree)
474
 
                sub_merge.merge_type = self.merge_type
475
 
                other_branch = self.other_branch.reference_parent(file_id, relpath)
476
 
                sub_merge.set_other_revision(other_revision, other_branch)
477
 
                base_revision = self.base_tree.get_reference_revision(file_id)
478
 
                sub_merge.base_tree = \
479
 
                    sub_tree.branch.repository.revision_tree(base_revision)
480
 
                sub_merge.base_rev_id = base_revision
481
 
                sub_merge.do_merge()
482
 
 
483
416
    def do_merge(self):
484
417
        self.this_tree.lock_tree_write()
 
418
        if self.base_tree is not None:
 
419
            self.base_tree.lock_read()
 
420
        if self.other_tree is not None:
 
421
            self.other_tree.lock_read()
485
422
        try:
 
423
            merge = self.make_merger()
 
424
            merge.do_merge()
 
425
            if self.recurse == 'down':
 
426
                for relpath, file_id in self.this_tree.iter_references():
 
427
                    sub_tree = self.this_tree.get_nested_tree(file_id, relpath)
 
428
                    other_revision = self.other_tree.get_reference_revision(
 
429
                        file_id, relpath)
 
430
                    if  other_revision == sub_tree.last_revision():
 
431
                        continue
 
432
                    sub_merge = Merger(sub_tree.branch, this_tree=sub_tree)
 
433
                    sub_merge.merge_type = self.merge_type
 
434
                    other_branch = self.other_branch.reference_parent(file_id, relpath)
 
435
                    sub_merge.set_other_revision(other_revision, other_branch)
 
436
                    base_revision = self.base_tree.get_reference_revision(file_id)
 
437
                    sub_merge.base_tree = \
 
438
                        sub_tree.branch.repository.revision_tree(base_revision)
 
439
                    sub_merge.base_rev_id = base_revision
 
440
                    sub_merge.do_merge()
 
441
 
 
442
        finally:
 
443
            if self.other_tree is not None:
 
444
                self.other_tree.unlock()
486
445
            if self.base_tree is not None:
487
 
                self.base_tree.lock_read()
488
 
            try:
489
 
                if self.other_tree is not None:
490
 
                    self.other_tree.lock_read()
491
 
                try:
492
 
                    merge = self.make_merger()
493
 
                    self._do_merge_to(merge)
494
 
                finally:
495
 
                    if self.other_tree is not None:
496
 
                        self.other_tree.unlock()
497
 
            finally:
498
 
                if self.base_tree is not None:
499
 
                    self.base_tree.unlock()
500
 
        finally:
 
446
                self.base_tree.unlock()
501
447
            self.this_tree.unlock()
502
448
        if len(merge.cooked_conflicts) == 0:
503
449
            if not self.ignore_zero and not is_quiet():
508
454
        return len(merge.cooked_conflicts)
509
455
 
510
456
 
511
 
class _InventoryNoneEntry(object):
512
 
    """This represents an inventory entry which *isn't there*.
513
 
 
514
 
    It simplifies the merging logic if we always have an InventoryEntry, even
515
 
    if it isn't actually present
516
 
    """
517
 
    executable = None
518
 
    kind = None
519
 
    name = None
520
 
    parent_id = None
521
 
    revision = None
522
 
    symlink_target = None
523
 
    text_sha1 = None
524
 
 
525
 
_none_entry = _InventoryNoneEntry()
526
 
 
527
 
 
528
457
class Merge3Merger(object):
529
458
    """Three-way merger that uses the merge3 text merger"""
530
459
    requires_base = True
534
463
    supports_cherrypick = True
535
464
    supports_reverse_cherrypick = True
536
465
    winner_idx = {"this": 2, "other": 1, "conflict": 1}
537
 
    supports_lca_trees = True
538
466
 
539
 
    def __init__(self, working_tree, this_tree, base_tree, other_tree,
 
467
    def __init__(self, working_tree, this_tree, base_tree, other_tree, 
540
468
                 interesting_ids=None, reprocess=False, show_base=False,
541
469
                 pb=DummyProgress(), pp=None, change_reporter=None,
542
470
                 interesting_files=None, do_merge=True,
543
 
                 cherrypick=False, lca_trees=None):
 
471
                 cherrypick=False):
544
472
        """Initialize the merger object and perform the merge.
545
473
 
546
474
        :param working_tree: The working tree to apply the merge to
547
475
        :param this_tree: The local tree in the merge operation
548
476
        :param base_tree: The common tree in the merge operation
549
 
        :param other_tree: The other tree to merge changes from
 
477
        :param other_tree: The other other tree to merge changes from
550
478
        :param interesting_ids: The file_ids of files that should be
551
479
            participate in the merge.  May not be combined with
552
480
            interesting_files.
562
490
            be combined with interesting_ids.  If neither interesting_files nor
563
491
            interesting_ids is specified, all files may participate in the
564
492
            merge.
565
 
        :param lca_trees: Can be set to a dictionary of {revision_id:rev_tree}
566
 
            if the ancestry was found to include a criss-cross merge.
567
 
            Otherwise should be None.
568
493
        """
569
494
        object.__init__(self)
570
495
        if interesting_files is not None and interesting_ids is not None:
579
504
        self.cooked_conflicts = []
580
505
        self.reprocess = reprocess
581
506
        self.show_base = show_base
582
 
        self._lca_trees = lca_trees
583
 
        # Uncommenting this will change the default algorithm to always use
584
 
        # _entries_lca. This can be useful for running the test suite and
585
 
        # making sure we haven't missed any corner cases.
586
 
        # if lca_trees is None:
587
 
        #     self._lca_trees = [self.base_tree]
588
507
        self.pb = pb
589
508
        self.pp = pp
590
509
        self.change_reporter = change_reporter
631
550
        return self.tt
632
551
 
633
552
    def _compute_transform(self):
634
 
        if self._lca_trees is None:
635
 
            entries = self._entries3()
636
 
            resolver = self._three_way
637
 
        else:
638
 
            entries = self._entries_lca()
639
 
            resolver = self._lca_multi_way
 
553
        entries = self._entries3()
640
554
        child_pb = ui.ui_factory.nested_progress_bar()
641
555
        try:
642
556
            for num, (file_id, changed, parents3, names3,
643
557
                      executable3) in enumerate(entries):
644
558
                child_pb.update('Preparing file merge', num, len(entries))
645
 
                self._merge_names(file_id, parents3, names3, resolver=resolver)
 
559
                self._merge_names(file_id, parents3, names3)
646
560
                if changed:
647
561
                    file_status = self.merge_contents(file_id)
648
562
                else:
649
563
                    file_status = 'unmodified'
650
564
                self._merge_executable(file_id,
651
 
                    executable3, file_status, resolver=resolver)
 
565
                    executable3, file_status)
652
566
        finally:
653
567
            child_pb.finished()
654
568
        self.fix_root()
680
594
        iterator = self.other_tree.iter_changes(self.base_tree,
681
595
                include_unchanged=True, specific_files=self.interesting_files,
682
596
                extra_trees=[self.this_tree])
683
 
        this_entries = dict((e.file_id, e) for p, e in
684
 
                            self.this_tree.iter_entries_by_dir(
685
 
                            self.interesting_ids))
686
597
        for (file_id, paths, changed, versioned, parents, names, kind,
687
598
             executable) in iterator:
688
599
            if (self.interesting_ids is not None and
689
600
                file_id not in self.interesting_ids):
690
601
                continue
691
 
            entry = this_entries.get(file_id)
692
 
            if entry is not None:
 
602
            if file_id in self.this_tree.inventory:
 
603
                entry = self.this_tree.inventory[file_id]
693
604
                this_name = entry.name
694
605
                this_parent = entry.parent_id
695
606
                this_executable = entry.executable
703
614
            result.append((file_id, changed, parents3, names3, executable3))
704
615
        return result
705
616
 
706
 
    def _entries_lca(self):
707
 
        """Gather data about files modified between multiple trees.
708
 
 
709
 
        This compares OTHER versus all LCA trees, and for interesting entries,
710
 
        it then compares with THIS and BASE.
711
 
 
712
 
        For the multi-valued entries, the format will be (BASE, [lca1, lca2])
713
 
        :return: [(file_id, changed, parents, names, executable)]
714
 
            file_id     Simple file_id of the entry
715
 
            changed     Boolean, True if the kind or contents changed
716
 
                        else False
717
 
            parents     ((base, [parent_id, in, lcas]), parent_id_other,
718
 
                         parent_id_this)
719
 
            names       ((base, [name, in, lcas]), name_in_other, name_in_this)
720
 
            executable  ((base, [exec, in, lcas]), exec_in_other, exec_in_this)
721
 
        """
722
 
        if self.interesting_files is not None:
723
 
            lookup_trees = [self.this_tree, self.base_tree]
724
 
            lookup_trees.extend(self._lca_trees)
725
 
            # I think we should include the lca trees as well
726
 
            interesting_ids = self.other_tree.paths2ids(self.interesting_files,
727
 
                                                        lookup_trees)
728
 
        else:
729
 
            interesting_ids = self.interesting_ids
730
 
        result = []
731
 
        walker = _mod_tree.MultiWalker(self.other_tree, self._lca_trees)
732
 
 
733
 
        base_inventory = self.base_tree.inventory
734
 
        this_inventory = self.this_tree.inventory
735
 
        for path, file_id, other_ie, lca_values in walker.iter_all():
736
 
            # Is this modified at all from any of the other trees?
737
 
            if other_ie is None:
738
 
                other_ie = _none_entry
739
 
            if interesting_ids is not None and file_id not in interesting_ids:
740
 
                continue
741
 
 
742
 
            # If other_revision is found in any of the lcas, that means this
743
 
            # node is uninteresting. This is because when merging, if there are
744
 
            # multiple heads(), we have to create a new node. So if we didn't,
745
 
            # we know that the ancestry is linear, and that OTHER did not
746
 
            # modify anything
747
 
            # See doc/developers/lca_merge_resolution.txt for details
748
 
            other_revision = other_ie.revision
749
 
            if other_revision is not None:
750
 
                # We can't use this shortcut when other_revision is None,
751
 
                # because it may be None because things are WorkingTrees, and
752
 
                # not because it is *actually* None.
753
 
                is_unmodified = False
754
 
                for lca_path, ie in lca_values:
755
 
                    if ie is not None and ie.revision == other_revision:
756
 
                        is_unmodified = True
757
 
                        break
758
 
                if is_unmodified:
759
 
                    continue
760
 
 
761
 
            lca_entries = []
762
 
            for lca_path, lca_ie in lca_values:
763
 
                if lca_ie is None:
764
 
                    lca_entries.append(_none_entry)
765
 
                else:
766
 
                    lca_entries.append(lca_ie)
767
 
 
768
 
            if file_id in base_inventory:
769
 
                base_ie = base_inventory[file_id]
770
 
            else:
771
 
                base_ie = _none_entry
772
 
 
773
 
            if file_id in this_inventory:
774
 
                this_ie = this_inventory[file_id]
775
 
            else:
776
 
                this_ie = _none_entry
777
 
 
778
 
            lca_kinds = []
779
 
            lca_parent_ids = []
780
 
            lca_names = []
781
 
            lca_executable = []
782
 
            for lca_ie in lca_entries:
783
 
                lca_kinds.append(lca_ie.kind)
784
 
                lca_parent_ids.append(lca_ie.parent_id)
785
 
                lca_names.append(lca_ie.name)
786
 
                lca_executable.append(lca_ie.executable)
787
 
 
788
 
            kind_winner = self._lca_multi_way(
789
 
                (base_ie.kind, lca_kinds),
790
 
                other_ie.kind, this_ie.kind)
791
 
            parent_id_winner = self._lca_multi_way(
792
 
                (base_ie.parent_id, lca_parent_ids),
793
 
                other_ie.parent_id, this_ie.parent_id)
794
 
            name_winner = self._lca_multi_way(
795
 
                (base_ie.name, lca_names),
796
 
                other_ie.name, this_ie.name)
797
 
 
798
 
            content_changed = True
799
 
            if kind_winner == 'this':
800
 
                # No kind change in OTHER, see if there are *any* changes
801
 
                if other_ie.kind == 'directory':
802
 
                    if parent_id_winner == 'this' and name_winner == 'this':
803
 
                        # No change for this directory in OTHER, skip
804
 
                        continue
805
 
                    content_changed = False
806
 
                elif other_ie.kind is None or other_ie.kind == 'file':
807
 
                    def get_sha1(ie, tree):
808
 
                        if ie.kind != 'file':
809
 
                            return None
810
 
                        return tree.get_file_sha1(file_id)
811
 
                    base_sha1 = get_sha1(base_ie, self.base_tree)
812
 
                    lca_sha1s = [get_sha1(ie, tree) for ie, tree
813
 
                                 in zip(lca_entries, self._lca_trees)]
814
 
                    this_sha1 = get_sha1(this_ie, self.this_tree)
815
 
                    other_sha1 = get_sha1(other_ie, self.other_tree)
816
 
                    sha1_winner = self._lca_multi_way(
817
 
                        (base_sha1, lca_sha1s), other_sha1, this_sha1,
818
 
                        allow_overriding_lca=False)
819
 
                    exec_winner = self._lca_multi_way(
820
 
                        (base_ie.executable, lca_executable),
821
 
                        other_ie.executable, this_ie.executable)
822
 
                    if (parent_id_winner == 'this' and name_winner == 'this'
823
 
                        and sha1_winner == 'this' and exec_winner == 'this'):
824
 
                        # No kind, parent, name, exec, or content change for
825
 
                        # OTHER, so this node is not considered interesting
826
 
                        continue
827
 
                    if sha1_winner == 'this':
828
 
                        content_changed = False
829
 
                elif other_ie.kind == 'symlink':
830
 
                    def get_target(ie, tree):
831
 
                        if ie.kind != 'symlink':
832
 
                            return None
833
 
                        return tree.get_symlink_target(file_id)
834
 
                    base_target = get_target(base_ie, self.base_tree)
835
 
                    lca_targets = [get_target(ie, tree) for ie, tree
836
 
                                   in zip(lca_entries, self._lca_trees)]
837
 
                    this_target = get_target(this_ie, self.this_tree)
838
 
                    other_target = get_target(other_ie, self.other_tree)
839
 
                    target_winner = self._lca_multi_way(
840
 
                        (base_target, lca_targets),
841
 
                        other_target, this_target)
842
 
                    if (parent_id_winner == 'this' and name_winner == 'this'
843
 
                        and target_winner == 'this'):
844
 
                        # No kind, parent, name, or symlink target change
845
 
                        # not interesting
846
 
                        continue
847
 
                    if target_winner == 'this':
848
 
                        content_changed = False
849
 
                elif other_ie.kind == 'tree-reference':
850
 
                    # The 'changed' information seems to be handled at a higher
851
 
                    # level. At least, _entries3 returns False for content
852
 
                    # changed, even when at a new revision_id.
853
 
                    content_changed = False
854
 
                    if (parent_id_winner == 'this' and name_winner == 'this'):
855
 
                        # Nothing interesting
856
 
                        continue
857
 
                else:
858
 
                    raise AssertionError('unhandled kind: %s' % other_ie.kind)
859
 
                # XXX: We need to handle kind == 'symlink'
860
 
 
861
 
            # If we have gotten this far, that means something has changed
862
 
            result.append((file_id, content_changed,
863
 
                           ((base_ie.parent_id, lca_parent_ids),
864
 
                            other_ie.parent_id, this_ie.parent_id),
865
 
                           ((base_ie.name, lca_names),
866
 
                            other_ie.name, this_ie.name),
867
 
                           ((base_ie.executable, lca_executable),
868
 
                            other_ie.executable, this_ie.executable)
869
 
                          ))
870
 
        return result
871
 
 
872
 
 
873
617
    def fix_root(self):
874
618
        try:
875
619
            self.tt.final_kind(self.tt.root)
876
620
        except NoSuchFile:
877
621
            self.tt.cancel_deletion(self.tt.root)
878
622
        if self.tt.final_file_id(self.tt.root) is None:
879
 
            self.tt.version_file(self.tt.tree_file_id(self.tt.root),
 
623
            self.tt.version_file(self.tt.tree_file_id(self.tt.root), 
880
624
                                 self.tt.root)
 
625
        if self.other_tree.inventory.root is None:
 
626
            return
881
627
        other_root_file_id = self.other_tree.get_root_id()
882
 
        if other_root_file_id is None:
883
 
            return
884
628
        other_root = self.tt.trans_id_file_id(other_root_file_id)
885
629
        if other_root == self.tt.root:
886
630
            return
925
669
        if entry is None:
926
670
            return None
927
671
        return entry.name
928
 
 
 
672
    
929
673
    @staticmethod
930
674
    def contents_sha1(tree, file_id):
931
675
        """Determine the sha1 of the file contents (used as a key method)."""
964
708
            return "other"
965
709
 
966
710
    @staticmethod
967
 
    def _lca_multi_way(bases, other, this, allow_overriding_lca=True):
968
 
        """Consider LCAs when determining whether a change has occurred.
969
 
 
970
 
        If LCAS are all identical, this is the same as a _three_way comparison.
971
 
 
972
 
        :param bases: value in (BASE, [LCAS])
973
 
        :param other: value in OTHER
974
 
        :param this: value in THIS
975
 
        :param allow_overriding_lca: If there is more than one unique lca
976
 
            value, allow OTHER to override THIS if it has a new value, and
977
 
            THIS only has an lca value, or vice versa. This is appropriate for
978
 
            truly scalar values, not as much for non-scalars.
979
 
        :return: 'this', 'other', or 'conflict' depending on whether an entry
980
 
            changed or not.
981
 
        """
982
 
        # See doc/developers/lca_tree_merging.txt for details about this
983
 
        # algorithm.
984
 
        if other == this:
985
 
            # Either Ambiguously clean, or nothing was actually changed. We
986
 
            # don't really care
987
 
            return 'this'
988
 
        base_val, lca_vals = bases
989
 
        # Remove 'base_val' from the lca_vals, because it is not interesting
990
 
        filtered_lca_vals = [lca_val for lca_val in lca_vals
991
 
                                      if lca_val != base_val]
992
 
        if len(filtered_lca_vals) == 0:
993
 
            return Merge3Merger._three_way(base_val, other, this)
994
 
 
995
 
        unique_lca_vals = set(filtered_lca_vals)
996
 
        if len(unique_lca_vals) == 1:
997
 
            return Merge3Merger._three_way(unique_lca_vals.pop(), other, this)
998
 
 
999
 
        if allow_overriding_lca:
1000
 
            if other in unique_lca_vals:
1001
 
                if this in unique_lca_vals:
1002
 
                    # Each side picked a different lca, conflict
1003
 
                    return 'conflict'
1004
 
                else:
1005
 
                    # This has a value which supersedes both lca values, and
1006
 
                    # other only has an lca value
1007
 
                    return 'this'
1008
 
            elif this in unique_lca_vals:
1009
 
                # OTHER has a value which supersedes both lca values, and this
1010
 
                # only has an lca value
1011
 
                return 'other'
1012
 
 
1013
 
        # At this point, the lcas disagree, and the tips disagree
1014
 
        return 'conflict'
1015
 
 
1016
 
    @staticmethod
1017
711
    def scalar_three_way(this_tree, base_tree, other_tree, file_id, key):
1018
712
        """Do a three-way test on a scalar.
1019
713
        Return "this", "other" or "conflict", depending whether a value wins.
1051
745
            else:
1052
746
                names.append(entry.name)
1053
747
                parents.append(entry.parent_id)
1054
 
        return self._merge_names(file_id, parents, names,
1055
 
                                 resolver=self._three_way)
 
748
        return self._merge_names(file_id, parents, names)
1056
749
 
1057
 
    def _merge_names(self, file_id, parents, names, resolver):
 
750
    def _merge_names(self, file_id, parents, names):
1058
751
        """Perform a merge on file_id names and parents"""
1059
752
        base_name, other_name, this_name = names
1060
753
        base_parent, other_parent, this_parent = parents
1061
754
 
1062
 
        name_winner = resolver(*names)
 
755
        name_winner = self._three_way(*names)
1063
756
 
1064
 
        parent_id_winner = resolver(*parents)
 
757
        parent_id_winner = self._three_way(*parents)
1065
758
        if this_name is None:
1066
759
            if name_winner == "this":
1067
760
                name_winner = "other"
1071
764
            return
1072
765
        if name_winner == "conflict":
1073
766
            trans_id = self.tt.trans_id_file_id(file_id)
1074
 
            self._raw_conflicts.append(('name conflict', trans_id,
 
767
            self._raw_conflicts.append(('name conflict', trans_id, 
1075
768
                                        this_name, other_name))
1076
769
        if parent_id_winner == "conflict":
1077
770
            trans_id = self.tt.trans_id_file_id(file_id)
1078
 
            self._raw_conflicts.append(('parent conflict', trans_id,
 
771
            self._raw_conflicts.append(('parent conflict', trans_id, 
1079
772
                                        this_parent, other_parent))
1080
773
        if other_name is None:
1081
 
            # it doesn't matter whether the result was 'other' or
 
774
            # it doesn't matter whether the result was 'other' or 
1082
775
            # 'conflict'-- if there's no 'other', we leave it alone.
1083
776
            return
1084
777
        # if we get here, name_winner and parent_winner are set to safe values.
1090
783
                                parent_trans_id, trans_id)
1091
784
 
1092
785
    def merge_contents(self, file_id):
1093
 
        """Performs a merge on file_id contents."""
 
786
        """Performa a merge on file_id contents."""
1094
787
        def contents_pair(tree):
1095
788
            if file_id not in tree:
1096
789
                return (None, None)
1111
804
                self.tt.unversion_file(trans_id)
1112
805
                if file_id in self.this_tree:
1113
806
                    self.tt.delete_contents(trans_id)
1114
 
            file_group = self._dump_conflicts(name, parent_id, file_id,
 
807
            file_group = self._dump_conflicts(name, parent_id, file_id, 
1115
808
                                              set_version=True)
1116
809
            self._raw_conflicts.append(('contents conflict', file_group))
1117
810
 
1120
813
        # file kind...
1121
814
        base_pair = contents_pair(self.base_tree)
1122
815
        other_pair = contents_pair(self.other_tree)
1123
 
        if self._lca_trees:
1124
 
            this_pair = contents_pair(self.this_tree)
1125
 
            lca_pairs = [contents_pair(tree) for tree in self._lca_trees]
1126
 
            winner = self._lca_multi_way((base_pair, lca_pairs), other_pair,
1127
 
                                         this_pair, allow_overriding_lca=False)
1128
 
        else:
1129
 
            if base_pair == other_pair:
1130
 
                winner = 'this'
1131
 
            else:
1132
 
                # We delayed evaluating this_pair as long as we can to avoid
1133
 
                # unnecessary sha1 calculation
1134
 
                this_pair = contents_pair(self.this_tree)
1135
 
                winner = self._three_way(base_pair, other_pair, this_pair)
1136
 
        if winner == 'this':
1137
 
            # No interesting changes introduced by OTHER
1138
 
            return "unmodified"
1139
 
        trans_id = self.tt.trans_id_file_id(file_id)
1140
 
        if winner == 'other':
1141
 
            # OTHER is a straight winner, so replace this contents with other
1142
 
            file_in_this = file_id in self.this_tree
1143
 
            if file_in_this:
1144
 
                # Remove any existing contents
1145
 
                self.tt.delete_contents(trans_id)
1146
 
            if file_id in self.other_tree:
1147
 
                # OTHER changed the file
1148
 
                create_from_tree(self.tt, trans_id,
1149
 
                                 self.other_tree, file_id)
1150
 
                if not file_in_this:
1151
 
                    self.tt.version_file(file_id, trans_id)
1152
 
                return "modified"
1153
 
            elif file_in_this:
1154
 
                # OTHER deleted the file
1155
 
                self.tt.unversion_file(trans_id)
1156
 
                return "deleted"
1157
 
        else:
1158
 
            # We have a hypothetical conflict, but if we have files, then we
1159
 
            # can try to merge the content
1160
 
            if this_pair[0] == 'file' and other_pair[0] == 'file':
 
816
        if base_pair == other_pair:
 
817
            # OTHER introduced no changes
 
818
            return "unmodified"
 
819
        this_pair = contents_pair(self.this_tree)
 
820
        if this_pair == other_pair:
 
821
            # THIS and OTHER introduced the same changes
 
822
            return "unmodified"
 
823
        else:
 
824
            trans_id = self.tt.trans_id_file_id(file_id)
 
825
            if this_pair == base_pair:
 
826
                # only OTHER introduced changes
 
827
                if file_id in self.this_tree:
 
828
                    # Remove any existing contents
 
829
                    self.tt.delete_contents(trans_id)
 
830
                if file_id in self.other_tree:
 
831
                    # OTHER changed the file
 
832
                    create_by_entry(self.tt, 
 
833
                                    self.other_tree.inventory[file_id], 
 
834
                                    self.other_tree, trans_id)
 
835
                    if file_id not in self.this_tree.inventory:
 
836
                        self.tt.version_file(file_id, trans_id)
 
837
                    return "modified"
 
838
                elif file_id in self.this_tree.inventory:
 
839
                    # OTHER deleted the file
 
840
                    self.tt.unversion_file(trans_id)
 
841
                    return "deleted"
 
842
            #BOTH THIS and OTHER introduced changes; scalar conflict
 
843
            elif this_pair[0] == "file" and other_pair[0] == "file":
1161
844
                # THIS and OTHER are both files, so text merge.  Either
1162
845
                # BASE is a file, or both converted to files, so at least we
1163
846
                # have agreement that output should be a file.
1165
848
                    self.text_merge(file_id, trans_id)
1166
849
                except BinaryFile:
1167
850
                    return contents_conflict()
1168
 
                if file_id not in self.this_tree:
 
851
                if file_id not in self.this_tree.inventory:
1169
852
                    self.tt.version_file(file_id, trans_id)
1170
853
                try:
1171
854
                    self.tt.tree_kind(trans_id)
1174
857
                    pass
1175
858
                return "modified"
1176
859
            else:
 
860
                # Scalar conflict, can't text merge.  Dump conflicts
1177
861
                return contents_conflict()
1178
862
 
1179
863
    def get_lines(self, tree, file_id):
1204
888
 
1205
889
        def iter_merge3(retval):
1206
890
            retval["text_conflicts"] = False
1207
 
            for line in m3.merge_lines(name_a = "TREE",
1208
 
                                       name_b = "MERGE-SOURCE",
 
891
            for line in m3.merge_lines(name_a = "TREE", 
 
892
                                       name_b = "MERGE-SOURCE", 
1209
893
                                       name_base = "BASE-REVISION",
1210
 
                                       start_marker=start_marker,
 
894
                                       start_marker=start_marker, 
1211
895
                                       base_marker=base_marker,
1212
896
                                       reprocess=self.reprocess):
1213
897
                if line.startswith(start_marker):
1222
906
            self._raw_conflicts.append(('text conflict', trans_id))
1223
907
            name = self.tt.final_name(trans_id)
1224
908
            parent_id = self.tt.final_parent(trans_id)
1225
 
            file_group = self._dump_conflicts(name, parent_id, file_id,
 
909
            file_group = self._dump_conflicts(name, parent_id, file_id, 
1226
910
                                              this_lines, base_lines,
1227
911
                                              other_lines)
1228
912
            file_group.append(trans_id)
1229
913
 
1230
 
    def _dump_conflicts(self, name, parent_id, file_id, this_lines=None,
 
914
    def _dump_conflicts(self, name, parent_id, file_id, this_lines=None, 
1231
915
                        base_lines=None, other_lines=None, set_version=False,
1232
916
                        no_base=False):
1233
917
        """Emit conflict files.
1235
919
        determined automatically.  If set_version is true, the .OTHER, .THIS
1236
920
        or .BASE (in that order) will be created as versioned files.
1237
921
        """
1238
 
        data = [('OTHER', self.other_tree, other_lines),
 
922
        data = [('OTHER', self.other_tree, other_lines), 
1239
923
                ('THIS', self.this_tree, this_lines)]
1240
924
        if not no_base:
1241
925
            data.append(('BASE', self.base_tree, base_lines))
1250
934
                    self.tt.version_file(file_id, trans_id)
1251
935
                    versioned = True
1252
936
        return file_group
1253
 
 
1254
 
    def _conflict_file(self, name, parent_id, tree, file_id, suffix,
 
937
           
 
938
    def _conflict_file(self, name, parent_id, tree, file_id, suffix, 
1255
939
                       lines=None):
1256
940
        """Emit a single conflict file."""
1257
941
        name = name + '.' + suffix
1258
942
        trans_id = self.tt.create_path(name, parent_id)
1259
 
        create_from_tree(self.tt, trans_id, tree, file_id, lines)
 
943
        entry = tree.inventory[file_id]
 
944
        create_by_entry(self.tt, entry, tree, trans_id, lines)
1260
945
        return trans_id
1261
946
 
1262
947
    def merge_executable(self, file_id, file_status):
1263
948
        """Perform a merge on the execute bit."""
1264
949
        executable = [self.executable(t, file_id) for t in (self.base_tree,
1265
950
                      self.other_tree, self.this_tree)]
1266
 
        self._merge_executable(file_id, executable, file_status,
1267
 
                               resolver=self._three_way)
 
951
        self._merge_executable(file_id, executable, file_status)
1268
952
 
1269
 
    def _merge_executable(self, file_id, executable, file_status,
1270
 
                          resolver):
 
953
    def _merge_executable(self, file_id, executable, file_status):
1271
954
        """Perform a merge on the execute bit."""
1272
955
        base_executable, other_executable, this_executable = executable
1273
956
        if file_status == "deleted":
1274
957
            return
1275
 
        winner = resolver(*executable)
 
958
        winner = self._three_way(*executable)
1276
959
        if winner == "conflict":
1277
960
        # There must be a None in here, if we have a conflict, but we
1278
961
        # need executability since file status was not deleted.
1314
997
                conflict_args = conflict[2:]
1315
998
                if trans_id not in name_conflicts:
1316
999
                    name_conflicts[trans_id] = {}
1317
 
                unique_add(name_conflicts[trans_id], conflict_type,
 
1000
                unique_add(name_conflicts[trans_id], conflict_type, 
1318
1001
                           conflict_args)
1319
1002
            if conflict_type == 'contents conflict':
1320
1003
                for trans_id in conflict[1]:
1398
1081
        """
1399
1082
        lines, conflicts = self._merged_lines(file_id)
1400
1083
        lines = list(lines)
1401
 
        # Note we're checking whether the OUTPUT is binary in this case,
 
1084
        # Note we're checking whether the OUTPUT is binary in this case, 
1402
1085
        # because we don't want to get into weave merge guts.
1403
1086
        check_text_lines(lines)
1404
1087
        self.tt.create_file(lines, trans_id)
1406
1089
            self._raw_conflicts.append(('text conflict', trans_id))
1407
1090
            name = self.tt.final_name(trans_id)
1408
1091
            parent_id = self.tt.final_parent(trans_id)
1409
 
            file_group = self._dump_conflicts(name, parent_id, file_id,
 
1092
            file_group = self._dump_conflicts(name, parent_id, file_id, 
1410
1093
                                              no_base=True)
1411
1094
            file_group.append(trans_id)
1412
1095
 
1489
1172
                this_tree=None,
1490
1173
                pb=DummyProgress(),
1491
1174
                change_reporter=None):
1492
 
    """Primary interface for merging.
 
1175
    """Primary interface for merging. 
1493
1176
 
1494
 
        typical use is probably
 
1177
        typical use is probably 
1495
1178
        'merge_inner(branch, branch.get_revision_tree(other_revision),
1496
1179
                     branch.get_revision_tree(base_revision))'
1497
1180
        """
1589
1272
 
1590
1273
    def get_lines(self, revisions):
1591
1274
        """Get lines for revisions from the backing VersionedFiles.
1592
 
 
 
1275
        
1593
1276
        :raises RevisionNotPresent: on absent texts.
1594
1277
        """
1595
1278
        keys = [(self._key_prefix + (rev,)) for rev in revisions]
1597
1280
        for record in self.vf.get_record_stream(keys, 'unordered', True):
1598
1281
            if record.storage_kind == 'absent':
1599
1282
                raise errors.RevisionNotPresent(record.key, self.vf)
1600
 
            result[record.key[-1]] = osutils.chunks_to_lines(
1601
 
                record.get_bytes_as('chunked'))
 
1283
            result[record.key[-1]] = osutils.split_lines(
 
1284
                record.get_bytes_as('fulltext'))
1602
1285
        return result
1603
1286
 
1604
1287
    def plan_merge(self):
1794
1477
 
1795
1478
    def _find_unique_parents(self, tip_keys, base_key):
1796
1479
        """Find ancestors of tip that aren't ancestors of base.
1797
 
 
 
1480
        
1798
1481
        :param tip_keys: Nodes that are interesting
1799
1482
        :param base_key: Cull all ancestors of this node
1800
1483
        :return: The parent map for all revisions between tip_keys and
1860
1543
    @staticmethod
1861
1544
    def _prune_tails(parent_map, child_map, tails_to_remove):
1862
1545
        """Remove tails from the parent map.
1863
 
 
 
1546
        
1864
1547
        This will remove the supplied revisions until no more children have 0
1865
1548
        parents.
1866
1549