~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tree.py

  • Committer: Jelmer Vernooij
  • Date: 2011-03-10 13:52:27 UTC
  • mto: (5712.4.5 bzrdir-weave)
  • mto: This revision was merged to the branch mainline in revision 5716.
  • Revision ID: jelmer@samba.org-20110310135227-ufcw0utlwsp8r6k6
Revert registry changes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2011 Canonical Ltd
 
1
# Copyright (C) 2005-2010 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
 
 
22
 
from bzrlib.lazy_import import lazy_import
23
 
lazy_import(globals(), """
24
 
import collections
25
 
 
 
21
from collections import deque
 
22
 
 
23
import bzrlib
26
24
from bzrlib import (
27
25
    conflicts as _mod_conflicts,
28
26
    debug,
29
27
    delta,
30
 
    errors,
31
28
    filters,
32
 
    inventory,
33
29
    osutils,
34
30
    revision as _mod_revision,
35
31
    rules,
36
 
    trace,
37
32
    )
38
 
""")
39
 
 
40
33
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
41
37
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
41
 
43
42
 
44
43
class Tree(object):
50
49
 
51
50
    * `RevisionTree` is a tree as recorded at some point in the past.
52
51
 
 
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
 
53
59
    Trees can be compared, etc, regardless of whether they are working
54
60
    trees or versioned trees.
55
61
    """
121
127
        raise NotImplementedError(self.has_filename)
122
128
 
123
129
    def has_id(self, file_id):
124
 
        raise NotImplementedError(self.has_id)
 
130
        return self.inventory.has_id(file_id)
125
131
 
126
132
    def __contains__(self, file_id):
127
133
        return self.has_id(file_id)
128
134
 
129
135
    def has_or_had_id(self, file_id):
130
 
        raise NotImplementedError(self.has_or_had_id)
 
136
        return self.inventory.has_id(file_id)
131
137
 
132
138
    def is_ignored(self, filename):
133
139
        """Check whether the filename is ignored by this tree.
138
144
        return False
139
145
 
140
146
    def __iter__(self):
141
 
        """Yield all file ids in this tree."""
142
 
        raise NotImplementedError(self.__iter__)
 
147
        return iter(self.inventory)
143
148
 
144
149
    def all_file_ids(self):
145
150
        """Iterate through all file ids, including ids for missing files."""
150
155
 
151
156
        :raises NoSuchId:
152
157
        """
153
 
        raise NotImplementedError(self.id2path)
 
158
        return self.inventory.id2path(file_id)
154
159
 
 
160
    @needs_read_lock
155
161
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
156
162
        """Walk the tree in 'by_dir' order.
157
163
 
180
186
            down to specific_file_ids that have been requested. This has no
181
187
            impact if specific_file_ids is None.
182
188
        """
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)
 
189
        return self.inventory.iter_entries_by_dir(
 
190
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
195
191
 
196
192
    def iter_references(self):
197
193
        if self.supports_tree_reference():
248
244
    def _file_size(self, entry, stat_value):
249
245
        raise NotImplementedError(self._file_size)
250
246
 
 
247
    def _get_inventory(self):
 
248
        return self._inventory
 
249
 
251
250
    def get_file(self, file_id, path=None):
252
251
        """Return a file object for the file file_id in the tree.
253
252
 
294
293
        """
295
294
        return osutils.split_lines(self.get_file_text(file_id, path))
296
295
 
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
 
 
306
296
    def get_file_mtime(self, file_id, path=None):
307
297
        """Return the modification time for a file.
308
298
 
322
312
        raise NotImplementedError(self.get_file_size)
323
313
 
324
314
    def get_file_by_path(self, 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)
 
315
        return self.get_file(self._inventory.path2id(path), path)
335
316
 
336
317
    def iter_files_bytes(self, desired_files):
337
318
        """Iterate through file contents.
369
350
        """
370
351
        raise NotImplementedError(self.get_symlink_target)
371
352
 
 
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.
372
430
 
373
431
    def get_root_id(self):
374
432
        """Return the file_id for the root of this tree."""
433
491
            except errors.NoSuchRevisionInTree:
434
492
                yield self.repository.revision_tree(revision_id)
435
493
 
 
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
 
436
503
    def _get_file_revision(self, file_id, vf, tree_revision):
437
504
        """Ensure that file_id, tree_revision is in vf to plan the merge."""
438
505
 
439
506
        if getattr(self, '_repository', None) is None:
440
507
            last_revision = tree_revision
441
 
            parent_keys = [(file_id, t.get_file_revision(file_id)) for t in
 
508
            parent_keys = [(file_id, self._file_revision(t, file_id)) for t in
442
509
                self._iter_parent_trees()]
443
510
            vf.add_lines((file_id, last_revision), parent_keys,
444
511
                         self.get_file_lines(file_id))
445
512
            repo = self.branch.repository
446
513
            base_vf = repo.texts
447
514
        else:
448
 
            last_revision = self.get_file_revision(file_id)
 
515
            last_revision = self._file_revision(self, file_id)
449
516
            base_vf = self._repository.texts
450
517
        if base_vf not in vf.fallback_versionedfiles:
451
518
            vf.fallback_versionedfiles.append(base_vf)
452
519
        return last_revision
453
520
 
 
521
    inventory = property(_get_inventory,
 
522
                         doc="Inventory of this Tree")
 
523
 
454
524
    def _check_retrieved(self, ie, f):
455
525
        if not __debug__:
456
526
            return
457
 
        fp = osutils.fingerprint_file(f)
 
527
        fp = fingerprint_file(f)
458
528
        f.seek(0)
459
529
 
460
530
        if ie.text_size is not None:
461
531
            if ie.text_size != fp['size']:
462
 
                raise errors.BzrError(
463
 
                        "mismatched size for file %r in %r" %
464
 
                        (ie.file_id, self._store),
 
532
                raise BzrError("mismatched size for file %r in %r" % (ie.file_id, self._store),
465
533
                        ["inventory expects %d bytes" % ie.text_size,
466
534
                         "file is actually %d bytes" % fp['size'],
467
535
                         "store is probably damaged/corrupt"])
468
536
 
469
537
        if ie.text_sha1 != fp['sha1']:
470
 
            raise errors.BzrError("wrong SHA-1 for file %r in %r" %
471
 
                    (ie.file_id, self._store),
 
538
            raise BzrError("wrong SHA-1 for file %r in %r" % (ie.file_id, self._store),
472
539
                    ["inventory expects %s" % ie.text_sha1,
473
540
                     "file is actually %s" % fp['sha1'],
474
541
                     "store is probably damaged/corrupt"])
475
542
 
 
543
    @needs_read_lock
476
544
    def path2id(self, path):
477
545
        """Return the id for path in this tree."""
478
 
        raise NotImplementedError(self.path2id)
 
546
        return self._inventory.path2id(path)
479
547
 
480
548
    def paths2ids(self, paths, trees=[], require_versioned=True):
481
549
        """Return all the ids that can be reached by walking from paths.
538
606
 
539
607
        :return: set of paths.
540
608
        """
541
 
        raise NotImplementedError(self.filter_unversioned_files)
 
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)))
542
614
 
543
615
    def walkdirs(self, prefix=""):
544
616
        """Walk the contents of this tree from path down.
596
668
        prefs = self.iter_search_rules([path], filter_pref_names).next()
597
669
        stk = filters._get_filter_stack_for(prefs)
598
670
        if 'filters' in debug.debug_flags:
599
 
            trace.note("*** %s content-filter: %s => %r" % (path,prefs,stk))
 
671
            note("*** %s content-filter: %s => %r" % (path,prefs,stk))
600
672
        return stk
601
673
 
602
674
    def _content_filter_stack_provider(self):
641
713
        return searcher
642
714
 
643
715
 
644
 
class InventoryTree(Tree):
645
 
    """A tree that relies on an inventory for its metadata.
646
 
 
647
 
    Trees contain an `Inventory` object, and also know how to retrieve
648
 
    file texts mentioned in the inventory, either from a working
649
 
    directory or from a store.
650
 
 
651
 
    It is possible for trees to contain files that are not described
652
 
    in their inventory or vice versa; for this use `filenames()`.
653
 
 
654
 
    Subclasses should set the _inventory attribute, which is considered
655
 
    private to external API users.
656
 
    """
657
 
 
658
 
    def get_canonical_inventory_paths(self, paths):
659
 
        """Like get_canonical_inventory_path() but works on multiple items.
660
 
 
661
 
        :param paths: A sequence of paths relative to the root of the tree.
662
 
        :return: A list of paths, with each item the corresponding input path
663
 
        adjusted to account for existing elements that match case
664
 
        insensitively.
665
 
        """
666
 
        return list(self._yield_canonical_inventory_paths(paths))
667
 
 
668
 
    def get_canonical_inventory_path(self, path):
669
 
        """Returns the first inventory item that case-insensitively matches path.
670
 
 
671
 
        If a path matches exactly, it is returned. If no path matches exactly
672
 
        but more than one path matches case-insensitively, it is implementation
673
 
        defined which is returned.
674
 
 
675
 
        If no path matches case-insensitively, the input path is returned, but
676
 
        with as many path entries that do exist changed to their canonical
677
 
        form.
678
 
 
679
 
        If you need to resolve many names from the same tree, you should
680
 
        use get_canonical_inventory_paths() to avoid O(N) behaviour.
681
 
 
682
 
        :param path: A paths relative to the root of the tree.
683
 
        :return: The input path adjusted to account for existing elements
684
 
        that match case insensitively.
685
 
        """
686
 
        return self._yield_canonical_inventory_paths([path]).next()
687
 
 
688
 
    def _yield_canonical_inventory_paths(self, paths):
689
 
        for path in paths:
690
 
            # First, if the path as specified exists exactly, just use it.
691
 
            if self.path2id(path) is not None:
692
 
                yield path
693
 
                continue
694
 
            # go walkin...
695
 
            cur_id = self.get_root_id()
696
 
            cur_path = ''
697
 
            bit_iter = iter(path.split("/"))
698
 
            for elt in bit_iter:
699
 
                lelt = elt.lower()
700
 
                new_path = None
701
 
                for child in self.iter_children(cur_id):
702
 
                    try:
703
 
                        # XXX: it seem like if the child is known to be in the
704
 
                        # tree, we shouldn't need to go from its id back to
705
 
                        # its path -- mbp 2010-02-11
706
 
                        #
707
 
                        # XXX: it seems like we could be more efficient
708
 
                        # by just directly looking up the original name and
709
 
                        # only then searching all children; also by not
710
 
                        # chopping paths so much. -- mbp 2010-02-11
711
 
                        child_base = os.path.basename(self.id2path(child))
712
 
                        if (child_base == elt):
713
 
                            # if we found an exact match, we can stop now; if
714
 
                            # we found an approximate match we need to keep
715
 
                            # searching because there might be an exact match
716
 
                            # later.  
717
 
                            cur_id = child
718
 
                            new_path = osutils.pathjoin(cur_path, child_base)
719
 
                            break
720
 
                        elif child_base.lower() == lelt:
721
 
                            cur_id = child
722
 
                            new_path = osutils.pathjoin(cur_path, child_base)
723
 
                    except errors.NoSuchId:
724
 
                        # before a change is committed we can see this error...
725
 
                        continue
726
 
                if new_path:
727
 
                    cur_path = new_path
728
 
                else:
729
 
                    # got to the end of this directory and no entries matched.
730
 
                    # Return what matched so far, plus the rest as specified.
731
 
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
732
 
                    break
733
 
            yield cur_path
734
 
        # all done.
735
 
 
736
 
    def _get_inventory(self):
737
 
        return self._inventory
738
 
 
739
 
    inventory = property(_get_inventory,
740
 
                         doc="Inventory of this Tree")
741
 
 
742
 
    @needs_read_lock
743
 
    def path2id(self, path):
744
 
        """Return the id for path in this tree."""
745
 
        return self._inventory.path2id(path)
746
 
 
747
 
    def id2path(self, file_id):
748
 
        """Return the path for a file id.
749
 
 
750
 
        :raises NoSuchId:
751
 
        """
752
 
        return self.inventory.id2path(file_id)
753
 
 
754
 
    def has_id(self, file_id):
755
 
        return self.inventory.has_id(file_id)
756
 
 
757
 
    def has_or_had_id(self, file_id):
758
 
        return self.inventory.has_id(file_id)
759
 
 
760
 
    def __iter__(self):
761
 
        return iter(self.inventory)
762
 
 
763
 
    def filter_unversioned_files(self, paths):
764
 
        """Filter out paths that are versioned.
765
 
 
766
 
        :return: set of paths.
767
 
        """
768
 
        # NB: we specifically *don't* call self.has_filename, because for
769
 
        # WorkingTrees that can indicate files that exist on disk but that
770
 
        # are not versioned.
771
 
        pred = self.inventory.has_filename
772
 
        return set((p for p in paths if not pred(p)))
773
 
 
774
 
    @needs_read_lock
775
 
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
776
 
        """Walk the tree in 'by_dir' order.
777
 
 
778
 
        This will yield each entry in the tree as a (path, entry) tuple.
779
 
        The order that they are yielded is:
780
 
 
781
 
        See Tree.iter_entries_by_dir for details.
782
 
 
783
 
        :param yield_parents: If True, yield the parents from the root leading
784
 
            down to specific_file_ids that have been requested. This has no
785
 
            impact if specific_file_ids is None.
786
 
        """
787
 
        return self.inventory.iter_entries_by_dir(
788
 
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
789
 
 
790
 
    def get_file_by_path(self, path):
791
 
        return self.get_file(self._inventory.path2id(path), path)
792
 
 
793
 
 
794
716
######################################################################
795
717
# diff
796
718
 
1046
968
            # All files are unversioned, so just return an empty delta
1047
969
            # _compare_trees would think we want a complete delta
1048
970
            result = delta.TreeDelta()
1049
 
            fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
 
971
            fake_entry = InventoryFile('unused', 'unused', 'unused')
1050
972
            result.unversioned = [(path, None,
1051
973
                self.target._comparison_data(fake_entry, path)[0]) for path in
1052
974
                specific_files]
1117
1039
                                     self.target.extras()
1118
1040
                if specific_files is None or
1119
1041
                    osutils.is_inside_any(specific_files, p)])
1120
 
            all_unversioned = collections.deque(all_unversioned)
 
1042
            all_unversioned = deque(all_unversioned)
1121
1043
        else:
1122
 
            all_unversioned = collections.deque()
 
1044
            all_unversioned = deque()
1123
1045
        to_paths = {}
1124
1046
        from_entries_by_dir = list(self.source.iter_entries_by_dir(
1125
1047
            specific_file_ids=specific_file_ids))
1131
1053
        # the unversioned path lookup only occurs on real trees - where there
1132
1054
        # can be extras. So the fake_entry is solely used to look up
1133
1055
        # executable it values when execute is not supported.
1134
 
        fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
 
1056
        fake_entry = InventoryFile('unused', 'unused', 'unused')
1135
1057
        for target_path, target_entry in to_entries_by_dir:
1136
1058
            while (all_unversioned and
1137
1059
                all_unversioned[0][0] < target_path.split('/')):