~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/dirstate.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2011-06-08 13:51:30 UTC
  • mfrom: (5945.1.5 bug38655-short-log)
  • Revision ID: pqm@pqm.ubuntu.com-20110608135130-lmzibvvzxrxwci0t
(vila) Allow -S as shorthand for --log-format=short (Martin von Gagern)

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006-2010 Canonical Ltd
 
1
# Copyright (C) 2006-2011 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
20
20
lines by NL. The field delimiters are ommitted in the grammar, line delimiters
21
21
are not - this is done for clarity of reading. All string data is in utf8.
22
22
 
23
 
MINIKIND = "f" | "d" | "l" | "a" | "r" | "t";
24
 
NL = "\n";
25
 
NULL = "\0";
26
 
WHOLE_NUMBER = {digit}, digit;
27
 
BOOLEAN = "y" | "n";
28
 
REVISION_ID = a non-empty utf8 string;
29
 
 
30
 
dirstate format = header line, full checksum, row count, parent details,
31
 
 ghost_details, entries;
32
 
header line = "#bazaar dirstate flat format 3", NL;
33
 
full checksum = "crc32: ", ["-"], WHOLE_NUMBER, NL;
34
 
row count = "num_entries: ", WHOLE_NUMBER, NL;
35
 
parent_details = WHOLE NUMBER, {REVISION_ID}* NL;
36
 
ghost_details = WHOLE NUMBER, {REVISION_ID}*, NL;
37
 
entries = {entry};
38
 
entry = entry_key, current_entry_details, {parent_entry_details};
39
 
entry_key = dirname,  basename, fileid;
40
 
current_entry_details = common_entry_details, working_entry_details;
41
 
parent_entry_details = common_entry_details, history_entry_details;
42
 
common_entry_details = MINIKIND, fingerprint, size, executable
43
 
working_entry_details = packed_stat
44
 
history_entry_details = REVISION_ID;
45
 
executable = BOOLEAN;
46
 
size = WHOLE_NUMBER;
47
 
fingerprint = a nonempty utf8 sequence with meaning defined by minikind.
48
 
 
49
 
Given this definition, the following is useful to know:
50
 
entry (aka row) - all the data for a given key.
51
 
entry[0]: The key (dirname, basename, fileid)
52
 
entry[0][0]: dirname
53
 
entry[0][1]: basename
54
 
entry[0][2]: fileid
55
 
entry[1]: The tree(s) data for this path and id combination.
56
 
entry[1][0]: The current tree
57
 
entry[1][1]: The second tree
58
 
 
59
 
For an entry for a tree, we have (using tree 0 - current tree) to demonstrate:
60
 
entry[1][0][0]: minikind
61
 
entry[1][0][1]: fingerprint
62
 
entry[1][0][2]: size
63
 
entry[1][0][3]: executable
64
 
entry[1][0][4]: packed_stat
65
 
OR (for non tree-0)
66
 
entry[1][1][4]: revision_id
 
23
::
 
24
 
 
25
    MINIKIND = "f" | "d" | "l" | "a" | "r" | "t";
 
26
    NL = "\\n";
 
27
    NULL = "\\0";
 
28
    WHOLE_NUMBER = {digit}, digit;
 
29
    BOOLEAN = "y" | "n";
 
30
    REVISION_ID = a non-empty utf8 string;
 
31
    
 
32
    dirstate format = header line, full checksum, row count, parent details,
 
33
     ghost_details, entries;
 
34
    header line = "#bazaar dirstate flat format 3", NL;
 
35
    full checksum = "crc32: ", ["-"], WHOLE_NUMBER, NL;
 
36
    row count = "num_entries: ", WHOLE_NUMBER, NL;
 
37
    parent_details = WHOLE NUMBER, {REVISION_ID}* NL;
 
38
    ghost_details = WHOLE NUMBER, {REVISION_ID}*, NL;
 
39
    entries = {entry};
 
40
    entry = entry_key, current_entry_details, {parent_entry_details};
 
41
    entry_key = dirname,  basename, fileid;
 
42
    current_entry_details = common_entry_details, working_entry_details;
 
43
    parent_entry_details = common_entry_details, history_entry_details;
 
44
    common_entry_details = MINIKIND, fingerprint, size, executable
 
45
    working_entry_details = packed_stat
 
46
    history_entry_details = REVISION_ID;
 
47
    executable = BOOLEAN;
 
48
    size = WHOLE_NUMBER;
 
49
    fingerprint = a nonempty utf8 sequence with meaning defined by minikind.
 
50
 
 
51
Given this definition, the following is useful to know::
 
52
 
 
53
    entry (aka row) - all the data for a given key.
 
54
    entry[0]: The key (dirname, basename, fileid)
 
55
    entry[0][0]: dirname
 
56
    entry[0][1]: basename
 
57
    entry[0][2]: fileid
 
58
    entry[1]: The tree(s) data for this path and id combination.
 
59
    entry[1][0]: The current tree
 
60
    entry[1][1]: The second tree
 
61
 
 
62
For an entry for a tree, we have (using tree 0 - current tree) to demonstrate::
 
63
 
 
64
    entry[1][0][0]: minikind
 
65
    entry[1][0][1]: fingerprint
 
66
    entry[1][0][2]: size
 
67
    entry[1][0][3]: executable
 
68
    entry[1][0][4]: packed_stat
 
69
 
 
70
OR (for non tree-0)::
 
71
 
 
72
    entry[1][1][4]: revision_id
67
73
 
68
74
There may be multiple rows at the root, one per id present in the root, so the
69
 
in memory root row is now:
70
 
self._dirblocks[0] -> ('', [entry ...]),
71
 
and the entries in there are
72
 
entries[0][0]: ''
73
 
entries[0][1]: ''
74
 
entries[0][2]: file_id
75
 
entries[1][0]: The tree data for the current tree for this fileid at /
76
 
etc.
77
 
 
78
 
Kinds:
79
 
'r' is a relocated entry: This path is not present in this tree with this id,
80
 
    but the id can be found at another location. The fingerprint is used to
81
 
    point to the target location.
82
 
'a' is an absent entry: In that tree the id is not present at this path.
83
 
'd' is a directory entry: This path in this tree is a directory with the
84
 
    current file id. There is no fingerprint for directories.
85
 
'f' is a file entry: As for directory, but it's a file. The fingerprint is the
86
 
    sha1 value of the file's canonical form, i.e. after any read filters have
87
 
    been applied to the convenience form stored in the working tree.
88
 
'l' is a symlink entry: As for directory, but a symlink. The fingerprint is the
89
 
    link target.
90
 
't' is a reference to a nested subtree; the fingerprint is the referenced
91
 
    revision.
 
75
in memory root row is now::
 
76
 
 
77
    self._dirblocks[0] -> ('', [entry ...]),
 
78
 
 
79
and the entries in there are::
 
80
 
 
81
    entries[0][0]: ''
 
82
    entries[0][1]: ''
 
83
    entries[0][2]: file_id
 
84
    entries[1][0]: The tree data for the current tree for this fileid at /
 
85
    etc.
 
86
 
 
87
Kinds::
 
88
 
 
89
    'r' is a relocated entry: This path is not present in this tree with this
 
90
        id, but the id can be found at another location. The fingerprint is
 
91
        used to point to the target location.
 
92
    'a' is an absent entry: In that tree the id is not present at this path.
 
93
    'd' is a directory entry: This path in this tree is a directory with the
 
94
        current file id. There is no fingerprint for directories.
 
95
    'f' is a file entry: As for directory, but it's a file. The fingerprint is
 
96
        the sha1 value of the file's canonical form, i.e. after any read
 
97
        filters have been applied to the convenience form stored in the working
 
98
        tree.
 
99
    'l' is a symlink entry: As for directory, but a symlink. The fingerprint is
 
100
        the link target.
 
101
    't' is a reference to a nested subtree; the fingerprint is the referenced
 
102
        revision.
92
103
 
93
104
Ordering:
94
105
 
95
 
The entries on disk and in memory are ordered according to the following keys:
 
106
The entries on disk and in memory are ordered according to the following keys::
96
107
 
97
108
    directory, as a list of components
98
109
    filename
99
110
    file-id
100
111
 
101
112
--- Format 1 had the following different definition: ---
102
 
rows = dirname, NULL, basename, NULL, MINIKIND, NULL, fileid_utf8, NULL,
103
 
    WHOLE NUMBER (* size *), NULL, packed stat, NULL, sha1|symlink target,
104
 
    {PARENT ROW}
105
 
PARENT ROW = NULL, revision_utf8, NULL, MINIKIND, NULL, dirname, NULL,
106
 
    basename, NULL, WHOLE NUMBER (* size *), NULL, "y" | "n", NULL,
107
 
    SHA1
 
113
 
 
114
::
 
115
 
 
116
    rows = dirname, NULL, basename, NULL, MINIKIND, NULL, fileid_utf8, NULL,
 
117
        WHOLE NUMBER (* size *), NULL, packed stat, NULL, sha1|symlink target,
 
118
        {PARENT ROW}
 
119
    PARENT ROW = NULL, revision_utf8, NULL, MINIKIND, NULL, dirname, NULL,
 
120
        basename, NULL, WHOLE NUMBER (* size *), NULL, "y" | "n", NULL,
 
121
        SHA1
108
122
 
109
123
PARENT ROW's are emitted for every parent that is not in the ghosts details
110
124
line. That is, if the parents are foo, bar, baz, and the ghosts are bar, then
135
149
----
136
150
 
137
151
Design priorities:
138
 
 1) Fast end to end use for bzr's top 5 uses cases. (commmit/diff/status/merge/???)
139
 
 2) fall back current object model as needed.
140
 
 3) scale usably to the largest trees known today - say 50K entries. (mozilla
 
152
 1. Fast end to end use for bzr's top 5 uses cases. (commmit/diff/status/merge/???)
 
153
 2. fall back current object model as needed.
 
154
 3. scale usably to the largest trees known today - say 50K entries. (mozilla
141
155
    is an example of this)
142
156
 
143
157
 
144
158
Locking:
 
159
 
145
160
 Eventually reuse dirstate objects across locks IFF the dirstate file has not
146
161
 been modified, but will require that we flush/ignore cached stat-hit data
147
162
 because we won't want to restat all files on disk just because a lock was
148
163
 acquired, yet we cannot trust the data after the previous lock was released.
149
164
 
150
 
Memory representation:
 
165
Memory representation::
 
166
 
151
167
 vector of all directories, and vector of the childen ?
152
168
   i.e.
153
169
     root_entrie = (direntry for root, [parent_direntries_for_root]),
167
183
    - What's the risk of error here? Once we have the base format being processed
168
184
      we should have a net win regardless of optimality. So we are going to
169
185
      go with what seems reasonable.
 
186
 
170
187
open questions:
171
188
 
172
189
Maybe we should do a test profile of the core structure - 10K simulated
265
282
        # return '%X.%X' % (int(st.st_mtime), st.st_mode)
266
283
 
267
284
 
 
285
def _unpack_stat(packed_stat):
 
286
    """Turn a packed_stat back into the stat fields.
 
287
 
 
288
    This is meant as a debugging tool, should not be used in real code.
 
289
    """
 
290
    (st_size, st_mtime, st_ctime, st_dev, st_ino,
 
291
     st_mode) = struct.unpack('>LLLLLL', binascii.a2b_base64(packed_stat))
 
292
    return dict(st_size=st_size, st_mtime=st_mtime, st_ctime=st_ctime,
 
293
                st_dev=st_dev, st_ino=st_ino, st_mode=st_mode)
 
294
 
 
295
 
268
296
class SHA1Provider(object):
269
297
    """An interface for getting sha1s of a file."""
270
298
 
355
383
    NOT_IN_MEMORY = 0
356
384
    IN_MEMORY_UNMODIFIED = 1
357
385
    IN_MEMORY_MODIFIED = 2
 
386
    IN_MEMORY_HASH_MODIFIED = 3 # Only hash-cache updates
358
387
 
359
388
    # A pack_stat (the x's) that is just noise and will never match the output
360
389
    # of base64 encode.
361
390
    NULLSTAT = 'x' * 32
362
 
    NULL_PARENT_DETAILS = ('a', '', 0, False, '')
 
391
    NULL_PARENT_DETAILS = static_tuple.StaticTuple('a', '', 0, False, '')
363
392
 
364
393
    HEADER_FORMAT_2 = '#bazaar dirstate flat format 2\n'
365
394
    HEADER_FORMAT_3 = '#bazaar dirstate flat format 3\n'
366
395
 
367
 
    def __init__(self, path, sha1_provider):
 
396
    def __init__(self, path, sha1_provider, worth_saving_limit=0):
368
397
        """Create a  DirState object.
369
398
 
370
399
        :param path: The path at which the dirstate file on disk should live.
371
400
        :param sha1_provider: an object meeting the SHA1Provider interface.
 
401
        :param worth_saving_limit: when the exact number of hash changed
 
402
            entries is known, only bother saving the dirstate if more than
 
403
            this count of entries have changed.
 
404
            -1 means never save hash changes, 0 means always save hash changes.
372
405
        """
373
406
        # _header_state and _dirblock_state represent the current state
374
407
        # of the dirstate metadata and the per-row data respectiely.
411
444
        # during commit.
412
445
        self._last_block_index = None
413
446
        self._last_entry_index = None
 
447
        # The set of known hash changes
 
448
        self._known_hash_changes = set()
 
449
        # How many hash changed entries can we have without saving
 
450
        self._worth_saving_limit = worth_saving_limit
414
451
 
415
452
    def __repr__(self):
416
453
        return "%s(%r)" % \
417
454
            (self.__class__.__name__, self._filename)
418
455
 
 
456
    def _mark_modified(self, hash_changed_entries=None, header_modified=False):
 
457
        """Mark this dirstate as modified.
 
458
 
 
459
        :param hash_changed_entries: if non-None, mark just these entries as
 
460
            having their hash modified.
 
461
        :param header_modified: mark the header modified as well, not just the
 
462
            dirblocks.
 
463
        """
 
464
        #trace.mutter_callsite(3, "modified hash entries: %s", hash_changed_entries)
 
465
        if hash_changed_entries:
 
466
            self._known_hash_changes.update([e[0] for e in hash_changed_entries])
 
467
            if self._dirblock_state in (DirState.NOT_IN_MEMORY,
 
468
                                        DirState.IN_MEMORY_UNMODIFIED):
 
469
                # If the dirstate is already marked a IN_MEMORY_MODIFIED, then
 
470
                # that takes precedence.
 
471
                self._dirblock_state = DirState.IN_MEMORY_HASH_MODIFIED
 
472
        else:
 
473
            # TODO: Since we now have a IN_MEMORY_HASH_MODIFIED state, we
 
474
            #       should fail noisily if someone tries to set
 
475
            #       IN_MEMORY_MODIFIED but we don't have a write-lock!
 
476
            # We don't know exactly what changed so disable smart saving
 
477
            self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
478
        if header_modified:
 
479
            self._header_state = DirState.IN_MEMORY_MODIFIED
 
480
 
 
481
    def _mark_unmodified(self):
 
482
        """Mark this dirstate as unmodified."""
 
483
        self._header_state = DirState.IN_MEMORY_UNMODIFIED
 
484
        self._dirblock_state = DirState.IN_MEMORY_UNMODIFIED
 
485
        self._known_hash_changes = set()
 
486
 
419
487
    def add(self, path, file_id, kind, stat, fingerprint):
420
488
        """Add a path to be tracked.
421
489
 
547
615
        if kind == 'directory':
548
616
           # insert a new dirblock
549
617
           self._ensure_block(block_index, entry_index, utf8path)
550
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
618
        self._mark_modified()
551
619
        if self._id_index:
552
620
            self._add_to_id_index(self._id_index, entry_key)
553
621
 
1019
1087
 
1020
1088
        self._ghosts = []
1021
1089
        self._parents = [parents[0]]
1022
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
1023
 
        self._header_state = DirState.IN_MEMORY_MODIFIED
 
1090
        self._mark_modified(header_modified=True)
1024
1091
 
1025
1092
    def _empty_parent_info(self):
1026
1093
        return [DirState.NULL_PARENT_DETAILS] * (len(self._parents) -
1155
1222
    def _fields_per_entry(self):
1156
1223
        """How many null separated fields should be in each entry row.
1157
1224
 
1158
 
        Each line now has an extra '\n' field which is not used
 
1225
        Each line now has an extra '\\n' field which is not used
1159
1226
        so we just skip over it
1160
 
        entry size:
 
1227
 
 
1228
        entry size::
1161
1229
            3 fields for the key
1162
1230
            + number of fields per tree_data (5) * tree count
1163
1231
            + newline
1276
1344
            raise
1277
1345
        return result
1278
1346
 
 
1347
    def _check_delta_is_valid(self, delta):
 
1348
        return list(inventory._check_delta_unique_ids(
 
1349
                    inventory._check_delta_unique_old_paths(
 
1350
                    inventory._check_delta_unique_new_paths(
 
1351
                    inventory._check_delta_ids_match_entry(
 
1352
                    inventory._check_delta_ids_are_valid(
 
1353
                    inventory._check_delta_new_path_entry_both_or_None(delta)))))))
 
1354
 
1279
1355
    def update_by_delta(self, delta):
1280
1356
        """Apply an inventory delta to the dirstate for tree 0
1281
1357
 
1299
1375
        new_ids = set()
1300
1376
        # This loop transforms the delta to single atomic operations that can
1301
1377
        # be executed and validated.
1302
 
        for old_path, new_path, file_id, inv_entry in sorted(
1303
 
            inventory._check_delta_unique_old_paths(
1304
 
            inventory._check_delta_unique_new_paths(
1305
 
            inventory._check_delta_ids_match_entry(
1306
 
            inventory._check_delta_ids_are_valid(
1307
 
            inventory._check_delta_new_path_entry_both_or_None(delta))))),
1308
 
            reverse=True):
 
1378
        delta = sorted(self._check_delta_is_valid(delta), reverse=True)
 
1379
        for old_path, new_path, file_id, inv_entry in delta:
1309
1380
            if (file_id in insertions) or (file_id in removals):
1310
 
                raise errors.InconsistentDelta(old_path or new_path, file_id,
 
1381
                self._raise_invalid(old_path or new_path, file_id,
1311
1382
                    "repeated file_id")
1312
1383
            if old_path is not None:
1313
1384
                old_path = old_path.encode('utf-8')
1316
1387
                new_ids.add(file_id)
1317
1388
            if new_path is not None:
1318
1389
                if inv_entry is None:
1319
 
                    raise errors.InconsistentDelta(new_path, file_id,
 
1390
                    self._raise_invalid(new_path, file_id,
1320
1391
                        "new_path with no entry")
1321
1392
                new_path = new_path.encode('utf-8')
1322
1393
                dirname_utf8, basename = osutils.split(new_path)
1363
1434
            # _get_entry raises BzrError when a request is inconsistent; we
1364
1435
            # want such errors to be shown as InconsistentDelta - and that 
1365
1436
            # fits the behaviour we trigger.
1366
 
            raise errors.InconsistentDeltaDelta(delta, "error from _get_entry.")
 
1437
            raise errors.InconsistentDeltaDelta(delta,
 
1438
                "error from _get_entry. %s" % (e,))
1367
1439
 
1368
1440
    def _apply_removals(self, removals):
1369
1441
        for file_id, path in sorted(removals, reverse=True,
1374
1446
            try:
1375
1447
                entry = self._dirblocks[block_i][1][entry_i]
1376
1448
            except IndexError:
1377
 
                self._changes_aborted = True
1378
 
                raise errors.InconsistentDelta(path, file_id,
 
1449
                self._raise_invalid(path, file_id,
1379
1450
                    "Wrong path for old path.")
1380
1451
            if not f_present or entry[1][0][0] in 'ar':
1381
 
                self._changes_aborted = True
1382
 
                raise errors.InconsistentDelta(path, file_id,
 
1452
                self._raise_invalid(path, file_id,
1383
1453
                    "Wrong path for old path.")
1384
1454
            if file_id != entry[0][2]:
1385
 
                self._changes_aborted = True
1386
 
                raise errors.InconsistentDelta(path, file_id,
 
1455
                self._raise_invalid(path, file_id,
1387
1456
                    "Attempt to remove path has wrong id - found %r."
1388
1457
                    % entry[0][2])
1389
1458
            self._make_absent(entry)
1399
1468
                # be due to it being in a parent tree, or a corrupt delta.
1400
1469
                for child_entry in self._dirblocks[block_i][1]:
1401
1470
                    if child_entry[1][0][0] not in ('r', 'a'):
1402
 
                        self._changes_aborted = True
1403
 
                        raise errors.InconsistentDelta(path, entry[0][2],
 
1471
                        self._raise_invalid(path, entry[0][2],
1404
1472
                            "The file id was deleted but its children were "
1405
1473
                            "not deleted.")
1406
1474
 
1410
1478
                self.update_minimal(key, minikind, executable, fingerprint,
1411
1479
                                    path_utf8=path_utf8)
1412
1480
        except errors.NotVersionedError:
1413
 
            self._changes_aborted = True
1414
 
            raise errors.InconsistentDelta(path_utf8.decode('utf8'), key[2],
 
1481
            self._raise_invalid(path_utf8.decode('utf8'), key[2],
1415
1482
                "Missing parent")
1416
1483
 
1417
1484
    def update_basis_by_delta(self, delta, new_revid):
1425
1492
        Note that an exception during the operation of this method will leave
1426
1493
        the dirstate in a corrupt state where it should not be saved.
1427
1494
 
1428
 
        Finally, we expect all changes to be synchronising the basis tree with
1429
 
        the working tree.
1430
 
 
1431
1495
        :param new_revid: The new revision id for the trees parent.
1432
1496
        :param delta: An inventory delta (see apply_inventory_delta) describing
1433
1497
            the changes from the current left most parent revision to new_revid.
1445
1509
 
1446
1510
        self._parents[0] = new_revid
1447
1511
 
1448
 
        delta = sorted(delta, reverse=True)
 
1512
        delta = sorted(self._check_delta_is_valid(delta), reverse=True)
1449
1513
        adds = []
1450
1514
        changes = []
1451
1515
        deletes = []
1472
1536
        new_ids = set()
1473
1537
        for old_path, new_path, file_id, inv_entry in delta:
1474
1538
            if inv_entry is not None and file_id != inv_entry.file_id:
1475
 
                raise errors.InconsistentDelta(new_path, file_id,
 
1539
                self._raise_invalid(new_path, file_id,
1476
1540
                    "mismatched entry file_id %r" % inv_entry)
1477
 
            if new_path is not None:
 
1541
            if new_path is None:
 
1542
                new_path_utf8 = None
 
1543
            else:
1478
1544
                if inv_entry is None:
1479
 
                    raise errors.InconsistentDelta(new_path, file_id,
 
1545
                    self._raise_invalid(new_path, file_id,
1480
1546
                        "new_path with no entry")
1481
1547
                new_path_utf8 = encode(new_path)
1482
1548
                # note the parent for validation
1484
1550
                if basename_utf8:
1485
1551
                    parents.add((dirname_utf8, inv_entry.parent_id))
1486
1552
            if old_path is None:
1487
 
                adds.append((None, encode(new_path), file_id,
 
1553
                old_path_utf8 = None
 
1554
            else:
 
1555
                old_path_utf8 = encode(old_path)
 
1556
            if old_path is None:
 
1557
                adds.append((None, new_path_utf8, file_id,
1488
1558
                    inv_to_entry(inv_entry), True))
1489
1559
                new_ids.add(file_id)
1490
1560
            elif new_path is None:
1491
 
                deletes.append((encode(old_path), None, file_id, None, True))
1492
 
            elif (old_path, new_path) != root_only:
 
1561
                deletes.append((old_path_utf8, None, file_id, None, True))
 
1562
            elif (old_path, new_path) == root_only:
 
1563
                # change things in-place
 
1564
                # Note: the case of a parent directory changing its file_id
 
1565
                #       tends to break optimizations here, because officially
 
1566
                #       the file has actually been moved, it just happens to
 
1567
                #       end up at the same path. If we can figure out how to
 
1568
                #       handle that case, we can avoid a lot of add+delete
 
1569
                #       pairs for objects that stay put.
 
1570
                # elif old_path == new_path:
 
1571
                changes.append((old_path_utf8, new_path_utf8, file_id,
 
1572
                                inv_to_entry(inv_entry)))
 
1573
            else:
1493
1574
                # Renames:
1494
1575
                # Because renames must preserve their children we must have
1495
1576
                # processed all relocations and removes before hand. The sort
1505
1586
                self._update_basis_apply_deletes(deletes)
1506
1587
                deletes = []
1507
1588
                # Split into an add/delete pair recursively.
1508
 
                adds.append((None, new_path_utf8, file_id,
1509
 
                    inv_to_entry(inv_entry), False))
 
1589
                adds.append((old_path_utf8, new_path_utf8, file_id,
 
1590
                             inv_to_entry(inv_entry), False))
1510
1591
                # Expunge deletes that we've seen so that deleted/renamed
1511
1592
                # children of a rename directory are handled correctly.
1512
 
                new_deletes = reversed(list(self._iter_child_entries(1,
1513
 
                    encode(old_path))))
 
1593
                new_deletes = reversed(list(
 
1594
                    self._iter_child_entries(1, old_path_utf8)))
1514
1595
                # Remove the current contents of the tree at orig_path, and
1515
1596
                # reinsert at the correct new path.
1516
1597
                for entry in new_deletes:
1517
 
                    if entry[0][0]:
1518
 
                        source_path = entry[0][0] + '/' + entry[0][1]
 
1598
                    child_dirname, child_basename, child_file_id = entry[0]
 
1599
                    if child_dirname:
 
1600
                        source_path = child_dirname + '/' + child_basename
1519
1601
                    else:
1520
 
                        source_path = entry[0][1]
 
1602
                        source_path = child_basename
1521
1603
                    if new_path_utf8:
1522
1604
                        target_path = new_path_utf8 + source_path[len(old_path):]
1523
1605
                    else:
1524
1606
                        if old_path == '':
1525
1607
                            raise AssertionError("cannot rename directory to"
1526
 
                                " itself")
 
1608
                                                 " itself")
1527
1609
                        target_path = source_path[len(old_path) + 1:]
1528
1610
                    adds.append((None, target_path, entry[0][2], entry[1][1], False))
1529
1611
                    deletes.append(
1530
1612
                        (source_path, target_path, entry[0][2], None, False))
1531
 
                deletes.append(
1532
 
                    (encode(old_path), new_path, file_id, None, False))
1533
 
            else:
1534
 
                # changes to just the root should not require remove/insertion
1535
 
                # of everything.
1536
 
                changes.append((encode(old_path), encode(new_path), file_id,
1537
 
                    inv_to_entry(inv_entry)))
 
1613
                deletes.append((old_path_utf8, new_path, file_id, None, False))
1538
1614
        self._check_delta_ids_absent(new_ids, delta, 1)
1539
1615
        try:
1540
1616
            # Finish expunging deletes/first half of renames.
1550
1626
            if 'integrity error' not in str(e):
1551
1627
                raise
1552
1628
            # _get_entry raises BzrError when a request is inconsistent; we
1553
 
            # want such errors to be shown as InconsistentDelta - and that 
1554
 
            # fits the behaviour we trigger. Partof this is driven by dirstate
1555
 
            # only supporting deltas that turn the basis into a closer fit to
1556
 
            # the active tree.
1557
 
            raise errors.InconsistentDeltaDelta(delta, "error from _get_entry.")
 
1629
            # want such errors to be shown as InconsistentDelta - and that
 
1630
            # fits the behaviour we trigger.
 
1631
            raise errors.InconsistentDeltaDelta(delta,
 
1632
                "error from _get_entry. %s" % (e,))
1558
1633
 
1559
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
1560
 
        self._header_state = DirState.IN_MEMORY_MODIFIED
 
1634
        self._mark_modified(header_modified=True)
1561
1635
        self._id_index = None
1562
1636
        return
1563
1637
 
1577
1651
                if entry[0][2] != file_id:
1578
1652
                    # Different file_id, so not what we want.
1579
1653
                    continue
1580
 
                # NB: No changes made before this helper is called, so no need
1581
 
                # to set the _changes_aborted flag.
1582
 
                raise errors.InconsistentDelta(
1583
 
                    ("%s/%s" % key[0:2]).decode('utf8'), file_id,
 
1654
                self._raise_invalid(("%s/%s" % key[0:2]).decode('utf8'), file_id,
1584
1655
                    "This file_id is new in the delta but already present in "
1585
1656
                    "the target")
1586
1657
 
 
1658
    def _raise_invalid(self, path, file_id, reason):
 
1659
        self._changes_aborted = True
 
1660
        raise errors.InconsistentDelta(path, file_id, reason)
 
1661
 
1587
1662
    def _update_basis_apply_adds(self, adds):
1588
1663
        """Apply a sequence of adds to tree 1 during update_basis_by_delta.
1589
1664
 
1597
1672
        """
1598
1673
        # Adds are accumulated partly from renames, so can be in any input
1599
1674
        # order - sort it.
1600
 
        adds.sort()
 
1675
        # TODO: we may want to sort in dirblocks order. That way each entry
 
1676
        #       will end up in the same directory, allowing the _get_entry
 
1677
        #       fast-path for looking up 2 items in the same dir work.
 
1678
        adds.sort(key=lambda x: x[1])
1601
1679
        # adds is now in lexographic order, which places all parents before
1602
1680
        # their children, so we can process it linearly.
1603
1681
        absent = 'ar'
 
1682
        st = static_tuple.StaticTuple
1604
1683
        for old_path, new_path, file_id, new_details, real_add in adds:
1605
 
            # the entry for this file_id must be in tree 0.
1606
 
            entry = self._get_entry(0, file_id, new_path)
1607
 
            if entry[0] is None or entry[0][2] != file_id:
1608
 
                self._changes_aborted = True
1609
 
                raise errors.InconsistentDelta(new_path, file_id,
1610
 
                    'working tree does not contain new entry')
1611
 
            if real_add and entry[1][1][0] not in absent:
1612
 
                self._changes_aborted = True
1613
 
                raise errors.InconsistentDelta(new_path, file_id,
1614
 
                    'The entry was considered to be a genuinely new record,'
1615
 
                    ' but there was already an old record for it.')
1616
 
            # We don't need to update the target of an 'r' because the handling
1617
 
            # of renames turns all 'r' situations into a delete at the original
1618
 
            # location.
1619
 
            entry[1][1] = new_details
 
1684
            dirname, basename = osutils.split(new_path)
 
1685
            entry_key = st(dirname, basename, file_id)
 
1686
            block_index, present = self._find_block_index_from_key(entry_key)
 
1687
            if not present:
 
1688
                self._raise_invalid(new_path, file_id,
 
1689
                    "Unable to find block for this record."
 
1690
                    " Was the parent added?")
 
1691
            block = self._dirblocks[block_index][1]
 
1692
            entry_index, present = self._find_entry_index(entry_key, block)
 
1693
            if real_add:
 
1694
                if old_path is not None:
 
1695
                    self._raise_invalid(new_path, file_id,
 
1696
                        'considered a real add but still had old_path at %s'
 
1697
                        % (old_path,))
 
1698
            if present:
 
1699
                entry = block[entry_index]
 
1700
                basis_kind = entry[1][1][0]
 
1701
                if basis_kind == 'a':
 
1702
                    entry[1][1] = new_details
 
1703
                elif basis_kind == 'r':
 
1704
                    raise NotImplementedError()
 
1705
                else:
 
1706
                    self._raise_invalid(new_path, file_id,
 
1707
                        "An entry was marked as a new add"
 
1708
                        " but the basis target already existed")
 
1709
            else:
 
1710
                # The exact key was not found in the block. However, we need to
 
1711
                # check if there is a key next to us that would have matched.
 
1712
                # We only need to check 2 locations, because there are only 2
 
1713
                # trees present.
 
1714
                for maybe_index in range(entry_index-1, entry_index+1):
 
1715
                    if maybe_index < 0 or maybe_index >= len(block):
 
1716
                        continue
 
1717
                    maybe_entry = block[maybe_index]
 
1718
                    if maybe_entry[0][:2] != (dirname, basename):
 
1719
                        # Just a random neighbor
 
1720
                        continue
 
1721
                    if maybe_entry[0][2] == file_id:
 
1722
                        raise AssertionError(
 
1723
                            '_find_entry_index didnt find a key match'
 
1724
                            ' but walking the data did, for %s'
 
1725
                            % (entry_key,))
 
1726
                    basis_kind = maybe_entry[1][1][0]
 
1727
                    if basis_kind not in 'ar':
 
1728
                        self._raise_invalid(new_path, file_id,
 
1729
                            "we have an add record for path, but the path"
 
1730
                            " is already present with another file_id %s"
 
1731
                            % (maybe_entry[0][2],))
 
1732
 
 
1733
                entry = (entry_key, [DirState.NULL_PARENT_DETAILS,
 
1734
                                     new_details])
 
1735
                block.insert(entry_index, entry)
 
1736
 
 
1737
            active_kind = entry[1][0][0]
 
1738
            if active_kind == 'a':
 
1739
                # The active record shows up as absent, this could be genuine,
 
1740
                # or it could be present at some other location. We need to
 
1741
                # verify.
 
1742
                id_index = self._get_id_index()
 
1743
                # The id_index may not be perfectly accurate for tree1, because
 
1744
                # we haven't been keeping it updated. However, it should be
 
1745
                # fine for tree0, and that gives us enough info for what we
 
1746
                # need
 
1747
                keys = id_index.get(file_id, ())
 
1748
                for key in keys:
 
1749
                    block_i, entry_i, d_present, f_present = \
 
1750
                        self._get_block_entry_index(key[0], key[1], 0)
 
1751
                    if not f_present:
 
1752
                        continue
 
1753
                    active_entry = self._dirblocks[block_i][1][entry_i]
 
1754
                    if (active_entry[0][2] != file_id):
 
1755
                        # Some other file is at this path, we don't need to
 
1756
                        # link it.
 
1757
                        continue
 
1758
                    real_active_kind = active_entry[1][0][0]
 
1759
                    if real_active_kind in 'ar':
 
1760
                        # We found a record, which was not *this* record,
 
1761
                        # which matches the file_id, but is not actually
 
1762
                        # present. Something seems *really* wrong.
 
1763
                        self._raise_invalid(new_path, file_id,
 
1764
                            "We found a tree0 entry that doesnt make sense")
 
1765
                    # Now, we've found a tree0 entry which matches the file_id
 
1766
                    # but is at a different location. So update them to be
 
1767
                    # rename records.
 
1768
                    active_dir, active_name = active_entry[0][:2]
 
1769
                    if active_dir:
 
1770
                        active_path = active_dir + '/' + active_name
 
1771
                    else:
 
1772
                        active_path = active_name
 
1773
                    active_entry[1][1] = st('r', new_path, 0, False, '')
 
1774
                    entry[1][0] = st('r', active_path, 0, False, '')
 
1775
            elif active_kind == 'r':
 
1776
                raise NotImplementedError()
 
1777
 
 
1778
            new_kind = new_details[0]
 
1779
            if new_kind == 'd':
 
1780
                self._ensure_block(block_index, entry_index, new_path)
1620
1781
 
1621
1782
    def _update_basis_apply_changes(self, changes):
1622
1783
        """Apply a sequence of changes to tree 1 during update_basis_by_delta.
1627
1788
        absent = 'ar'
1628
1789
        for old_path, new_path, file_id, new_details in changes:
1629
1790
            # the entry for this file_id must be in tree 0.
1630
 
            entry = self._get_entry(0, file_id, new_path)
1631
 
            if entry[0] is None or entry[0][2] != file_id:
1632
 
                self._changes_aborted = True
1633
 
                raise errors.InconsistentDelta(new_path, file_id,
1634
 
                    'working tree does not contain new entry')
1635
 
            if (entry[1][0][0] in absent or
1636
 
                entry[1][1][0] in absent):
1637
 
                self._changes_aborted = True
1638
 
                raise errors.InconsistentDelta(new_path, file_id,
1639
 
                    'changed considered absent')
 
1791
            entry = self._get_entry(1, file_id, new_path)
 
1792
            if entry[0] is None or entry[1][1][0] in 'ar':
 
1793
                self._raise_invalid(new_path, file_id,
 
1794
                    'changed entry considered not present')
1640
1795
            entry[1][1] = new_details
1641
1796
 
1642
1797
    def _update_basis_apply_deletes(self, deletes):
1654
1809
        null = DirState.NULL_PARENT_DETAILS
1655
1810
        for old_path, new_path, file_id, _, real_delete in deletes:
1656
1811
            if real_delete != (new_path is None):
1657
 
                self._changes_aborted = True
1658
 
                raise AssertionError("bad delete delta")
 
1812
                self._raise_invalid(old_path, file_id, "bad delete delta")
1659
1813
            # the entry for this file_id must be in tree 1.
1660
1814
            dirname, basename = osutils.split(old_path)
1661
1815
            block_index, entry_index, dir_present, file_present = \
1662
1816
                self._get_block_entry_index(dirname, basename, 1)
1663
1817
            if not file_present:
1664
 
                self._changes_aborted = True
1665
 
                raise errors.InconsistentDelta(old_path, file_id,
 
1818
                self._raise_invalid(old_path, file_id,
1666
1819
                    'basis tree does not contain removed entry')
1667
1820
            entry = self._dirblocks[block_index][1][entry_index]
 
1821
            # The state of the entry in the 'active' WT
 
1822
            active_kind = entry[1][0][0]
1668
1823
            if entry[0][2] != file_id:
1669
 
                self._changes_aborted = True
1670
 
                raise errors.InconsistentDelta(old_path, file_id,
 
1824
                self._raise_invalid(old_path, file_id,
1671
1825
                    'mismatched file_id in tree 1')
1672
 
            if real_delete:
1673
 
                if entry[1][0][0] != 'a':
1674
 
                    self._changes_aborted = True
1675
 
                    raise errors.InconsistentDelta(old_path, file_id,
1676
 
                            'This was marked as a real delete, but the WT state'
1677
 
                            ' claims that it still exists and is versioned.')
 
1826
            dir_block = ()
 
1827
            old_kind = entry[1][1][0]
 
1828
            if active_kind in 'ar':
 
1829
                # The active tree doesn't have this file_id.
 
1830
                # The basis tree is changing this record. If this is a
 
1831
                # rename, then we don't want the record here at all
 
1832
                # anymore. If it is just an in-place change, we want the
 
1833
                # record here, but we'll add it if we need to. So we just
 
1834
                # delete it
 
1835
                if active_kind == 'r':
 
1836
                    active_path = entry[1][0][1]
 
1837
                    active_entry = self._get_entry(0, file_id, active_path)
 
1838
                    if active_entry[1][1][0] != 'r':
 
1839
                        self._raise_invalid(old_path, file_id,
 
1840
                            "Dirstate did not have matching rename entries")
 
1841
                    elif active_entry[1][0][0] in 'ar':
 
1842
                        self._raise_invalid(old_path, file_id,
 
1843
                            "Dirstate had a rename pointing at an inactive"
 
1844
                            " tree0")
 
1845
                    active_entry[1][1] = null
1678
1846
                del self._dirblocks[block_index][1][entry_index]
 
1847
                if old_kind == 'd':
 
1848
                    # This was a directory, and the active tree says it
 
1849
                    # doesn't exist, and now the basis tree says it doesn't
 
1850
                    # exist. Remove its dirblock if present
 
1851
                    (dir_block_index,
 
1852
                     present) = self._find_block_index_from_key(
 
1853
                        (old_path, '', ''))
 
1854
                    if present:
 
1855
                        dir_block = self._dirblocks[dir_block_index][1]
 
1856
                        if not dir_block:
 
1857
                            # This entry is empty, go ahead and just remove it
 
1858
                            del self._dirblocks[dir_block_index]
1679
1859
            else:
1680
 
                if entry[1][0][0] == 'a':
1681
 
                    self._changes_aborted = True
1682
 
                    raise errors.InconsistentDelta(old_path, file_id,
1683
 
                        'The entry was considered a rename, but the source path'
1684
 
                        ' is marked as absent.')
1685
 
                    # For whatever reason, we were asked to rename an entry
1686
 
                    # that was originally marked as deleted. This could be
1687
 
                    # because we are renaming the parent directory, and the WT
1688
 
                    # current state has the file marked as deleted.
1689
 
                elif entry[1][0][0] == 'r':
1690
 
                    # implement the rename
1691
 
                    del self._dirblocks[block_index][1][entry_index]
1692
 
                else:
1693
 
                    # it is being resurrected here, so blank it out temporarily.
1694
 
                    self._dirblocks[block_index][1][entry_index][1][1] = null
 
1860
                # There is still an active record, so just mark this
 
1861
                # removed.
 
1862
                entry[1][1] = null
 
1863
                block_i, entry_i, d_present, f_present = \
 
1864
                    self._get_block_entry_index(old_path, '', 1)
 
1865
                if d_present:
 
1866
                    dir_block = self._dirblocks[block_i][1]
 
1867
            for child_entry in dir_block:
 
1868
                child_basis_kind = child_entry[1][1][0]
 
1869
                if child_basis_kind not in 'ar':
 
1870
                    self._raise_invalid(old_path, file_id,
 
1871
                        "The file id was deleted but its children were "
 
1872
                        "not deleted.")
1695
1873
 
1696
1874
    def _after_delta_check_parents(self, parents, index):
1697
1875
        """Check that parents required by the delta are all intact.
1706
1884
            # has the right file id.
1707
1885
            entry = self._get_entry(index, file_id, dirname_utf8)
1708
1886
            if entry[1] is None:
1709
 
                self._changes_aborted = True
1710
 
                raise errors.InconsistentDelta(dirname_utf8.decode('utf8'),
 
1887
                self._raise_invalid(dirname_utf8.decode('utf8'),
1711
1888
                    file_id, "This parent is not present.")
1712
1889
            # Parents of things must be directories
1713
1890
            if entry[1][index][0] != 'd':
1714
 
                self._changes_aborted = True
1715
 
                raise errors.InconsistentDelta(dirname_utf8.decode('utf8'),
 
1891
                self._raise_invalid(dirname_utf8.decode('utf8'),
1716
1892
                    file_id, "This parent is not a directory.")
1717
1893
 
1718
1894
    def _observed_sha1(self, entry, sha1, stat_value,
1734
1910
                self._sha_cutoff_time()
1735
1911
            if (stat_value.st_mtime < self._cutoff_time
1736
1912
                and stat_value.st_ctime < self._cutoff_time):
1737
 
                entry[1][0] = ('f', sha1, entry[1][0][2], entry[1][0][3],
1738
 
                    packed_stat)
1739
 
                self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
1913
                entry[1][0] = ('f', sha1, stat_value.st_size, entry[1][0][3],
 
1914
                               packed_stat)
 
1915
                self._mark_modified([entry])
1740
1916
 
1741
1917
    def _sha_cutoff_time(self):
1742
1918
        """Return cutoff time.
1800
1976
        """Serialise the entire dirstate to a sequence of lines."""
1801
1977
        if (self._header_state == DirState.IN_MEMORY_UNMODIFIED and
1802
1978
            self._dirblock_state == DirState.IN_MEMORY_UNMODIFIED):
1803
 
            # read whats on disk.
 
1979
            # read what's on disk.
1804
1980
            self._state_file.seek(0)
1805
1981
            return self._state_file.readlines()
1806
1982
        lines = []
1807
1983
        lines.append(self._get_parents_line(self.get_parent_ids()))
1808
1984
        lines.append(self._get_ghosts_line(self._ghosts))
1809
 
        # append the root line which is special cased
1810
 
        lines.extend(map(self._entry_to_line, self._iter_entries()))
 
1985
        lines.extend(self._get_entry_lines())
1811
1986
        return self._get_output_lines(lines)
1812
1987
 
1813
1988
    def _get_ghosts_line(self, ghost_ids):
1818
1993
        """Create a line for the state file for parents information."""
1819
1994
        return '\0'.join([str(len(parent_ids))] + parent_ids)
1820
1995
 
 
1996
    def _get_entry_lines(self):
 
1997
        """Create lines for entries."""
 
1998
        return map(self._entry_to_line, self._iter_entries())
 
1999
 
1821
2000
    def _get_fields_to_entry(self):
1822
2001
        """Get a function which converts entry fields into a entry record.
1823
2002
 
1941
2120
            entry_index += 1
1942
2121
        return block_index, entry_index, True, False
1943
2122
 
1944
 
    def _get_entry(self, tree_index, fileid_utf8=None, path_utf8=None, include_deleted=False):
 
2123
    def _get_entry(self, tree_index, fileid_utf8=None, path_utf8=None,
 
2124
                   include_deleted=False):
1945
2125
        """Get the dirstate entry for path in tree tree_index.
1946
2126
 
1947
2127
        If either file_id or path is supplied, it is used as the key to lookup.
2089
2269
            executable = False
2090
2270
        else:
2091
2271
            raise Exception("can't pack %s" % inv_entry)
2092
 
        return (minikind, fingerprint, size, executable, tree_data)
 
2272
        return static_tuple.StaticTuple(minikind, fingerprint, size,
 
2273
                                        executable, tree_data)
2093
2274
 
2094
2275
    def _iter_child_entries(self, tree_index, path_utf8):
2095
2276
        """Iterate over all the entries that are children of path_utf.
2145
2326
 
2146
2327
    def _get_id_index(self):
2147
2328
        """Get an id index of self._dirblocks.
2148
 
        
 
2329
 
2149
2330
        This maps from file_id => [(directory, name, file_id)] entries where
2150
2331
        that file_id appears in one of the trees.
2151
2332
        """
2165
2346
        # such, we use a simple tuple, and do our own uniqueness checks. While
2166
2347
        # the 'in' check is O(N) since N is nicely bounded it shouldn't ever
2167
2348
        # cause quadratic failure.
2168
 
        # TODO: This should use StaticTuple
2169
2349
        file_id = entry_key[2]
2170
2350
        entry_key = static_tuple.StaticTuple.from_sequence(entry_key)
2171
2351
        if file_id not in id_index:
2211
2391
        """The number of parent entries in each record row."""
2212
2392
        return len(self._parents) - len(self._ghosts)
2213
2393
 
2214
 
    @staticmethod
2215
 
    def on_file(path, sha1_provider=None):
 
2394
    @classmethod
 
2395
    def on_file(cls, path, sha1_provider=None, worth_saving_limit=0):
2216
2396
        """Construct a DirState on the file at path "path".
2217
2397
 
2218
2398
        :param path: The path at which the dirstate file on disk should live.
2219
2399
        :param sha1_provider: an object meeting the SHA1Provider interface.
2220
2400
            If None, a DefaultSHA1Provider is used.
 
2401
        :param worth_saving_limit: when the exact number of hash changed
 
2402
            entries is known, only bother saving the dirstate if more than
 
2403
            this count of entries have changed. -1 means never save.
2221
2404
        :return: An unlocked DirState object, associated with the given path.
2222
2405
        """
2223
2406
        if sha1_provider is None:
2224
2407
            sha1_provider = DefaultSHA1Provider()
2225
 
        result = DirState(path, sha1_provider)
 
2408
        result = cls(path, sha1_provider,
 
2409
                     worth_saving_limit=worth_saving_limit)
2226
2410
        return result
2227
2411
 
2228
2412
    def _read_dirblocks_if_needed(self):
2320
2504
            trace.mutter('Not saving DirState because '
2321
2505
                    '_changes_aborted is set.')
2322
2506
            return
2323
 
        if (self._header_state == DirState.IN_MEMORY_MODIFIED or
2324
 
            self._dirblock_state == DirState.IN_MEMORY_MODIFIED):
2325
 
 
 
2507
        # TODO: Since we now distinguish IN_MEMORY_MODIFIED from
 
2508
        #       IN_MEMORY_HASH_MODIFIED, we should only fail quietly if we fail
 
2509
        #       to save an IN_MEMORY_HASH_MODIFIED, and fail *noisily* if we
 
2510
        #       fail to save IN_MEMORY_MODIFIED
 
2511
        if self._worth_saving():
2326
2512
            grabbed_write_lock = False
2327
2513
            if self._lock_state != 'w':
2328
2514
                grabbed_write_lock, new_lock = self._lock_token.temporary_write_lock()
2336
2522
                    # We couldn't grab a write lock, so we switch back to a read one
2337
2523
                    return
2338
2524
            try:
 
2525
                lines = self.get_lines()
2339
2526
                self._state_file.seek(0)
2340
 
                self._state_file.writelines(self.get_lines())
 
2527
                self._state_file.writelines(lines)
2341
2528
                self._state_file.truncate()
2342
2529
                self._state_file.flush()
2343
 
                self._header_state = DirState.IN_MEMORY_UNMODIFIED
2344
 
                self._dirblock_state = DirState.IN_MEMORY_UNMODIFIED
 
2530
                self._mark_unmodified()
2345
2531
            finally:
2346
2532
                if grabbed_write_lock:
2347
2533
                    self._lock_token = self._lock_token.restore_read_lock()
2350
2536
                    #       not changed contents. Since restore_read_lock may
2351
2537
                    #       not be an atomic operation.
2352
2538
 
 
2539
    def _worth_saving(self):
 
2540
        """Is it worth saving the dirstate or not?"""
 
2541
        if (self._header_state == DirState.IN_MEMORY_MODIFIED
 
2542
            or self._dirblock_state == DirState.IN_MEMORY_MODIFIED):
 
2543
            return True
 
2544
        if self._dirblock_state == DirState.IN_MEMORY_HASH_MODIFIED:
 
2545
            if self._worth_saving_limit == -1:
 
2546
                # We never save hash changes when the limit is -1
 
2547
                return False
 
2548
            # If we're using smart saving and only a small number of
 
2549
            # entries have changed their hash, don't bother saving. John has
 
2550
            # suggested using a heuristic here based on the size of the
 
2551
            # changed files and/or tree. For now, we go with a configurable
 
2552
            # number of changes, keeping the calculation time
 
2553
            # as low overhead as possible. (This also keeps all existing
 
2554
            # tests passing as the default is 0, i.e. always save.)
 
2555
            if len(self._known_hash_changes) >= self._worth_saving_limit:
 
2556
                return True
 
2557
        return False
 
2558
 
2353
2559
    def _set_data(self, parent_ids, dirblocks):
2354
2560
        """Set the full dirstate data in memory.
2355
2561
 
2363
2569
        """
2364
2570
        # our memory copy is now authoritative.
2365
2571
        self._dirblocks = dirblocks
2366
 
        self._header_state = DirState.IN_MEMORY_MODIFIED
2367
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
2572
        self._mark_modified(header_modified=True)
2368
2573
        self._parents = list(parent_ids)
2369
2574
        self._id_index = None
2370
2575
        self._packed_stat_index = None
2390
2595
        self._make_absent(entry)
2391
2596
        self.update_minimal(('', '', new_id), 'd',
2392
2597
            path_utf8='', packed_stat=entry[1][0][4])
2393
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
2598
        self._mark_modified()
 
2599
        # XXX: This was added by Ian, we need to make sure there
 
2600
        #      are tests for it, because it isn't in bzr.dev TRUNK
 
2601
        #      It looks like the only place it is called is in setting the root
 
2602
        #      id of the tree. So probably we never had an _id_index when we
 
2603
        #      don't even have a root yet.
 
2604
        if self._id_index is not None:
 
2605
            self._add_to_id_index(self._id_index, entry[0])
2394
2606
 
2395
2607
    def set_parent_trees(self, trees, ghosts):
2396
2608
        """Set the parent trees for the dirstate.
2441
2653
        parent_trees = [tree for rev_id, tree in trees if rev_id not in ghosts]
2442
2654
        # how many trees do we end up with
2443
2655
        parent_count = len(parent_trees)
 
2656
        st = static_tuple.StaticTuple
2444
2657
 
2445
2658
        # one: the current tree
2446
2659
        for entry in self._iter_entries():
2463
2676
            # the suffix is from tree_index+1:parent_count+1.
2464
2677
            new_location_suffix = [DirState.NULL_PARENT_DETAILS] * (parent_count - tree_index)
2465
2678
            # now stitch in all the entries from this tree
2466
 
            for path, entry in tree.inventory.iter_entries_by_dir():
 
2679
            last_dirname = None
 
2680
            for path, entry in tree.iter_entries_by_dir():
2467
2681
                # here we process each trees details for each item in the tree.
2468
2682
                # we first update any existing entries for the id at other paths,
2469
2683
                # then we either create or update the entry for the id at the
2476
2690
                file_id = entry.file_id
2477
2691
                path_utf8 = path.encode('utf8')
2478
2692
                dirname, basename = osutils.split(path_utf8)
2479
 
                new_entry_key = (dirname, basename, file_id)
 
2693
                if dirname == last_dirname:
 
2694
                    # Try to re-use objects as much as possible
 
2695
                    dirname = last_dirname
 
2696
                else:
 
2697
                    last_dirname = dirname
 
2698
                new_entry_key = st(dirname, basename, file_id)
2480
2699
                # tree index consistency: All other paths for this id in this tree
2481
2700
                # index must point to the correct path.
2482
 
                for entry_key in id_index.get(file_id, ()):
 
2701
                entry_keys = id_index.get(file_id, ())
 
2702
                for entry_key in entry_keys:
2483
2703
                    # TODO:PROFILING: It might be faster to just update
2484
2704
                    # rather than checking if we need to, and then overwrite
2485
2705
                    # the one we are located at.
2488
2708
                        # other trees, so put absent pointers there
2489
2709
                        # This is the vertical axis in the matrix, all pointing
2490
2710
                        # to the real path.
2491
 
                        by_path[entry_key][tree_index] = ('r', path_utf8, 0, False, '')
2492
 
                # by path consistency: Insert into an existing path record (trivial), or
2493
 
                # add a new one with relocation pointers for the other tree indexes.
2494
 
                entry_keys = id_index.get(file_id, ())
 
2711
                        by_path[entry_key][tree_index] = st('r', path_utf8, 0,
 
2712
                                                            False, '')
 
2713
                # by path consistency: Insert into an existing path record
 
2714
                # (trivial), or add a new one with relocation pointers for the
 
2715
                # other tree indexes.
2495
2716
                if new_entry_key in entry_keys:
2496
 
                    # there is already an entry where this data belongs, just insert it.
 
2717
                    # there is already an entry where this data belongs, just
 
2718
                    # insert it.
2497
2719
                    by_path[new_entry_key][tree_index] = \
2498
2720
                        self._inv_entry_to_details(entry)
2499
2721
                else:
2509
2731
                            new_details.append(DirState.NULL_PARENT_DETAILS)
2510
2732
                        else:
2511
2733
                            # grab any one entry, use it to find the right path.
2512
 
                            # TODO: optimise this to reduce memory use in highly
2513
 
                            # fragmented situations by reusing the relocation
2514
 
                            # records.
2515
2734
                            a_key = iter(entry_keys).next()
2516
2735
                            if by_path[a_key][lookup_index][0] in ('r', 'a'):
2517
 
                                # its a pointer or missing statement, use it as is.
 
2736
                                # its a pointer or missing statement, use it as
 
2737
                                # is.
2518
2738
                                new_details.append(by_path[a_key][lookup_index])
2519
2739
                            else:
2520
2740
                                # we have the right key, make a pointer to it.
2521
2741
                                real_path = ('/'.join(a_key[0:2])).strip('/')
2522
 
                                new_details.append(('r', real_path, 0, False, ''))
 
2742
                                new_details.append(st('r', real_path, 0, False,
 
2743
                                                      ''))
2523
2744
                    new_details.append(self._inv_entry_to_details(entry))
2524
2745
                    new_details.extend(new_location_suffix)
2525
2746
                    by_path[new_entry_key] = new_details
2531
2752
        self._entries_to_current_state(new_entries)
2532
2753
        self._parents = [rev_id for rev_id, tree in trees]
2533
2754
        self._ghosts = list(ghosts)
2534
 
        self._header_state = DirState.IN_MEMORY_MODIFIED
2535
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
2755
        self._mark_modified(header_modified=True)
2536
2756
        self._id_index = id_index
2537
2757
 
2538
2758
    def _sort_entries(self, entry_list):
2542
2762
        try to keep everything in sorted blocks all the time, but sometimes
2543
2763
        it's easier to sort after the fact.
2544
2764
        """
2545
 
        def _key(entry):
 
2765
        # When sorting, we usually have 10x more entries than directories. (69k
 
2766
        # total entries, 4k directories). So cache the results of splitting.
 
2767
        # Saving time and objects. Also, use StaticTuple to avoid putting all
 
2768
        # of these object into python's garbage collector.
 
2769
        split_dirs = {}
 
2770
        def _key(entry, _split_dirs=split_dirs, _st=static_tuple.StaticTuple):
2546
2771
            # sort by: directory parts, file name, file id
2547
 
            return entry[0][0].split('/'), entry[0][1], entry[0][2]
 
2772
            dirpath, fname, file_id = entry[0]
 
2773
            try:
 
2774
                split = _split_dirs[dirpath]
 
2775
            except KeyError:
 
2776
                split = _st.from_sequence(dirpath.split('/'))
 
2777
                _split_dirs[dirpath] = split
 
2778
            return _st(split, fname, file_id)
2548
2779
        return sorted(entry_list, key=_key)
2549
2780
 
2550
2781
    def set_state_from_inventory(self, new_inv):
2675
2906
                        current_old[0][1].decode('utf8'))
2676
2907
                self._make_absent(current_old)
2677
2908
                current_old = advance(old_iterator)
2678
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
2909
        self._mark_modified()
2679
2910
        self._id_index = None
2680
2911
        self._packed_stat_index = None
2681
2912
        if tracing:
2682
2913
            trace.mutter("set_state_from_inventory complete.")
2683
2914
 
 
2915
    def set_state_from_scratch(self, working_inv, parent_trees, parent_ghosts):
 
2916
        """Wipe the currently stored state and set it to something new.
 
2917
 
 
2918
        This is a hard-reset for the data we are working with.
 
2919
        """
 
2920
        # Technically, we really want a write lock, but until we write, we
 
2921
        # don't really need it.
 
2922
        self._requires_lock()
 
2923
        # root dir and root dir contents with no children. We have to have a
 
2924
        # root for set_state_from_inventory to work correctly.
 
2925
        empty_root = (('', '', inventory.ROOT_ID),
 
2926
                      [('d', '', 0, False, DirState.NULLSTAT)])
 
2927
        empty_tree_dirblocks = [('', [empty_root]), ('', [])]
 
2928
        self._set_data([], empty_tree_dirblocks)
 
2929
        self.set_state_from_inventory(working_inv)
 
2930
        self.set_parent_trees(parent_trees, parent_ghosts)
 
2931
 
2684
2932
    def _make_absent(self, current_old):
2685
2933
        """Mark current_old - an entry - as absent for tree 0.
2686
2934
 
2730
2978
            if update_tree_details[0][0] == 'a': # absent
2731
2979
                raise AssertionError('bad row %r' % (update_tree_details,))
2732
2980
            update_tree_details[0] = DirState.NULL_PARENT_DETAILS
2733
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
2981
        self._mark_modified()
2734
2982
        return last_reference
2735
2983
 
2736
2984
    def update_minimal(self, key, minikind, executable=False, fingerprint='',
2778
3026
                            # This entry has the same path (but a different id) as
2779
3027
                            # the new entry we're adding, and is present in ths
2780
3028
                            # tree.
2781
 
                            raise errors.InconsistentDelta(
 
3029
                            self._raise_invalid(
2782
3030
                                ("%s/%s" % key[0:2]).decode('utf8'), key[2],
2783
3031
                                "Attempt to add item at path already occupied by "
2784
3032
                                "id %r" % entry[0][2])
2905
3153
            if not present:
2906
3154
                self._dirblocks.insert(block_index, (subdir_key[0], []))
2907
3155
 
2908
 
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
3156
        self._mark_modified()
2909
3157
 
2910
3158
    def _maybe_remove_row(self, block, index, id_index):
2911
3159
        """Remove index if it is absent or relocated across the row.
3177
3425
    # If we have gotten this far, that means that we need to actually
3178
3426
    # process this entry.
3179
3427
    link_or_sha1 = None
 
3428
    worth_saving = True
3180
3429
    if minikind == 'f':
3181
3430
        executable = state._is_executable(stat_value.st_mode,
3182
3431
                                         saved_executable)
3198
3447
        else:
3199
3448
            entry[1][0] = ('f', '', stat_value.st_size,
3200
3449
                           executable, DirState.NULLSTAT)
 
3450
            worth_saving = False
3201
3451
    elif minikind == 'd':
3202
3452
        link_or_sha1 = None
3203
3453
        entry[1][0] = ('d', '', 0, False, packed_stat)
3209
3459
                state._get_block_entry_index(entry[0][0], entry[0][1], 0)
3210
3460
            state._ensure_block(block_index, entry_index,
3211
3461
                               osutils.pathjoin(entry[0][0], entry[0][1]))
 
3462
        else:
 
3463
            worth_saving = False
3212
3464
    elif minikind == 'l':
 
3465
        if saved_minikind == 'l':
 
3466
            worth_saving = False
3213
3467
        link_or_sha1 = state._read_link(abspath, saved_link_or_sha1)
3214
3468
        if state._cutoff_time is None:
3215
3469
            state._sha_cutoff_time()
3220
3474
        else:
3221
3475
            entry[1][0] = ('l', '', stat_value.st_size,
3222
3476
                           False, DirState.NULLSTAT)
3223
 
    state._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
3477
    if worth_saving:
 
3478
        state._mark_modified([entry])
3224
3479
    return link_or_sha1
3225
3480
 
3226
3481
 
3535
3790
            raise AssertionError("don't know how to compare "
3536
3791
                "source_minikind=%r, target_minikind=%r"
3537
3792
                % (source_minikind, target_minikind))
3538
 
            ## import pdb;pdb.set_trace()
3539
3793
        return None, None
3540
3794
 
3541
3795
    def __iter__(self):