~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/dirstate.py

(jameinel) Bug #581311,
 treat WSAECONNABORTED as ConnectionReset. (John A Meinel)

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006-2011 Canonical Ltd
 
1
# Copyright (C) 2006-2010 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
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
 
::
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
 
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
73
67
 
74
68
There may be multiple rows at the root, one per id present in the root, so the
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.
 
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.
103
92
 
104
93
Ordering:
105
94
 
106
 
The entries on disk and in memory are ordered according to the following keys::
 
95
The entries on disk and in memory are ordered according to the following keys:
107
96
 
108
97
    directory, as a list of components
109
98
    filename
110
99
    file-id
111
100
 
112
101
--- Format 1 had the following different definition: ---
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
 
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
122
108
 
123
109
PARENT ROW's are emitted for every parent that is not in the ghosts details
124
110
line. That is, if the parents are foo, bar, baz, and the ghosts are bar, then
149
135
----
150
136
 
151
137
Design priorities:
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
 
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
155
141
    is an example of this)
156
142
 
157
143
 
158
144
Locking:
159
 
 
160
145
 Eventually reuse dirstate objects across locks IFF the dirstate file has not
161
146
 been modified, but will require that we flush/ignore cached stat-hit data
162
147
 because we won't want to restat all files on disk just because a lock was
163
148
 acquired, yet we cannot trust the data after the previous lock was released.
164
149
 
165
 
Memory representation::
166
 
 
 
150
Memory representation:
167
151
 vector of all directories, and vector of the childen ?
168
152
   i.e.
169
153
     root_entrie = (direntry for root, [parent_direntries_for_root]),
183
167
    - What's the risk of error here? Once we have the base format being processed
184
168
      we should have a net win regardless of optimality. So we are going to
185
169
      go with what seems reasonable.
186
 
 
187
170
open questions:
188
171
 
189
172
Maybe we should do a test profile of the core structure - 10K simulated
282
265
        # return '%X.%X' % (int(st.st_mtime), st.st_mode)
283
266
 
284
267
 
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
 
 
296
268
class SHA1Provider(object):
297
269
    """An interface for getting sha1s of a file."""
298
270
 
383
355
    NOT_IN_MEMORY = 0
384
356
    IN_MEMORY_UNMODIFIED = 1
385
357
    IN_MEMORY_MODIFIED = 2
386
 
    IN_MEMORY_HASH_MODIFIED = 3 # Only hash-cache updates
387
358
 
388
359
    # A pack_stat (the x's) that is just noise and will never match the output
389
360
    # of base64 encode.
390
361
    NULLSTAT = 'x' * 32
391
 
    NULL_PARENT_DETAILS = static_tuple.StaticTuple('a', '', 0, False, '')
 
362
    NULL_PARENT_DETAILS = ('a', '', 0, False, '')
392
363
 
393
364
    HEADER_FORMAT_2 = '#bazaar dirstate flat format 2\n'
394
365
    HEADER_FORMAT_3 = '#bazaar dirstate flat format 3\n'
395
366
 
396
 
    def __init__(self, path, sha1_provider, worth_saving_limit=0):
 
367
    def __init__(self, path, sha1_provider):
397
368
        """Create a  DirState object.
398
369
 
399
370
        :param path: The path at which the dirstate file on disk should live.
400
371
        :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.
405
372
        """
406
373
        # _header_state and _dirblock_state represent the current state
407
374
        # of the dirstate metadata and the per-row data respectiely.
444
411
        # during commit.
445
412
        self._last_block_index = None
446
413
        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
451
414
 
452
415
    def __repr__(self):
453
416
        return "%s(%r)" % \
454
417
            (self.__class__.__name__, self._filename)
455
418
 
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
 
 
487
419
    def add(self, path, file_id, kind, stat, fingerprint):
488
420
        """Add a path to be tracked.
489
421
 
615
547
        if kind == 'directory':
616
548
           # insert a new dirblock
617
549
           self._ensure_block(block_index, entry_index, utf8path)
618
 
        self._mark_modified()
 
550
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
619
551
        if self._id_index:
620
552
            self._add_to_id_index(self._id_index, entry_key)
621
553
 
1087
1019
 
1088
1020
        self._ghosts = []
1089
1021
        self._parents = [parents[0]]
1090
 
        self._mark_modified(header_modified=True)
 
1022
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
1023
        self._header_state = DirState.IN_MEMORY_MODIFIED
1091
1024
 
1092
1025
    def _empty_parent_info(self):
1093
1026
        return [DirState.NULL_PARENT_DETAILS] * (len(self._parents) -
1222
1155
    def _fields_per_entry(self):
1223
1156
        """How many null separated fields should be in each entry row.
1224
1157
 
1225
 
        Each line now has an extra '\\n' field which is not used
 
1158
        Each line now has an extra '\n' field which is not used
1226
1159
        so we just skip over it
1227
 
 
1228
 
        entry size::
 
1160
        entry size:
1229
1161
            3 fields for the key
1230
1162
            + number of fields per tree_data (5) * tree count
1231
1163
            + newline
1344
1276
            raise
1345
1277
        return result
1346
1278
 
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
 
 
1355
1279
    def update_by_delta(self, delta):
1356
1280
        """Apply an inventory delta to the dirstate for tree 0
1357
1281
 
1375
1299
        new_ids = set()
1376
1300
        # This loop transforms the delta to single atomic operations that can
1377
1301
        # be executed and validated.
1378
 
        delta = sorted(self._check_delta_is_valid(delta), reverse=True)
1379
 
        for old_path, new_path, file_id, inv_entry in delta:
 
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):
1380
1309
            if (file_id in insertions) or (file_id in removals):
1381
 
                self._raise_invalid(old_path or new_path, file_id,
 
1310
                raise errors.InconsistentDelta(old_path or new_path, file_id,
1382
1311
                    "repeated file_id")
1383
1312
            if old_path is not None:
1384
1313
                old_path = old_path.encode('utf-8')
1387
1316
                new_ids.add(file_id)
1388
1317
            if new_path is not None:
1389
1318
                if inv_entry is None:
1390
 
                    self._raise_invalid(new_path, file_id,
 
1319
                    raise errors.InconsistentDelta(new_path, file_id,
1391
1320
                        "new_path with no entry")
1392
1321
                new_path = new_path.encode('utf-8')
1393
1322
                dirname_utf8, basename = osutils.split(new_path)
1434
1363
            # _get_entry raises BzrError when a request is inconsistent; we
1435
1364
            # want such errors to be shown as InconsistentDelta - and that 
1436
1365
            # fits the behaviour we trigger.
1437
 
            raise errors.InconsistentDeltaDelta(delta,
1438
 
                "error from _get_entry. %s" % (e,))
 
1366
            raise errors.InconsistentDeltaDelta(delta, "error from _get_entry.")
1439
1367
 
1440
1368
    def _apply_removals(self, removals):
1441
1369
        for file_id, path in sorted(removals, reverse=True,
1446
1374
            try:
1447
1375
                entry = self._dirblocks[block_i][1][entry_i]
1448
1376
            except IndexError:
1449
 
                self._raise_invalid(path, file_id,
 
1377
                self._changes_aborted = True
 
1378
                raise errors.InconsistentDelta(path, file_id,
1450
1379
                    "Wrong path for old path.")
1451
1380
            if not f_present or entry[1][0][0] in 'ar':
1452
 
                self._raise_invalid(path, file_id,
 
1381
                self._changes_aborted = True
 
1382
                raise errors.InconsistentDelta(path, file_id,
1453
1383
                    "Wrong path for old path.")
1454
1384
            if file_id != entry[0][2]:
1455
 
                self._raise_invalid(path, file_id,
 
1385
                self._changes_aborted = True
 
1386
                raise errors.InconsistentDelta(path, file_id,
1456
1387
                    "Attempt to remove path has wrong id - found %r."
1457
1388
                    % entry[0][2])
1458
1389
            self._make_absent(entry)
1468
1399
                # be due to it being in a parent tree, or a corrupt delta.
1469
1400
                for child_entry in self._dirblocks[block_i][1]:
1470
1401
                    if child_entry[1][0][0] not in ('r', 'a'):
1471
 
                        self._raise_invalid(path, entry[0][2],
 
1402
                        self._changes_aborted = True
 
1403
                        raise errors.InconsistentDelta(path, entry[0][2],
1472
1404
                            "The file id was deleted but its children were "
1473
1405
                            "not deleted.")
1474
1406
 
1478
1410
                self.update_minimal(key, minikind, executable, fingerprint,
1479
1411
                                    path_utf8=path_utf8)
1480
1412
        except errors.NotVersionedError:
1481
 
            self._raise_invalid(path_utf8.decode('utf8'), key[2],
 
1413
            self._changes_aborted = True
 
1414
            raise errors.InconsistentDelta(path_utf8.decode('utf8'), key[2],
1482
1415
                "Missing parent")
1483
1416
 
1484
1417
    def update_basis_by_delta(self, delta, new_revid):
1492
1425
        Note that an exception during the operation of this method will leave
1493
1426
        the dirstate in a corrupt state where it should not be saved.
1494
1427
 
 
1428
        Finally, we expect all changes to be synchronising the basis tree with
 
1429
        the working tree.
 
1430
 
1495
1431
        :param new_revid: The new revision id for the trees parent.
1496
1432
        :param delta: An inventory delta (see apply_inventory_delta) describing
1497
1433
            the changes from the current left most parent revision to new_revid.
1509
1445
 
1510
1446
        self._parents[0] = new_revid
1511
1447
 
1512
 
        delta = sorted(self._check_delta_is_valid(delta), reverse=True)
 
1448
        delta = sorted(delta, reverse=True)
1513
1449
        adds = []
1514
1450
        changes = []
1515
1451
        deletes = []
1536
1472
        new_ids = set()
1537
1473
        for old_path, new_path, file_id, inv_entry in delta:
1538
1474
            if inv_entry is not None and file_id != inv_entry.file_id:
1539
 
                self._raise_invalid(new_path, file_id,
 
1475
                raise errors.InconsistentDelta(new_path, file_id,
1540
1476
                    "mismatched entry file_id %r" % inv_entry)
1541
 
            if new_path is None:
1542
 
                new_path_utf8 = None
1543
 
            else:
 
1477
            if new_path is not None:
1544
1478
                if inv_entry is None:
1545
 
                    self._raise_invalid(new_path, file_id,
 
1479
                    raise errors.InconsistentDelta(new_path, file_id,
1546
1480
                        "new_path with no entry")
1547
1481
                new_path_utf8 = encode(new_path)
1548
1482
                # note the parent for validation
1550
1484
                if basename_utf8:
1551
1485
                    parents.add((dirname_utf8, inv_entry.parent_id))
1552
1486
            if old_path is None:
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,
 
1487
                adds.append((None, encode(new_path), file_id,
1558
1488
                    inv_to_entry(inv_entry), True))
1559
1489
                new_ids.add(file_id)
1560
1490
            elif new_path is None:
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:
 
1491
                deletes.append((encode(old_path), None, file_id, None, True))
 
1492
            elif (old_path, new_path) != root_only:
1574
1493
                # Renames:
1575
1494
                # Because renames must preserve their children we must have
1576
1495
                # processed all relocations and removes before hand. The sort
1586
1505
                self._update_basis_apply_deletes(deletes)
1587
1506
                deletes = []
1588
1507
                # Split into an add/delete pair recursively.
1589
 
                adds.append((old_path_utf8, new_path_utf8, file_id,
1590
 
                             inv_to_entry(inv_entry), False))
 
1508
                adds.append((None, new_path_utf8, file_id,
 
1509
                    inv_to_entry(inv_entry), False))
1591
1510
                # Expunge deletes that we've seen so that deleted/renamed
1592
1511
                # children of a rename directory are handled correctly.
1593
 
                new_deletes = reversed(list(
1594
 
                    self._iter_child_entries(1, old_path_utf8)))
 
1512
                new_deletes = reversed(list(self._iter_child_entries(1,
 
1513
                    encode(old_path))))
1595
1514
                # Remove the current contents of the tree at orig_path, and
1596
1515
                # reinsert at the correct new path.
1597
1516
                for entry in new_deletes:
1598
 
                    child_dirname, child_basename, child_file_id = entry[0]
1599
 
                    if child_dirname:
1600
 
                        source_path = child_dirname + '/' + child_basename
 
1517
                    if entry[0][0]:
 
1518
                        source_path = entry[0][0] + '/' + entry[0][1]
1601
1519
                    else:
1602
 
                        source_path = child_basename
 
1520
                        source_path = entry[0][1]
1603
1521
                    if new_path_utf8:
1604
1522
                        target_path = new_path_utf8 + source_path[len(old_path):]
1605
1523
                    else:
1606
1524
                        if old_path == '':
1607
1525
                            raise AssertionError("cannot rename directory to"
1608
 
                                                 " itself")
 
1526
                                " itself")
1609
1527
                        target_path = source_path[len(old_path) + 1:]
1610
1528
                    adds.append((None, target_path, entry[0][2], entry[1][1], False))
1611
1529
                    deletes.append(
1612
1530
                        (source_path, target_path, entry[0][2], None, False))
1613
 
                deletes.append((old_path_utf8, new_path, file_id, 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)))
1614
1538
        self._check_delta_ids_absent(new_ids, delta, 1)
1615
1539
        try:
1616
1540
            # Finish expunging deletes/first half of renames.
1626
1550
            if 'integrity error' not in str(e):
1627
1551
                raise
1628
1552
            # _get_entry raises BzrError when a request is inconsistent; we
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,))
 
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.")
1633
1558
 
1634
 
        self._mark_modified(header_modified=True)
 
1559
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
 
1560
        self._header_state = DirState.IN_MEMORY_MODIFIED
1635
1561
        self._id_index = None
1636
1562
        return
1637
1563
 
1651
1577
                if entry[0][2] != file_id:
1652
1578
                    # Different file_id, so not what we want.
1653
1579
                    continue
1654
 
                self._raise_invalid(("%s/%s" % key[0:2]).decode('utf8'), file_id,
 
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,
1655
1584
                    "This file_id is new in the delta but already present in "
1656
1585
                    "the target")
1657
1586
 
1658
 
    def _raise_invalid(self, path, file_id, reason):
1659
 
        self._changes_aborted = True
1660
 
        raise errors.InconsistentDelta(path, file_id, reason)
1661
 
 
1662
1587
    def _update_basis_apply_adds(self, adds):
1663
1588
        """Apply a sequence of adds to tree 1 during update_basis_by_delta.
1664
1589
 
1672
1597
        """
1673
1598
        # Adds are accumulated partly from renames, so can be in any input
1674
1599
        # order - sort it.
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])
 
1600
        adds.sort()
1679
1601
        # adds is now in lexographic order, which places all parents before
1680
1602
        # their children, so we can process it linearly.
1681
1603
        absent = 'ar'
1682
 
        st = static_tuple.StaticTuple
1683
1604
        for old_path, new_path, file_id, new_details, real_add in adds:
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)
 
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
1781
1620
 
1782
1621
    def _update_basis_apply_changes(self, changes):
1783
1622
        """Apply a sequence of changes to tree 1 during update_basis_by_delta.
1788
1627
        absent = 'ar'
1789
1628
        for old_path, new_path, file_id, new_details in changes:
1790
1629
            # the entry for this file_id must be in tree 0.
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')
 
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')
1795
1640
            entry[1][1] = new_details
1796
1641
 
1797
1642
    def _update_basis_apply_deletes(self, deletes):
1809
1654
        null = DirState.NULL_PARENT_DETAILS
1810
1655
        for old_path, new_path, file_id, _, real_delete in deletes:
1811
1656
            if real_delete != (new_path is None):
1812
 
                self._raise_invalid(old_path, file_id, "bad delete delta")
 
1657
                self._changes_aborted = True
 
1658
                raise AssertionError("bad delete delta")
1813
1659
            # the entry for this file_id must be in tree 1.
1814
1660
            dirname, basename = osutils.split(old_path)
1815
1661
            block_index, entry_index, dir_present, file_present = \
1816
1662
                self._get_block_entry_index(dirname, basename, 1)
1817
1663
            if not file_present:
1818
 
                self._raise_invalid(old_path, file_id,
 
1664
                self._changes_aborted = True
 
1665
                raise errors.InconsistentDelta(old_path, file_id,
1819
1666
                    'basis tree does not contain removed entry')
1820
1667
            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]
1823
1668
            if entry[0][2] != file_id:
1824
 
                self._raise_invalid(old_path, file_id,
 
1669
                self._changes_aborted = True
 
1670
                raise errors.InconsistentDelta(old_path, file_id,
1825
1671
                    'mismatched file_id in tree 1')
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
 
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.')
1846
1678
                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]
1859
1679
            else:
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.")
 
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
1873
1695
 
1874
1696
    def _after_delta_check_parents(self, parents, index):
1875
1697
        """Check that parents required by the delta are all intact.
1884
1706
            # has the right file id.
1885
1707
            entry = self._get_entry(index, file_id, dirname_utf8)
1886
1708
            if entry[1] is None:
1887
 
                self._raise_invalid(dirname_utf8.decode('utf8'),
 
1709
                self._changes_aborted = True
 
1710
                raise errors.InconsistentDelta(dirname_utf8.decode('utf8'),
1888
1711
                    file_id, "This parent is not present.")
1889
1712
            # Parents of things must be directories
1890
1713
            if entry[1][index][0] != 'd':
1891
 
                self._raise_invalid(dirname_utf8.decode('utf8'),
 
1714
                self._changes_aborted = True
 
1715
                raise errors.InconsistentDelta(dirname_utf8.decode('utf8'),
1892
1716
                    file_id, "This parent is not a directory.")
1893
1717
 
1894
1718
    def _observed_sha1(self, entry, sha1, stat_value,
1910
1734
                self._sha_cutoff_time()
1911
1735
            if (stat_value.st_mtime < self._cutoff_time
1912
1736
                and stat_value.st_ctime < self._cutoff_time):
1913
 
                entry[1][0] = ('f', sha1, stat_value.st_size, entry[1][0][3],
1914
 
                               packed_stat)
1915
 
                self._mark_modified([entry])
 
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
1916
1740
 
1917
1741
    def _sha_cutoff_time(self):
1918
1742
        """Return cutoff time.
1976
1800
        """Serialise the entire dirstate to a sequence of lines."""
1977
1801
        if (self._header_state == DirState.IN_MEMORY_UNMODIFIED and
1978
1802
            self._dirblock_state == DirState.IN_MEMORY_UNMODIFIED):
1979
 
            # read what's on disk.
 
1803
            # read whats on disk.
1980
1804
            self._state_file.seek(0)
1981
1805
            return self._state_file.readlines()
1982
1806
        lines = []
1983
1807
        lines.append(self._get_parents_line(self.get_parent_ids()))
1984
1808
        lines.append(self._get_ghosts_line(self._ghosts))
1985
 
        lines.extend(self._get_entry_lines())
 
1809
        # append the root line which is special cased
 
1810
        lines.extend(map(self._entry_to_line, self._iter_entries()))
1986
1811
        return self._get_output_lines(lines)
1987
1812
 
1988
1813
    def _get_ghosts_line(self, ghost_ids):
1993
1818
        """Create a line for the state file for parents information."""
1994
1819
        return '\0'.join([str(len(parent_ids))] + parent_ids)
1995
1820
 
1996
 
    def _get_entry_lines(self):
1997
 
        """Create lines for entries."""
1998
 
        return map(self._entry_to_line, self._iter_entries())
1999
 
 
2000
1821
    def _get_fields_to_entry(self):
2001
1822
        """Get a function which converts entry fields into a entry record.
2002
1823
 
2120
1941
            entry_index += 1
2121
1942
        return block_index, entry_index, True, False
2122
1943
 
2123
 
    def _get_entry(self, tree_index, fileid_utf8=None, path_utf8=None,
2124
 
                   include_deleted=False):
 
1944
    def _get_entry(self, tree_index, fileid_utf8=None, path_utf8=None, include_deleted=False):
2125
1945
        """Get the dirstate entry for path in tree tree_index.
2126
1946
 
2127
1947
        If either file_id or path is supplied, it is used as the key to lookup.
2269
2089
            executable = False
2270
2090
        else:
2271
2091
            raise Exception("can't pack %s" % inv_entry)
2272
 
        return static_tuple.StaticTuple(minikind, fingerprint, size,
2273
 
                                        executable, tree_data)
 
2092
        return (minikind, fingerprint, size, executable, tree_data)
2274
2093
 
2275
2094
    def _iter_child_entries(self, tree_index, path_utf8):
2276
2095
        """Iterate over all the entries that are children of path_utf.
2326
2145
 
2327
2146
    def _get_id_index(self):
2328
2147
        """Get an id index of self._dirblocks.
2329
 
 
 
2148
        
2330
2149
        This maps from file_id => [(directory, name, file_id)] entries where
2331
2150
        that file_id appears in one of the trees.
2332
2151
        """
2346
2165
        # such, we use a simple tuple, and do our own uniqueness checks. While
2347
2166
        # the 'in' check is O(N) since N is nicely bounded it shouldn't ever
2348
2167
        # cause quadratic failure.
 
2168
        # TODO: This should use StaticTuple
2349
2169
        file_id = entry_key[2]
2350
2170
        entry_key = static_tuple.StaticTuple.from_sequence(entry_key)
2351
2171
        if file_id not in id_index:
2391
2211
        """The number of parent entries in each record row."""
2392
2212
        return len(self._parents) - len(self._ghosts)
2393
2213
 
2394
 
    @classmethod
2395
 
    def on_file(cls, path, sha1_provider=None, worth_saving_limit=0):
 
2214
    @staticmethod
 
2215
    def on_file(path, sha1_provider=None):
2396
2216
        """Construct a DirState on the file at path "path".
2397
2217
 
2398
2218
        :param path: The path at which the dirstate file on disk should live.
2399
2219
        :param sha1_provider: an object meeting the SHA1Provider interface.
2400
2220
            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.
2404
2221
        :return: An unlocked DirState object, associated with the given path.
2405
2222
        """
2406
2223
        if sha1_provider is None:
2407
2224
            sha1_provider = DefaultSHA1Provider()
2408
 
        result = cls(path, sha1_provider,
2409
 
                     worth_saving_limit=worth_saving_limit)
 
2225
        result = DirState(path, sha1_provider)
2410
2226
        return result
2411
2227
 
2412
2228
    def _read_dirblocks_if_needed(self):
2504
2320
            trace.mutter('Not saving DirState because '
2505
2321
                    '_changes_aborted is set.')
2506
2322
            return
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():
 
2323
        if (self._header_state == DirState.IN_MEMORY_MODIFIED or
 
2324
            self._dirblock_state == DirState.IN_MEMORY_MODIFIED):
 
2325
 
2512
2326
            grabbed_write_lock = False
2513
2327
            if self._lock_state != 'w':
2514
2328
                grabbed_write_lock, new_lock = self._lock_token.temporary_write_lock()
2522
2336
                    # We couldn't grab a write lock, so we switch back to a read one
2523
2337
                    return
2524
2338
            try:
2525
 
                lines = self.get_lines()
2526
2339
                self._state_file.seek(0)
2527
 
                self._state_file.writelines(lines)
 
2340
                self._state_file.writelines(self.get_lines())
2528
2341
                self._state_file.truncate()
2529
2342
                self._state_file.flush()
2530
 
                self._mark_unmodified()
 
2343
                self._header_state = DirState.IN_MEMORY_UNMODIFIED
 
2344
                self._dirblock_state = DirState.IN_MEMORY_UNMODIFIED
2531
2345
            finally:
2532
2346
                if grabbed_write_lock:
2533
2347
                    self._lock_token = self._lock_token.restore_read_lock()
2536
2350
                    #       not changed contents. Since restore_read_lock may
2537
2351
                    #       not be an atomic operation.
2538
2352
 
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
 
 
2559
2353
    def _set_data(self, parent_ids, dirblocks):
2560
2354
        """Set the full dirstate data in memory.
2561
2355
 
2569
2363
        """
2570
2364
        # our memory copy is now authoritative.
2571
2365
        self._dirblocks = dirblocks
2572
 
        self._mark_modified(header_modified=True)
 
2366
        self._header_state = DirState.IN_MEMORY_MODIFIED
 
2367
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
2573
2368
        self._parents = list(parent_ids)
2574
2369
        self._id_index = None
2575
2370
        self._packed_stat_index = None
2595
2390
        self._make_absent(entry)
2596
2391
        self.update_minimal(('', '', new_id), 'd',
2597
2392
            path_utf8='', packed_stat=entry[1][0][4])
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])
 
2393
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
2606
2394
 
2607
2395
    def set_parent_trees(self, trees, ghosts):
2608
2396
        """Set the parent trees for the dirstate.
2653
2441
        parent_trees = [tree for rev_id, tree in trees if rev_id not in ghosts]
2654
2442
        # how many trees do we end up with
2655
2443
        parent_count = len(parent_trees)
2656
 
        st = static_tuple.StaticTuple
2657
2444
 
2658
2445
        # one: the current tree
2659
2446
        for entry in self._iter_entries():
2676
2463
            # the suffix is from tree_index+1:parent_count+1.
2677
2464
            new_location_suffix = [DirState.NULL_PARENT_DETAILS] * (parent_count - tree_index)
2678
2465
            # now stitch in all the entries from this tree
2679
 
            last_dirname = None
2680
 
            for path, entry in tree.iter_entries_by_dir():
 
2466
            for path, entry in tree.inventory.iter_entries_by_dir():
2681
2467
                # here we process each trees details for each item in the tree.
2682
2468
                # we first update any existing entries for the id at other paths,
2683
2469
                # then we either create or update the entry for the id at the
2690
2476
                file_id = entry.file_id
2691
2477
                path_utf8 = path.encode('utf8')
2692
2478
                dirname, basename = osutils.split(path_utf8)
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)
 
2479
                new_entry_key = (dirname, basename, file_id)
2699
2480
                # tree index consistency: All other paths for this id in this tree
2700
2481
                # index must point to the correct path.
2701
 
                entry_keys = id_index.get(file_id, ())
2702
 
                for entry_key in entry_keys:
 
2482
                for entry_key in id_index.get(file_id, ()):
2703
2483
                    # TODO:PROFILING: It might be faster to just update
2704
2484
                    # rather than checking if we need to, and then overwrite
2705
2485
                    # the one we are located at.
2708
2488
                        # other trees, so put absent pointers there
2709
2489
                        # This is the vertical axis in the matrix, all pointing
2710
2490
                        # to the real path.
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.
 
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, ())
2716
2495
                if new_entry_key in entry_keys:
2717
 
                    # there is already an entry where this data belongs, just
2718
 
                    # insert it.
 
2496
                    # there is already an entry where this data belongs, just insert it.
2719
2497
                    by_path[new_entry_key][tree_index] = \
2720
2498
                        self._inv_entry_to_details(entry)
2721
2499
                else:
2731
2509
                            new_details.append(DirState.NULL_PARENT_DETAILS)
2732
2510
                        else:
2733
2511
                            # 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.
2734
2515
                            a_key = iter(entry_keys).next()
2735
2516
                            if by_path[a_key][lookup_index][0] in ('r', 'a'):
2736
 
                                # its a pointer or missing statement, use it as
2737
 
                                # is.
 
2517
                                # its a pointer or missing statement, use it as is.
2738
2518
                                new_details.append(by_path[a_key][lookup_index])
2739
2519
                            else:
2740
2520
                                # we have the right key, make a pointer to it.
2741
2521
                                real_path = ('/'.join(a_key[0:2])).strip('/')
2742
 
                                new_details.append(st('r', real_path, 0, False,
2743
 
                                                      ''))
 
2522
                                new_details.append(('r', real_path, 0, False, ''))
2744
2523
                    new_details.append(self._inv_entry_to_details(entry))
2745
2524
                    new_details.extend(new_location_suffix)
2746
2525
                    by_path[new_entry_key] = new_details
2752
2531
        self._entries_to_current_state(new_entries)
2753
2532
        self._parents = [rev_id for rev_id, tree in trees]
2754
2533
        self._ghosts = list(ghosts)
2755
 
        self._mark_modified(header_modified=True)
 
2534
        self._header_state = DirState.IN_MEMORY_MODIFIED
 
2535
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
2756
2536
        self._id_index = id_index
2757
2537
 
2758
2538
    def _sort_entries(self, entry_list):
2762
2542
        try to keep everything in sorted blocks all the time, but sometimes
2763
2543
        it's easier to sort after the fact.
2764
2544
        """
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):
 
2545
        def _key(entry):
2771
2546
            # sort by: directory parts, file name, file id
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)
 
2547
            return entry[0][0].split('/'), entry[0][1], entry[0][2]
2779
2548
        return sorted(entry_list, key=_key)
2780
2549
 
2781
2550
    def set_state_from_inventory(self, new_inv):
2906
2675
                        current_old[0][1].decode('utf8'))
2907
2676
                self._make_absent(current_old)
2908
2677
                current_old = advance(old_iterator)
2909
 
        self._mark_modified()
 
2678
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
2910
2679
        self._id_index = None
2911
2680
        self._packed_stat_index = None
2912
2681
        if tracing:
2913
2682
            trace.mutter("set_state_from_inventory complete.")
2914
2683
 
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
 
 
2932
2684
    def _make_absent(self, current_old):
2933
2685
        """Mark current_old - an entry - as absent for tree 0.
2934
2686
 
2978
2730
            if update_tree_details[0][0] == 'a': # absent
2979
2731
                raise AssertionError('bad row %r' % (update_tree_details,))
2980
2732
            update_tree_details[0] = DirState.NULL_PARENT_DETAILS
2981
 
        self._mark_modified()
 
2733
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
2982
2734
        return last_reference
2983
2735
 
2984
2736
    def update_minimal(self, key, minikind, executable=False, fingerprint='',
3026
2778
                            # This entry has the same path (but a different id) as
3027
2779
                            # the new entry we're adding, and is present in ths
3028
2780
                            # tree.
3029
 
                            self._raise_invalid(
 
2781
                            raise errors.InconsistentDelta(
3030
2782
                                ("%s/%s" % key[0:2]).decode('utf8'), key[2],
3031
2783
                                "Attempt to add item at path already occupied by "
3032
2784
                                "id %r" % entry[0][2])
3153
2905
            if not present:
3154
2906
                self._dirblocks.insert(block_index, (subdir_key[0], []))
3155
2907
 
3156
 
        self._mark_modified()
 
2908
        self._dirblock_state = DirState.IN_MEMORY_MODIFIED
3157
2909
 
3158
2910
    def _maybe_remove_row(self, block, index, id_index):
3159
2911
        """Remove index if it is absent or relocated across the row.
3425
3177
    # If we have gotten this far, that means that we need to actually
3426
3178
    # process this entry.
3427
3179
    link_or_sha1 = None
3428
 
    worth_saving = True
3429
3180
    if minikind == 'f':
3430
3181
        executable = state._is_executable(stat_value.st_mode,
3431
3182
                                         saved_executable)
3447
3198
        else:
3448
3199
            entry[1][0] = ('f', '', stat_value.st_size,
3449
3200
                           executable, DirState.NULLSTAT)
3450
 
            worth_saving = False
3451
3201
    elif minikind == 'd':
3452
3202
        link_or_sha1 = None
3453
3203
        entry[1][0] = ('d', '', 0, False, packed_stat)
3459
3209
                state._get_block_entry_index(entry[0][0], entry[0][1], 0)
3460
3210
            state._ensure_block(block_index, entry_index,
3461
3211
                               osutils.pathjoin(entry[0][0], entry[0][1]))
3462
 
        else:
3463
 
            worth_saving = False
3464
3212
    elif minikind == 'l':
3465
 
        if saved_minikind == 'l':
3466
 
            worth_saving = False
3467
3213
        link_or_sha1 = state._read_link(abspath, saved_link_or_sha1)
3468
3214
        if state._cutoff_time is None:
3469
3215
            state._sha_cutoff_time()
3474
3220
        else:
3475
3221
            entry[1][0] = ('l', '', stat_value.st_size,
3476
3222
                           False, DirState.NULLSTAT)
3477
 
    if worth_saving:
3478
 
        state._mark_modified([entry])
 
3223
    state._dirblock_state = DirState.IN_MEMORY_MODIFIED
3479
3224
    return link_or_sha1
3480
3225
 
3481
3226
 
3790
3535
            raise AssertionError("don't know how to compare "
3791
3536
                "source_minikind=%r, target_minikind=%r"
3792
3537
                % (source_minikind, target_minikind))
 
3538
            ## import pdb;pdb.set_trace()
3793
3539
        return None, None
3794
3540
 
3795
3541
    def __iter__(self):