~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/workingtree_4.py

  • Committer: Vincent Ladeuil
  • Date: 2009-06-22 12:52:39 UTC
  • mto: (4471.1.1 integration)
  • mto: This revision was merged to the branch mainline in revision 4472.
  • Revision ID: v.ladeuil+lp@free.fr-20090622125239-kabo9smxt9c3vnir
Use a consistent scheme for naming pyrex source files.

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
 
58
58
    trace,
59
59
    transform,
60
60
    urlutils,
 
61
    views,
61
62
    xml5,
62
63
    xml6,
63
64
    )
68
69
 
69
70
from bzrlib import symbol_versioning
70
71
from bzrlib.decorators import needs_read_lock, needs_write_lock
 
72
from bzrlib.filters import filtered_input_file, internal_size_sha_file_byname
71
73
from bzrlib.inventory import InventoryEntry, Inventory, ROOT_ID, entry_factory
72
 
from bzrlib.lockable_files import LockableFiles, TransportLock
73
 
from bzrlib.lockdir import LockDir
74
74
import bzrlib.mutabletree
75
75
from bzrlib.mutabletree import needs_tree_write_lock
76
76
from bzrlib.osutils import (
98
98
from bzrlib.workingtree import WorkingTree, WorkingTree3, WorkingTreeFormat3
99
99
 
100
100
 
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
 
 
 
101
class DirStateWorkingTree(WorkingTree3):
120
102
    def __init__(self, basedir,
121
103
                 branch,
122
104
                 _control_files=None,
138
120
        # if branch is at our basedir and is a format 6 or less
139
121
        # assume all other formats have their own control files.
140
122
        self._control_files = _control_files
 
123
        self._transport = self._control_files._transport
141
124
        self._dirty = None
142
125
        #-------------
143
126
        # during a read or write lock these objects are set, and are
147
130
        #-------------
148
131
        self._setup_directory_is_tree_reference()
149
132
        self._detect_case_handling()
 
133
        self._rules_searcher = None
 
134
        self.views = self._make_views()
 
135
        #--- allow tests to select the dirstate iter_changes implementation
 
136
        self._iter_changes = dirstate._process_entry
150
137
 
151
138
    @needs_tree_write_lock
152
139
    def _add(self, files, ids, kinds):
180
167
    @needs_tree_write_lock
181
168
    def add_reference(self, sub_tree):
182
169
        # use standard implementation, which calls back to self._add
183
 
        # 
 
170
        #
184
171
        # So we don't store the reference_revision in the working dirstate,
185
 
        # it's just recorded at the moment of commit. 
 
172
        # it's just recorded at the moment of commit.
186
173
        self._add_reference(sub_tree)
187
174
 
188
175
    def break_lock(self):
227
214
            WorkingTree3._comparison_data(self, entry, path)
228
215
        # it looks like a plain directory, but it's really a reference -- see
229
216
        # also kind()
230
 
        if (self._repo_supports_tree_reference and
231
 
            kind == 'directory' and
232
 
            self._directory_is_tree_reference(path)):
 
217
        if (self._repo_supports_tree_reference and kind == 'directory'
 
218
            and entry is not None and entry.kind == 'tree-reference'):
233
219
            kind = 'tree-reference'
234
220
        return kind, executable, stat_value
235
221
 
261
247
            return self._dirstate
262
248
        local_path = self.bzrdir.get_workingtree_transport(None
263
249
            ).local_abspath('dirstate')
264
 
        self._dirstate = dirstate.DirState.on_file(local_path)
 
250
        self._dirstate = dirstate.DirState.on_file(local_path,
 
251
            self._sha1_provider())
265
252
        return self._dirstate
266
253
 
 
254
    def _sha1_provider(self):
 
255
        """A function that returns a SHA1Provider suitable for this tree.
 
256
 
 
257
        :return: None if content filtering is not supported by this tree.
 
258
          Otherwise, a SHA1Provider is returned that sha's the canonical
 
259
          form of files, i.e. after read filters are applied.
 
260
        """
 
261
        if self.supports_content_filtering():
 
262
            return ContentFilterAwareSHA1Provider(self)
 
263
        else:
 
264
            return None
 
265
 
267
266
    def filter_unversioned_files(self, paths):
268
267
        """Filter out paths that are versioned.
269
268
 
301
300
 
302
301
    def _generate_inventory(self):
303
302
        """Create and set self.inventory from the dirstate object.
304
 
        
 
303
 
305
304
        This is relatively expensive: we have to walk the entire dirstate.
306
305
        Ideally we would not, and can deprecate this function.
307
306
        """
352
351
                    parent_ies[(dirname + '/' + name).strip('/')] = inv_entry
353
352
                elif kind == 'tree-reference':
354
353
                    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))
 
354
                        raise errors.UnsupportedOperation(
 
355
                            self._generate_inventory,
 
356
                            self.branch.repository)
360
357
                    inv_entry.reference_revision = link_or_sha1 or None
361
358
                elif kind != 'symlink':
362
359
                    raise AssertionError("unknown kind %r" % kind)
377
374
        If either file_id or path is supplied, it is used as the key to lookup.
378
375
        If both are supplied, the fastest lookup is used, and an error is
379
376
        raised if they do not both point at the same row.
380
 
        
 
377
 
381
378
        :param file_id: An optional unicode file_id to be looked up.
382
379
        :param path: An optional unicode path to be looked up.
383
380
        :return: The dirstate row tuple for path/file_id, or (None, None)
407
404
                    return None
408
405
                else:
409
406
                    raise
410
 
        link_or_sha1 = state.update_entry(entry, file_abspath,
411
 
                                          stat_value=stat_value)
 
407
        link_or_sha1 = dirstate.update_entry(state, entry, file_abspath,
 
408
            stat_value=stat_value)
412
409
        if entry[1][0][0] == 'f':
413
 
            return link_or_sha1
 
410
            if link_or_sha1 is None:
 
411
                file_obj, statvalue = self.get_file_with_stat(file_id, path)
 
412
                try:
 
413
                    sha1 = osutils.sha_file(file_obj)
 
414
                finally:
 
415
                    file_obj.close()
 
416
                self._observed_sha1(file_id, path, (sha1, statvalue))
 
417
                return sha1
 
418
            else:
 
419
                return link_or_sha1
414
420
        return None
415
421
 
416
422
    def _get_inventory(self):
430
436
    @needs_read_lock
431
437
    def get_parent_ids(self):
432
438
        """See Tree.get_parent_ids.
433
 
        
 
439
 
434
440
        This implementation requests the ids list from the dirstate file.
435
441
        """
436
442
        return self.current_dirstate().get_parent_ids()
527
533
        return iter(result)
528
534
 
529
535
    def iter_references(self):
 
536
        if not self._repo_supports_tree_reference:
 
537
            # When the repo doesn't support references, we will have nothing to
 
538
            # return
 
539
            return
530
540
        for key, tree_details in self.current_dirstate()._iter_entries():
531
541
            if tree_details[0][0] in ('a', 'r'): # absent, relocated
532
542
                # not relevant to the working tree
534
544
            if not key[1]:
535
545
                # the root is not a reference.
536
546
                continue
537
 
            path = pathjoin(self.basedir, key[0].decode('utf8'), key[1].decode('utf8'))
 
547
            relpath = pathjoin(key[0].decode('utf8'), key[1].decode('utf8'))
538
548
            try:
539
 
                if self._kind(path) == 'tree-reference':
540
 
                    yield path, key[2]
 
549
                if self._kind(relpath) == 'tree-reference':
 
550
                    yield relpath, key[2]
541
551
            except errors.NoSuchFile:
542
552
                # path is missing on disk.
543
553
                continue
544
554
 
 
555
    def _observed_sha1(self, file_id, path, (sha1, statvalue)):
 
556
        """See MutableTree._observed_sha1."""
 
557
        state = self.current_dirstate()
 
558
        entry = self._get_entry(file_id=file_id, path=path)
 
559
        state._observed_sha1(entry, sha1, statvalue)
 
560
 
545
561
    def kind(self, file_id):
546
562
        """Return the kind of a file.
547
563
 
559
575
    def _kind(self, relpath):
560
576
        abspath = self.abspath(relpath)
561
577
        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'
 
578
        if (self._repo_supports_tree_reference and kind == 'directory'):
 
579
            entry = self._get_entry(path=relpath)
 
580
            if entry[1] is not None:
 
581
                if entry[1][0][0] == 't':
 
582
                    kind = 'tree-reference'
566
583
        return kind
567
584
 
568
585
    @needs_read_lock
880
897
        for tree in trees:
881
898
            if not (isinstance(tree, DirStateRevisionTree) and tree._revision_id in
882
899
                parents):
883
 
                return super(WorkingTree4, self).paths2ids(paths, trees, require_versioned)
 
900
                return super(DirStateWorkingTree, self).paths2ids(paths,
 
901
                    trees, require_versioned)
884
902
        search_indexes = [0] + [1 + parents.index(tree._revision_id) for tree in trees]
885
903
        # -- make all paths utf8 --
886
904
        paths_utf8 = set()
947
965
                raise errors.PathsNotVersionedError(paths)
948
966
        # -- remove redundancy in supplied paths to prevent over-scanning --
949
967
        search_paths = osutils.minimum_path_selection(paths)
950
 
        # sketch: 
 
968
        # sketch:
951
969
        # for all search_indexs in each path at or under each element of
952
970
        # search_paths, if the detail is relocated: add the id, and add the
953
971
        # relocated path as one to search if its not searched already. If the
1009
1027
 
1010
1028
    def read_working_inventory(self):
1011
1029
        """Read the working inventory.
1012
 
        
 
1030
 
1013
1031
        This is a meaningless operation for dirstate, but we obey it anyhow.
1014
1032
        """
1015
1033
        return self.inventory
1046
1064
    @needs_tree_write_lock
1047
1065
    def set_parent_ids(self, revision_ids, allow_leftmost_as_ghost=False):
1048
1066
        """Set the parent ids to revision_ids.
1049
 
        
 
1067
 
1050
1068
        See also set_parent_trees. This api will try to retrieve the tree data
1051
1069
        for each element of revision_ids from the trees repository. If you have
1052
1070
        tree data already available, it is more efficient to use
1084
1102
                raise errors.GhostRevisionUnusableHere(parents_list[0][0])
1085
1103
        real_trees = []
1086
1104
        ghosts = []
 
1105
 
 
1106
        parent_ids = [rev_id for rev_id, tree in parents_list]
 
1107
        graph = self.branch.repository.get_graph()
 
1108
        heads = graph.heads(parent_ids)
 
1109
        accepted_revisions = set()
 
1110
 
1087
1111
        # convert absent trees to the null tree, which we convert back to
1088
1112
        # missing on access.
1089
1113
        for rev_id, tree in parents_list:
 
1114
            if len(accepted_revisions) > 0:
 
1115
                # we always accept the first tree
 
1116
                if rev_id in accepted_revisions or rev_id not in heads:
 
1117
                    # We have already included either this tree, or its
 
1118
                    # descendent, so we skip it.
 
1119
                    continue
1090
1120
            _mod_revision.check_not_reserved_id(rev_id)
1091
1121
            if tree is not None:
1092
1122
                real_trees.append((rev_id, tree))
1093
1123
            else:
1094
1124
                real_trees.append((rev_id,
1095
 
                    self.branch.repository.revision_tree(None)))
 
1125
                    self.branch.repository.revision_tree(
 
1126
                        _mod_revision.NULL_REVISION)))
1096
1127
                ghosts.append(rev_id)
 
1128
            accepted_revisions.add(rev_id)
1097
1129
        dirstate.set_parent_trees(real_trees, ghosts=ghosts)
1098
1130
        self._make_dirty(reset_inventory=False)
1099
1131
 
1263
1295
        self.flush()
1264
1296
 
1265
1297
 
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
 
 
 
1298
class ContentFilterAwareSHA1Provider(dirstate.SHA1Provider):
 
1299
 
 
1300
    def __init__(self, tree):
 
1301
        self.tree = tree
 
1302
 
 
1303
    def sha1(self, abspath):
 
1304
        """See dirstate.SHA1Provider.sha1()."""
 
1305
        filters = self.tree._content_filter_stack(
 
1306
            self.tree.relpath(osutils.safe_unicode(abspath)))
 
1307
        return internal_size_sha_file_byname(abspath, filters)[1]
 
1308
 
 
1309
    def stat_and_sha1(self, abspath):
 
1310
        """See dirstate.SHA1Provider.stat_and_sha1()."""
 
1311
        filters = self.tree._content_filter_stack(
 
1312
            self.tree.relpath(osutils.safe_unicode(abspath)))
 
1313
        file_obj = file(abspath, 'rb', 65000)
 
1314
        try:
 
1315
            statvalue = os.fstat(file_obj.fileno())
 
1316
            if filters:
 
1317
                file_obj = filtered_input_file(file_obj, filters)
 
1318
            sha1 = osutils.size_sha_file(file_obj)[1]
 
1319
        finally:
 
1320
            file_obj.close()
 
1321
        return statvalue, sha1
 
1322
 
 
1323
 
 
1324
class WorkingTree4(DirStateWorkingTree):
 
1325
    """This is the Format 4 working tree.
 
1326
 
 
1327
    This differs from WorkingTree3 by:
 
1328
     - Having a consolidated internal dirstate, stored in a
 
1329
       randomly-accessible sorted file on disk.
 
1330
     - Not having a regular inventory attribute.  One can be synthesized
 
1331
       on demand but this is expensive and should be avoided.
 
1332
 
 
1333
    This is new in bzr 0.15.
 
1334
    """
 
1335
 
 
1336
 
 
1337
class WorkingTree5(DirStateWorkingTree):
 
1338
    """This is the Format 5 working tree.
 
1339
 
 
1340
    This differs from WorkingTree4 by:
 
1341
     - Supporting content filtering.
 
1342
 
 
1343
    This is new in bzr 1.11.
 
1344
    """
 
1345
 
 
1346
 
 
1347
class WorkingTree6(DirStateWorkingTree):
 
1348
    """This is the Format 6 working tree.
 
1349
 
 
1350
    This differs from WorkingTree5 by:
 
1351
     - Supporting a current view that may mask the set of files in a tree
 
1352
       impacted by most user operations.
 
1353
 
 
1354
    This is new in bzr 1.14.
 
1355
    """
 
1356
 
 
1357
    def _make_views(self):
 
1358
        return views.PathBasedViews(self)
 
1359
 
 
1360
 
 
1361
class DirStateWorkingTreeFormat(WorkingTreeFormat3):
1288
1362
    def initialize(self, a_bzrdir, revision_id=None, from_branch=None,
1289
1363
                   accelerator_tree=None, hardlink=False):
1290
1364
        """See WorkingTreeFormat.initialize().
1307
1381
        control_files = self._open_control_files(a_bzrdir)
1308
1382
        control_files.create_lock()
1309
1383
        control_files.lock_write()
1310
 
        control_files.put_utf8('format', self.get_format_string())
 
1384
        transport.put_bytes('format', self.get_format_string(),
 
1385
            mode=a_bzrdir._get_file_mode())
1311
1386
        if from_branch is not None:
1312
1387
            branch = from_branch
1313
1388
        else:
1319
1394
        state = dirstate.DirState.initialize(local_path)
1320
1395
        state.unlock()
1321
1396
        del state
1322
 
        wt = WorkingTree4(a_bzrdir.root_transport.local_abspath('.'),
 
1397
        wt = self._tree_class(a_bzrdir.root_transport.local_abspath('.'),
1323
1398
                         branch,
1324
1399
                         _format=self,
1325
1400
                         _bzrdir=a_bzrdir,
1327
1402
        wt._new_tree()
1328
1403
        wt.lock_tree_write()
1329
1404
        try:
 
1405
            self._init_custom_control_files(wt)
1330
1406
            if revision_id in (None, NULL_REVISION):
1331
1407
                if branch.repository.supports_rich_root():
1332
1408
                    wt._set_root_id(generate_ids.gen_root_id())
1358
1434
                if basis_root_id is not None:
1359
1435
                    wt._set_root_id(basis_root_id)
1360
1436
                    wt.flush()
 
1437
                # If content filtering is supported, do not use the accelerator
 
1438
                # tree - the cost of transforming the content both ways and
 
1439
                # checking for changed content can outweight the gains it gives.
 
1440
                # Note: do NOT move this logic up higher - using the basis from
 
1441
                # the accelerator tree is still desirable because that can save
 
1442
                # a minute or more of processing on large trees!
 
1443
                # The original tree may not have the same content filters
 
1444
                # applied so we can't safely build the inventory delta from
 
1445
                # the source tree.
 
1446
                if wt.supports_content_filtering():
 
1447
                    accelerator_tree = None
 
1448
                    delta_from_tree = False
 
1449
                else:
 
1450
                    delta_from_tree = True
 
1451
                # delta_from_tree is safe even for DirStateRevisionTrees,
 
1452
                # because wt4.apply_inventory_delta does not mutate the input
 
1453
                # inventory entries.
1361
1454
                transform.build_tree(basis, wt, accelerator_tree,
1362
 
                                     hardlink=hardlink)
 
1455
                                     hardlink=hardlink,
 
1456
                                     delta_from_tree=delta_from_tree)
1363
1457
            finally:
1364
1458
                basis.unlock()
1365
1459
        finally:
1367
1461
            wt.unlock()
1368
1462
        return wt
1369
1463
 
 
1464
    def _init_custom_control_files(self, wt):
 
1465
        """Subclasses with custom control files should override this method.
 
1466
 
 
1467
        The working tree and control files are locked for writing when this
 
1468
        method is called.
 
1469
 
 
1470
        :param wt: the WorkingTree object
 
1471
        """
 
1472
 
1370
1473
    def _open(self, a_bzrdir, control_files):
1371
1474
        """Open the tree itself.
1372
1475
 
1373
1476
        :param a_bzrdir: the dir for the tree.
1374
1477
        :param control_files: the control files for the tree.
1375
1478
        """
1376
 
        return WorkingTree4(a_bzrdir.root_transport.local_abspath('.'),
 
1479
        return self._tree_class(a_bzrdir.root_transport.local_abspath('.'),
1377
1480
                           branch=a_bzrdir.open_branch(),
1378
1481
                           _format=self,
1379
1482
                           _bzrdir=a_bzrdir,
1380
1483
                           _control_files=control_files)
1381
1484
 
1382
1485
    def __get_matchingbzrdir(self):
 
1486
        return self._get_matchingbzrdir()
 
1487
 
 
1488
    def _get_matchingbzrdir(self):
 
1489
        """Overrideable method to get a bzrdir for testing."""
1383
1490
        # please test against something that will let us do tree references
1384
1491
        return bzrdir.format_registry.make_bzrdir(
1385
1492
            'dirstate-with-subtree')
1387
1494
    _matchingbzrdir = property(__get_matchingbzrdir)
1388
1495
 
1389
1496
 
 
1497
class WorkingTreeFormat4(DirStateWorkingTreeFormat):
 
1498
    """The first consolidated dirstate working tree format.
 
1499
 
 
1500
    This format:
 
1501
        - exists within a metadir controlling .bzr
 
1502
        - includes an explicit version marker for the workingtree control
 
1503
          files, separate from the BzrDir format
 
1504
        - modifies the hash cache format
 
1505
        - is new in bzr 0.15
 
1506
        - uses a LockDir to guard access to it.
 
1507
    """
 
1508
 
 
1509
    upgrade_recommended = False
 
1510
 
 
1511
    _tree_class = WorkingTree4
 
1512
 
 
1513
    def get_format_string(self):
 
1514
        """See WorkingTreeFormat.get_format_string()."""
 
1515
        return "Bazaar Working Tree Format 4 (bzr 0.15)\n"
 
1516
 
 
1517
    def get_format_description(self):
 
1518
        """See WorkingTreeFormat.get_format_description()."""
 
1519
        return "Working tree format 4"
 
1520
 
 
1521
 
 
1522
class WorkingTreeFormat5(DirStateWorkingTreeFormat):
 
1523
    """WorkingTree format supporting content filtering.
 
1524
    """
 
1525
 
 
1526
    upgrade_recommended = False
 
1527
 
 
1528
    _tree_class = WorkingTree5
 
1529
 
 
1530
    def get_format_string(self):
 
1531
        """See WorkingTreeFormat.get_format_string()."""
 
1532
        return "Bazaar Working Tree Format 5 (bzr 1.11)\n"
 
1533
 
 
1534
    def get_format_description(self):
 
1535
        """See WorkingTreeFormat.get_format_description()."""
 
1536
        return "Working tree format 5"
 
1537
 
 
1538
    def supports_content_filtering(self):
 
1539
        return True
 
1540
 
 
1541
 
 
1542
class WorkingTreeFormat6(DirStateWorkingTreeFormat):
 
1543
    """WorkingTree format supporting views.
 
1544
    """
 
1545
 
 
1546
    upgrade_recommended = False
 
1547
 
 
1548
    _tree_class = WorkingTree6
 
1549
 
 
1550
    def get_format_string(self):
 
1551
        """See WorkingTreeFormat.get_format_string()."""
 
1552
        return "Bazaar Working Tree Format 6 (bzr 1.14)\n"
 
1553
 
 
1554
    def get_format_description(self):
 
1555
        """See WorkingTreeFormat.get_format_description()."""
 
1556
        return "Working tree format 6"
 
1557
 
 
1558
    def _init_custom_control_files(self, wt):
 
1559
        """Subclasses with custom control files should override this method."""
 
1560
        wt._transport.put_bytes('views', '', mode=wt.bzrdir._get_file_mode())
 
1561
 
 
1562
    def supports_content_filtering(self):
 
1563
        return True
 
1564
 
 
1565
    def supports_views(self):
 
1566
        return True
 
1567
 
 
1568
 
1390
1569
class DirStateRevisionTree(Tree):
1391
1570
    """A revision tree pulling the inventory from a dirstate."""
1392
1571
 
1397
1576
        self._inventory = None
1398
1577
        self._locked = 0
1399
1578
        self._dirstate_locked = False
 
1579
        self._repo_supports_tree_reference = getattr(
 
1580
            repository._format, "supports_tree_reference",
 
1581
            False)
1400
1582
 
1401
1583
    def __repr__(self):
1402
1584
        return "<%s of %s in %s>" % \
1405
1587
    def annotate_iter(self, file_id,
1406
1588
                      default_revision=_mod_revision.CURRENT_REVISION):
1407
1589
        """See Tree.annotate_iter"""
1408
 
        w = self._get_weave(file_id)
1409
 
        return w.annotate(self.inventory[file_id].revision)
 
1590
        text_key = (file_id, self.inventory[file_id].revision)
 
1591
        annotations = self._repository.texts.annotate(text_key)
 
1592
        return [(key[-1], line) for (key, line) in annotations]
1410
1593
 
1411
1594
    def _get_ancestors(self, default_revision):
1412
1595
        return set(self._repository.get_ancestry(self._revision_id,
1441
1624
        path_utf8 = osutils.pathjoin(entry[0][0], entry[0][1])
1442
1625
        return path_utf8.decode('utf8')
1443
1626
 
 
1627
    def iter_references(self):
 
1628
        if not self._repo_supports_tree_reference:
 
1629
            # When the repo doesn't support references, we will have nothing to
 
1630
            # return
 
1631
            return iter([])
 
1632
        # Otherwise, fall back to the default implementation
 
1633
        return super(DirStateRevisionTree, self).iter_references()
 
1634
 
1444
1635
    def _get_parent_index(self):
1445
1636
        """Return the index in the dirstate referenced by this tree."""
1446
1637
        return self._dirstate.get_parent_ids().index(self._revision_id) + 1
1451
1642
        If either file_id or path is supplied, it is used as the key to lookup.
1452
1643
        If both are supplied, the fastest lookup is used, and an error is
1453
1644
        raised if they do not both point at the same row.
1454
 
        
 
1645
 
1455
1646
        :param file_id: An optional unicode file_id to be looked up.
1456
1647
        :param path: An optional unicode path to be looked up.
1457
1648
        :return: The dirstate row tuple for path/file_id, or (None, None)
1564
1755
            return parent_details[1]
1565
1756
        return None
1566
1757
 
1567
 
    def _get_weave(self, file_id):
1568
 
        return self._repository.weave_store.get_weave(file_id,
1569
 
                self._repository.get_transaction())
1570
 
 
1571
1758
    def get_file(self, file_id, path=None):
1572
1759
        return StringIO(self.get_file_text(file_id))
1573
1760
 
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
1761
    def get_file_size(self, file_id):
1581
1762
        """See Tree.get_file_size"""
1582
1763
        return self.inventory[file_id].text_size
1583
1764
 
1584
 
    def get_file_text(self, file_id):
1585
 
        return ''.join(self.get_file_lines(file_id))
 
1765
    def get_file_text(self, file_id, path=None):
 
1766
        _, content = list(self.iter_files_bytes([(file_id, None)]))[0]
 
1767
        return ''.join(content)
1586
1768
 
1587
1769
    def get_reference_revision(self, file_id, path=None):
1588
1770
        return self.inventory[file_id].reference_revision
1607
1789
        if entry[1][parent_index][0] != 'l':
1608
1790
            return None
1609
1791
        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]
 
1792
            target = entry[1][parent_index][1]
 
1793
            target = target.decode('utf8')
 
1794
            return target
1614
1795
 
1615
1796
    def get_revision_id(self):
1616
1797
        """Return the revision id for this tree."""
1663
1844
            return None
1664
1845
        return ie.executable
1665
1846
 
1666
 
    def list_files(self, include_root=False):
 
1847
    def list_files(self, include_root=False, from_dir=None, recursive=True):
1667
1848
        # We use a standard implementation, because DirStateRevisionTree is
1668
1849
        # dealing with one of the parents of the current state
1669
1850
        inv = self._get_inventory()
1670
 
        entries = inv.iter_entries()
1671
 
        if self.inventory.root is not None and not include_root:
 
1851
        if from_dir is None:
 
1852
            from_dir_id = None
 
1853
        else:
 
1854
            from_dir_id = inv.path2id(from_dir)
 
1855
            if from_dir_id is None:
 
1856
                # Directory not versioned
 
1857
                return
 
1858
        entries = inv.iter_entries(from_dir=from_dir_id, recursive=recursive)
 
1859
        if inv.root is not None and not include_root and from_dir is None:
1672
1860
            entries.next()
1673
1861
        for path, entry in entries:
1674
1862
            yield path, 'V', entry.kind, entry.file_id, entry
1707
1895
                self._dirstate_locked = False
1708
1896
            self._repository.unlock()
1709
1897
 
 
1898
    @needs_read_lock
 
1899
    def supports_tree_reference(self):
 
1900
        return self._repo_supports_tree_reference
 
1901
 
1710
1902
    def walkdirs(self, prefix=""):
1711
1903
        # TODO: jam 20070215 This is the lazy way by using the RevisionTree
1712
 
        # implementation based on an inventory.  
 
1904
        # implementation based on an inventory.
1713
1905
        # This should be cleaned up to use the much faster Dirstate code
1714
1906
        # So for now, we just build up the parent inventory, and extract
1715
1907
        # it the same way RevisionTree does.
1744
1936
 
1745
1937
class InterDirStateTree(InterTree):
1746
1938
    """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 
 
1939
 
 
1940
    This is used only when both trees are in the dirstate working file, and
 
1941
    the source is any parent within the dirstate, and the destination is
1750
1942
    the current working tree of the same dirstate.
1751
1943
    """
1752
1944
    # this could be generalized to allow comparisons between any trees in the
1765
1957
        target.set_parent_ids([revid])
1766
1958
        return target.basis_tree(), target
1767
1959
 
 
1960
    @classmethod
 
1961
    def make_source_parent_tree_python_dirstate(klass, test_case, source, target):
 
1962
        result = klass.make_source_parent_tree(source, target)
 
1963
        result[1]._iter_changes = dirstate.ProcessEntryPython
 
1964
        return result
 
1965
 
 
1966
    @classmethod
 
1967
    def make_source_parent_tree_compiled_dirstate(klass, test_case, source, target):
 
1968
        from bzrlib.tests.test__dirstate_helpers import \
 
1969
            CompiledDirstateHelpersFeature
 
1970
        if not CompiledDirstateHelpersFeature.available():
 
1971
            from bzrlib.tests import UnavailableFeature
 
1972
            raise UnavailableFeature(CompiledDirstateHelpersFeature)
 
1973
        from bzrlib._dirstate_helpers_pyx import ProcessEntryC
 
1974
        result = klass.make_source_parent_tree(source, target)
 
1975
        result[1]._iter_changes = ProcessEntryC
 
1976
        return result
 
1977
 
1768
1978
    _matching_from_tree_format = WorkingTreeFormat4()
1769
1979
    _matching_to_tree_format = WorkingTreeFormat4()
1770
 
    _test_mutable_trees_to_test_trees = make_source_parent_tree
 
1980
 
 
1981
    @classmethod
 
1982
    def _test_mutable_trees_to_test_trees(klass, test_case, source, target):
 
1983
        # This method shouldn't be called, because we have python and C
 
1984
        # specific flavours.
 
1985
        raise NotImplementedError
1771
1986
 
1772
1987
    def iter_changes(self, include_unchanged=False,
1773
1988
                      specific_files=None, pb=None, extra_trees=[],
1791
2006
            output. An unversioned file is defined as one with (False, False)
1792
2007
            for the versioned pair.
1793
2008
        """
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
2009
        # NB: show_status depends on being able to pass in non-versioned files
1798
2010
        # and report them as unknown
1799
2011
        # TODO: handle extra trees in the dirstate.
1800
2012
        if (extra_trees or specific_files == []):
1801
2013
            # we can't fast-path these cases (yet)
1802
 
            for f in super(InterDirStateTree, self).iter_changes(
 
2014
            return super(InterDirStateTree, self).iter_changes(
1803
2015
                include_unchanged, specific_files, pb, extra_trees,
1804
 
                require_versioned, want_unversioned=want_unversioned):
1805
 
                yield f
1806
 
            return
 
2016
                require_versioned, want_unversioned=want_unversioned)
1807
2017
        parent_ids = self.target.get_parent_ids()
1808
2018
        if not (self.source._revision_id in parent_ids
1809
2019
                or self.source._revision_id == NULL_REVISION):
1826
2036
        if specific_files:
1827
2037
            specific_files_utf8 = set()
1828
2038
            for path in specific_files:
 
2039
                # Note, if there are many specific files, using cache_utf8
 
2040
                # would be good here.
1829
2041
                specific_files_utf8.add(path.encode('utf8'))
1830
2042
            specific_files = specific_files_utf8
1831
2043
        else:
1832
2044
            specific_files = set([''])
1833
2045
        # -- specific_files is now a utf8 path set --
 
2046
 
1834
2047
        # -- get the state object and prepare it.
1835
2048
        state = self.target.current_dirstate()
1836
2049
        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
2050
        if require_versioned:
1856
2051
            # -- check all supplied paths are versioned in a search tree. --
1857
2052
            all_versioned = True
1858
2053
            for path in specific_files:
1859
 
                path_entries = _entries_for_path(path)
 
2054
                path_entries = state._entries_for_path(path)
1860
2055
                if not path_entries:
1861
2056
                    # this specified path is not present at all: error
1862
2057
                    all_versioned = False
1878
2073
            if not all_versioned:
1879
2074
                raise errors.PathsNotVersionedError(specific_files)
1880
2075
        # -- 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]
 
2076
        search_specific_files = osutils.minimum_path_selection(specific_files)
1932
2077
 
1933
2078
        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
 
 
 
2079
        iter_changes = self.target._iter_changes(include_unchanged,
 
2080
            use_filesystem_for_exec, search_specific_files, state,
 
2081
            source_index, target_index, want_unversioned, self.target)
 
2082
        return iter_changes.iter_changes()
2475
2083
 
2476
2084
    @staticmethod
2477
2085
    def is_compatible(source, target):
2478
2086
        # the target must be a dirstate working tree
2479
 
        if not isinstance(target, WorkingTree4):
 
2087
        if not isinstance(target, DirStateWorkingTree):
2480
2088
            return False
2481
 
        # the source must be a revtreee or dirstate rev tree.
 
2089
        # the source must be a revtree or dirstate rev tree.
2482
2090
        if not isinstance(source,
2483
2091
            (revisiontree.RevisionTree, DirStateRevisionTree)):
2484
2092
            return False
2485
2093
        # the source revid must be in the target dirstate
2486
2094
        if not (source._revision_id == NULL_REVISION or
2487
2095
            source._revision_id in target.get_parent_ids()):
2488
 
            # TODO: what about ghosts? it may well need to 
 
2096
            # TODO: what about ghosts? it may well need to
2489
2097
            # check for them explicitly.
2490
2098
            return False
2491
2099
        return True
2501
2109
 
2502
2110
    def convert(self, tree):
2503
2111
        # 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 
 
2112
        # on-unlock behaviours, and so that noone else diddles with the
2505
2113
        # tree during upgrade.
2506
2114
        tree._control_files.lock_write()
2507
2115
        try:
2533
2141
 
2534
2142
    def update_format(self, tree):
2535
2143
        """Change the format marker."""
2536
 
        tree._control_files.put_utf8('format',
2537
 
            self.target_format.get_format_string())
 
2144
        tree._transport.put_bytes('format',
 
2145
            self.target_format.get_format_string(),
 
2146
            mode=tree.bzrdir._get_file_mode())
 
2147
 
 
2148
 
 
2149
class Converter4to5(object):
 
2150
    """Perform an in-place upgrade of format 4 to format 5 trees."""
 
2151
 
 
2152
    def __init__(self):
 
2153
        self.target_format = WorkingTreeFormat5()
 
2154
 
 
2155
    def convert(self, tree):
 
2156
        # lock the control files not the tree, so that we don't get tree
 
2157
        # on-unlock behaviours, and so that no-one else diddles with the
 
2158
        # tree during upgrade.
 
2159
        tree._control_files.lock_write()
 
2160
        try:
 
2161
            self.update_format(tree)
 
2162
        finally:
 
2163
            tree._control_files.unlock()
 
2164
 
 
2165
    def update_format(self, tree):
 
2166
        """Change the format marker."""
 
2167
        tree._transport.put_bytes('format',
 
2168
            self.target_format.get_format_string(),
 
2169
            mode=tree.bzrdir._get_file_mode())
 
2170
 
 
2171
 
 
2172
class Converter4or5to6(object):
 
2173
    """Perform an in-place upgrade of format 4 or 5 to format 6 trees."""
 
2174
 
 
2175
    def __init__(self):
 
2176
        self.target_format = WorkingTreeFormat6()
 
2177
 
 
2178
    def convert(self, tree):
 
2179
        # lock the control files not the tree, so that we don't get tree
 
2180
        # on-unlock behaviours, and so that no-one else diddles with the
 
2181
        # tree during upgrade.
 
2182
        tree._control_files.lock_write()
 
2183
        try:
 
2184
            self.init_custom_control_files(tree)
 
2185
            self.update_format(tree)
 
2186
        finally:
 
2187
            tree._control_files.unlock()
 
2188
 
 
2189
    def init_custom_control_files(self, tree):
 
2190
        """Initialize custom control files."""
 
2191
        tree._transport.put_bytes('views', '',
 
2192
            mode=tree.bzrdir._get_file_mode())
 
2193
 
 
2194
    def update_format(self, tree):
 
2195
        """Change the format marker."""
 
2196
        tree._transport.put_bytes('format',
 
2197
            self.target_format.get_format_string(),
 
2198
            mode=tree.bzrdir._get_file_mode())