~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tree.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2011-08-17 18:13:57 UTC
  • mfrom: (5268.7.29 transport-segments)
  • Revision ID: pqm@pqm.ubuntu.com-20110817181357-y5q5eth1hk8bl3om
(jelmer) Allow specifying the colocated branch to use in the branch URL,
 and retrieving the branch name using ControlDir._get_selected_branch.
 (Jelmer Vernooij)

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2009 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
 
import bzrlib.revision
40
 
from bzrlib.symbol_versioning import deprecated_function, deprecated_in
41
 
from bzrlib.trace import note
 
42
from bzrlib.symbol_versioning import (
 
43
    deprecated_in,
 
44
    deprecated_method,
 
45
    )
42
46
 
43
47
 
44
48
class Tree(object):
50
54
 
51
55
    * `RevisionTree` is a tree as recorded at some point in the past.
52
56
 
53
 
    Trees contain an `Inventory` object, and also know how to retrieve
54
 
    file texts mentioned in the inventory, either from a working
55
 
    directory or from a store.
56
 
 
57
 
    It is possible for trees to contain files that are not described
58
 
    in their inventory or vice versa; for this use `filenames()`.
59
 
 
60
57
    Trees can be compared, etc, regardless of whether they are working
61
58
    trees or versioned trees.
62
59
    """
98
95
    def iter_changes(self, from_tree, include_unchanged=False,
99
96
                     specific_files=None, pb=None, extra_trees=None,
100
97
                     require_versioned=True, want_unversioned=False):
 
98
        """See InterTree.iter_changes"""
101
99
        intertree = InterTree.get(from_tree, self)
102
100
        return intertree.iter_changes(include_unchanged, specific_files, pb,
103
101
            extra_trees, require_versioned, want_unversioned=want_unversioned)
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
 
 
130
    @deprecated_method(deprecated_in((2, 4, 0)))
132
131
    def __contains__(self, file_id):
133
132
        return self.has_id(file_id)
134
133
 
135
134
    def has_or_had_id(self, file_id):
136
 
        return self.inventory.has_id(file_id)
 
135
        raise NotImplementedError(self.has_or_had_id)
137
136
 
138
137
    def is_ignored(self, filename):
139
138
        """Check whether the filename is ignored by this tree.
143
142
        """
144
143
        return False
145
144
 
146
 
    def __iter__(self):
147
 
        return iter(self.inventory)
148
 
 
149
145
    def all_file_ids(self):
150
146
        """Iterate through all file ids, including ids for missing files."""
151
 
        return set(self.inventory)
 
147
        raise NotImplementedError(self.all_file_ids)
152
148
 
153
149
    def id2path(self, file_id):
154
150
        """Return the path for a file id.
155
151
 
156
152
        :raises NoSuchId:
157
153
        """
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
 
154
        raise NotImplementedError(self.id2path)
 
155
 
173
156
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
174
157
        """Walk the tree in 'by_dir' order.
175
158
 
192
175
             g
193
176
 
194
177
        The yield order (ignoring root) would be::
 
178
 
195
179
          a, f, a/b, a/d, a/b/c, a/d/e, f/g
196
180
 
197
181
        :param yield_parents: If True, yield the parents from the root leading
198
182
            down to specific_file_ids that have been requested. This has no
199
183
            impact if specific_file_ids is None.
200
184
        """
201
 
        return self.inventory.iter_entries_by_dir(
202
 
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
 
185
        raise NotImplementedError(self.iter_entries_by_dir)
 
186
 
 
187
    def list_files(self, include_root=False, from_dir=None, recursive=True):
 
188
        """List all files in this tree.
 
189
 
 
190
        :param include_root: Whether to include the entry for the tree root
 
191
        :param from_dir: Directory under which to list files
 
192
        :param recursive: Whether to list files recursively
 
193
        :return: iterator over tuples of (path, versioned, kind, file_id,
 
194
            inventory entry)
 
195
        """
 
196
        raise NotImplementedError(self.list_files)
203
197
 
204
198
    def iter_references(self):
205
199
        if self.supports_tree_reference():
256
250
    def _file_size(self, entry, stat_value):
257
251
        raise NotImplementedError(self._file_size)
258
252
 
259
 
    def _get_inventory(self):
260
 
        return self._inventory
261
 
 
262
253
    def get_file(self, file_id, path=None):
263
254
        """Return a file object for the file file_id in the tree.
264
255
 
286
277
 
287
278
        :param file_id: The file_id of the file.
288
279
        :param path: The path of the file.
 
280
 
289
281
        If both file_id and path are supplied, an implementation may use
290
282
        either one.
 
283
 
 
284
        :returns: A single byte string for the whole file.
291
285
        """
292
286
        my_file = self.get_file(file_id, path)
293
287
        try:
300
294
 
301
295
        :param file_id: The file_id of the file.
302
296
        :param path: The path of the file.
 
297
 
303
298
        If both file_id and path are supplied, an implementation may use
304
299
        either one.
305
300
        """
306
301
        return osutils.split_lines(self.get_file_text(file_id, path))
307
302
 
 
303
    def get_file_verifier(self, file_id, path=None, stat_value=None):
 
304
        """Return a verifier for a file.
 
305
 
 
306
        The default implementation returns a sha1.
 
307
 
 
308
        :param file_id: The handle for this file.
 
309
        :param path: The path that this file can be found at.
 
310
            These must point to the same object.
 
311
        :param stat_value: Optional stat value for the object
 
312
        :return: Tuple with verifier name and verifier data
 
313
        """
 
314
        return ("SHA1", self.get_file_sha1(file_id, path=path,
 
315
            stat_value=stat_value))
 
316
 
 
317
    def get_file_sha1(self, file_id, path=None, stat_value=None):
 
318
        """Return the SHA1 file for a file.
 
319
 
 
320
        :note: callers should use get_file_verifier instead
 
321
            where possible, as the underlying repository implementation may
 
322
            have quicker access to a non-sha1 verifier.
 
323
 
 
324
        :param file_id: The handle for this file.
 
325
        :param path: The path that this file can be found at.
 
326
            These must point to the same object.
 
327
        :param stat_value: Optional stat value for the object
 
328
        """
 
329
        raise NotImplementedError(self.get_file_sha1)
 
330
 
308
331
    def get_file_mtime(self, file_id, path=None):
309
332
        """Return the modification time for a file.
310
333
 
324
347
        raise NotImplementedError(self.get_file_size)
325
348
 
326
349
    def get_file_by_path(self, path):
327
 
        return self.get_file(self._inventory.path2id(path), path)
 
350
        raise NotImplementedError(self.get_file_by_path)
 
351
 
 
352
    def is_executable(self, file_id, path=None):
 
353
        """Check if a file is executable.
 
354
 
 
355
        :param file_id: The handle for this file.
 
356
        :param path: The path that this file can be found at.
 
357
            These must point to the same object.
 
358
        """
 
359
        raise NotImplementedError(self.is_executable)
328
360
 
329
361
    def iter_files_bytes(self, desired_files):
330
362
        """Iterate through file contents.
352
384
            cur_file = (self.get_file_text(file_id),)
353
385
            yield identifier, cur_file
354
386
 
355
 
    def get_symlink_target(self, file_id):
 
387
    def get_symlink_target(self, file_id, path=None):
356
388
        """Get the target for a given file_id.
357
389
 
358
390
        It is assumed that the caller already knows that file_id is referencing
359
391
        a symlink.
360
392
        :param file_id: Handle for the symlink entry.
 
393
        :param path: The path of the file.
 
394
        If both file_id and path are supplied, an implementation may use
 
395
        either one.
361
396
        :return: The path the symlink points to.
362
397
        """
363
398
        raise NotImplementedError(self.get_symlink_target)
364
399
 
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
 
                for child in self.iter_children(cur_id):
408
 
                    try:
409
 
                        child_base = os.path.basename(self.id2path(child))
410
 
                        if child_base.lower() == lelt:
411
 
                            cur_id = child
412
 
                            cur_path = osutils.pathjoin(cur_path, child_base)
413
 
                            break
414
 
                    except NoSuchId:
415
 
                        # before a change is committed we can see this error...
416
 
                        continue
417
 
                else:
418
 
                    # got to the end of this directory and no entries matched.
419
 
                    # Return what matched so far, plus the rest as specified.
420
 
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
421
 
                    break
422
 
            yield cur_path
423
 
        # all done.
424
 
 
425
400
    def get_root_id(self):
426
401
        """Return the file_id for the root of this tree."""
427
402
        raise NotImplementedError(self.get_root_id)
485
460
            except errors.NoSuchRevisionInTree:
486
461
                yield self.repository.revision_tree(revision_id)
487
462
 
488
 
    @staticmethod
489
 
    def _file_revision(revision_tree, file_id):
490
 
        """Determine the revision associated with a file in a given tree."""
491
 
        revision_tree.lock_read()
492
 
        try:
493
 
            return revision_tree.inventory[file_id].revision
494
 
        finally:
495
 
            revision_tree.unlock()
496
 
 
497
463
    def _get_file_revision(self, file_id, vf, tree_revision):
498
464
        """Ensure that file_id, tree_revision is in vf to plan the merge."""
499
465
 
500
466
        if getattr(self, '_repository', None) is None:
501
467
            last_revision = tree_revision
502
 
            parent_keys = [(file_id, self._file_revision(t, file_id)) for t in
 
468
            parent_keys = [(file_id, t.get_file_revision(file_id)) for t in
503
469
                self._iter_parent_trees()]
504
470
            vf.add_lines((file_id, last_revision), parent_keys,
505
 
                         self.get_file(file_id).readlines())
 
471
                         self.get_file_lines(file_id))
506
472
            repo = self.branch.repository
507
473
            base_vf = repo.texts
508
474
        else:
509
 
            last_revision = self._file_revision(self, file_id)
 
475
            last_revision = self.get_file_revision(file_id)
510
476
            base_vf = self._repository.texts
511
477
        if base_vf not in vf.fallback_versionedfiles:
512
478
            vf.fallback_versionedfiles.append(base_vf)
513
479
        return last_revision
514
480
 
515
 
    inventory = property(_get_inventory,
516
 
                         doc="Inventory of this Tree")
517
 
 
518
481
    def _check_retrieved(self, ie, f):
519
482
        if not __debug__:
520
483
            return
521
 
        fp = fingerprint_file(f)
 
484
        fp = osutils.fingerprint_file(f)
522
485
        f.seek(0)
523
486
 
524
487
        if ie.text_size is not None:
525
488
            if ie.text_size != fp['size']:
526
 
                raise BzrError("mismatched size for file %r in %r" % (ie.file_id, self._store),
 
489
                raise errors.BzrError(
 
490
                        "mismatched size for file %r in %r" %
 
491
                        (ie.file_id, self._store),
527
492
                        ["inventory expects %d bytes" % ie.text_size,
528
493
                         "file is actually %d bytes" % fp['size'],
529
494
                         "store is probably damaged/corrupt"])
530
495
 
531
496
        if ie.text_sha1 != fp['sha1']:
532
 
            raise BzrError("wrong SHA-1 for file %r in %r" % (ie.file_id, self._store),
 
497
            raise errors.BzrError("wrong SHA-1 for file %r in %r" %
 
498
                    (ie.file_id, self._store),
533
499
                    ["inventory expects %s" % ie.text_sha1,
534
500
                     "file is actually %s" % fp['sha1'],
535
501
                     "store is probably damaged/corrupt"])
536
502
 
537
 
    @needs_read_lock
538
503
    def path2id(self, path):
539
504
        """Return the id for path in this tree."""
540
 
        return self._inventory.path2id(path)
 
505
        raise NotImplementedError(self.path2id)
541
506
 
542
507
    def paths2ids(self, paths, trees=[], require_versioned=True):
543
508
        """Return all the ids that can be reached by walking from paths.
564
529
            yield child.file_id
565
530
 
566
531
    def lock_read(self):
 
532
        """Lock this tree for multiple read only operations.
 
533
        
 
534
        :return: A bzrlib.lock.LogicalLockResult.
 
535
        """
567
536
        pass
568
537
 
569
538
    def revision_tree(self, revision_id):
596
565
 
597
566
        :return: set of paths.
598
567
        """
599
 
        # NB: we specifically *don't* call self.has_filename, because for
600
 
        # WorkingTrees that can indicate files that exist on disk but that
601
 
        # are not versioned.
602
 
        pred = self.inventory.has_filename
603
 
        return set((p for p in paths if not pred(p)))
 
568
        raise NotImplementedError(self.filter_unversioned_files)
604
569
 
605
570
    def walkdirs(self, prefix=""):
606
571
        """Walk the contents of this tree from path down.
658
623
        prefs = self.iter_search_rules([path], filter_pref_names).next()
659
624
        stk = filters._get_filter_stack_for(prefs)
660
625
        if 'filters' in debug.debug_flags:
661
 
            note("*** %s content-filter: %s => %r" % (path,prefs,stk))
 
626
            trace.note("*** %s content-filter: %s => %r" % (path,prefs,stk))
662
627
        return stk
663
628
 
664
629
    def _content_filter_stack_provider(self):
703
668
        return searcher
704
669
 
705
670
 
706
 
######################################################################
707
 
# diff
708
 
 
709
 
# TODO: Merge these two functions into a single one that can operate
710
 
# on either a whole tree or a set of files.
711
 
 
712
 
# TODO: Return the diff in order by filename, not by category or in
713
 
# random order.  Can probably be done by lock-stepping through the
714
 
# filenames from both trees.
715
 
 
716
 
 
717
 
def file_status(filename, old_tree, new_tree):
718
 
    """Return single-letter status, old and new names for a file.
719
 
 
720
 
    The complexity here is in deciding how to represent renames;
721
 
    many complex cases are possible.
 
671
class InventoryTree(Tree):
 
672
    """A tree that relies on an inventory for its metadata.
 
673
 
 
674
    Trees contain an `Inventory` object, and also know how to retrieve
 
675
    file texts mentioned in the inventory, either from a working
 
676
    directory or from a store.
 
677
 
 
678
    It is possible for trees to contain files that are not described
 
679
    in their inventory or vice versa; for this use `filenames()`.
 
680
 
 
681
    Subclasses should set the _inventory attribute, which is considered
 
682
    private to external API users.
722
683
    """
723
 
    old_inv = old_tree.inventory
724
 
    new_inv = new_tree.inventory
725
 
    new_id = new_inv.path2id(filename)
726
 
    old_id = old_inv.path2id(filename)
727
 
 
728
 
    if not new_id and not old_id:
729
 
        # easy: doesn't exist in either; not versioned at all
730
 
        if new_tree.is_ignored(filename):
731
 
            return 'I', None, None
732
 
        else:
733
 
            return '?', None, None
734
 
    elif new_id:
735
 
        # There is now a file of this name, great.
736
 
        pass
737
 
    else:
738
 
        # There is no longer a file of this name, but we can describe
739
 
        # what happened to the file that used to have
740
 
        # this name.  There are two possibilities: either it was
741
 
        # deleted entirely, or renamed.
742
 
        if new_inv.has_id(old_id):
743
 
            return 'X', old_inv.id2path(old_id), new_inv.id2path(old_id)
744
 
        else:
745
 
            return 'D', old_inv.id2path(old_id), None
746
 
 
747
 
    # if the file_id is new in this revision, it is added
748
 
    if new_id and not old_inv.has_id(new_id):
749
 
        return 'A'
750
 
 
751
 
    # if there used to be a file of this name, but that ID has now
752
 
    # disappeared, it is deleted
753
 
    if old_id and not new_inv.has_id(old_id):
754
 
        return 'D'
755
 
 
756
 
    return 'wtf?'
757
 
 
758
 
 
759
 
@deprecated_function(deprecated_in((1, 9, 0)))
760
 
def find_renames(old_inv, new_inv):
761
 
    for file_id in old_inv:
762
 
        if file_id not in new_inv:
763
 
            continue
764
 
        old_name = old_inv.id2path(file_id)
765
 
        new_name = new_inv.id2path(file_id)
766
 
        if old_name != new_name:
767
 
            yield (old_name, new_name)
 
684
 
 
685
    def get_canonical_inventory_paths(self, paths):
 
686
        """Like get_canonical_inventory_path() but works on multiple items.
 
687
 
 
688
        :param paths: A sequence of paths relative to the root of the tree.
 
689
        :return: A list of paths, with each item the corresponding input path
 
690
        adjusted to account for existing elements that match case
 
691
        insensitively.
 
692
        """
 
693
        return list(self._yield_canonical_inventory_paths(paths))
 
694
 
 
695
    def get_canonical_inventory_path(self, path):
 
696
        """Returns the first inventory item that case-insensitively matches path.
 
697
 
 
698
        If a path matches exactly, it is returned. If no path matches exactly
 
699
        but more than one path matches case-insensitively, it is implementation
 
700
        defined which is returned.
 
701
 
 
702
        If no path matches case-insensitively, the input path is returned, but
 
703
        with as many path entries that do exist changed to their canonical
 
704
        form.
 
705
 
 
706
        If you need to resolve many names from the same tree, you should
 
707
        use get_canonical_inventory_paths() to avoid O(N) behaviour.
 
708
 
 
709
        :param path: A paths relative to the root of the tree.
 
710
        :return: The input path adjusted to account for existing elements
 
711
        that match case insensitively.
 
712
        """
 
713
        return self._yield_canonical_inventory_paths([path]).next()
 
714
 
 
715
    def _yield_canonical_inventory_paths(self, paths):
 
716
        for path in paths:
 
717
            # First, if the path as specified exists exactly, just use it.
 
718
            if self.path2id(path) is not None:
 
719
                yield path
 
720
                continue
 
721
            # go walkin...
 
722
            cur_id = self.get_root_id()
 
723
            cur_path = ''
 
724
            bit_iter = iter(path.split("/"))
 
725
            for elt in bit_iter:
 
726
                lelt = elt.lower()
 
727
                new_path = None
 
728
                for child in self.iter_children(cur_id):
 
729
                    try:
 
730
                        # XXX: it seem like if the child is known to be in the
 
731
                        # tree, we shouldn't need to go from its id back to
 
732
                        # its path -- mbp 2010-02-11
 
733
                        #
 
734
                        # XXX: it seems like we could be more efficient
 
735
                        # by just directly looking up the original name and
 
736
                        # only then searching all children; also by not
 
737
                        # chopping paths so much. -- mbp 2010-02-11
 
738
                        child_base = os.path.basename(self.id2path(child))
 
739
                        if (child_base == elt):
 
740
                            # if we found an exact match, we can stop now; if
 
741
                            # we found an approximate match we need to keep
 
742
                            # searching because there might be an exact match
 
743
                            # later.  
 
744
                            cur_id = child
 
745
                            new_path = osutils.pathjoin(cur_path, child_base)
 
746
                            break
 
747
                        elif child_base.lower() == lelt:
 
748
                            cur_id = child
 
749
                            new_path = osutils.pathjoin(cur_path, child_base)
 
750
                    except errors.NoSuchId:
 
751
                        # before a change is committed we can see this error...
 
752
                        continue
 
753
                if new_path:
 
754
                    cur_path = new_path
 
755
                else:
 
756
                    # got to the end of this directory and no entries matched.
 
757
                    # Return what matched so far, plus the rest as specified.
 
758
                    cur_path = osutils.pathjoin(cur_path, elt, *list(bit_iter))
 
759
                    break
 
760
            yield cur_path
 
761
        # all done.
 
762
 
 
763
    def _get_inventory(self):
 
764
        return self._inventory
 
765
 
 
766
    inventory = property(_get_inventory,
 
767
                         doc="Inventory of this Tree")
 
768
 
 
769
    @needs_read_lock
 
770
    def path2id(self, path):
 
771
        """Return the id for path in this tree."""
 
772
        return self._inventory.path2id(path)
 
773
 
 
774
    def id2path(self, file_id):
 
775
        """Return the path for a file id.
 
776
 
 
777
        :raises NoSuchId:
 
778
        """
 
779
        return self.inventory.id2path(file_id)
 
780
 
 
781
    def has_id(self, file_id):
 
782
        return self.inventory.has_id(file_id)
 
783
 
 
784
    def has_or_had_id(self, file_id):
 
785
        return self.inventory.has_id(file_id)
 
786
 
 
787
    def all_file_ids(self):
 
788
        return set(self.inventory)
 
789
 
 
790
    @deprecated_method(deprecated_in((2, 4, 0)))
 
791
    def __iter__(self):
 
792
        return iter(self.inventory)
 
793
 
 
794
    def filter_unversioned_files(self, paths):
 
795
        """Filter out paths that are versioned.
 
796
 
 
797
        :return: set of paths.
 
798
        """
 
799
        # NB: we specifically *don't* call self.has_filename, because for
 
800
        # WorkingTrees that can indicate files that exist on disk but that
 
801
        # are not versioned.
 
802
        pred = self.inventory.has_filename
 
803
        return set((p for p in paths if not pred(p)))
 
804
 
 
805
    @needs_read_lock
 
806
    def iter_entries_by_dir(self, specific_file_ids=None, yield_parents=False):
 
807
        """Walk the tree in 'by_dir' order.
 
808
 
 
809
        This will yield each entry in the tree as a (path, entry) tuple.
 
810
        The order that they are yielded is:
 
811
 
 
812
        See Tree.iter_entries_by_dir for details.
 
813
 
 
814
        :param yield_parents: If True, yield the parents from the root leading
 
815
            down to specific_file_ids that have been requested. This has no
 
816
            impact if specific_file_ids is None.
 
817
        """
 
818
        return self.inventory.iter_entries_by_dir(
 
819
            specific_file_ids=specific_file_ids, yield_parents=yield_parents)
 
820
 
 
821
    def get_file_by_path(self, path):
 
822
        return self.get_file(self._inventory.path2id(path), path)
768
823
 
769
824
 
770
825
def find_ids_across_trees(filenames, trees, require_versioned=True):
777
832
        None)
778
833
    :param trees: The trees to find file_ids within
779
834
    :param require_versioned: if true, all specified filenames must occur in
780
 
    at least one tree.
 
835
        at least one tree.
781
836
    :return: a set of file ids for the specified filenames and their children.
782
837
    """
783
838
    if not filenames:
859
914
 
860
915
    _optimisers = []
861
916
 
 
917
    @classmethod
 
918
    def is_compatible(kls, source, target):
 
919
        # The default implementation is naive and uses the public API, so
 
920
        # it works for all trees.
 
921
        return True
 
922
 
862
923
    def _changes_from_entries(self, source_entry, target_entry,
863
924
        source_path=None, target_path=None):
864
925
        """Generate a iter_changes tuple between source_entry and target_entry.
912
973
        if source_kind != target_kind:
913
974
            changed_content = True
914
975
        elif source_kind == 'file':
915
 
            if (self.source.get_file_sha1(file_id, source_path, source_stat) !=
916
 
                self.target.get_file_sha1(file_id, target_path, target_stat)):
 
976
            if not self.file_content_matches(file_id, file_id, source_path,
 
977
                    target_path, source_stat, target_stat):
917
978
                changed_content = True
918
979
        elif source_kind == 'symlink':
919
980
            if (self.source.get_symlink_target(file_id) !=
969
1030
            # All files are unversioned, so just return an empty delta
970
1031
            # _compare_trees would think we want a complete delta
971
1032
            result = delta.TreeDelta()
972
 
            fake_entry = InventoryFile('unused', 'unused', 'unused')
 
1033
            fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
973
1034
            result.unversioned = [(path, None,
974
1035
                self.target._comparison_data(fake_entry, path)[0]) for path in
975
1036
                specific_files]
1040
1101
                                     self.target.extras()
1041
1102
                if specific_files is None or
1042
1103
                    osutils.is_inside_any(specific_files, p)])
1043
 
            all_unversioned = deque(all_unversioned)
 
1104
            all_unversioned = collections.deque(all_unversioned)
1044
1105
        else:
1045
 
            all_unversioned = deque()
 
1106
            all_unversioned = collections.deque()
1046
1107
        to_paths = {}
1047
1108
        from_entries_by_dir = list(self.source.iter_entries_by_dir(
1048
1109
            specific_file_ids=specific_file_ids))
1054
1115
        # the unversioned path lookup only occurs on real trees - where there
1055
1116
        # can be extras. So the fake_entry is solely used to look up
1056
1117
        # executable it values when execute is not supported.
1057
 
        fake_entry = InventoryFile('unused', 'unused', 'unused')
 
1118
        fake_entry = inventory.InventoryFile('unused', 'unused', 'unused')
1058
1119
        for target_path, target_entry in to_entries_by_dir:
1059
1120
            while (all_unversioned and
1060
1121
                all_unversioned[0][0] < target_path.split('/')):
1108
1169
            if file_id in to_paths:
1109
1170
                # already returned
1110
1171
                continue
1111
 
            if file_id not in self.target.all_file_ids():
 
1172
            if not self.target.has_id(file_id):
1112
1173
                # common case - paths we have not emitted are not present in
1113
1174
                # target.
1114
1175
                to_path = None
1232
1293
                    changed_file_ids.add(result[0])
1233
1294
                    yield result
1234
1295
 
 
1296
    @needs_read_lock
 
1297
    def file_content_matches(self, source_file_id, target_file_id,
 
1298
            source_path=None, target_path=None, source_stat=None, target_stat=None):
 
1299
        """Check if two files are the same in the source and target trees.
 
1300
 
 
1301
        This only checks that the contents of the files are the same,
 
1302
        it does not touch anything else.
 
1303
 
 
1304
        :param source_file_id: File id of the file in the source tree
 
1305
        :param target_file_id: File id of the file in the target tree
 
1306
        :param source_path: Path of the file in the source tree
 
1307
        :param target_path: Path of the file in the target tree
 
1308
        :param source_stat: Optional stat value of the file in the source tree
 
1309
        :param target_stat: Optional stat value of the file in the target tree
 
1310
        :return: Boolean indicating whether the files have the same contents
 
1311
        """
 
1312
        source_verifier_kind, source_verifier_data = self.source.get_file_verifier(
 
1313
            source_file_id, source_path, source_stat)
 
1314
        target_verifier_kind, target_verifier_data = self.target.get_file_verifier(
 
1315
            target_file_id, target_path, target_stat)
 
1316
        if source_verifier_kind == target_verifier_kind:
 
1317
            return (source_verifier_data == target_verifier_data)
 
1318
        # Fall back to SHA1 for now
 
1319
        if source_verifier_kind != "SHA1":
 
1320
            source_sha1 = self.source.get_file_sha1(source_file_id,
 
1321
                    source_path, source_stat)
 
1322
        else:
 
1323
            source_sha1 = source_verifier_data
 
1324
        if target_verifier_kind != "SHA1":
 
1325
            target_sha1 = self.target.get_file_sha1(target_file_id,
 
1326
                    target_path, target_stat)
 
1327
        else:
 
1328
            target_sha1 = target_verifier_data
 
1329
        return (source_sha1 == target_sha1)
 
1330
 
 
1331
InterTree.register_optimiser(InterTree)
 
1332
 
1235
1333
 
1236
1334
class MultiWalker(object):
1237
1335
    """Walk multiple trees simultaneously, getting combined results."""