~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tree.py

resolve conflicts against trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2010 Canonical Ltd
 
1
# Copyright (C) 2005-2011 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
18
18
"""
19
19
 
20
20
import os
21
 
from collections import deque
22
 
 
23
 
import bzrlib
 
21
 
 
22
from bzrlib.lazy_import import lazy_import
 
23
lazy_import(globals(), """
 
24
import collections
 
25
 
24
26
from bzrlib import (
25
27
    conflicts as _mod_conflicts,
26
28
    debug,
27
29
    delta,
 
30
    errors,
28
31
    filters,
 
32
    inventory,
29
33
    osutils,
30
34
    revision as _mod_revision,
31
35
    rules,
 
36
    trace,
32
37
    )
 
38
""")
 
39
 
33
40
from bzrlib.decorators import needs_read_lock
34
 
from bzrlib.errors import BzrError, NoSuchId
35
 
from bzrlib import errors
36
 
from bzrlib.inventory import InventoryFile
37
41
from bzrlib.inter import InterObject
38
 
from bzrlib.osutils import fingerprint_file
39
 
from bzrlib.symbol_versioning import deprecated_function, deprecated_in
40
 
from bzrlib.trace import note
 
42
from bzrlib.symbol_versioning import (
 
43
    deprecated_in,
 
44
    deprecated_method,
 
45
    )
41
46
 
42
47
 
43
48
class Tree(object):
49
54
 
50
55
    * `RevisionTree` is a tree as recorded at some point in the past.
51
56
 
52
 
    Trees contain an `Inventory` object, and also know how to retrieve
53
 
    file texts mentioned in the inventory, either from a working
54
 
    directory or from a store.
55
 
 
56
 
    It is possible for trees to contain files that are not described
57
 
    in their inventory or vice versa; for this use `filenames()`.
58
 
 
59
57
    Trees can be compared, etc, regardless of whether they are working
60
58
    trees or versioned trees.
61
59
    """
127
125
        raise NotImplementedError(self.has_filename)
128
126
 
129
127
    def has_id(self, file_id):
130
 
        return self.inventory.has_id(file_id)
 
128
        raise NotImplementedError(self.has_id)
131
129
 
132
130
    def __contains__(self, file_id):
133
131
        return self.has_id(file_id)
134
132
 
135
133
    def has_or_had_id(self, file_id):
136
 
        return self.inventory.has_id(file_id)
 
134
        raise NotImplementedError(self.has_or_had_id)
137
135
 
138
136
    def is_ignored(self, filename):
139
137
        """Check whether the filename is ignored by this tree.
143
141
        """
144
142
        return False
145
143
 
146
 
    def __iter__(self):
147
 
        return iter(self.inventory)
148
 
 
149
144
    def all_file_ids(self):
150
145
        """Iterate through all file ids, including ids for missing files."""
151
 
        return set(self.inventory)
 
146
        raise NotImplementedError(self.all_file_ids)
152
147
 
153
148
    def id2path(self, file_id):
154
149
        """Return the path for a file id.
155
150
 
156
151
        :raises NoSuchId:
157
152
        """
158
 
        return self.inventory.id2path(file_id)
 
153
        raise NotImplementedError(self.id2path)
159
154
 
160
 
    @needs_read_lock
161
155
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
162
156
        """Walk the tree in 'by_dir' order.
163
157
 
180
174
             g
181
175
 
182
176
        The yield order (ignoring root) would be::
 
177
 
183
178
          a, f, a/b, a/d, a/b/c, a/d/e, f/g
184
179
 
185
180
        :param yield_parents: If True, yield the parents from the root leading
186
181
            down to specific_file_ids that have been requested. This has no
187
182
            impact if specific_file_ids is None.
188
183
        """
189
 
        return self.inventory.iter_entries_by_dir(
190
 
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
 
184
        raise NotImplementedError(self.iter_entries_by_dir)
 
185
 
 
186
    def list_files(self, include_root=False, from_dir=None, recursive=True):
 
187
        """List all files in this tree.
 
188
 
 
189
        :param include_root: Whether to include the entry for the tree root
 
190
        :param from_dir: Directory under which to list files
 
191
        :param recursive: Whether to list files recursively
 
192
        :return: iterator over tuples of (path, versioned, kind, file_id,
 
193
            inventory entry)
 
194
        """
 
195
        raise NotImplementedError(self.list_files)
191
196
 
192
197
    def iter_references(self):
193
198
        if self.supports_tree_reference():
244
249
    def _file_size(self, entry, stat_value):
245
250
        raise NotImplementedError(self._file_size)
246
251
 
247
 
    def _get_inventory(self):
248
 
        return self._inventory
249
 
 
250
252
    def get_file(self, file_id, path=None):
251
253
        """Return a file object for the file file_id in the tree.
252
254
 
288
290
 
289
291
        :param file_id: The file_id of the file.
290
292
        :param path: The path of the file.
 
293
 
291
294
        If both file_id and path are supplied, an implementation may use
292
295
        either one.
293
296
        """
294
297
        return osutils.split_lines(self.get_file_text(file_id, path))
295
298
 
 
299
    def get_file_sha1(self, file_id, path=None, stat_value=None):
 
300
        """Return the SHA1 file for a file.
 
301
 
 
302
        :param file_id: The handle for this file.
 
303
        :param path: The path that this file can be found at.
 
304
            These must point to the same object.
 
305
        :param stat_value: Optional stat value for the object
 
306
        """
 
307
        raise NotImplementedError(self.get_file_sha1)
 
308
 
296
309
    def get_file_mtime(self, file_id, path=None):
297
310
        """Return the modification time for a file.
298
311
 
312
325
        raise NotImplementedError(self.get_file_size)
313
326
 
314
327
    def get_file_by_path(self, path):
315
 
        return self.get_file(self._inventory.path2id(path), path)
 
328
        raise NotImplementedError(self.get_file_by_path)
 
329
 
 
330
    def is_executable(self, file_id, path=None):
 
331
        """Check if a file is executable.
 
332
 
 
333
        :param file_id: The handle for this file.
 
334
        :param path: The path that this file can be found at.
 
335
            These must point to the same object.
 
336
        """
 
337
        raise NotImplementedError(self.is_executable)
316
338
 
317
339
    def iter_files_bytes(self, desired_files):
318
340
        """Iterate through file contents.
340
362
            cur_file = (self.get_file_text(file_id),)
341
363
            yield identifier, cur_file
342
364
 
343
 
    def get_symlink_target(self, file_id):
 
365
    def get_symlink_target(self, file_id, path=None):
344
366
        """Get the target for a given file_id.
345
367
 
346
368
        It is assumed that the caller already knows that file_id is referencing
347
369
        a symlink.
348
370
        :param file_id: Handle for the symlink entry.
 
371
        :param path: The path of the file.
 
372
        If both file_id and path are supplied, an implementation may use
 
373
        either one.
349
374
        :return: The path the symlink points to.
350
375
        """
351
376
        raise NotImplementedError(self.get_symlink_target)
352
377
 
353
 
    def get_canonical_inventory_paths(self, paths):
354
 
        """Like get_canonical_inventory_path() but works on multiple items.
355
 
 
356
 
        :param paths: A sequence of paths relative to the root of the tree.
357
 
        :return: A list of paths, with each item the corresponding input path
358
 
        adjusted to account for existing elements that match case
359
 
        insensitively.
360
 
        """
361
 
        return list(self._yield_canonical_inventory_paths(paths))
362
 
 
363
 
    def get_canonical_inventory_path(self, path):
364
 
        """Returns the first inventory item that case-insensitively matches path.
365
 
 
366
 
        If a path matches exactly, it is returned. If no path matches exactly
367
 
        but more than one path matches case-insensitively, it is implementation
368
 
        defined which is returned.
369
 
 
370
 
        If no path matches case-insensitively, the input path is returned, but
371
 
        with as many path entries that do exist changed to their canonical
372
 
        form.
373
 
 
374
 
        If you need to resolve many names from the same tree, you should
375
 
        use get_canonical_inventory_paths() to avoid O(N) behaviour.
376
 
 
377
 
        :param path: A paths relative to the root of the tree.
378
 
        :return: The input path adjusted to account for existing elements
379
 
        that match case insensitively.
380
 
        """
381
 
        return self._yield_canonical_inventory_paths([path]).next()
382
 
 
383
 
    def _yield_canonical_inventory_paths(self, paths):
384
 
        for path in paths:
385
 
            # First, if the path as specified exists exactly, just use it.
386
 
            if self.path2id(path) is not None:
387
 
                yield path
388
 
                continue
389
 
            # go walkin...
390
 
            cur_id = self.get_root_id()
391
 
            cur_path = ''
392
 
            bit_iter = iter(path.split("/"))
393
 
            for elt in bit_iter:
394
 
                lelt = elt.lower()
395
 
                new_path = None
396
 
                for child in self.iter_children(cur_id):
397
 
                    try:
398
 
                        # XXX: it seem like if the child is known to be in the
399
 
                        # tree, we shouldn't need to go from its id back to
400
 
                        # its path -- mbp 2010-02-11
401
 
                        #
402
 
                        # XXX: it seems like we could be more efficient
403
 
                        # by just directly looking up the original name and
404
 
                        # only then searching all children; also by not
405
 
                        # chopping paths so much. -- mbp 2010-02-11
406
 
                        child_base = os.path.basename(self.id2path(child))
407
 
                        if (child_base == elt):
408
 
                            # if we found an exact match, we can stop now; if
409
 
                            # we found an approximate match we need to keep
410
 
                            # searching because there might be an exact match
411
 
                            # later.  
412
 
                            cur_id = child
413
 
                            new_path = osutils.pathjoin(cur_path, child_base)
414
 
                            break
415
 
                        elif child_base.lower() == lelt:
416
 
                            cur_id = child
417
 
                            new_path = osutils.pathjoin(cur_path, child_base)
418
 
                    except NoSuchId:
419
 
                        # before a change is committed we can see this error...
420
 
                        continue
421
 
                if new_path:
422
 
                    cur_path = new_path
423
 
                else:
424
 
                    # got to the end of this directory and no entries matched.
425
 
                    # Return what matched so far, plus the rest as specified.
426
 
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
427
 
                    break
428
 
            yield cur_path
429
 
        # all done.
430
 
 
431
378
    def get_root_id(self):
432
379
        """Return the file_id for the root of this tree."""
433
380
        raise NotImplementedError(self.get_root_id)
491
438
            except errors.NoSuchRevisionInTree:
492
439
                yield self.repository.revision_tree(revision_id)
493
440
 
494
 
    @staticmethod
495
 
    def _file_revision(revision_tree, file_id):
496
 
        """Determine the revision associated with a file in a given tree."""
497
 
        revision_tree.lock_read()
498
 
        try:
499
 
            return revision_tree.inventory[file_id].revision
500
 
        finally:
501
 
            revision_tree.unlock()
502
 
 
503
441
    def _get_file_revision(self, file_id, vf, tree_revision):
504
442
        """Ensure that file_id, tree_revision is in vf to plan the merge."""
505
443
 
506
444
        if getattr(self, '_repository', None) is None:
507
445
            last_revision = tree_revision
508
 
            parent_keys = [(file_id, self._file_revision(t, file_id)) for t in
 
446
            parent_keys = [(file_id, t.get_file_revision(file_id)) for t in
509
447
                self._iter_parent_trees()]
510
448
            vf.add_lines((file_id, last_revision), parent_keys,
511
449
                         self.get_file_lines(file_id))
512
450
            repo = self.branch.repository
513
451
            base_vf = repo.texts
514
452
        else:
515
 
            last_revision = self._file_revision(self, file_id)
 
453
            last_revision = self.get_file_revision(file_id)
516
454
            base_vf = self._repository.texts
517
455
        if base_vf not in vf.fallback_versionedfiles:
518
456
            vf.fallback_versionedfiles.append(base_vf)
519
457
        return last_revision
520
458
 
521
 
    inventory = property(_get_inventory,
522
 
                         doc="Inventory of this Tree")
523
 
 
524
459
    def _check_retrieved(self, ie, f):
525
460
        if not __debug__:
526
461
            return
527
 
        fp = fingerprint_file(f)
 
462
        fp = osutils.fingerprint_file(f)
528
463
        f.seek(0)
529
464
 
530
465
        if ie.text_size is not None:
531
466
            if ie.text_size != fp['size']:
532
 
                raise BzrError("mismatched size for file %r in %r" % (ie.file_id, self._store),
 
467
                raise errors.BzrError(
 
468
                        "mismatched size for file %r in %r" %
 
469
                        (ie.file_id, self._store),
533
470
                        ["inventory expects %d bytes" % ie.text_size,
534
471
                         "file is actually %d bytes" % fp['size'],
535
472
                         "store is probably damaged/corrupt"])
536
473
 
537
474
        if ie.text_sha1 != fp['sha1']:
538
 
            raise BzrError("wrong SHA-1 for file %r in %r" % (ie.file_id, self._store),
 
475
            raise errors.BzrError("wrong SHA-1 for file %r in %r" %
 
476
                    (ie.file_id, self._store),
539
477
                    ["inventory expects %s" % ie.text_sha1,
540
478
                     "file is actually %s" % fp['sha1'],
541
479
                     "store is probably damaged/corrupt"])
542
480
 
543
 
    @needs_read_lock
544
481
    def path2id(self, path):
545
482
        """Return the id for path in this tree."""
546
 
        return self._inventory.path2id(path)
 
483
        raise NotImplementedError(self.path2id)
547
484
 
548
485
    def paths2ids(self, paths, trees=[], require_versioned=True):
549
486
        """Return all the ids that can be reached by walking from paths.
606
543
 
607
544
        :return: set of paths.
608
545
        """
609
 
        # NB: we specifically *don't* call self.has_filename, because for
610
 
        # WorkingTrees that can indicate files that exist on disk but that
611
 
        # are not versioned.
612
 
        pred = self.inventory.has_filename
613
 
        return set((p for p in paths if not pred(p)))
 
546
        raise NotImplementedError(self.filter_unversioned_files)
614
547
 
615
548
    def walkdirs(self, prefix=""):
616
549
        """Walk the contents of this tree from path down.
668
601
        prefs = self.iter_search_rules([path], filter_pref_names).next()
669
602
        stk = filters._get_filter_stack_for(prefs)
670
603
        if 'filters' in debug.debug_flags:
671
 
            note("*** %s content-filter: %s => %r" % (path,prefs,stk))
 
604
            trace.note("*** %s content-filter: %s => %r" % (path,prefs,stk))
672
605
        return stk
673
606
 
674
607
    def _content_filter_stack_provider(self):
713
646
        return searcher
714
647
 
715
648
 
 
649
class InventoryTree(Tree):
 
650
    """A tree that relies on an inventory for its metadata.
 
651
 
 
652
    Trees contain an `Inventory` object, and also know how to retrieve
 
653
    file texts mentioned in the inventory, either from a working
 
654
    directory or from a store.
 
655
 
 
656
    It is possible for trees to contain files that are not described
 
657
    in their inventory or vice versa; for this use `filenames()`.
 
658
 
 
659
    Subclasses should set the _inventory attribute, which is considered
 
660
    private to external API users.
 
661
    """
 
662
 
 
663
    def get_canonical_inventory_paths(self, paths):
 
664
        """Like get_canonical_inventory_path() but works on multiple items.
 
665
 
 
666
        :param paths: A sequence of paths relative to the root of the tree.
 
667
        :return: A list of paths, with each item the corresponding input path
 
668
        adjusted to account for existing elements that match case
 
669
        insensitively.
 
670
        """
 
671
        return list(self._yield_canonical_inventory_paths(paths))
 
672
 
 
673
    def get_canonical_inventory_path(self, path):
 
674
        """Returns the first inventory item that case-insensitively matches path.
 
675
 
 
676
        If a path matches exactly, it is returned. If no path matches exactly
 
677
        but more than one path matches case-insensitively, it is implementation
 
678
        defined which is returned.
 
679
 
 
680
        If no path matches case-insensitively, the input path is returned, but
 
681
        with as many path entries that do exist changed to their canonical
 
682
        form.
 
683
 
 
684
        If you need to resolve many names from the same tree, you should
 
685
        use get_canonical_inventory_paths() to avoid O(N) behaviour.
 
686
 
 
687
        :param path: A paths relative to the root of the tree.
 
688
        :return: The input path adjusted to account for existing elements
 
689
        that match case insensitively.
 
690
        """
 
691
        return self._yield_canonical_inventory_paths([path]).next()
 
692
 
 
693
    def _yield_canonical_inventory_paths(self, paths):
 
694
        for path in paths:
 
695
            # First, if the path as specified exists exactly, just use it.
 
696
            if self.path2id(path) is not None:
 
697
                yield path
 
698
                continue
 
699
            # go walkin...
 
700
            cur_id = self.get_root_id()
 
701
            cur_path = ''
 
702
            bit_iter = iter(path.split("/"))
 
703
            for elt in bit_iter:
 
704
                lelt = elt.lower()
 
705
                new_path = None
 
706
                for child in self.iter_children(cur_id):
 
707
                    try:
 
708
                        # XXX: it seem like if the child is known to be in the
 
709
                        # tree, we shouldn't need to go from its id back to
 
710
                        # its path -- mbp 2010-02-11
 
711
                        #
 
712
                        # XXX: it seems like we could be more efficient
 
713
                        # by just directly looking up the original name and
 
714
                        # only then searching all children; also by not
 
715
                        # chopping paths so much. -- mbp 2010-02-11
 
716
                        child_base = os.path.basename(self.id2path(child))
 
717
                        if (child_base == elt):
 
718
                            # if we found an exact match, we can stop now; if
 
719
                            # we found an approximate match we need to keep
 
720
                            # searching because there might be an exact match
 
721
                            # later.  
 
722
                            cur_id = child
 
723
                            new_path = osutils.pathjoin(cur_path, child_base)
 
724
                            break
 
725
                        elif child_base.lower() == lelt:
 
726
                            cur_id = child
 
727
                            new_path = osutils.pathjoin(cur_path, child_base)
 
728
                    except errors.NoSuchId:
 
729
                        # before a change is committed we can see this error...
 
730
                        continue
 
731
                if new_path:
 
732
                    cur_path = new_path
 
733
                else:
 
734
                    # got to the end of this directory and no entries matched.
 
735
                    # Return what matched so far, plus the rest as specified.
 
736
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
 
737
                    break
 
738
            yield cur_path
 
739
        # all done.
 
740
 
 
741
    def _get_inventory(self):
 
742
        return self._inventory
 
743
 
 
744
    inventory = property(_get_inventory,
 
745
                         doc="Inventory of this Tree")
 
746
 
 
747
    @needs_read_lock
 
748
    def path2id(self, path):
 
749
        """Return the id for path in this tree."""
 
750
        return self._inventory.path2id(path)
 
751
 
 
752
    def id2path(self, file_id):
 
753
        """Return the path for a file id.
 
754
 
 
755
        :raises NoSuchId:
 
756
        """
 
757
        return self.inventory.id2path(file_id)
 
758
 
 
759
    def has_id(self, file_id):
 
760
        return self.inventory.has_id(file_id)
 
761
 
 
762
    def has_or_had_id(self, file_id):
 
763
        return self.inventory.has_id(file_id)
 
764
 
 
765
    def all_file_ids(self):
 
766
        return set(self.inventory)
 
767
 
 
768
    @deprecated_method(deprecated_in((2, 4, 0)))
 
769
    def __iter__(self):
 
770
        return iter(self.inventory)
 
771
 
 
772
    def filter_unversioned_files(self, paths):
 
773
        """Filter out paths that are versioned.
 
774
 
 
775
        :return: set of paths.
 
776
        """
 
777
        # NB: we specifically *don't* call self.has_filename, because for
 
778
        # WorkingTrees that can indicate files that exist on disk but that
 
779
        # are not versioned.
 
780
        pred = self.inventory.has_filename
 
781
        return set((p for p in paths if not pred(p)))
 
782
 
 
783
    @needs_read_lock
 
784
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
 
785
        """Walk the tree in 'by_dir' order.
 
786
 
 
787
        This will yield each entry in the tree as a (path, entry) tuple.
 
788
        The order that they are yielded is:
 
789
 
 
790
        See Tree.iter_entries_by_dir for details.
 
791
 
 
792
        :param yield_parents: If True, yield the parents from the root leading
 
793
            down to specific_file_ids that have been requested. This has no
 
794
            impact if specific_file_ids is None.
 
795
        """
 
796
        return self.inventory.iter_entries_by_dir(
 
797
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
 
798
 
 
799
    def get_file_by_path(self, path):
 
800
        return self.get_file(self._inventory.path2id(path), path)
 
801
 
 
802
 
716
803
######################################################################
717
804
# diff
718
805
 
776
863
        None)
777
864
    :param trees: The trees to find file_ids within
778
865
    :param require_versioned: if true, all specified filenames must occur in
779
 
    at least one tree.
 
866
        at least one tree.
780
867
    :return: a set of file ids for the specified filenames and their children.
781
868
    """
782
869
    if not filenames:
858
945
 
859
946
    _optimisers = []
860
947
 
 
948
    @classmethod
 
949
    def is_compatible(kls, source, target):
 
950
        # The default implementation is naive and uses the public API, so
 
951
        # it works for all trees.
 
952
        return True
 
953
 
861
954
    def _changes_from_entries(self, source_entry, target_entry,
862
955
        source_path=None, target_path=None):
863
956
        """Generate a iter_changes tuple between source_entry and target_entry.
968
1061
            # All files are unversioned, so just return an empty delta
969
1062
            # _compare_trees would think we want a complete delta
970
1063
            result = delta.TreeDelta()
971
 
            fake_entry = InventoryFile('unused', 'unused', 'unused')
 
1064
            fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
972
1065
            result.unversioned = [(path, None,
973
1066
                self.target._comparison_data(fake_entry, path)[0]) for path in
974
1067
                specific_files]
1039
1132
                                     self.target.extras()
1040
1133
                if specific_files is None or
1041
1134
                    osutils.is_inside_any(specific_files, p)])
1042
 
            all_unversioned = deque(all_unversioned)
 
1135
            all_unversioned = collections.deque(all_unversioned)
1043
1136
        else:
1044
 
            all_unversioned = deque()
 
1137
            all_unversioned = collections.deque()
1045
1138
        to_paths = {}
1046
1139
        from_entries_by_dir = list(self.source.iter_entries_by_dir(
1047
1140
            specific_file_ids=specific_file_ids))
1053
1146
        # the unversioned path lookup only occurs on real trees - where there
1054
1147
        # can be extras. So the fake_entry is solely used to look up
1055
1148
        # executable it values when execute is not supported.
1056
 
        fake_entry = InventoryFile('unused', 'unused', 'unused')
 
1149
        fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
1057
1150
        for target_path, target_entry in to_entries_by_dir:
1058
1151
            while (all_unversioned and
1059
1152
                all_unversioned[0][0] < target_path.split('/')):
1232
1325
                    yield result
1233
1326
 
1234
1327
 
 
1328
InterTree.register_optimiser(InterTree)
 
1329
 
 
1330
 
1235
1331
class MultiWalker(object):
1236
1332
    """Walk multiple trees simultaneously, getting combined results."""
1237
1333