~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tree.py

  • Committer: Vincent Ladeuil
  • Date: 2011-05-17 20:58:43 UTC
  • mfrom: (5609.39.5 2.3)
  • mto: This revision was merged to the branch mainline in revision 5885.
  • Revision ID: v.ladeuil+lp@free.fr-20110517205843-uo1tntrz6kqfn1hb
Merge 2.3 into 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)
159
 
 
160
 
    def is_control_filename(self, filename):
161
 
        """True if filename is the name of a control file in this tree.
162
 
 
163
 
        :param filename: A filename within the tree. This is a relative path
164
 
        from the root of this tree.
165
 
 
166
 
        This is true IF and ONLY IF the filename is part of the meta data
167
 
        that bzr controls in this tree. I.E. a random .bzr directory placed
168
 
        on disk will not be a control file for this tree.
169
 
        """
170
 
        return self.bzrdir.is_control_filename(filename)
171
 
 
172
 
    @needs_read_lock
 
153
        raise NotImplementedError(self.id2path)
 
154
 
173
155
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
174
156
        """Walk the tree in 'by_dir' order.
175
157
 
198
180
            down to specific_file_ids that have been requested. This has no
199
181
            impact if specific_file_ids is None.
200
182
        """
201
 
        return self.inventory.iter_entries_by_dir(
202
 
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
 
183
        raise NotImplementedError(self.iter_entries_by_dir)
 
184
 
 
185
    def list_files(self, include_root=False, from_dir=None, recursive=True):
 
186
        """List all files in this tree.
 
187
 
 
188
        :param include_root: Whether to include the entry for the tree root
 
189
        :param from_dir: Directory under which to list files
 
190
        :param recursive: Whether to list files recursively
 
191
        :return: iterator over tuples of (path, versioned, kind, file_id,
 
192
            inventory entry)
 
193
        """
 
194
        raise NotImplementedError(self.list_files)
203
195
 
204
196
    def iter_references(self):
205
197
        if self.supports_tree_reference():
256
248
    def _file_size(self, entry, stat_value):
257
249
        raise NotImplementedError(self._file_size)
258
250
 
259
 
    def _get_inventory(self):
260
 
        return self._inventory
261
 
 
262
251
    def get_file(self, file_id, path=None):
263
252
        """Return a file object for the file file_id in the tree.
264
253
 
305
294
        """
306
295
        return osutils.split_lines(self.get_file_text(file_id, path))
307
296
 
 
297
    def get_file_sha1(self, file_id, path=None):
 
298
        """Return the SHA1 file for a file.
 
299
 
 
300
        :param file_id: The handle for this file.
 
301
        :param path: The path that this file can be found at.
 
302
            These must point to the same object.
 
303
        """
 
304
        raise NotImplementedError(self.get_file_sha1)
 
305
 
308
306
    def get_file_mtime(self, file_id, path=None):
309
307
        """Return the modification time for a file.
310
308
 
324
322
        raise NotImplementedError(self.get_file_size)
325
323
 
326
324
    def get_file_by_path(self, path):
327
 
        return self.get_file(self._inventory.path2id(path), path)
 
325
        raise NotImplementedError(self.get_file_by_path)
 
326
 
 
327
    def is_executable(self, file_id, path=None):
 
328
        """Check if a file is executable.
 
329
 
 
330
        :param file_id: The handle for this file.
 
331
        :param path: The path that this file can be found at.
 
332
            These must point to the same object.
 
333
        """
 
334
        raise NotImplementedError(self.is_executable)
328
335
 
329
336
    def iter_files_bytes(self, desired_files):
330
337
        """Iterate through file contents.
352
359
            cur_file = (self.get_file_text(file_id),)
353
360
            yield identifier, cur_file
354
361
 
355
 
    def get_symlink_target(self, file_id):
 
362
    def get_symlink_target(self, file_id, path=None):
356
363
        """Get the target for a given file_id.
357
364
 
358
365
        It is assumed that the caller already knows that file_id is referencing
359
366
        a symlink.
360
367
        :param file_id: Handle for the symlink entry.
 
368
        :param path: The path of the file.
 
369
        If both file_id and path are supplied, an implementation may use
 
370
        either one.
361
371
        :return: The path the symlink points to.
362
372
        """
363
373
        raise NotImplementedError(self.get_symlink_target)
364
374
 
365
 
    def get_canonical_inventory_paths(self, paths):
366
 
        """Like get_canonical_inventory_path() but works on multiple items.
367
 
 
368
 
        :param paths: A sequence of paths relative to the root of the tree.
369
 
        :return: A list of paths, with each item the corresponding input path
370
 
        adjusted to account for existing elements that match case
371
 
        insensitively.
372
 
        """
373
 
        return list(self._yield_canonical_inventory_paths(paths))
374
 
 
375
 
    def get_canonical_inventory_path(self, path):
376
 
        """Returns the first inventory item that case-insensitively matches path.
377
 
 
378
 
        If a path matches exactly, it is returned. If no path matches exactly
379
 
        but more than one path matches case-insensitively, it is implementation
380
 
        defined which is returned.
381
 
 
382
 
        If no path matches case-insensitively, the input path is returned, but
383
 
        with as many path entries that do exist changed to their canonical
384
 
        form.
385
 
 
386
 
        If you need to resolve many names from the same tree, you should
387
 
        use get_canonical_inventory_paths() to avoid O(N) behaviour.
388
 
 
389
 
        :param path: A paths relative to the root of the tree.
390
 
        :return: The input path adjusted to account for existing elements
391
 
        that match case insensitively.
392
 
        """
393
 
        return self._yield_canonical_inventory_paths([path]).next()
394
 
 
395
 
    def _yield_canonical_inventory_paths(self, paths):
396
 
        for path in paths:
397
 
            # First, if the path as specified exists exactly, just use it.
398
 
            if self.path2id(path) is not None:
399
 
                yield path
400
 
                continue
401
 
            # go walkin...
402
 
            cur_id = self.get_root_id()
403
 
            cur_path = ''
404
 
            bit_iter = iter(path.split("/"))
405
 
            for elt in bit_iter:
406
 
                lelt = elt.lower()
407
 
                new_path = None
408
 
                for child in self.iter_children(cur_id):
409
 
                    try:
410
 
                        # XXX: it seem like if the child is known to be in the
411
 
                        # tree, we shouldn't need to go from its id back to
412
 
                        # its path -- mbp 2010-02-11
413
 
                        #
414
 
                        # XXX: it seems like we could be more efficient
415
 
                        # by just directly looking up the original name and
416
 
                        # only then searching all children; also by not
417
 
                        # chopping paths so much. -- mbp 2010-02-11
418
 
                        child_base = os.path.basename(self.id2path(child))
419
 
                        if (child_base == elt):
420
 
                            # if we found an exact match, we can stop now; if
421
 
                            # we found an approximate match we need to keep
422
 
                            # searching because there might be an exact match
423
 
                            # later.  
424
 
                            cur_id = child
425
 
                            new_path = osutils.pathjoin(cur_path, child_base)
426
 
                            break
427
 
                        elif child_base.lower() == lelt:
428
 
                            cur_id = child
429
 
                            new_path = osutils.pathjoin(cur_path, child_base)
430
 
                    except NoSuchId:
431
 
                        # before a change is committed we can see this error...
432
 
                        continue
433
 
                if new_path:
434
 
                    cur_path = new_path
435
 
                else:
436
 
                    # got to the end of this directory and no entries matched.
437
 
                    # Return what matched so far, plus the rest as specified.
438
 
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
439
 
                    break
440
 
            yield cur_path
441
 
        # all done.
442
 
 
443
375
    def get_root_id(self):
444
376
        """Return the file_id for the root of this tree."""
445
377
        raise NotImplementedError(self.get_root_id)
503
435
            except errors.NoSuchRevisionInTree:
504
436
                yield self.repository.revision_tree(revision_id)
505
437
 
506
 
    @staticmethod
507
 
    def _file_revision(revision_tree, file_id):
508
 
        """Determine the revision associated with a file in a given tree."""
509
 
        revision_tree.lock_read()
510
 
        try:
511
 
            return revision_tree.inventory[file_id].revision
512
 
        finally:
513
 
            revision_tree.unlock()
514
 
 
515
438
    def _get_file_revision(self, file_id, vf, tree_revision):
516
439
        """Ensure that file_id, tree_revision is in vf to plan the merge."""
517
440
 
518
441
        if getattr(self, '_repository', None) is None:
519
442
            last_revision = tree_revision
520
 
            parent_keys = [(file_id, self._file_revision(t, file_id)) for t in
 
443
            parent_keys = [(file_id, t.get_file_revision(file_id)) for t in
521
444
                self._iter_parent_trees()]
522
445
            vf.add_lines((file_id, last_revision), parent_keys,
523
446
                         self.get_file_lines(file_id))
524
447
            repo = self.branch.repository
525
448
            base_vf = repo.texts
526
449
        else:
527
 
            last_revision = self._file_revision(self, file_id)
 
450
            last_revision = self.get_file_revision(file_id)
528
451
            base_vf = self._repository.texts
529
452
        if base_vf not in vf.fallback_versionedfiles:
530
453
            vf.fallback_versionedfiles.append(base_vf)
531
454
        return last_revision
532
455
 
533
 
    inventory = property(_get_inventory,
534
 
                         doc="Inventory of this Tree")
535
 
 
536
456
    def _check_retrieved(self, ie, f):
537
457
        if not __debug__:
538
458
            return
539
 
        fp = fingerprint_file(f)
 
459
        fp = osutils.fingerprint_file(f)
540
460
        f.seek(0)
541
461
 
542
462
        if ie.text_size is not None:
543
463
            if ie.text_size != fp['size']:
544
 
                raise BzrError("mismatched size for file %r in %r" % (ie.file_id, self._store),
 
464
                raise errors.BzrError(
 
465
                        "mismatched size for file %r in %r" %
 
466
                        (ie.file_id, self._store),
545
467
                        ["inventory expects %d bytes" % ie.text_size,
546
468
                         "file is actually %d bytes" % fp['size'],
547
469
                         "store is probably damaged/corrupt"])
548
470
 
549
471
        if ie.text_sha1 != fp['sha1']:
550
 
            raise BzrError("wrong SHA-1 for file %r in %r" % (ie.file_id, self._store),
 
472
            raise errors.BzrError("wrong SHA-1 for file %r in %r" %
 
473
                    (ie.file_id, self._store),
551
474
                    ["inventory expects %s" % ie.text_sha1,
552
475
                     "file is actually %s" % fp['sha1'],
553
476
                     "store is probably damaged/corrupt"])
554
477
 
555
 
    @needs_read_lock
556
478
    def path2id(self, path):
557
479
        """Return the id for path in this tree."""
558
 
        return self._inventory.path2id(path)
 
480
        raise NotImplementedError(self.path2id)
559
481
 
560
482
    def paths2ids(self, paths, trees=[], require_versioned=True):
561
483
        """Return all the ids that can be reached by walking from paths.
618
540
 
619
541
        :return: set of paths.
620
542
        """
621
 
        # NB: we specifically *don't* call self.has_filename, because for
622
 
        # WorkingTrees that can indicate files that exist on disk but that
623
 
        # are not versioned.
624
 
        pred = self.inventory.has_filename
625
 
        return set((p for p in paths if not pred(p)))
 
543
        raise NotImplementedError(self.filter_unversioned_files)
626
544
 
627
545
    def walkdirs(self, prefix=""):
628
546
        """Walk the contents of this tree from path down.
680
598
        prefs = self.iter_search_rules([path], filter_pref_names).next()
681
599
        stk = filters._get_filter_stack_for(prefs)
682
600
        if 'filters' in debug.debug_flags:
683
 
            note("*** %s content-filter: %s => %r" % (path,prefs,stk))
 
601
            trace.note("*** %s content-filter: %s => %r" % (path,prefs,stk))
684
602
        return stk
685
603
 
686
604
    def _content_filter_stack_provider(self):
725
643
        return searcher
726
644
 
727
645
 
 
646
class InventoryTree(Tree):
 
647
    """A tree that relies on an inventory for its metadata.
 
648
 
 
649
    Trees contain an `Inventory` object, and also know how to retrieve
 
650
    file texts mentioned in the inventory, either from a working
 
651
    directory or from a store.
 
652
 
 
653
    It is possible for trees to contain files that are not described
 
654
    in their inventory or vice versa; for this use `filenames()`.
 
655
 
 
656
    Subclasses should set the _inventory attribute, which is considered
 
657
    private to external API users.
 
658
    """
 
659
 
 
660
    def get_canonical_inventory_paths(self, paths):
 
661
        """Like get_canonical_inventory_path() but works on multiple items.
 
662
 
 
663
        :param paths: A sequence of paths relative to the root of the tree.
 
664
        :return: A list of paths, with each item the corresponding input path
 
665
        adjusted to account for existing elements that match case
 
666
        insensitively.
 
667
        """
 
668
        return list(self._yield_canonical_inventory_paths(paths))
 
669
 
 
670
    def get_canonical_inventory_path(self, path):
 
671
        """Returns the first inventory item that case-insensitively matches path.
 
672
 
 
673
        If a path matches exactly, it is returned. If no path matches exactly
 
674
        but more than one path matches case-insensitively, it is implementation
 
675
        defined which is returned.
 
676
 
 
677
        If no path matches case-insensitively, the input path is returned, but
 
678
        with as many path entries that do exist changed to their canonical
 
679
        form.
 
680
 
 
681
        If you need to resolve many names from the same tree, you should
 
682
        use get_canonical_inventory_paths() to avoid O(N) behaviour.
 
683
 
 
684
        :param path: A paths relative to the root of the tree.
 
685
        :return: The input path adjusted to account for existing elements
 
686
        that match case insensitively.
 
687
        """
 
688
        return self._yield_canonical_inventory_paths([path]).next()
 
689
 
 
690
    def _yield_canonical_inventory_paths(self, paths):
 
691
        for path in paths:
 
692
            # First, if the path as specified exists exactly, just use it.
 
693
            if self.path2id(path) is not None:
 
694
                yield path
 
695
                continue
 
696
            # go walkin...
 
697
            cur_id = self.get_root_id()
 
698
            cur_path = ''
 
699
            bit_iter = iter(path.split("/"))
 
700
            for elt in bit_iter:
 
701
                lelt = elt.lower()
 
702
                new_path = None
 
703
                for child in self.iter_children(cur_id):
 
704
                    try:
 
705
                        # XXX: it seem like if the child is known to be in the
 
706
                        # tree, we shouldn't need to go from its id back to
 
707
                        # its path -- mbp 2010-02-11
 
708
                        #
 
709
                        # XXX: it seems like we could be more efficient
 
710
                        # by just directly looking up the original name and
 
711
                        # only then searching all children; also by not
 
712
                        # chopping paths so much. -- mbp 2010-02-11
 
713
                        child_base = os.path.basename(self.id2path(child))
 
714
                        if (child_base == elt):
 
715
                            # if we found an exact match, we can stop now; if
 
716
                            # we found an approximate match we need to keep
 
717
                            # searching because there might be an exact match
 
718
                            # later.  
 
719
                            cur_id = child
 
720
                            new_path = osutils.pathjoin(cur_path, child_base)
 
721
                            break
 
722
                        elif child_base.lower() == lelt:
 
723
                            cur_id = child
 
724
                            new_path = osutils.pathjoin(cur_path, child_base)
 
725
                    except errors.NoSuchId:
 
726
                        # before a change is committed we can see this error...
 
727
                        continue
 
728
                if new_path:
 
729
                    cur_path = new_path
 
730
                else:
 
731
                    # got to the end of this directory and no entries matched.
 
732
                    # Return what matched so far, plus the rest as specified.
 
733
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
 
734
                    break
 
735
            yield cur_path
 
736
        # all done.
 
737
 
 
738
    def _get_inventory(self):
 
739
        return self._inventory
 
740
 
 
741
    inventory = property(_get_inventory,
 
742
                         doc="Inventory of this Tree")
 
743
 
 
744
    @needs_read_lock
 
745
    def path2id(self, path):
 
746
        """Return the id for path in this tree."""
 
747
        return self._inventory.path2id(path)
 
748
 
 
749
    def id2path(self, file_id):
 
750
        """Return the path for a file id.
 
751
 
 
752
        :raises NoSuchId:
 
753
        """
 
754
        return self.inventory.id2path(file_id)
 
755
 
 
756
    def has_id(self, file_id):
 
757
        return self.inventory.has_id(file_id)
 
758
 
 
759
    def has_or_had_id(self, file_id):
 
760
        return self.inventory.has_id(file_id)
 
761
 
 
762
    def all_file_ids(self):
 
763
        return set(self.inventory)
 
764
 
 
765
    @deprecated_method(deprecated_in((2, 4, 0)))
 
766
    def __iter__(self):
 
767
        return iter(self.inventory)
 
768
 
 
769
    def filter_unversioned_files(self, paths):
 
770
        """Filter out paths that are versioned.
 
771
 
 
772
        :return: set of paths.
 
773
        """
 
774
        # NB: we specifically *don't* call self.has_filename, because for
 
775
        # WorkingTrees that can indicate files that exist on disk but that
 
776
        # are not versioned.
 
777
        pred = self.inventory.has_filename
 
778
        return set((p for p in paths if not pred(p)))
 
779
 
 
780
    @needs_read_lock
 
781
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
 
782
        """Walk the tree in 'by_dir' order.
 
783
 
 
784
        This will yield each entry in the tree as a (path, entry) tuple.
 
785
        The order that they are yielded is:
 
786
 
 
787
        See Tree.iter_entries_by_dir for details.
 
788
 
 
789
        :param yield_parents: If True, yield the parents from the root leading
 
790
            down to specific_file_ids that have been requested. This has no
 
791
            impact if specific_file_ids is None.
 
792
        """
 
793
        return self.inventory.iter_entries_by_dir(
 
794
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
 
795
 
 
796
    def get_file_by_path(self, path):
 
797
        return self.get_file(self._inventory.path2id(path), path)
 
798
 
 
799
 
728
800
######################################################################
729
801
# diff
730
802
 
778
850
    return 'wtf?'
779
851
 
780
852
 
781
 
@deprecated_function(deprecated_in((1, 9, 0)))
782
 
def find_renames(old_inv, new_inv):
783
 
    for file_id in old_inv:
784
 
        if file_id not in new_inv:
785
 
            continue
786
 
        old_name = old_inv.id2path(file_id)
787
 
        new_name = new_inv.id2path(file_id)
788
 
        if old_name != new_name:
789
 
            yield (old_name, new_name)
790
 
 
791
 
 
792
853
def find_ids_across_trees(filenames, trees, require_versioned=True):
793
854
    """Find the ids corresponding to specified filenames.
794
855
 
881
942
 
882
943
    _optimisers = []
883
944
 
 
945
    @classmethod
 
946
    def is_compatible(kls, source, target):
 
947
        # The default implementation is naive and uses the public API, so
 
948
        # it works for all trees.
 
949
        return True
 
950
 
884
951
    def _changes_from_entries(self, source_entry, target_entry,
885
952
        source_path=None, target_path=None):
886
953
        """Generate a iter_changes tuple between source_entry and target_entry.
991
1058
            # All files are unversioned, so just return an empty delta
992
1059
            # _compare_trees would think we want a complete delta
993
1060
            result = delta.TreeDelta()
994
 
            fake_entry = InventoryFile('unused', 'unused', 'unused')
 
1061
            fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
995
1062
            result.unversioned = [(path, None,
996
1063
                self.target._comparison_data(fake_entry, path)[0]) for path in
997
1064
                specific_files]
1062
1129
                                     self.target.extras()
1063
1130
                if specific_files is None or
1064
1131
                    osutils.is_inside_any(specific_files, p)])
1065
 
            all_unversioned = deque(all_unversioned)
 
1132
            all_unversioned = collections.deque(all_unversioned)
1066
1133
        else:
1067
 
            all_unversioned = deque()
 
1134
            all_unversioned = collections.deque()
1068
1135
        to_paths = {}
1069
1136
        from_entries_by_dir = list(self.source.iter_entries_by_dir(
1070
1137
            specific_file_ids=specific_file_ids))
1076
1143
        # the unversioned path lookup only occurs on real trees - where there
1077
1144
        # can be extras. So the fake_entry is solely used to look up
1078
1145
        # executable it values when execute is not supported.
1079
 
        fake_entry = InventoryFile('unused', 'unused', 'unused')
 
1146
        fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
1080
1147
        for target_path, target_entry in to_entries_by_dir:
1081
1148
            while (all_unversioned and
1082
1149
                all_unversioned[0][0] < target_path.split('/')):
1255
1322
                    yield result
1256
1323
 
1257
1324
 
 
1325
InterTree.register_optimiser(InterTree)
 
1326
 
 
1327
 
1258
1328
class MultiWalker(object):
1259
1329
    """Walk multiple trees simultaneously, getting combined results."""
1260
1330