/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/workingtree_4.py

  • Committer: Martin Pool
  • Date: 2009-12-14 06:06:59 UTC
  • mfrom: (4889 +trunk)
  • mto: This revision was merged to the branch mainline in revision 4891.
  • Revision ID: mbp@sourcefrog.net-20091214060659-1ucv8hpnky0cbnaj
merge trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
 
1
# Copyright (C) 2005, 2006, 2007, 2008, 2009 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
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
17
17
"""WorkingTree4 format and implementation.
18
18
 
28
28
 
29
29
from bzrlib.lazy_import import lazy_import
30
30
lazy_import(globals(), """
31
 
from bisect import bisect_left
32
 
import collections
33
 
from copy import deepcopy
34
31
import errno
35
 
import itertools
36
 
import operator
37
32
import stat
38
 
from time import time
39
 
import warnings
40
33
 
41
34
import bzrlib
42
35
from bzrlib import (
43
36
    bzrdir,
44
37
    cache_utf8,
45
 
    conflicts as _mod_conflicts,
46
38
    debug,
47
 
    delta,
48
39
    dirstate,
49
40
    errors,
50
41
    generate_ids,
51
 
    globbing,
52
 
    ignores,
53
 
    merge,
54
42
    osutils,
55
43
    revision as _mod_revision,
56
44
    revisiontree,
57
 
    textui,
58
45
    trace,
59
46
    transform,
60
 
    urlutils,
61
 
    xml5,
62
 
    xml6,
 
47
    views,
63
48
    )
64
49
import bzrlib.branch
65
 
from bzrlib.transport import get_transport
66
50
import bzrlib.ui
67
51
""")
68
52
 
69
 
from bzrlib import symbol_versioning
70
53
from bzrlib.decorators import needs_read_lock, needs_write_lock
71
 
from bzrlib.inventory import InventoryEntry, Inventory, ROOT_ID, entry_factory
72
 
from bzrlib.lockable_files import LockableFiles, TransportLock
73
 
from bzrlib.lockdir import LockDir
 
54
from bzrlib.filters import filtered_input_file, internal_size_sha_file_byname
 
55
from bzrlib.inventory import Inventory, ROOT_ID, entry_factory
74
56
import bzrlib.mutabletree
75
57
from bzrlib.mutabletree import needs_tree_write_lock
76
58
from bzrlib.osutils import (
77
59
    file_kind,
78
60
    isdir,
79
 
    normpath,
80
61
    pathjoin,
81
 
    rand_chars,
82
62
    realpath,
83
63
    safe_unicode,
84
 
    splitpath,
85
64
    )
86
 
from bzrlib.trace import mutter, note
 
65
from bzrlib.trace import mutter
87
66
from bzrlib.transport.local import LocalTransport
88
67
from bzrlib.tree import InterTree
89
 
from bzrlib.progress import DummyProgress, ProgressPhase
90
 
from bzrlib.revision import NULL_REVISION, CURRENT_REVISION
91
 
from bzrlib.rio import RioReader, rio_file, Stanza
92
 
from bzrlib.symbol_versioning import (deprecated_passed,
93
 
        deprecated_method,
94
 
        deprecated_function,
95
 
        DEPRECATED_PARAMETER,
96
 
        )
97
68
from bzrlib.tree import Tree
98
69
from bzrlib.workingtree import WorkingTree, WorkingTree3, WorkingTreeFormat3
99
70
 
100
71
 
101
 
# This is the Windows equivalent of ENOTDIR
102
 
# It is defined in pywin32.winerror, but we don't want a strong dependency for
103
 
# just an error code.
104
 
ERROR_PATH_NOT_FOUND = 3
105
 
ERROR_DIRECTORY = 267
106
 
 
107
 
 
108
 
class WorkingTree4(WorkingTree3):
109
 
    """This is the Format 4 working tree.
110
 
 
111
 
    This differs from WorkingTree3 by:
112
 
     - Having a consolidated internal dirstate, stored in a
113
 
       randomly-accessible sorted file on disk.
114
 
     - Not having a regular inventory attribute.  One can be synthesized 
115
 
       on demand but this is expensive and should be avoided.
116
 
 
117
 
    This is new in bzr 0.15.
118
 
    """
119
 
 
 
72
class DirStateWorkingTree(WorkingTree3):
120
73
    def __init__(self, basedir,
121
74
                 branch,
122
75
                 _control_files=None,
138
91
        # if branch is at our basedir and is a format 6 or less
139
92
        # assume all other formats have their own control files.
140
93
        self._control_files = _control_files
 
94
        self._transport = self._control_files._transport
141
95
        self._dirty = None
142
96
        #-------------
143
97
        # during a read or write lock these objects are set, and are
147
101
        #-------------
148
102
        self._setup_directory_is_tree_reference()
149
103
        self._detect_case_handling()
 
104
        self._rules_searcher = None
 
105
        self.views = self._make_views()
 
106
        #--- allow tests to select the dirstate iter_changes implementation
 
107
        self._iter_changes = dirstate._process_entry
150
108
 
151
109
    @needs_tree_write_lock
152
110
    def _add(self, files, ids, kinds):
180
138
    @needs_tree_write_lock
181
139
    def add_reference(self, sub_tree):
182
140
        # use standard implementation, which calls back to self._add
183
 
        # 
 
141
        #
184
142
        # So we don't store the reference_revision in the working dirstate,
185
 
        # it's just recorded at the moment of commit. 
 
143
        # it's just recorded at the moment of commit.
186
144
        self._add_reference(sub_tree)
187
145
 
188
146
    def break_lock(self):
227
185
            WorkingTree3._comparison_data(self, entry, path)
228
186
        # it looks like a plain directory, but it's really a reference -- see
229
187
        # also kind()
230
 
        if (self._repo_supports_tree_reference and
231
 
            kind == 'directory' and
232
 
            self._directory_is_tree_reference(path)):
 
188
        if (self._repo_supports_tree_reference and kind == 'directory'
 
189
            and entry is not None and entry.kind == 'tree-reference'):
233
190
            kind = 'tree-reference'
234
191
        return kind, executable, stat_value
235
192
 
261
218
            return self._dirstate
262
219
        local_path = self.bzrdir.get_workingtree_transport(None
263
220
            ).local_abspath('dirstate')
264
 
        self._dirstate = dirstate.DirState.on_file(local_path)
 
221
        self._dirstate = dirstate.DirState.on_file(local_path,
 
222
            self._sha1_provider())
265
223
        return self._dirstate
266
224
 
 
225
    def _sha1_provider(self):
 
226
        """A function that returns a SHA1Provider suitable for this tree.
 
227
 
 
228
        :return: None if content filtering is not supported by this tree.
 
229
          Otherwise, a SHA1Provider is returned that sha's the canonical
 
230
          form of files, i.e. after read filters are applied.
 
231
        """
 
232
        if self.supports_content_filtering():
 
233
            return ContentFilterAwareSHA1Provider(self)
 
234
        else:
 
235
            return None
 
236
 
267
237
    def filter_unversioned_files(self, paths):
268
238
        """Filter out paths that are versioned.
269
239
 
301
271
 
302
272
    def _generate_inventory(self):
303
273
        """Create and set self.inventory from the dirstate object.
304
 
        
 
274
 
305
275
        This is relatively expensive: we have to walk the entire dirstate.
306
276
        Ideally we would not, and can deprecate this function.
307
277
        """
352
322
                    parent_ies[(dirname + '/' + name).strip('/')] = inv_entry
353
323
                elif kind == 'tree-reference':
354
324
                    if not self._repo_supports_tree_reference:
355
 
                        raise AssertionError(
356
 
                            "repository of %r "
357
 
                            "doesn't support tree references "
358
 
                            "required by entry %r"
359
 
                            % (self, name))
 
325
                        raise errors.UnsupportedOperation(
 
326
                            self._generate_inventory,
 
327
                            self.branch.repository)
360
328
                    inv_entry.reference_revision = link_or_sha1 or None
361
329
                elif kind != 'symlink':
362
330
                    raise AssertionError("unknown kind %r" % kind)
377
345
        If either file_id or path is supplied, it is used as the key to lookup.
378
346
        If both are supplied, the fastest lookup is used, and an error is
379
347
        raised if they do not both point at the same row.
380
 
        
 
348
 
381
349
        :param file_id: An optional unicode file_id to be looked up.
382
350
        :param path: An optional unicode path to be looked up.
383
351
        :return: The dirstate row tuple for path/file_id, or (None, None)
407
375
                    return None
408
376
                else:
409
377
                    raise
410
 
        link_or_sha1 = state.update_entry(entry, file_abspath,
411
 
                                          stat_value=stat_value)
 
378
        link_or_sha1 = dirstate.update_entry(state, entry, file_abspath,
 
379
            stat_value=stat_value)
412
380
        if entry[1][0][0] == 'f':
413
 
            return link_or_sha1
 
381
            if link_or_sha1 is None:
 
382
                file_obj, statvalue = self.get_file_with_stat(file_id, path)
 
383
                try:
 
384
                    sha1 = osutils.sha_file(file_obj)
 
385
                finally:
 
386
                    file_obj.close()
 
387
                self._observed_sha1(file_id, path, (sha1, statvalue))
 
388
                return sha1
 
389
            else:
 
390
                return link_or_sha1
414
391
        return None
415
392
 
416
393
    def _get_inventory(self):
430
407
    @needs_read_lock
431
408
    def get_parent_ids(self):
432
409
        """See Tree.get_parent_ids.
433
 
        
 
410
 
434
411
        This implementation requests the ids list from the dirstate file.
435
412
        """
436
413
        return self.current_dirstate().get_parent_ids()
458
435
        return osutils.lexists(pathjoin(
459
436
                    self.basedir, row[0].decode('utf8'), row[1].decode('utf8')))
460
437
 
 
438
    def has_or_had_id(self, file_id):
 
439
        state = self.current_dirstate()
 
440
        row, parents = self._get_entry(file_id=file_id)
 
441
        return row is not None
 
442
 
461
443
    @needs_read_lock
462
444
    def id2path(self, file_id):
463
445
        "Convert a file-id to a path."
527
509
        return iter(result)
528
510
 
529
511
    def iter_references(self):
 
512
        if not self._repo_supports_tree_reference:
 
513
            # When the repo doesn't support references, we will have nothing to
 
514
            # return
 
515
            return
530
516
        for key, tree_details in self.current_dirstate()._iter_entries():
531
517
            if tree_details[0][0] in ('a', 'r'): # absent, relocated
532
518
                # not relevant to the working tree
534
520
            if not key[1]:
535
521
                # the root is not a reference.
536
522
                continue
537
 
            path = pathjoin(self.basedir, key[0].decode('utf8'), key[1].decode('utf8'))
 
523
            relpath = pathjoin(key[0].decode('utf8'), key[1].decode('utf8'))
538
524
            try:
539
 
                if self._kind(path) == 'tree-reference':
540
 
                    yield path, key[2]
 
525
                if self._kind(relpath) == 'tree-reference':
 
526
                    yield relpath, key[2]
541
527
            except errors.NoSuchFile:
542
528
                # path is missing on disk.
543
529
                continue
544
530
 
 
531
    def _observed_sha1(self, file_id, path, (sha1, statvalue)):
 
532
        """See MutableTree._observed_sha1."""
 
533
        state = self.current_dirstate()
 
534
        entry = self._get_entry(file_id=file_id, path=path)
 
535
        state._observed_sha1(entry, sha1, statvalue)
 
536
 
545
537
    def kind(self, file_id):
546
538
        """Return the kind of a file.
547
539
 
559
551
    def _kind(self, relpath):
560
552
        abspath = self.abspath(relpath)
561
553
        kind = file_kind(abspath)
562
 
        if (self._repo_supports_tree_reference and
563
 
            kind == 'directory' and
564
 
            self._directory_is_tree_reference(relpath)):
565
 
            kind = 'tree-reference'
 
554
        if (self._repo_supports_tree_reference and kind == 'directory'):
 
555
            entry = self._get_entry(path=relpath)
 
556
            if entry[1] is not None:
 
557
                if entry[1][0][0] == 't':
 
558
                    kind = 'tree-reference'
566
559
        return kind
567
560
 
568
561
    @needs_read_lock
699
692
            from_entry = self._get_entry(path=from_rel)
700
693
            if from_entry == (None, None):
701
694
                raise errors.BzrMoveFailedError(from_rel,to_dir,
702
 
                    errors.NotVersionedError(path=str(from_rel)))
 
695
                    errors.NotVersionedError(path=from_rel))
703
696
 
704
697
            from_id = from_entry[0][2]
705
698
            to_rel = pathjoin(to_dir, from_tail)
880
873
        for tree in trees:
881
874
            if not (isinstance(tree, DirStateRevisionTree) and tree._revision_id in
882
875
                parents):
883
 
                return super(WorkingTree4, self).paths2ids(paths, trees, require_versioned)
 
876
                return super(DirStateWorkingTree, self).paths2ids(paths,
 
877
                    trees, require_versioned)
884
878
        search_indexes = [0] + [1 + parents.index(tree._revision_id) for tree in trees]
885
879
        # -- make all paths utf8 --
886
880
        paths_utf8 = set()
947
941
                raise errors.PathsNotVersionedError(paths)
948
942
        # -- remove redundancy in supplied paths to prevent over-scanning --
949
943
        search_paths = osutils.minimum_path_selection(paths)
950
 
        # sketch: 
 
944
        # sketch:
951
945
        # for all search_indexs in each path at or under each element of
952
946
        # search_paths, if the detail is relocated: add the id, and add the
953
947
        # relocated path as one to search if its not searched already. If the
1009
1003
 
1010
1004
    def read_working_inventory(self):
1011
1005
        """Read the working inventory.
1012
 
        
 
1006
 
1013
1007
        This is a meaningless operation for dirstate, but we obey it anyhow.
1014
1008
        """
1015
1009
        return self.inventory
1033
1027
    def set_last_revision(self, new_revision):
1034
1028
        """Change the last revision in the working tree."""
1035
1029
        parents = self.get_parent_ids()
1036
 
        if new_revision in (NULL_REVISION, None):
 
1030
        if new_revision in (_mod_revision.NULL_REVISION, None):
1037
1031
            if len(parents) >= 2:
1038
1032
                raise AssertionError(
1039
1033
                    "setting the last parent to none with a pending merge is "
1046
1040
    @needs_tree_write_lock
1047
1041
    def set_parent_ids(self, revision_ids, allow_leftmost_as_ghost=False):
1048
1042
        """Set the parent ids to revision_ids.
1049
 
        
 
1043
 
1050
1044
        See also set_parent_trees. This api will try to retrieve the tree data
1051
1045
        for each element of revision_ids from the trees repository. If you have
1052
1046
        tree data already available, it is more efficient to use
1084
1078
                raise errors.GhostRevisionUnusableHere(parents_list[0][0])
1085
1079
        real_trees = []
1086
1080
        ghosts = []
 
1081
 
 
1082
        parent_ids = [rev_id for rev_id, tree in parents_list]
 
1083
        graph = self.branch.repository.get_graph()
 
1084
        heads = graph.heads(parent_ids)
 
1085
        accepted_revisions = set()
 
1086
 
1087
1087
        # convert absent trees to the null tree, which we convert back to
1088
1088
        # missing on access.
1089
1089
        for rev_id, tree in parents_list:
 
1090
            if len(accepted_revisions) > 0:
 
1091
                # we always accept the first tree
 
1092
                if rev_id in accepted_revisions or rev_id not in heads:
 
1093
                    # We have already included either this tree, or its
 
1094
                    # descendent, so we skip it.
 
1095
                    continue
1090
1096
            _mod_revision.check_not_reserved_id(rev_id)
1091
1097
            if tree is not None:
1092
1098
                real_trees.append((rev_id, tree))
1093
1099
            else:
1094
1100
                real_trees.append((rev_id,
1095
 
                    self.branch.repository.revision_tree(None)))
 
1101
                    self.branch.repository.revision_tree(
 
1102
                        _mod_revision.NULL_REVISION)))
1096
1103
                ghosts.append(rev_id)
 
1104
            accepted_revisions.add(rev_id)
1097
1105
        dirstate.set_parent_trees(real_trees, ghosts=ghosts)
1098
1106
        self._make_dirty(reset_inventory=False)
1099
1107
 
1192
1200
                # just forget the whole block.
1193
1201
                entry_index = 0
1194
1202
                while entry_index < len(block[1]):
1195
 
                    # Mark this file id as having been removed
1196
1203
                    entry = block[1][entry_index]
1197
 
                    ids_to_unversion.discard(entry[0][2])
1198
 
                    if (entry[1][0][0] in 'ar' # don't remove absent or renamed
1199
 
                                               # entries
1200
 
                        or not state._make_absent(entry)):
 
1204
                    if entry[1][0][0] in 'ar':
 
1205
                        # don't remove absent or renamed entries
1201
1206
                        entry_index += 1
 
1207
                    else:
 
1208
                        # Mark this file id as having been removed
 
1209
                        ids_to_unversion.discard(entry[0][2])
 
1210
                        if not state._make_absent(entry):
 
1211
                            # The block has not shrunk.
 
1212
                            entry_index += 1
1202
1213
                # go to the next block. (At the moment we dont delete empty
1203
1214
                # dirblocks)
1204
1215
                block_index += 1
1256
1267
        if self._dirty:
1257
1268
            raise AssertionError("attempting to write an inventory when the "
1258
1269
                "dirstate is dirty will lose pending changes")
1259
 
        self.current_dirstate().set_state_from_inventory(inv)
1260
 
        self._make_dirty(reset_inventory=False)
1261
 
        if self._inventory is not None:
 
1270
        had_inventory = self._inventory is not None
 
1271
        # Setting self._inventory = None forces the dirstate to regenerate the
 
1272
        # working inventory. We do this because self.inventory may be inv, or
 
1273
        # may have been modified, and either case would prevent a clean delta
 
1274
        # being created.
 
1275
        self._inventory = None
 
1276
        # generate a delta,
 
1277
        delta = inv._make_delta(self.inventory)
 
1278
        # and apply it.
 
1279
        self.apply_inventory_delta(delta)
 
1280
        if had_inventory:
1262
1281
            self._inventory = inv
1263
1282
        self.flush()
1264
1283
 
1265
1284
 
1266
 
class WorkingTreeFormat4(WorkingTreeFormat3):
1267
 
    """The first consolidated dirstate working tree format.
1268
 
 
1269
 
    This format:
1270
 
        - exists within a metadir controlling .bzr
1271
 
        - includes an explicit version marker for the workingtree control
1272
 
          files, separate from the BzrDir format
1273
 
        - modifies the hash cache format
1274
 
        - is new in bzr 0.15
1275
 
        - uses a LockDir to guard access to it.
1276
 
    """
1277
 
 
1278
 
    upgrade_recommended = False
1279
 
 
1280
 
    def get_format_string(self):
1281
 
        """See WorkingTreeFormat.get_format_string()."""
1282
 
        return "Bazaar Working Tree Format 4 (bzr 0.15)\n"
1283
 
 
1284
 
    def get_format_description(self):
1285
 
        """See WorkingTreeFormat.get_format_description()."""
1286
 
        return "Working tree format 4"
1287
 
 
 
1285
class ContentFilterAwareSHA1Provider(dirstate.SHA1Provider):
 
1286
 
 
1287
    def __init__(self, tree):
 
1288
        self.tree = tree
 
1289
 
 
1290
    def sha1(self, abspath):
 
1291
        """See dirstate.SHA1Provider.sha1()."""
 
1292
        filters = self.tree._content_filter_stack(
 
1293
            self.tree.relpath(osutils.safe_unicode(abspath)))
 
1294
        return internal_size_sha_file_byname(abspath, filters)[1]
 
1295
 
 
1296
    def stat_and_sha1(self, abspath):
 
1297
        """See dirstate.SHA1Provider.stat_and_sha1()."""
 
1298
        filters = self.tree._content_filter_stack(
 
1299
            self.tree.relpath(osutils.safe_unicode(abspath)))
 
1300
        file_obj = file(abspath, 'rb', 65000)
 
1301
        try:
 
1302
            statvalue = os.fstat(file_obj.fileno())
 
1303
            if filters:
 
1304
                file_obj = filtered_input_file(file_obj, filters)
 
1305
            sha1 = osutils.size_sha_file(file_obj)[1]
 
1306
        finally:
 
1307
            file_obj.close()
 
1308
        return statvalue, sha1
 
1309
 
 
1310
 
 
1311
class ContentFilteringDirStateWorkingTree(DirStateWorkingTree):
 
1312
    """Dirstate working tree that supports content filtering.
 
1313
 
 
1314
    The dirstate holds the hash and size of the canonical form of the file, 
 
1315
    and most methods must return that.
 
1316
    """
 
1317
 
 
1318
    def _file_content_summary(self, path, stat_result):
 
1319
        # This is to support the somewhat obsolete path_content_summary method
 
1320
        # with content filtering: see
 
1321
        # <https://bugs.edge.launchpad.net/bzr/+bug/415508>.
 
1322
        #
 
1323
        # If the dirstate cache is up to date and knows the hash and size,
 
1324
        # return that.
 
1325
        # Otherwise if there are no content filters, return the on-disk size
 
1326
        # and leave the hash blank.
 
1327
        # Otherwise, read and filter the on-disk file and use its size and
 
1328
        # hash.
 
1329
        #
 
1330
        # The dirstate doesn't store the size of the canonical form so we
 
1331
        # can't trust it for content-filtered trees.  We just return None.
 
1332
        dirstate_sha1 = self._dirstate.sha1_from_stat(path, stat_result)
 
1333
        executable = self._is_executable_from_path_and_stat(path, stat_result)
 
1334
        return ('file', None, executable, dirstate_sha1)
 
1335
 
 
1336
 
 
1337
class WorkingTree4(DirStateWorkingTree):
 
1338
    """This is the Format 4 working tree.
 
1339
 
 
1340
    This differs from WorkingTree3 by:
 
1341
     - Having a consolidated internal dirstate, stored in a
 
1342
       randomly-accessible sorted file on disk.
 
1343
     - Not having a regular inventory attribute.  One can be synthesized
 
1344
       on demand but this is expensive and should be avoided.
 
1345
 
 
1346
    This is new in bzr 0.15.
 
1347
    """
 
1348
 
 
1349
 
 
1350
class WorkingTree5(ContentFilteringDirStateWorkingTree):
 
1351
    """This is the Format 5 working tree.
 
1352
 
 
1353
    This differs from WorkingTree4 by:
 
1354
     - Supporting content filtering.
 
1355
 
 
1356
    This is new in bzr 1.11.
 
1357
    """
 
1358
 
 
1359
 
 
1360
class WorkingTree6(ContentFilteringDirStateWorkingTree):
 
1361
    """This is the Format 6 working tree.
 
1362
 
 
1363
    This differs from WorkingTree5 by:
 
1364
     - Supporting a current view that may mask the set of files in a tree
 
1365
       impacted by most user operations.
 
1366
 
 
1367
    This is new in bzr 1.14.
 
1368
    """
 
1369
 
 
1370
    def _make_views(self):
 
1371
        return views.PathBasedViews(self)
 
1372
 
 
1373
 
 
1374
class DirStateWorkingTreeFormat(WorkingTreeFormat3):
1288
1375
    def initialize(self, a_bzrdir, revision_id=None, from_branch=None,
1289
1376
                   accelerator_tree=None, hardlink=False):
1290
1377
        """See WorkingTreeFormat.initialize().
1307
1394
        control_files = self._open_control_files(a_bzrdir)
1308
1395
        control_files.create_lock()
1309
1396
        control_files.lock_write()
1310
 
        control_files.put_utf8('format', self.get_format_string())
 
1397
        transport.put_bytes('format', self.get_format_string(),
 
1398
            mode=a_bzrdir._get_file_mode())
1311
1399
        if from_branch is not None:
1312
1400
            branch = from_branch
1313
1401
        else:
1319
1407
        state = dirstate.DirState.initialize(local_path)
1320
1408
        state.unlock()
1321
1409
        del state
1322
 
        wt = WorkingTree4(a_bzrdir.root_transport.local_abspath('.'),
 
1410
        wt = self._tree_class(a_bzrdir.root_transport.local_abspath('.'),
1323
1411
                         branch,
1324
1412
                         _format=self,
1325
1413
                         _bzrdir=a_bzrdir,
1327
1415
        wt._new_tree()
1328
1416
        wt.lock_tree_write()
1329
1417
        try:
1330
 
            if revision_id in (None, NULL_REVISION):
 
1418
            self._init_custom_control_files(wt)
 
1419
            if revision_id in (None, _mod_revision.NULL_REVISION):
1331
1420
                if branch.repository.supports_rich_root():
1332
1421
                    wt._set_root_id(generate_ids.gen_root_id())
1333
1422
                else:
1344
1433
                    pass
1345
1434
            if basis is None:
1346
1435
                basis = branch.repository.revision_tree(revision_id)
1347
 
            if revision_id == NULL_REVISION:
 
1436
            if revision_id == _mod_revision.NULL_REVISION:
1348
1437
                parents_list = []
1349
1438
            else:
1350
1439
                parents_list = [(revision_id, basis)]
1358
1447
                if basis_root_id is not None:
1359
1448
                    wt._set_root_id(basis_root_id)
1360
1449
                    wt.flush()
 
1450
                if wt.supports_content_filtering():
 
1451
                    # The original tree may not have the same content filters
 
1452
                    # applied so we can't safely build the inventory delta from
 
1453
                    # the source tree.
 
1454
                    delta_from_tree = False
 
1455
                else:
 
1456
                    delta_from_tree = True
 
1457
                # delta_from_tree is safe even for DirStateRevisionTrees,
 
1458
                # because wt4.apply_inventory_delta does not mutate the input
 
1459
                # inventory entries.
1361
1460
                transform.build_tree(basis, wt, accelerator_tree,
1362
 
                                     hardlink=hardlink)
 
1461
                                     hardlink=hardlink,
 
1462
                                     delta_from_tree=delta_from_tree)
1363
1463
            finally:
1364
1464
                basis.unlock()
1365
1465
        finally:
1367
1467
            wt.unlock()
1368
1468
        return wt
1369
1469
 
 
1470
    def _init_custom_control_files(self, wt):
 
1471
        """Subclasses with custom control files should override this method.
 
1472
 
 
1473
        The working tree and control files are locked for writing when this
 
1474
        method is called.
 
1475
 
 
1476
        :param wt: the WorkingTree object
 
1477
        """
 
1478
 
1370
1479
    def _open(self, a_bzrdir, control_files):
1371
1480
        """Open the tree itself.
1372
1481
 
1373
1482
        :param a_bzrdir: the dir for the tree.
1374
1483
        :param control_files: the control files for the tree.
1375
1484
        """
1376
 
        return WorkingTree4(a_bzrdir.root_transport.local_abspath('.'),
 
1485
        return self._tree_class(a_bzrdir.root_transport.local_abspath('.'),
1377
1486
                           branch=a_bzrdir.open_branch(),
1378
1487
                           _format=self,
1379
1488
                           _bzrdir=a_bzrdir,
1380
1489
                           _control_files=control_files)
1381
1490
 
1382
1491
    def __get_matchingbzrdir(self):
 
1492
        return self._get_matchingbzrdir()
 
1493
 
 
1494
    def _get_matchingbzrdir(self):
 
1495
        """Overrideable method to get a bzrdir for testing."""
1383
1496
        # please test against something that will let us do tree references
1384
1497
        return bzrdir.format_registry.make_bzrdir(
1385
1498
            'dirstate-with-subtree')
1387
1500
    _matchingbzrdir = property(__get_matchingbzrdir)
1388
1501
 
1389
1502
 
 
1503
class WorkingTreeFormat4(DirStateWorkingTreeFormat):
 
1504
    """The first consolidated dirstate working tree format.
 
1505
 
 
1506
    This format:
 
1507
        - exists within a metadir controlling .bzr
 
1508
        - includes an explicit version marker for the workingtree control
 
1509
          files, separate from the BzrDir format
 
1510
        - modifies the hash cache format
 
1511
        - is new in bzr 0.15
 
1512
        - uses a LockDir to guard access to it.
 
1513
    """
 
1514
 
 
1515
    upgrade_recommended = False
 
1516
 
 
1517
    _tree_class = WorkingTree4
 
1518
 
 
1519
    def get_format_string(self):
 
1520
        """See WorkingTreeFormat.get_format_string()."""
 
1521
        return "Bazaar Working Tree Format 4 (bzr 0.15)\n"
 
1522
 
 
1523
    def get_format_description(self):
 
1524
        """See WorkingTreeFormat.get_format_description()."""
 
1525
        return "Working tree format 4"
 
1526
 
 
1527
 
 
1528
class WorkingTreeFormat5(DirStateWorkingTreeFormat):
 
1529
    """WorkingTree format supporting content filtering.
 
1530
    """
 
1531
 
 
1532
    upgrade_recommended = False
 
1533
 
 
1534
    _tree_class = WorkingTree5
 
1535
 
 
1536
    def get_format_string(self):
 
1537
        """See WorkingTreeFormat.get_format_string()."""
 
1538
        return "Bazaar Working Tree Format 5 (bzr 1.11)\n"
 
1539
 
 
1540
    def get_format_description(self):
 
1541
        """See WorkingTreeFormat.get_format_description()."""
 
1542
        return "Working tree format 5"
 
1543
 
 
1544
    def supports_content_filtering(self):
 
1545
        return True
 
1546
 
 
1547
 
 
1548
class WorkingTreeFormat6(DirStateWorkingTreeFormat):
 
1549
    """WorkingTree format supporting views.
 
1550
    """
 
1551
 
 
1552
    upgrade_recommended = False
 
1553
 
 
1554
    _tree_class = WorkingTree6
 
1555
 
 
1556
    def get_format_string(self):
 
1557
        """See WorkingTreeFormat.get_format_string()."""
 
1558
        return "Bazaar Working Tree Format 6 (bzr 1.14)\n"
 
1559
 
 
1560
    def get_format_description(self):
 
1561
        """See WorkingTreeFormat.get_format_description()."""
 
1562
        return "Working tree format 6"
 
1563
 
 
1564
    def _init_custom_control_files(self, wt):
 
1565
        """Subclasses with custom control files should override this method."""
 
1566
        wt._transport.put_bytes('views', '', mode=wt.bzrdir._get_file_mode())
 
1567
 
 
1568
    def supports_content_filtering(self):
 
1569
        return True
 
1570
 
 
1571
    def supports_views(self):
 
1572
        return True
 
1573
 
 
1574
 
1390
1575
class DirStateRevisionTree(Tree):
1391
 
    """A revision tree pulling the inventory from a dirstate."""
 
1576
    """A revision tree pulling the inventory from a dirstate.
 
1577
    
 
1578
    Note that this is one of the historical (ie revision) trees cached in the
 
1579
    dirstate for easy access, not the workingtree.
 
1580
    """
1392
1581
 
1393
1582
    def __init__(self, dirstate, revision_id, repository):
1394
1583
        self._dirstate = dirstate
1397
1586
        self._inventory = None
1398
1587
        self._locked = 0
1399
1588
        self._dirstate_locked = False
 
1589
        self._repo_supports_tree_reference = getattr(
 
1590
            repository._format, "supports_tree_reference",
 
1591
            False)
1400
1592
 
1401
1593
    def __repr__(self):
1402
1594
        return "<%s of %s in %s>" % \
1405
1597
    def annotate_iter(self, file_id,
1406
1598
                      default_revision=_mod_revision.CURRENT_REVISION):
1407
1599
        """See Tree.annotate_iter"""
1408
 
        w = self._get_weave(file_id)
1409
 
        return w.annotate(self.inventory[file_id].revision)
 
1600
        text_key = (file_id, self.inventory[file_id].revision)
 
1601
        annotations = self._repository.texts.annotate(text_key)
 
1602
        return [(key[-1], line) for (key, line) in annotations]
1410
1603
 
1411
1604
    def _get_ancestors(self, default_revision):
1412
1605
        return set(self._repository.get_ancestry(self._revision_id,
1441
1634
        path_utf8 = osutils.pathjoin(entry[0][0], entry[0][1])
1442
1635
        return path_utf8.decode('utf8')
1443
1636
 
 
1637
    def iter_references(self):
 
1638
        if not self._repo_supports_tree_reference:
 
1639
            # When the repo doesn't support references, we will have nothing to
 
1640
            # return
 
1641
            return iter([])
 
1642
        # Otherwise, fall back to the default implementation
 
1643
        return super(DirStateRevisionTree, self).iter_references()
 
1644
 
1444
1645
    def _get_parent_index(self):
1445
1646
        """Return the index in the dirstate referenced by this tree."""
1446
1647
        return self._dirstate.get_parent_ids().index(self._revision_id) + 1
1451
1652
        If either file_id or path is supplied, it is used as the key to lookup.
1452
1653
        If both are supplied, the fastest lookup is used, and an error is
1453
1654
        raised if they do not both point at the same row.
1454
 
        
 
1655
 
1455
1656
        :param file_id: An optional unicode file_id to be looked up.
1456
1657
        :param path: An optional unicode path to be looked up.
1457
1658
        :return: The dirstate row tuple for path/file_id, or (None, None)
1564
1765
            return parent_details[1]
1565
1766
        return None
1566
1767
 
1567
 
    def _get_weave(self, file_id):
1568
 
        return self._repository.weave_store.get_weave(file_id,
1569
 
                self._repository.get_transaction())
1570
 
 
1571
1768
    def get_file(self, file_id, path=None):
1572
1769
        return StringIO(self.get_file_text(file_id))
1573
1770
 
1574
 
    def get_file_lines(self, file_id):
1575
 
        entry = self._get_entry(file_id=file_id)[1]
1576
 
        if entry is None:
1577
 
            raise errors.NoSuchId(tree=self, file_id=file_id)
1578
 
        return self._get_weave(file_id).get_lines(entry[1][4])
1579
 
 
1580
1771
    def get_file_size(self, file_id):
1581
1772
        """See Tree.get_file_size"""
1582
1773
        return self.inventory[file_id].text_size
1583
1774
 
1584
 
    def get_file_text(self, file_id):
1585
 
        return ''.join(self.get_file_lines(file_id))
 
1775
    def get_file_text(self, file_id, path=None):
 
1776
        _, content = list(self.iter_files_bytes([(file_id, None)]))[0]
 
1777
        return ''.join(content)
1586
1778
 
1587
1779
    def get_reference_revision(self, file_id, path=None):
1588
1780
        return self.inventory[file_id].reference_revision
1607
1799
        if entry[1][parent_index][0] != 'l':
1608
1800
            return None
1609
1801
        else:
1610
 
            # At present, none of the tree implementations supports non-ascii
1611
 
            # symlink targets. So we will just assume that the dirstate path is
1612
 
            # correct.
1613
 
            return entry[1][parent_index][1]
 
1802
            target = entry[1][parent_index][1]
 
1803
            target = target.decode('utf8')
 
1804
            return target
1614
1805
 
1615
1806
    def get_revision_id(self):
1616
1807
        """Return the revision id for this tree."""
1663
1854
            return None
1664
1855
        return ie.executable
1665
1856
 
1666
 
    def list_files(self, include_root=False):
 
1857
    def list_files(self, include_root=False, from_dir=None, recursive=True):
1667
1858
        # We use a standard implementation, because DirStateRevisionTree is
1668
1859
        # dealing with one of the parents of the current state
1669
1860
        inv = self._get_inventory()
1670
 
        entries = inv.iter_entries()
1671
 
        if self.inventory.root is not None and not include_root:
 
1861
        if from_dir is None:
 
1862
            from_dir_id = None
 
1863
        else:
 
1864
            from_dir_id = inv.path2id(from_dir)
 
1865
            if from_dir_id is None:
 
1866
                # Directory not versioned
 
1867
                return
 
1868
        entries = inv.iter_entries(from_dir=from_dir_id, recursive=recursive)
 
1869
        if inv.root is not None and not include_root and from_dir is None:
1672
1870
            entries.next()
1673
1871
        for path, entry in entries:
1674
1872
            yield path, 'V', entry.kind, entry.file_id, entry
1707
1905
                self._dirstate_locked = False
1708
1906
            self._repository.unlock()
1709
1907
 
 
1908
    @needs_read_lock
 
1909
    def supports_tree_reference(self):
 
1910
        return self._repo_supports_tree_reference
 
1911
 
1710
1912
    def walkdirs(self, prefix=""):
1711
1913
        # TODO: jam 20070215 This is the lazy way by using the RevisionTree
1712
 
        # implementation based on an inventory.  
 
1914
        # implementation based on an inventory.
1713
1915
        # This should be cleaned up to use the much faster Dirstate code
1714
1916
        # So for now, we just build up the parent inventory, and extract
1715
1917
        # it the same way RevisionTree does.
1744
1946
 
1745
1947
class InterDirStateTree(InterTree):
1746
1948
    """Fast path optimiser for changes_from with dirstate trees.
1747
 
    
1748
 
    This is used only when both trees are in the dirstate working file, and 
1749
 
    the source is any parent within the dirstate, and the destination is 
 
1949
 
 
1950
    This is used only when both trees are in the dirstate working file, and
 
1951
    the source is any parent within the dirstate, and the destination is
1750
1952
    the current working tree of the same dirstate.
1751
1953
    """
1752
1954
    # this could be generalized to allow comparisons between any trees in the
1765
1967
        target.set_parent_ids([revid])
1766
1968
        return target.basis_tree(), target
1767
1969
 
 
1970
    @classmethod
 
1971
    def make_source_parent_tree_python_dirstate(klass, test_case, source, target):
 
1972
        result = klass.make_source_parent_tree(source, target)
 
1973
        result[1]._iter_changes = dirstate.ProcessEntryPython
 
1974
        return result
 
1975
 
 
1976
    @classmethod
 
1977
    def make_source_parent_tree_compiled_dirstate(klass, test_case, source, target):
 
1978
        from bzrlib.tests.test__dirstate_helpers import \
 
1979
            CompiledDirstateHelpersFeature
 
1980
        if not CompiledDirstateHelpersFeature.available():
 
1981
            from bzrlib.tests import UnavailableFeature
 
1982
            raise UnavailableFeature(CompiledDirstateHelpersFeature)
 
1983
        from bzrlib._dirstate_helpers_pyx import ProcessEntryC
 
1984
        result = klass.make_source_parent_tree(source, target)
 
1985
        result[1]._iter_changes = ProcessEntryC
 
1986
        return result
 
1987
 
1768
1988
    _matching_from_tree_format = WorkingTreeFormat4()
1769
1989
    _matching_to_tree_format = WorkingTreeFormat4()
1770
 
    _test_mutable_trees_to_test_trees = make_source_parent_tree
 
1990
 
 
1991
    @classmethod
 
1992
    def _test_mutable_trees_to_test_trees(klass, test_case, source, target):
 
1993
        # This method shouldn't be called, because we have python and C
 
1994
        # specific flavours.
 
1995
        raise NotImplementedError
1771
1996
 
1772
1997
    def iter_changes(self, include_unchanged=False,
1773
1998
                      specific_files=None, pb=None, extra_trees=[],
1791
2016
            output. An unversioned file is defined as one with (False, False)
1792
2017
            for the versioned pair.
1793
2018
        """
1794
 
        utf8_decode = cache_utf8._utf8_decode
1795
 
        _minikind_to_kind = dirstate.DirState._minikind_to_kind
1796
 
        cmp_by_dirs = dirstate.cmp_by_dirs
1797
 
        # NB: show_status depends on being able to pass in non-versioned files
1798
 
        # and report them as unknown
1799
2019
        # TODO: handle extra trees in the dirstate.
1800
2020
        if (extra_trees or specific_files == []):
1801
2021
            # we can't fast-path these cases (yet)
1802
 
            for f in super(InterDirStateTree, self).iter_changes(
 
2022
            return super(InterDirStateTree, self).iter_changes(
1803
2023
                include_unchanged, specific_files, pb, extra_trees,
1804
 
                require_versioned, want_unversioned=want_unversioned):
1805
 
                yield f
1806
 
            return
 
2024
                require_versioned, want_unversioned=want_unversioned)
1807
2025
        parent_ids = self.target.get_parent_ids()
1808
2026
        if not (self.source._revision_id in parent_ids
1809
 
                or self.source._revision_id == NULL_REVISION):
 
2027
                or self.source._revision_id == _mod_revision.NULL_REVISION):
1810
2028
            raise AssertionError(
1811
2029
                "revision {%s} is not stored in {%s}, but %s "
1812
2030
                "can only be used for trees stored in the dirstate"
1813
2031
                % (self.source._revision_id, self.target, self.iter_changes))
1814
2032
        target_index = 0
1815
 
        if self.source._revision_id == NULL_REVISION:
 
2033
        if self.source._revision_id == _mod_revision.NULL_REVISION:
1816
2034
            source_index = None
1817
2035
            indices = (target_index,)
1818
2036
        else:
1826
2044
        if specific_files:
1827
2045
            specific_files_utf8 = set()
1828
2046
            for path in specific_files:
 
2047
                # Note, if there are many specific files, using cache_utf8
 
2048
                # would be good here.
1829
2049
                specific_files_utf8.add(path.encode('utf8'))
1830
2050
            specific_files = specific_files_utf8
1831
2051
        else:
1832
2052
            specific_files = set([''])
1833
2053
        # -- specific_files is now a utf8 path set --
 
2054
 
1834
2055
        # -- get the state object and prepare it.
1835
2056
        state = self.target.current_dirstate()
1836
2057
        state._read_dirblocks_if_needed()
1837
 
        def _entries_for_path(path):
1838
 
            """Return a list with all the entries that match path for all ids.
1839
 
            """
1840
 
            dirname, basename = os.path.split(path)
1841
 
            key = (dirname, basename, '')
1842
 
            block_index, present = state._find_block_index_from_key(key)
1843
 
            if not present:
1844
 
                # the block which should contain path is absent.
1845
 
                return []
1846
 
            result = []
1847
 
            block = state._dirblocks[block_index][1]
1848
 
            entry_index, _ = state._find_entry_index(key, block)
1849
 
            # we may need to look at multiple entries at this path: walk while the specific_files match.
1850
 
            while (entry_index < len(block) and
1851
 
                block[entry_index][0][0:2] == key[0:2]):
1852
 
                result.append(block[entry_index])
1853
 
                entry_index += 1
1854
 
            return result
1855
2058
        if require_versioned:
1856
2059
            # -- check all supplied paths are versioned in a search tree. --
1857
 
            all_versioned = True
 
2060
            not_versioned = []
1858
2061
            for path in specific_files:
1859
 
                path_entries = _entries_for_path(path)
 
2062
                path_entries = state._entries_for_path(path)
1860
2063
                if not path_entries:
1861
2064
                    # this specified path is not present at all: error
1862
 
                    all_versioned = False
1863
 
                    break
 
2065
                    not_versioned.append(path)
 
2066
                    continue
1864
2067
                found_versioned = False
1865
2068
                # for each id at this path
1866
2069
                for entry in path_entries:
1873
2076
                if not found_versioned:
1874
2077
                    # none of the indexes was not 'absent' at all ids for this
1875
2078
                    # path.
1876
 
                    all_versioned = False
1877
 
                    break
1878
 
            if not all_versioned:
1879
 
                raise errors.PathsNotVersionedError(specific_files)
 
2079
                    not_versioned.append(path)
 
2080
            if len(not_versioned) > 0:
 
2081
                raise errors.PathsNotVersionedError(not_versioned)
1880
2082
        # -- remove redundancy in supplied specific_files to prevent over-scanning --
1881
 
        search_specific_files = set()
1882
 
        for path in specific_files:
1883
 
            other_specific_files = specific_files.difference(set([path]))
1884
 
            if not osutils.is_inside_any(other_specific_files, path):
1885
 
                # this is a top level path, we must check it.
1886
 
                search_specific_files.add(path)
1887
 
        # sketch: 
1888
 
        # compare source_index and target_index at or under each element of search_specific_files.
1889
 
        # follow the following comparison table. Note that we only want to do diff operations when
1890
 
        # the target is fdl because thats when the walkdirs logic will have exposed the pathinfo 
1891
 
        # for the target.
1892
 
        # cases:
1893
 
        # 
1894
 
        # Source | Target | disk | action
1895
 
        #   r    | fdlt   |      | add source to search, add id path move and perform
1896
 
        #        |        |      | diff check on source-target
1897
 
        #   r    | fdlt   |  a   | dangling file that was present in the basis. 
1898
 
        #        |        |      | ???
1899
 
        #   r    |  a     |      | add source to search
1900
 
        #   r    |  a     |  a   | 
1901
 
        #   r    |  r     |      | this path is present in a non-examined tree, skip.
1902
 
        #   r    |  r     |  a   | this path is present in a non-examined tree, skip.
1903
 
        #   a    | fdlt   |      | add new id
1904
 
        #   a    | fdlt   |  a   | dangling locally added file, skip
1905
 
        #   a    |  a     |      | not present in either tree, skip
1906
 
        #   a    |  a     |  a   | not present in any tree, skip
1907
 
        #   a    |  r     |      | not present in either tree at this path, skip as it
1908
 
        #        |        |      | may not be selected by the users list of paths.
1909
 
        #   a    |  r     |  a   | not present in either tree at this path, skip as it
1910
 
        #        |        |      | may not be selected by the users list of paths.
1911
 
        #  fdlt  | fdlt   |      | content in both: diff them
1912
 
        #  fdlt  | fdlt   |  a   | deleted locally, but not unversioned - show as deleted ?
1913
 
        #  fdlt  |  a     |      | unversioned: output deleted id for now
1914
 
        #  fdlt  |  a     |  a   | unversioned and deleted: output deleted id
1915
 
        #  fdlt  |  r     |      | relocated in this tree, so add target to search.
1916
 
        #        |        |      | Dont diff, we will see an r,fd; pair when we reach
1917
 
        #        |        |      | this id at the other path.
1918
 
        #  fdlt  |  r     |  a   | relocated in this tree, so add target to search.
1919
 
        #        |        |      | Dont diff, we will see an r,fd; pair when we reach
1920
 
        #        |        |      | this id at the other path.
1921
 
 
1922
 
        # for all search_indexs in each path at or under each element of
1923
 
        # search_specific_files, if the detail is relocated: add the id, and add the
1924
 
        # relocated path as one to search if its not searched already. If the
1925
 
        # detail is not relocated, add the id.
1926
 
        searched_specific_files = set()
1927
 
        NULL_PARENT_DETAILS = dirstate.DirState.NULL_PARENT_DETAILS
1928
 
        # Using a list so that we can access the values and change them in
1929
 
        # nested scope. Each one is [path, file_id, entry]
1930
 
        last_source_parent = [None, None]
1931
 
        last_target_parent = [None, None]
 
2083
        search_specific_files = osutils.minimum_path_selection(specific_files)
1932
2084
 
1933
2085
        use_filesystem_for_exec = (sys.platform != 'win32')
1934
 
 
1935
 
        # Just a sentry, so that _process_entry can say that this
1936
 
        # record is handled, but isn't interesting to process (unchanged)
1937
 
        uninteresting = object()
1938
 
 
1939
 
 
1940
 
        old_dirname_to_file_id = {}
1941
 
        new_dirname_to_file_id = {}
1942
 
        # TODO: jam 20070516 - Avoid the _get_entry lookup overhead by
1943
 
        #       keeping a cache of directories that we have seen.
1944
 
 
1945
 
        def _process_entry(entry, path_info):
1946
 
            """Compare an entry and real disk to generate delta information.
1947
 
 
1948
 
            :param path_info: top_relpath, basename, kind, lstat, abspath for
1949
 
                the path of entry. If None, then the path is considered absent.
1950
 
                (Perhaps we should pass in a concrete entry for this ?)
1951
 
                Basename is returned as a utf8 string because we expect this
1952
 
                tuple will be ignored, and don't want to take the time to
1953
 
                decode.
1954
 
            :return: None if these don't match
1955
 
                     A tuple of information about the change, or
1956
 
                     the object 'uninteresting' if these match, but are
1957
 
                     basically identical.
1958
 
            """
1959
 
            if source_index is None:
1960
 
                source_details = NULL_PARENT_DETAILS
1961
 
            else:
1962
 
                source_details = entry[1][source_index]
1963
 
            target_details = entry[1][target_index]
1964
 
            target_minikind = target_details[0]
1965
 
            if path_info is not None and target_minikind in 'fdlt':
1966
 
                if not (target_index == 0):
1967
 
                    raise AssertionError()
1968
 
                link_or_sha1 = state.update_entry(entry, abspath=path_info[4],
1969
 
                                                  stat_value=path_info[3])
1970
 
                # The entry may have been modified by update_entry
1971
 
                target_details = entry[1][target_index]
1972
 
                target_minikind = target_details[0]
1973
 
            else:
1974
 
                link_or_sha1 = None
1975
 
            file_id = entry[0][2]
1976
 
            source_minikind = source_details[0]
1977
 
            if source_minikind in 'fdltr' and target_minikind in 'fdlt':
1978
 
                # claimed content in both: diff
1979
 
                #   r    | fdlt   |      | add source to search, add id path move and perform
1980
 
                #        |        |      | diff check on source-target
1981
 
                #   r    | fdlt   |  a   | dangling file that was present in the basis.
1982
 
                #        |        |      | ???
1983
 
                if source_minikind in 'r':
1984
 
                    # add the source to the search path to find any children it
1985
 
                    # has.  TODO ? : only add if it is a container ?
1986
 
                    if not osutils.is_inside_any(searched_specific_files,
1987
 
                                                 source_details[1]):
1988
 
                        search_specific_files.add(source_details[1])
1989
 
                    # generate the old path; this is needed for stating later
1990
 
                    # as well.
1991
 
                    old_path = source_details[1]
1992
 
                    old_dirname, old_basename = os.path.split(old_path)
1993
 
                    path = pathjoin(entry[0][0], entry[0][1])
1994
 
                    old_entry = state._get_entry(source_index,
1995
 
                                                 path_utf8=old_path)
1996
 
                    # update the source details variable to be the real
1997
 
                    # location.
1998
 
                    if old_entry == (None, None):
1999
 
                        raise errors.CorruptDirstate(state._filename,
2000
 
                            "entry '%s/%s' is considered renamed from %r"
2001
 
                            " but source does not exist\n"
2002
 
                            "entry: %s" % (entry[0][0], entry[0][1], old_path, entry))
2003
 
                    source_details = old_entry[1][source_index]
2004
 
                    source_minikind = source_details[0]
2005
 
                else:
2006
 
                    old_dirname = entry[0][0]
2007
 
                    old_basename = entry[0][1]
2008
 
                    old_path = path = None
2009
 
                if path_info is None:
2010
 
                    # the file is missing on disk, show as removed.
2011
 
                    content_change = True
2012
 
                    target_kind = None
2013
 
                    target_exec = False
2014
 
                else:
2015
 
                    # source and target are both versioned and disk file is present.
2016
 
                    target_kind = path_info[2]
2017
 
                    if target_kind == 'directory':
2018
 
                        if path is None:
2019
 
                            old_path = path = pathjoin(old_dirname, old_basename)
2020
 
                        new_dirname_to_file_id[path] = file_id
2021
 
                        if source_minikind != 'd':
2022
 
                            content_change = True
2023
 
                        else:
2024
 
                            # directories have no fingerprint
2025
 
                            content_change = False
2026
 
                        target_exec = False
2027
 
                    elif target_kind == 'file':
2028
 
                        if source_minikind != 'f':
2029
 
                            content_change = True
2030
 
                        else:
2031
 
                            # We could check the size, but we already have the
2032
 
                            # sha1 hash.
2033
 
                            content_change = (link_or_sha1 != source_details[1])
2034
 
                        # Target details is updated at update_entry time
2035
 
                        if use_filesystem_for_exec:
2036
 
                            # We don't need S_ISREG here, because we are sure
2037
 
                            # we are dealing with a file.
2038
 
                            target_exec = bool(stat.S_IEXEC & path_info[3].st_mode)
2039
 
                        else:
2040
 
                            target_exec = target_details[3]
2041
 
                    elif target_kind == 'symlink':
2042
 
                        if source_minikind != 'l':
2043
 
                            content_change = True
2044
 
                        else:
2045
 
                            content_change = (link_or_sha1 != source_details[1])
2046
 
                        target_exec = False
2047
 
                    elif target_kind == 'tree-reference':
2048
 
                        if source_minikind != 't':
2049
 
                            content_change = True
2050
 
                        else:
2051
 
                            content_change = False
2052
 
                        target_exec = False
2053
 
                    else:
2054
 
                        raise Exception, "unknown kind %s" % path_info[2]
2055
 
                if source_minikind == 'd':
2056
 
                    if path is None:
2057
 
                        old_path = path = pathjoin(old_dirname, old_basename)
2058
 
                    old_dirname_to_file_id[old_path] = file_id
2059
 
                # parent id is the entry for the path in the target tree
2060
 
                if old_dirname == last_source_parent[0]:
2061
 
                    source_parent_id = last_source_parent[1]
2062
 
                else:
2063
 
                    try:
2064
 
                        source_parent_id = old_dirname_to_file_id[old_dirname]
2065
 
                    except KeyError:
2066
 
                        source_parent_entry = state._get_entry(source_index,
2067
 
                                                               path_utf8=old_dirname)
2068
 
                        source_parent_id = source_parent_entry[0][2]
2069
 
                    if source_parent_id == entry[0][2]:
2070
 
                        # This is the root, so the parent is None
2071
 
                        source_parent_id = None
2072
 
                    else:
2073
 
                        last_source_parent[0] = old_dirname
2074
 
                        last_source_parent[1] = source_parent_id
2075
 
                new_dirname = entry[0][0]
2076
 
                if new_dirname == last_target_parent[0]:
2077
 
                    target_parent_id = last_target_parent[1]
2078
 
                else:
2079
 
                    try:
2080
 
                        target_parent_id = new_dirname_to_file_id[new_dirname]
2081
 
                    except KeyError:
2082
 
                        # TODO: We don't always need to do the lookup, because the
2083
 
                        #       parent entry will be the same as the source entry.
2084
 
                        target_parent_entry = state._get_entry(target_index,
2085
 
                                                               path_utf8=new_dirname)
2086
 
                        if target_parent_entry == (None, None):
2087
 
                            raise AssertionError(
2088
 
                                "Could not find target parent in wt: %s\nparent of: %s"
2089
 
                                % (new_dirname, entry))
2090
 
                        target_parent_id = target_parent_entry[0][2]
2091
 
                    if target_parent_id == entry[0][2]:
2092
 
                        # This is the root, so the parent is None
2093
 
                        target_parent_id = None
2094
 
                    else:
2095
 
                        last_target_parent[0] = new_dirname
2096
 
                        last_target_parent[1] = target_parent_id
2097
 
 
2098
 
                source_exec = source_details[3]
2099
 
                if (include_unchanged
2100
 
                    or content_change
2101
 
                    or source_parent_id != target_parent_id
2102
 
                    or old_basename != entry[0][1]
2103
 
                    or source_exec != target_exec
2104
 
                    ):
2105
 
                    if old_path is None:
2106
 
                        old_path = path = pathjoin(old_dirname, old_basename)
2107
 
                        old_path_u = utf8_decode(old_path)[0]
2108
 
                        path_u = old_path_u
2109
 
                    else:
2110
 
                        old_path_u = utf8_decode(old_path)[0]
2111
 
                        if old_path == path:
2112
 
                            path_u = old_path_u
2113
 
                        else:
2114
 
                            path_u = utf8_decode(path)[0]
2115
 
                    source_kind = _minikind_to_kind[source_minikind]
2116
 
                    return (entry[0][2],
2117
 
                           (old_path_u, path_u),
2118
 
                           content_change,
2119
 
                           (True, True),
2120
 
                           (source_parent_id, target_parent_id),
2121
 
                           (utf8_decode(old_basename)[0], utf8_decode(entry[0][1])[0]),
2122
 
                           (source_kind, target_kind),
2123
 
                           (source_exec, target_exec))
2124
 
                else:
2125
 
                    return uninteresting
2126
 
            elif source_minikind in 'a' and target_minikind in 'fdlt':
2127
 
                # looks like a new file
2128
 
                if path_info is not None:
2129
 
                    path = pathjoin(entry[0][0], entry[0][1])
2130
 
                    # parent id is the entry for the path in the target tree
2131
 
                    # TODO: these are the same for an entire directory: cache em.
2132
 
                    parent_id = state._get_entry(target_index,
2133
 
                                                 path_utf8=entry[0][0])[0][2]
2134
 
                    if parent_id == entry[0][2]:
2135
 
                        parent_id = None
2136
 
                    if use_filesystem_for_exec:
2137
 
                        # We need S_ISREG here, because we aren't sure if this
2138
 
                        # is a file or not.
2139
 
                        target_exec = bool(
2140
 
                            stat.S_ISREG(path_info[3].st_mode)
2141
 
                            and stat.S_IEXEC & path_info[3].st_mode)
2142
 
                    else:
2143
 
                        target_exec = target_details[3]
2144
 
                    return (entry[0][2],
2145
 
                           (None, utf8_decode(path)[0]),
2146
 
                           True,
2147
 
                           (False, True),
2148
 
                           (None, parent_id),
2149
 
                           (None, utf8_decode(entry[0][1])[0]),
2150
 
                           (None, path_info[2]),
2151
 
                           (None, target_exec))
2152
 
                else:
2153
 
                    # but its not on disk: we deliberately treat this as just
2154
 
                    # never-present. (Why ?! - RBC 20070224)
2155
 
                    pass
2156
 
            elif source_minikind in 'fdlt' and target_minikind in 'a':
2157
 
                # unversioned, possibly, or possibly not deleted: we dont care.
2158
 
                # if its still on disk, *and* theres no other entry at this
2159
 
                # path [we dont know this in this routine at the moment -
2160
 
                # perhaps we should change this - then it would be an unknown.
2161
 
                old_path = pathjoin(entry[0][0], entry[0][1])
2162
 
                # parent id is the entry for the path in the target tree
2163
 
                parent_id = state._get_entry(source_index, path_utf8=entry[0][0])[0][2]
2164
 
                if parent_id == entry[0][2]:
2165
 
                    parent_id = None
2166
 
                return (entry[0][2],
2167
 
                       (utf8_decode(old_path)[0], None),
2168
 
                       True,
2169
 
                       (True, False),
2170
 
                       (parent_id, None),
2171
 
                       (utf8_decode(entry[0][1])[0], None),
2172
 
                       (_minikind_to_kind[source_minikind], None),
2173
 
                       (source_details[3], None))
2174
 
            elif source_minikind in 'fdlt' and target_minikind in 'r':
2175
 
                # a rename; could be a true rename, or a rename inherited from
2176
 
                # a renamed parent. TODO: handle this efficiently. Its not
2177
 
                # common case to rename dirs though, so a correct but slow
2178
 
                # implementation will do.
2179
 
                if not osutils.is_inside_any(searched_specific_files, target_details[1]):
2180
 
                    search_specific_files.add(target_details[1])
2181
 
            elif source_minikind in 'ra' and target_minikind in 'ra':
2182
 
                # neither of the selected trees contain this file,
2183
 
                # so skip over it. This is not currently directly tested, but
2184
 
                # is indirectly via test_too_much.TestCommands.test_conflicts.
2185
 
                pass
2186
 
            else:
2187
 
                raise AssertionError("don't know how to compare "
2188
 
                    "source_minikind=%r, target_minikind=%r"
2189
 
                    % (source_minikind, target_minikind))
2190
 
                ## import pdb;pdb.set_trace()
2191
 
            return None
2192
 
 
2193
 
        while search_specific_files:
2194
 
            # TODO: the pending list should be lexically sorted?  the
2195
 
            # interface doesn't require it.
2196
 
            current_root = search_specific_files.pop()
2197
 
            current_root_unicode = current_root.decode('utf8')
2198
 
            searched_specific_files.add(current_root)
2199
 
            # process the entries for this containing directory: the rest will be
2200
 
            # found by their parents recursively.
2201
 
            root_entries = _entries_for_path(current_root)
2202
 
            root_abspath = self.target.abspath(current_root_unicode)
2203
 
            try:
2204
 
                root_stat = os.lstat(root_abspath)
2205
 
            except OSError, e:
2206
 
                if e.errno == errno.ENOENT:
2207
 
                    # the path does not exist: let _process_entry know that.
2208
 
                    root_dir_info = None
2209
 
                else:
2210
 
                    # some other random error: hand it up.
2211
 
                    raise
2212
 
            else:
2213
 
                root_dir_info = ('', current_root,
2214
 
                    osutils.file_kind_from_stat_mode(root_stat.st_mode), root_stat,
2215
 
                    root_abspath)
2216
 
                if root_dir_info[2] == 'directory':
2217
 
                    if self.target._directory_is_tree_reference(
2218
 
                        current_root.decode('utf8')):
2219
 
                        root_dir_info = root_dir_info[:2] + \
2220
 
                            ('tree-reference',) + root_dir_info[3:]
2221
 
 
2222
 
            if not root_entries and not root_dir_info:
2223
 
                # this specified path is not present at all, skip it.
2224
 
                continue
2225
 
            path_handled = False
2226
 
            for entry in root_entries:
2227
 
                result = _process_entry(entry, root_dir_info)
2228
 
                if result is not None:
2229
 
                    path_handled = True
2230
 
                    if result is not uninteresting:
2231
 
                        yield result
2232
 
            if want_unversioned and not path_handled and root_dir_info:
2233
 
                new_executable = bool(
2234
 
                    stat.S_ISREG(root_dir_info[3].st_mode)
2235
 
                    and stat.S_IEXEC & root_dir_info[3].st_mode)
2236
 
                yield (None,
2237
 
                       (None, current_root_unicode),
2238
 
                       True,
2239
 
                       (False, False),
2240
 
                       (None, None),
2241
 
                       (None, splitpath(current_root_unicode)[-1]),
2242
 
                       (None, root_dir_info[2]),
2243
 
                       (None, new_executable)
2244
 
                      )
2245
 
            initial_key = (current_root, '', '')
2246
 
            block_index, _ = state._find_block_index_from_key(initial_key)
2247
 
            if block_index == 0:
2248
 
                # we have processed the total root already, but because the
2249
 
                # initial key matched it we should skip it here.
2250
 
                block_index +=1
2251
 
            if root_dir_info and root_dir_info[2] == 'tree-reference':
2252
 
                current_dir_info = None
2253
 
            else:
2254
 
                dir_iterator = osutils._walkdirs_utf8(root_abspath, prefix=current_root)
2255
 
                try:
2256
 
                    current_dir_info = dir_iterator.next()
2257
 
                except OSError, e:
2258
 
                    # on win32, python2.4 has e.errno == ERROR_DIRECTORY, but
2259
 
                    # python 2.5 has e.errno == EINVAL,
2260
 
                    #            and e.winerror == ERROR_DIRECTORY
2261
 
                    e_winerror = getattr(e, 'winerror', None)
2262
 
                    win_errors = (ERROR_DIRECTORY, ERROR_PATH_NOT_FOUND)
2263
 
                    # there may be directories in the inventory even though
2264
 
                    # this path is not a file on disk: so mark it as end of
2265
 
                    # iterator
2266
 
                    if e.errno in (errno.ENOENT, errno.ENOTDIR, errno.EINVAL):
2267
 
                        current_dir_info = None
2268
 
                    elif (sys.platform == 'win32'
2269
 
                          and (e.errno in win_errors
2270
 
                               or e_winerror in win_errors)):
2271
 
                        current_dir_info = None
2272
 
                    else:
2273
 
                        raise
2274
 
                else:
2275
 
                    if current_dir_info[0][0] == '':
2276
 
                        # remove .bzr from iteration
2277
 
                        bzr_index = bisect_left(current_dir_info[1], ('.bzr',))
2278
 
                        if current_dir_info[1][bzr_index][0] != '.bzr':
2279
 
                            raise AssertionError()
2280
 
                        del current_dir_info[1][bzr_index]
2281
 
            # walk until both the directory listing and the versioned metadata
2282
 
            # are exhausted. 
2283
 
            if (block_index < len(state._dirblocks) and
2284
 
                osutils.is_inside(current_root, state._dirblocks[block_index][0])):
2285
 
                current_block = state._dirblocks[block_index]
2286
 
            else:
2287
 
                current_block = None
2288
 
            while (current_dir_info is not None or
2289
 
                   current_block is not None):
2290
 
                if (current_dir_info and current_block
2291
 
                    and current_dir_info[0][0] != current_block[0]):
2292
 
                    if cmp_by_dirs(current_dir_info[0][0], current_block[0]) < 0:
2293
 
                        # filesystem data refers to paths not covered by the dirblock.
2294
 
                        # this has two possibilities:
2295
 
                        # A) it is versioned but empty, so there is no block for it
2296
 
                        # B) it is not versioned.
2297
 
 
2298
 
                        # if (A) then we need to recurse into it to check for
2299
 
                        # new unknown files or directories.
2300
 
                        # if (B) then we should ignore it, because we don't
2301
 
                        # recurse into unknown directories.
2302
 
                        path_index = 0
2303
 
                        while path_index < len(current_dir_info[1]):
2304
 
                                current_path_info = current_dir_info[1][path_index]
2305
 
                                if want_unversioned:
2306
 
                                    if current_path_info[2] == 'directory':
2307
 
                                        if self.target._directory_is_tree_reference(
2308
 
                                            current_path_info[0].decode('utf8')):
2309
 
                                            current_path_info = current_path_info[:2] + \
2310
 
                                                ('tree-reference',) + current_path_info[3:]
2311
 
                                    new_executable = bool(
2312
 
                                        stat.S_ISREG(current_path_info[3].st_mode)
2313
 
                                        and stat.S_IEXEC & current_path_info[3].st_mode)
2314
 
                                    yield (None,
2315
 
                                        (None, utf8_decode(current_path_info[0])[0]),
2316
 
                                        True,
2317
 
                                        (False, False),
2318
 
                                        (None, None),
2319
 
                                        (None, utf8_decode(current_path_info[1])[0]),
2320
 
                                        (None, current_path_info[2]),
2321
 
                                        (None, new_executable))
2322
 
                                # dont descend into this unversioned path if it is
2323
 
                                # a dir
2324
 
                                if current_path_info[2] in ('directory',
2325
 
                                                            'tree-reference'):
2326
 
                                    del current_dir_info[1][path_index]
2327
 
                                    path_index -= 1
2328
 
                                path_index += 1
2329
 
 
2330
 
                        # This dir info has been handled, go to the next
2331
 
                        try:
2332
 
                            current_dir_info = dir_iterator.next()
2333
 
                        except StopIteration:
2334
 
                            current_dir_info = None
2335
 
                    else:
2336
 
                        # We have a dirblock entry for this location, but there
2337
 
                        # is no filesystem path for this. This is most likely
2338
 
                        # because a directory was removed from the disk.
2339
 
                        # We don't have to report the missing directory,
2340
 
                        # because that should have already been handled, but we
2341
 
                        # need to handle all of the files that are contained
2342
 
                        # within.
2343
 
                        for current_entry in current_block[1]:
2344
 
                            # entry referring to file not present on disk.
2345
 
                            # advance the entry only, after processing.
2346
 
                            result = _process_entry(current_entry, None)
2347
 
                            if result is not None:
2348
 
                                if result is not uninteresting:
2349
 
                                    yield result
2350
 
                        block_index +=1
2351
 
                        if (block_index < len(state._dirblocks) and
2352
 
                            osutils.is_inside(current_root,
2353
 
                                              state._dirblocks[block_index][0])):
2354
 
                            current_block = state._dirblocks[block_index]
2355
 
                        else:
2356
 
                            current_block = None
2357
 
                    continue
2358
 
                entry_index = 0
2359
 
                if current_block and entry_index < len(current_block[1]):
2360
 
                    current_entry = current_block[1][entry_index]
2361
 
                else:
2362
 
                    current_entry = None
2363
 
                advance_entry = True
2364
 
                path_index = 0
2365
 
                if current_dir_info and path_index < len(current_dir_info[1]):
2366
 
                    current_path_info = current_dir_info[1][path_index]
2367
 
                    if current_path_info[2] == 'directory':
2368
 
                        if self.target._directory_is_tree_reference(
2369
 
                            current_path_info[0].decode('utf8')):
2370
 
                            current_path_info = current_path_info[:2] + \
2371
 
                                ('tree-reference',) + current_path_info[3:]
2372
 
                else:
2373
 
                    current_path_info = None
2374
 
                advance_path = True
2375
 
                path_handled = False
2376
 
                while (current_entry is not None or
2377
 
                    current_path_info is not None):
2378
 
                    if current_entry is None:
2379
 
                        # the check for path_handled when the path is adnvaced
2380
 
                        # will yield this path if needed.
2381
 
                        pass
2382
 
                    elif current_path_info is None:
2383
 
                        # no path is fine: the per entry code will handle it.
2384
 
                        result = _process_entry(current_entry, current_path_info)
2385
 
                        if result is not None:
2386
 
                            if result is not uninteresting:
2387
 
                                yield result
2388
 
                    elif (current_entry[0][1] != current_path_info[1]
2389
 
                          or current_entry[1][target_index][0] in 'ar'):
2390
 
                        # The current path on disk doesn't match the dirblock
2391
 
                        # record. Either the dirblock is marked as absent, or
2392
 
                        # the file on disk is not present at all in the
2393
 
                        # dirblock. Either way, report about the dirblock
2394
 
                        # entry, and let other code handle the filesystem one.
2395
 
 
2396
 
                        # Compare the basename for these files to determine
2397
 
                        # which comes first
2398
 
                        if current_path_info[1] < current_entry[0][1]:
2399
 
                            # extra file on disk: pass for now, but only
2400
 
                            # increment the path, not the entry
2401
 
                            advance_entry = False
2402
 
                        else:
2403
 
                            # entry referring to file not present on disk.
2404
 
                            # advance the entry only, after processing.
2405
 
                            result = _process_entry(current_entry, None)
2406
 
                            if result is not None:
2407
 
                                if result is not uninteresting:
2408
 
                                    yield result
2409
 
                            advance_path = False
2410
 
                    else:
2411
 
                        result = _process_entry(current_entry, current_path_info)
2412
 
                        if result is not None:
2413
 
                            path_handled = True
2414
 
                            if result is not uninteresting:
2415
 
                                yield result
2416
 
                    if advance_entry and current_entry is not None:
2417
 
                        entry_index += 1
2418
 
                        if entry_index < len(current_block[1]):
2419
 
                            current_entry = current_block[1][entry_index]
2420
 
                        else:
2421
 
                            current_entry = None
2422
 
                    else:
2423
 
                        advance_entry = True # reset the advance flaga
2424
 
                    if advance_path and current_path_info is not None:
2425
 
                        if not path_handled:
2426
 
                            # unversioned in all regards
2427
 
                            if want_unversioned:
2428
 
                                new_executable = bool(
2429
 
                                    stat.S_ISREG(current_path_info[3].st_mode)
2430
 
                                    and stat.S_IEXEC & current_path_info[3].st_mode)
2431
 
                                yield (None,
2432
 
                                    (None, utf8_decode(current_path_info[0])[0]),
2433
 
                                    True,
2434
 
                                    (False, False),
2435
 
                                    (None, None),
2436
 
                                    (None, utf8_decode(current_path_info[1])[0]),
2437
 
                                    (None, current_path_info[2]),
2438
 
                                    (None, new_executable))
2439
 
                            # dont descend into this unversioned path if it is
2440
 
                            # a dir
2441
 
                            if current_path_info[2] in ('directory'):
2442
 
                                del current_dir_info[1][path_index]
2443
 
                                path_index -= 1
2444
 
                        # dont descend the disk iterator into any tree 
2445
 
                        # paths.
2446
 
                        if current_path_info[2] == 'tree-reference':
2447
 
                            del current_dir_info[1][path_index]
2448
 
                            path_index -= 1
2449
 
                        path_index += 1
2450
 
                        if path_index < len(current_dir_info[1]):
2451
 
                            current_path_info = current_dir_info[1][path_index]
2452
 
                            if current_path_info[2] == 'directory':
2453
 
                                if self.target._directory_is_tree_reference(
2454
 
                                    current_path_info[0].decode('utf8')):
2455
 
                                    current_path_info = current_path_info[:2] + \
2456
 
                                        ('tree-reference',) + current_path_info[3:]
2457
 
                        else:
2458
 
                            current_path_info = None
2459
 
                        path_handled = False
2460
 
                    else:
2461
 
                        advance_path = True # reset the advance flagg.
2462
 
                if current_block is not None:
2463
 
                    block_index += 1
2464
 
                    if (block_index < len(state._dirblocks) and
2465
 
                        osutils.is_inside(current_root, state._dirblocks[block_index][0])):
2466
 
                        current_block = state._dirblocks[block_index]
2467
 
                    else:
2468
 
                        current_block = None
2469
 
                if current_dir_info is not None:
2470
 
                    try:
2471
 
                        current_dir_info = dir_iterator.next()
2472
 
                    except StopIteration:
2473
 
                        current_dir_info = None
2474
 
 
 
2086
        iter_changes = self.target._iter_changes(include_unchanged,
 
2087
            use_filesystem_for_exec, search_specific_files, state,
 
2088
            source_index, target_index, want_unversioned, self.target)
 
2089
        return iter_changes.iter_changes()
2475
2090
 
2476
2091
    @staticmethod
2477
2092
    def is_compatible(source, target):
2478
2093
        # the target must be a dirstate working tree
2479
 
        if not isinstance(target, WorkingTree4):
 
2094
        if not isinstance(target, DirStateWorkingTree):
2480
2095
            return False
2481
 
        # the source must be a revtreee or dirstate rev tree.
 
2096
        # the source must be a revtree or dirstate rev tree.
2482
2097
        if not isinstance(source,
2483
2098
            (revisiontree.RevisionTree, DirStateRevisionTree)):
2484
2099
            return False
2485
2100
        # the source revid must be in the target dirstate
2486
 
        if not (source._revision_id == NULL_REVISION or
 
2101
        if not (source._revision_id == _mod_revision.NULL_REVISION or
2487
2102
            source._revision_id in target.get_parent_ids()):
2488
 
            # TODO: what about ghosts? it may well need to 
 
2103
            # TODO: what about ghosts? it may well need to
2489
2104
            # check for them explicitly.
2490
2105
            return False
2491
2106
        return True
2501
2116
 
2502
2117
    def convert(self, tree):
2503
2118
        # lock the control files not the tree, so that we dont get tree
2504
 
        # on-unlock behaviours, and so that noone else diddles with the 
 
2119
        # on-unlock behaviours, and so that noone else diddles with the
2505
2120
        # tree during upgrade.
2506
2121
        tree._control_files.lock_write()
2507
2122
        try:
2533
2148
 
2534
2149
    def update_format(self, tree):
2535
2150
        """Change the format marker."""
2536
 
        tree._control_files.put_utf8('format',
2537
 
            self.target_format.get_format_string())
 
2151
        tree._transport.put_bytes('format',
 
2152
            self.target_format.get_format_string(),
 
2153
            mode=tree.bzrdir._get_file_mode())
 
2154
 
 
2155
 
 
2156
class Converter4to5(object):
 
2157
    """Perform an in-place upgrade of format 4 to format 5 trees."""
 
2158
 
 
2159
    def __init__(self):
 
2160
        self.target_format = WorkingTreeFormat5()
 
2161
 
 
2162
    def convert(self, tree):
 
2163
        # lock the control files not the tree, so that we don't get tree
 
2164
        # on-unlock behaviours, and so that no-one else diddles with the
 
2165
        # tree during upgrade.
 
2166
        tree._control_files.lock_write()
 
2167
        try:
 
2168
            self.update_format(tree)
 
2169
        finally:
 
2170
            tree._control_files.unlock()
 
2171
 
 
2172
    def update_format(self, tree):
 
2173
        """Change the format marker."""
 
2174
        tree._transport.put_bytes('format',
 
2175
            self.target_format.get_format_string(),
 
2176
            mode=tree.bzrdir._get_file_mode())
 
2177
 
 
2178
 
 
2179
class Converter4or5to6(object):
 
2180
    """Perform an in-place upgrade of format 4 or 5 to format 6 trees."""
 
2181
 
 
2182
    def __init__(self):
 
2183
        self.target_format = WorkingTreeFormat6()
 
2184
 
 
2185
    def convert(self, tree):
 
2186
        # lock the control files not the tree, so that we don't get tree
 
2187
        # on-unlock behaviours, and so that no-one else diddles with the
 
2188
        # tree during upgrade.
 
2189
        tree._control_files.lock_write()
 
2190
        try:
 
2191
            self.init_custom_control_files(tree)
 
2192
            self.update_format(tree)
 
2193
        finally:
 
2194
            tree._control_files.unlock()
 
2195
 
 
2196
    def init_custom_control_files(self, tree):
 
2197
        """Initialize custom control files."""
 
2198
        tree._transport.put_bytes('views', '',
 
2199
            mode=tree.bzrdir._get_file_mode())
 
2200
 
 
2201
    def update_format(self, tree):
 
2202
        """Change the format marker."""
 
2203
        tree._transport.put_bytes('format',
 
2204
            self.target_format.get_format_string(),
 
2205
            mode=tree.bzrdir._get_file_mode())