/brz/remove-bazaar

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

« back to all changes in this revision

Viewing changes to bzrlib/tests/test_dirstate.py

  • Committer: John Arbash Meinel
  • Date: 2007-03-14 20:15:52 UTC
  • mto: (2353.4.2 locking)
  • mto: This revision was merged to the branch mainline in revision 2360.
  • Revision ID: john@arbash-meinel.com-20070314201552-bjtfua57456dviep
Update the lock code and test code so that if more than one
lock implementation is available, they will both be tested.

It is quite a bit of overhead, for a case where we are likely to only have 1
real lock implementation per platform, but hey, for now we have 2.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006-2010 Canonical Ltd
 
1
# Copyright (C) 2006, 2007 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
17
"""Tests of the dirstate functionality being built for WorkingTreeFormat4."""
18
18
 
19
19
import bisect
20
20
import os
 
21
import time
21
22
 
22
23
from bzrlib import (
23
24
    dirstate,
24
25
    errors,
25
 
    inventory,
26
 
    memorytree,
27
26
    osutils,
28
 
    revision as _mod_revision,
29
 
    tests,
30
27
    )
31
 
from bzrlib.tests import test_osutils
 
28
from bzrlib.memorytree import MemoryTree
 
29
from bzrlib.tests import TestCase, TestCaseWithTransport
32
30
 
33
31
 
34
32
# TODO:
44
42
# set_path_id  setting id when state is in memory modified
45
43
 
46
44
 
47
 
def load_tests(basic_tests, module, loader):
48
 
    suite = loader.suiteClass()
49
 
    dir_reader_tests, remaining_tests = tests.split_suite_by_condition(
50
 
        basic_tests, tests.condition_isinstance(TestCaseWithDirState))
51
 
    tests.multiply_tests(dir_reader_tests,
52
 
                         test_osutils.dir_reader_scenarios(), suite)
53
 
    suite.addTest(remaining_tests)
54
 
    return suite
55
 
 
56
 
 
57
 
class TestCaseWithDirState(tests.TestCaseWithTransport):
 
45
class TestCaseWithDirState(TestCaseWithTransport):
58
46
    """Helper functions for creating DirState objects with various content."""
59
47
 
60
 
    # Set by load_tests
61
 
    _dir_reader_class = None
62
 
    _native_to_unicode = None # Not used yet
63
 
 
64
 
    def setUp(self):
65
 
        tests.TestCaseWithTransport.setUp(self)
66
 
 
67
 
        self.overrideAttr(osutils,
68
 
                          '_selected_dir_reader', self._dir_reader_class())
69
 
 
70
48
    def create_empty_dirstate(self):
71
49
        """Return a locked but empty dirstate"""
72
50
        state = dirstate.DirState.initialize('dirstate')
119
97
         b/g      g-file
120
98
         b/h\xc3\xa5  h-\xc3\xa5-file  #This is u'\xe5' encoded into utf-8
121
99
 
122
 
        Notice that a/e is an empty directory.
123
 
 
124
 
        :return: The dirstate, still write-locked.
 
100
        # Notice that a/e is an empty directory.
125
101
        """
126
102
        packed_stat = 'AAAAREUHaIpFB2iKAAADAQAtkqUAAIGk'
127
103
        null_sha = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
180
156
        """
181
157
        # The state should already be write locked, since we just had to do
182
158
        # some operation to get here.
183
 
        self.assertTrue(state._lock_token is not None)
 
159
        assert state._lock_token is not None
184
160
        try:
185
161
            self.assertEqual(expected_result[0],  state.get_parent_ids())
186
162
            # there should be no ghosts in this tree.
190
166
            state.save()
191
167
        finally:
192
168
            state.unlock()
193
 
        del state
 
169
        del state # Callers should unlock
194
170
        state = dirstate.DirState.on_file('dirstate')
195
171
        state.lock_read()
196
172
        try:
198
174
        finally:
199
175
            state.unlock()
200
176
 
201
 
    def create_basic_dirstate(self):
202
 
        """Create a dirstate with a few files and directories.
203
 
 
204
 
            a
205
 
            b/
206
 
              c
207
 
              d/
208
 
                e
209
 
            b-c
210
 
            f
211
 
        """
212
 
        tree = self.make_branch_and_tree('tree')
213
 
        paths = ['a', 'b/', 'b/c', 'b/d/', 'b/d/e', 'b-c', 'f']
214
 
        file_ids = ['a-id', 'b-id', 'c-id', 'd-id', 'e-id', 'b-c-id', 'f-id']
215
 
        self.build_tree(['tree/' + p for p in paths])
216
 
        tree.set_root_id('TREE_ROOT')
217
 
        tree.add([p.rstrip('/') for p in paths], file_ids)
218
 
        tree.commit('initial', rev_id='rev-1')
219
 
        revision_id = 'rev-1'
220
 
        # a_packed_stat = dirstate.pack_stat(os.stat('tree/a'))
221
 
        t = self.get_transport('tree')
222
 
        a_text = t.get_bytes('a')
223
 
        a_sha = osutils.sha_string(a_text)
224
 
        a_len = len(a_text)
225
 
        # b_packed_stat = dirstate.pack_stat(os.stat('tree/b'))
226
 
        # c_packed_stat = dirstate.pack_stat(os.stat('tree/b/c'))
227
 
        c_text = t.get_bytes('b/c')
228
 
        c_sha = osutils.sha_string(c_text)
229
 
        c_len = len(c_text)
230
 
        # d_packed_stat = dirstate.pack_stat(os.stat('tree/b/d'))
231
 
        # e_packed_stat = dirstate.pack_stat(os.stat('tree/b/d/e'))
232
 
        e_text = t.get_bytes('b/d/e')
233
 
        e_sha = osutils.sha_string(e_text)
234
 
        e_len = len(e_text)
235
 
        b_c_text = t.get_bytes('b-c')
236
 
        b_c_sha = osutils.sha_string(b_c_text)
237
 
        b_c_len = len(b_c_text)
238
 
        # f_packed_stat = dirstate.pack_stat(os.stat('tree/f'))
239
 
        f_text = t.get_bytes('f')
240
 
        f_sha = osutils.sha_string(f_text)
241
 
        f_len = len(f_text)
242
 
        null_stat = dirstate.DirState.NULLSTAT
243
 
        expected = {
244
 
            '':(('', '', 'TREE_ROOT'), [
245
 
                  ('d', '', 0, False, null_stat),
246
 
                  ('d', '', 0, False, revision_id),
247
 
                ]),
248
 
            'a':(('', 'a', 'a-id'), [
249
 
                   ('f', '', 0, False, null_stat),
250
 
                   ('f', a_sha, a_len, False, revision_id),
251
 
                 ]),
252
 
            'b':(('', 'b', 'b-id'), [
253
 
                  ('d', '', 0, False, null_stat),
254
 
                  ('d', '', 0, False, revision_id),
255
 
                 ]),
256
 
            'b/c':(('b', 'c', 'c-id'), [
257
 
                    ('f', '', 0, False, null_stat),
258
 
                    ('f', c_sha, c_len, False, revision_id),
259
 
                   ]),
260
 
            'b/d':(('b', 'd', 'd-id'), [
261
 
                    ('d', '', 0, False, null_stat),
262
 
                    ('d', '', 0, False, revision_id),
263
 
                   ]),
264
 
            'b/d/e':(('b/d', 'e', 'e-id'), [
265
 
                      ('f', '', 0, False, null_stat),
266
 
                      ('f', e_sha, e_len, False, revision_id),
267
 
                     ]),
268
 
            'b-c':(('', 'b-c', 'b-c-id'), [
269
 
                      ('f', '', 0, False, null_stat),
270
 
                      ('f', b_c_sha, b_c_len, False, revision_id),
271
 
                     ]),
272
 
            'f':(('', 'f', 'f-id'), [
273
 
                  ('f', '', 0, False, null_stat),
274
 
                  ('f', f_sha, f_len, False, revision_id),
275
 
                 ]),
276
 
        }
277
 
        state = dirstate.DirState.from_tree(tree, 'dirstate')
278
 
        try:
279
 
            state.save()
280
 
        finally:
281
 
            state.unlock()
282
 
        # Use a different object, to make sure nothing is pre-cached in memory.
283
 
        state = dirstate.DirState.on_file('dirstate')
284
 
        state.lock_read()
285
 
        self.addCleanup(state.unlock)
286
 
        self.assertEqual(dirstate.DirState.NOT_IN_MEMORY,
287
 
                         state._dirblock_state)
288
 
        # This is code is only really tested if we actually have to make more
289
 
        # than one read, so set the page size to something smaller.
290
 
        # We want it to contain about 2.2 records, so that we have a couple
291
 
        # records that we can read per attempt
292
 
        state._bisect_page_size = 200
293
 
        return tree, state, expected
294
 
 
295
 
    def create_duplicated_dirstate(self):
296
 
        """Create a dirstate with a deleted and added entries.
297
 
 
298
 
        This grabs a basic_dirstate, and then removes and re adds every entry
299
 
        with a new file id.
300
 
        """
301
 
        tree, state, expected = self.create_basic_dirstate()
302
 
        # Now we will just remove and add every file so we get an extra entry
303
 
        # per entry. Unversion in reverse order so we handle subdirs
304
 
        tree.unversion(['f-id', 'b-c-id', 'e-id', 'd-id', 'c-id', 'b-id', 'a-id'])
305
 
        tree.add(['a', 'b', 'b/c', 'b/d', 'b/d/e', 'b-c', 'f'],
306
 
                 ['a-id2', 'b-id2', 'c-id2', 'd-id2', 'e-id2', 'b-c-id2', 'f-id2'])
307
 
 
308
 
        # Update the expected dictionary.
309
 
        for path in ['a', 'b', 'b/c', 'b/d', 'b/d/e', 'b-c', 'f']:
310
 
            orig = expected[path]
311
 
            path2 = path + '2'
312
 
            # This record was deleted in the current tree
313
 
            expected[path] = (orig[0], [dirstate.DirState.NULL_PARENT_DETAILS,
314
 
                                        orig[1][1]])
315
 
            new_key = (orig[0][0], orig[0][1], orig[0][2]+'2')
316
 
            # And didn't exist in the basis tree
317
 
            expected[path2] = (new_key, [orig[1][0],
318
 
                                         dirstate.DirState.NULL_PARENT_DETAILS])
319
 
 
320
 
        # We will replace the 'dirstate' file underneath 'state', but that is
321
 
        # okay as lock as we unlock 'state' first.
322
 
        state.unlock()
323
 
        try:
324
 
            new_state = dirstate.DirState.from_tree(tree, 'dirstate')
325
 
            try:
326
 
                new_state.save()
327
 
            finally:
328
 
                new_state.unlock()
329
 
        finally:
330
 
            # But we need to leave state in a read-lock because we already have
331
 
            # a cleanup scheduled
332
 
            state.lock_read()
333
 
        return tree, state, expected
334
 
 
335
 
    def create_renamed_dirstate(self):
336
 
        """Create a dirstate with a few internal renames.
337
 
 
338
 
        This takes the basic dirstate, and moves the paths around.
339
 
        """
340
 
        tree, state, expected = self.create_basic_dirstate()
341
 
        # Rename a file
342
 
        tree.rename_one('a', 'b/g')
343
 
        # And a directory
344
 
        tree.rename_one('b/d', 'h')
345
 
 
346
 
        old_a = expected['a']
347
 
        expected['a'] = (old_a[0], [('r', 'b/g', 0, False, ''), old_a[1][1]])
348
 
        expected['b/g'] = (('b', 'g', 'a-id'), [old_a[1][0],
349
 
                                                ('r', 'a', 0, False, '')])
350
 
        old_d = expected['b/d']
351
 
        expected['b/d'] = (old_d[0], [('r', 'h', 0, False, ''), old_d[1][1]])
352
 
        expected['h'] = (('', 'h', 'd-id'), [old_d[1][0],
353
 
                                             ('r', 'b/d', 0, False, '')])
354
 
 
355
 
        old_e = expected['b/d/e']
356
 
        expected['b/d/e'] = (old_e[0], [('r', 'h/e', 0, False, ''),
357
 
                             old_e[1][1]])
358
 
        expected['h/e'] = (('h', 'e', 'e-id'), [old_e[1][0],
359
 
                                                ('r', 'b/d/e', 0, False, '')])
360
 
 
361
 
        state.unlock()
362
 
        try:
363
 
            new_state = dirstate.DirState.from_tree(tree, 'dirstate')
364
 
            try:
365
 
                new_state.save()
366
 
            finally:
367
 
                new_state.unlock()
368
 
        finally:
369
 
            state.lock_read()
370
 
        return tree, state, expected
371
 
 
372
177
 
373
178
class TestTreeToDirState(TestCaseWithDirState):
374
179
 
377
182
        # There are no files on disk and no parents
378
183
        tree = self.make_branch_and_tree('tree')
379
184
        expected_result = ([], [
380
 
            (('', '', tree.get_root_id()), # common details
 
185
            (('', '', tree.path2id('')), # common details
381
186
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
382
187
             ])])
383
188
        state = dirstate.DirState.from_tree(tree, 'dirstate')
390
195
        rev_id = tree.commit('first post').encode('utf8')
391
196
        root_stat_pack = dirstate.pack_stat(os.stat(tree.basedir))
392
197
        expected_result = ([rev_id], [
393
 
            (('', '', tree.get_root_id()), # common details
 
198
            (('', '', tree.path2id('')), # common details
394
199
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
395
200
              ('d', '', 0, False, rev_id), # first parent details
396
201
             ])])
397
202
        state = dirstate.DirState.from_tree(tree, 'dirstate')
398
203
        self.check_state_with_reopen(expected_result, state)
399
 
        state.lock_read()
400
 
        try:
401
 
            state._validate()
402
 
        finally:
403
 
            state.unlock()
 
204
        state._validate()
404
205
 
405
206
    def test_2_parents_empty_to_dirstate(self):
406
207
        # create a parent by doing a commit
410
211
        rev_id2 = tree2.commit('second post', allow_pointless=True)
411
212
        tree.merge_from_branch(tree2.branch)
412
213
        expected_result = ([rev_id, rev_id2], [
413
 
            (('', '', tree.get_root_id()), # common details
 
214
            (('', '', tree.path2id('')), # common details
414
215
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
415
216
              ('d', '', 0, False, rev_id), # first parent details
416
 
              ('d', '', 0, False, rev_id), # second parent details
 
217
              ('d', '', 0, False, rev_id2), # second parent details
417
218
             ])])
418
219
        state = dirstate.DirState.from_tree(tree, 'dirstate')
419
220
        self.check_state_with_reopen(expected_result, state)
420
 
        state.lock_read()
421
 
        try:
422
 
            state._validate()
423
 
        finally:
424
 
            state.unlock()
 
221
        state._validate()
425
222
 
426
223
    def test_empty_unknowns_are_ignored_to_dirstate(self):
427
224
        """We should be able to create a dirstate for an empty tree."""
429
226
        tree = self.make_branch_and_tree('tree')
430
227
        self.build_tree(['tree/unknown'])
431
228
        expected_result = ([], [
432
 
            (('', '', tree.get_root_id()), # common details
 
229
            (('', '', tree.path2id('')), # common details
433
230
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
434
231
             ])])
435
232
        state = dirstate.DirState.from_tree(tree, 'dirstate')
438
235
    def get_tree_with_a_file(self):
439
236
        tree = self.make_branch_and_tree('tree')
440
237
        self.build_tree(['tree/a file'])
441
 
        tree.add('a file', 'a-file-id')
 
238
        tree.add('a file', 'a file id')
442
239
        return tree
443
240
 
444
241
    def test_non_empty_no_parents_to_dirstate(self):
446
243
        # There are files on disk and no parents
447
244
        tree = self.get_tree_with_a_file()
448
245
        expected_result = ([], [
449
 
            (('', '', tree.get_root_id()), # common details
 
246
            (('', '', tree.path2id('')), # common details
450
247
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
451
248
             ]),
452
 
            (('', 'a file', 'a-file-id'), # common
 
249
            (('', 'a file', 'a file id'), # common
453
250
             [('f', '', 0, False, dirstate.DirState.NULLSTAT), # current
454
251
             ]),
455
252
            ])
464
261
        # and length:
465
262
        self.build_tree_contents([('tree/a file', 'new content\n')])
466
263
        expected_result = ([rev_id], [
467
 
            (('', '', tree.get_root_id()), # common details
 
264
            (('', '', tree.path2id('')), # common details
468
265
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
469
266
              ('d', '', 0, False, rev_id), # first parent details
470
267
             ]),
471
 
            (('', 'a file', 'a-file-id'), # common
 
268
            (('', 'a file', 'a file id'), # common
472
269
             [('f', '', 0, False, dirstate.DirState.NULLSTAT), # current
473
270
              ('f', 'c3ed76e4bfd45ff1763ca206055bca8e9fc28aa8', 24, False,
474
271
               rev_id), # first parent
491
288
        # and length again, giving us three distinct values:
492
289
        self.build_tree_contents([('tree/a file', 'new content\n')])
493
290
        expected_result = ([rev_id, rev_id2], [
494
 
            (('', '', tree.get_root_id()), # common details
 
291
            (('', '', tree.path2id('')), # common details
495
292
             [('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
496
293
              ('d', '', 0, False, rev_id), # first parent details
497
 
              ('d', '', 0, False, rev_id), # second parent details
 
294
              ('d', '', 0, False, rev_id2), # second parent details
498
295
             ]),
499
 
            (('', 'a file', 'a-file-id'), # common
 
296
            (('', 'a file', 'a file id'), # common
500
297
             [('f', '', 0, False, dirstate.DirState.NULLSTAT), # current
501
298
              ('f', 'c3ed76e4bfd45ff1763ca206055bca8e9fc28aa8', 24, False,
502
299
               rev_id), # first parent
543
340
        # get a state object
544
341
        # no parents, default tree content
545
342
        expected_result = ([], [
546
 
            (('', '', tree.get_root_id()), # common details
 
343
            (('', '', tree.path2id('')), # common details
547
344
             # current tree details, but new from_tree skips statting, it
548
345
             # uses set_state_from_inventory, and thus depends on the
549
346
             # inventory state.
565
362
        finally:
566
363
            state.unlock()
567
364
 
568
 
    def test_can_save_in_read_lock(self):
569
 
        self.build_tree(['a-file'])
570
 
        state = dirstate.DirState.initialize('dirstate')
571
 
        try:
572
 
            # No stat and no sha1 sum.
573
 
            state.add('a-file', 'a-file-id', 'file', None, '')
574
 
            state.save()
575
 
        finally:
576
 
            state.unlock()
577
 
 
578
 
        # Now open in readonly mode
579
 
        state = dirstate.DirState.on_file('dirstate')
580
 
        state.lock_read()
581
 
        try:
582
 
            entry = state._get_entry(0, path_utf8='a-file')
583
 
            # The current size should be 0 (default)
584
 
            self.assertEqual(0, entry[1][0][2])
585
 
            # We should have a real entry.
586
 
            self.assertNotEqual((None, None), entry)
587
 
            # Make sure everything is old enough
588
 
            state._sha_cutoff_time()
589
 
            state._cutoff_time += 10
590
 
            # Change the file length
591
 
            self.build_tree_contents([('a-file', 'shorter')])
592
 
            sha1sum = dirstate.update_entry(state, entry, 'a-file',
593
 
                os.lstat('a-file'))
594
 
            # new file, no cached sha:
595
 
            self.assertEqual(None, sha1sum)
596
 
 
597
 
            # The dirblock has been updated
598
 
            self.assertEqual(7, entry[1][0][2])
599
 
            self.assertEqual(dirstate.DirState.IN_MEMORY_MODIFIED,
600
 
                             state._dirblock_state)
601
 
 
602
 
            del entry
603
 
            # Now, since we are the only one holding a lock, we should be able
604
 
            # to save and have it written to disk
605
 
            state.save()
606
 
        finally:
607
 
            state.unlock()
608
 
 
609
 
        # Re-open the file, and ensure that the state has been updated.
610
 
        state = dirstate.DirState.on_file('dirstate')
611
 
        state.lock_read()
612
 
        try:
613
 
            entry = state._get_entry(0, path_utf8='a-file')
614
 
            self.assertEqual(7, entry[1][0][2])
615
 
        finally:
616
 
            state.unlock()
617
 
 
618
 
    def test_save_fails_quietly_if_locked(self):
619
 
        """If dirstate is locked, save will fail without complaining."""
620
 
        self.build_tree(['a-file'])
621
 
        state = dirstate.DirState.initialize('dirstate')
622
 
        try:
623
 
            # No stat and no sha1 sum.
624
 
            state.add('a-file', 'a-file-id', 'file', None, '')
625
 
            state.save()
626
 
        finally:
627
 
            state.unlock()
628
 
 
629
 
        state = dirstate.DirState.on_file('dirstate')
630
 
        state.lock_read()
631
 
        try:
632
 
            entry = state._get_entry(0, path_utf8='a-file')
633
 
            sha1sum = dirstate.update_entry(state, entry, 'a-file',
634
 
                os.lstat('a-file'))
635
 
            # No sha - too new
636
 
            self.assertEqual(None, sha1sum)
637
 
            self.assertEqual(dirstate.DirState.IN_MEMORY_MODIFIED,
638
 
                             state._dirblock_state)
639
 
 
640
 
            # Now, before we try to save, grab another dirstate, and take out a
641
 
            # read lock.
642
 
            # TODO: jam 20070315 Ideally this would be locked by another
643
 
            #       process. To make sure the file is really OS locked.
644
 
            state2 = dirstate.DirState.on_file('dirstate')
645
 
            state2.lock_read()
646
 
            try:
647
 
                # This won't actually write anything, because it couldn't grab
648
 
                # a write lock. But it shouldn't raise an error, either.
649
 
                # TODO: jam 20070315 We should probably distinguish between
650
 
                #       being dirty because of 'update_entry'. And dirty
651
 
                #       because of real modification. So that save() *does*
652
 
                #       raise a real error if it fails when we have real
653
 
                #       modifications.
654
 
                state.save()
655
 
            finally:
656
 
                state2.unlock()
657
 
        finally:
658
 
            state.unlock()
659
 
 
660
 
        # The file on disk should not be modified.
661
 
        state = dirstate.DirState.on_file('dirstate')
662
 
        state.lock_read()
663
 
        try:
664
 
            entry = state._get_entry(0, path_utf8='a-file')
665
 
            self.assertEqual('', entry[1][0][1])
666
 
        finally:
667
 
            state.unlock()
668
 
 
669
 
    def test_save_refuses_if_changes_aborted(self):
670
 
        self.build_tree(['a-file', 'a-dir/'])
671
 
        state = dirstate.DirState.initialize('dirstate')
672
 
        try:
673
 
            # No stat and no sha1 sum.
674
 
            state.add('a-file', 'a-file-id', 'file', None, '')
675
 
            state.save()
676
 
        finally:
677
 
            state.unlock()
678
 
 
679
 
        # The dirstate should include TREE_ROOT and 'a-file' and nothing else
680
 
        expected_blocks = [
681
 
            ('', [(('', '', 'TREE_ROOT'),
682
 
                   [('d', '', 0, False, dirstate.DirState.NULLSTAT)])]),
683
 
            ('', [(('', 'a-file', 'a-file-id'),
684
 
                   [('f', '', 0, False, dirstate.DirState.NULLSTAT)])]),
685
 
        ]
686
 
 
687
 
        state = dirstate.DirState.on_file('dirstate')
688
 
        state.lock_write()
689
 
        try:
690
 
            state._read_dirblocks_if_needed()
691
 
            self.assertEqual(expected_blocks, state._dirblocks)
692
 
 
693
 
            # Now modify the state, but mark it as inconsistent
694
 
            state.add('a-dir', 'a-dir-id', 'directory', None, '')
695
 
            state._changes_aborted = True
696
 
            state.save()
697
 
        finally:
698
 
            state.unlock()
699
 
 
700
 
        state = dirstate.DirState.on_file('dirstate')
701
 
        state.lock_read()
702
 
        try:
703
 
            state._read_dirblocks_if_needed()
704
 
            self.assertEqual(expected_blocks, state._dirblocks)
705
 
        finally:
706
 
            state.unlock()
707
 
 
708
365
 
709
366
class TestDirStateInitialize(TestCaseWithDirState):
710
367
 
718
375
        try:
719
376
            self.assertIsInstance(state, dirstate.DirState)
720
377
            lines = state.get_lines()
721
 
        finally:
 
378
            self.assertFileEqual(''.join(state.get_lines()),
 
379
                'dirstate')
 
380
            self.check_state_with_reopen(expected_result, state)
 
381
        except:
722
382
            state.unlock()
723
 
        # On win32 you can't read from a locked file, even within the same
724
 
        # process. So we have to unlock and release before we check the file
725
 
        # contents.
726
 
        self.assertFileEqual(''.join(lines), 'dirstate')
727
 
        state.lock_read() # check_state_with_reopen will unlock
728
 
        self.check_state_with_reopen(expected_result, state)
 
383
            raise
729
384
 
730
385
 
731
386
class TestDirStateManipulations(TestCaseWithDirState):
737
392
        try:
738
393
            tree1.add('')
739
394
            revid1 = tree1.commit('foo').encode('utf8')
740
 
            root_id = tree1.get_root_id()
 
395
            root_id = tree1.inventory.root.file_id
741
396
            inv = tree1.inventory
742
397
        finally:
743
398
            tree1.unlock()
758
413
            # This will unlock it
759
414
            self.check_state_with_reopen(expected_result, state)
760
415
 
761
 
    def test_set_state_from_inventory_preserves_hashcache(self):
762
 
        # https://bugs.launchpad.net/bzr/+bug/146176
763
 
        # set_state_from_inventory should preserve the stat and hash value for
764
 
        # workingtree files that are not changed by the inventory.
765
 
 
766
 
        tree = self.make_branch_and_tree('.')
767
 
        # depends on the default format using dirstate...
768
 
        tree.lock_write()
769
 
        try:
770
 
            # make a dirstate with some valid hashcache data
771
 
            # file on disk, but that's not needed for this test
772
 
            foo_contents = 'contents of foo'
773
 
            self.build_tree_contents([('foo', foo_contents)])
774
 
            tree.add('foo', 'foo-id')
775
 
 
776
 
            foo_stat = os.stat('foo')
777
 
            foo_packed = dirstate.pack_stat(foo_stat)
778
 
            foo_sha = osutils.sha_string(foo_contents)
779
 
            foo_size = len(foo_contents)
780
 
 
781
 
            # should not be cached yet, because the file's too fresh
782
 
            self.assertEqual(
783
 
                (('', 'foo', 'foo-id',),
784
 
                 [('f', '', 0, False, dirstate.DirState.NULLSTAT)]),
785
 
                tree._dirstate._get_entry(0, 'foo-id'))
786
 
            # poke in some hashcache information - it wouldn't normally be
787
 
            # stored because it's too fresh
788
 
            tree._dirstate.update_minimal(
789
 
                ('', 'foo', 'foo-id'),
790
 
                'f', False, foo_sha, foo_packed, foo_size, 'foo')
791
 
            # now should be cached
792
 
            self.assertEqual(
793
 
                (('', 'foo', 'foo-id',),
794
 
                 [('f', foo_sha, foo_size, False, foo_packed)]),
795
 
                tree._dirstate._get_entry(0, 'foo-id'))
796
 
 
797
 
            # extract the inventory, and add something to it
798
 
            inv = tree._get_inventory()
799
 
            # should see the file we poked in...
800
 
            self.assertTrue(inv.has_id('foo-id'))
801
 
            self.assertTrue(inv.has_filename('foo'))
802
 
            inv.add_path('bar', 'file', 'bar-id')
803
 
            tree._dirstate._validate()
804
 
            # this used to cause it to lose its hashcache
805
 
            tree._dirstate.set_state_from_inventory(inv)
806
 
            tree._dirstate._validate()
807
 
        finally:
808
 
            tree.unlock()
809
 
 
810
 
        tree.lock_read()
811
 
        try:
812
 
            # now check that the state still has the original hashcache value
813
 
            state = tree._dirstate
814
 
            state._validate()
815
 
            foo_tuple = state._get_entry(0, path_utf8='foo')
816
 
            self.assertEqual(
817
 
                (('', 'foo', 'foo-id',),
818
 
                 [('f', foo_sha, len(foo_contents), False,
819
 
                   dirstate.pack_stat(foo_stat))]),
820
 
                foo_tuple)
821
 
        finally:
822
 
            tree.unlock()
823
 
 
824
 
    def test_set_state_from_inventory_mixed_paths(self):
825
 
        tree1 = self.make_branch_and_tree('tree1')
826
 
        self.build_tree(['tree1/a/', 'tree1/a/b/', 'tree1/a-b/',
827
 
                         'tree1/a/b/foo', 'tree1/a-b/bar'])
828
 
        tree1.lock_write()
829
 
        try:
830
 
            tree1.add(['a', 'a/b', 'a-b', 'a/b/foo', 'a-b/bar'],
831
 
                      ['a-id', 'b-id', 'a-b-id', 'foo-id', 'bar-id'])
832
 
            tree1.commit('rev1', rev_id='rev1')
833
 
            root_id = tree1.get_root_id()
834
 
            inv = tree1.inventory
835
 
        finally:
836
 
            tree1.unlock()
837
 
        expected_result1 = [('', '', root_id, 'd'),
838
 
                            ('', 'a', 'a-id', 'd'),
839
 
                            ('', 'a-b', 'a-b-id', 'd'),
840
 
                            ('a', 'b', 'b-id', 'd'),
841
 
                            ('a/b', 'foo', 'foo-id', 'f'),
842
 
                            ('a-b', 'bar', 'bar-id', 'f'),
843
 
                           ]
844
 
        expected_result2 = [('', '', root_id, 'd'),
845
 
                            ('', 'a', 'a-id', 'd'),
846
 
                            ('', 'a-b', 'a-b-id', 'd'),
847
 
                            ('a-b', 'bar', 'bar-id', 'f'),
848
 
                           ]
849
 
        state = dirstate.DirState.initialize('dirstate')
850
 
        try:
851
 
            state.set_state_from_inventory(inv)
852
 
            values = []
853
 
            for entry in state._iter_entries():
854
 
                values.append(entry[0] + entry[1][0][:1])
855
 
            self.assertEqual(expected_result1, values)
856
 
            del inv['b-id']
857
 
            state.set_state_from_inventory(inv)
858
 
            values = []
859
 
            for entry in state._iter_entries():
860
 
                values.append(entry[0] + entry[1][0][:1])
861
 
            self.assertEqual(expected_result2, values)
862
 
        finally:
863
 
            state.unlock()
864
 
 
865
416
    def test_set_path_id_no_parents(self):
866
417
        """The id of a path can be changed trivally with no parents."""
867
418
        state = dirstate.DirState.initialize('dirstate')
868
419
        try:
869
420
            # check precondition to be sure the state does change appropriately.
870
 
            root_entry = (('', '', 'TREE_ROOT'), [('d', '', 0, False, 'x'*32)])
871
 
            self.assertEqual([root_entry], list(state._iter_entries()))
872
 
            self.assertEqual(root_entry, state._get_entry(0, path_utf8=''))
873
 
            self.assertEqual(root_entry,
874
 
                             state._get_entry(0, fileid_utf8='TREE_ROOT'))
875
 
            self.assertEqual((None, None),
876
 
                             state._get_entry(0, fileid_utf8='second-root-id'))
877
 
            state.set_path_id('', 'second-root-id')
878
 
            new_root_entry = (('', '', 'second-root-id'),
879
 
                              [('d', '', 0, False, 'x'*32)])
880
 
            expected_rows = [new_root_entry]
 
421
            self.assertEqual(
 
422
                [(('', '', 'TREE_ROOT'), [('d', '', 0, False,
 
423
                   'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx')])],
 
424
                list(state._iter_entries()))
 
425
            state.set_path_id('', 'foobarbaz')
 
426
            expected_rows = [
 
427
                (('', '', 'foobarbaz'), [('d', '', 0, False,
 
428
                   'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx')])]
881
429
            self.assertEqual(expected_rows, list(state._iter_entries()))
882
 
            self.assertEqual(new_root_entry, state._get_entry(0, path_utf8=''))
883
 
            self.assertEqual(new_root_entry, 
884
 
                             state._get_entry(0, fileid_utf8='second-root-id'))
885
 
            self.assertEqual((None, None),
886
 
                             state._get_entry(0, fileid_utf8='TREE_ROOT'))
887
430
            # should work across save too
888
431
            state.save()
889
432
        finally:
890
433
            state.unlock()
891
434
        state = dirstate.DirState.on_file('dirstate')
 
435
        state._validate()
892
436
        state.lock_read()
893
437
        try:
894
 
            state._validate()
895
438
            self.assertEqual(expected_rows, list(state._iter_entries()))
896
439
        finally:
897
440
            state.unlock()
907
450
        state._validate()
908
451
        try:
909
452
            state.set_parent_trees([('parent-revid', rt)], ghosts=[])
910
 
            root_entry = (('', '', 'TREE_ROOT'),
911
 
                          [('d', '', 0, False, 'x'*32),
912
 
                           ('d', '', 0, False, 'parent-revid')])
913
 
            self.assertEqual(root_entry, state._get_entry(0, path_utf8=''))
914
 
            self.assertEqual(root_entry,
915
 
                             state._get_entry(0, fileid_utf8='TREE_ROOT'))
916
 
            self.assertEqual((None, None),
917
 
                             state._get_entry(0, fileid_utf8='Asecond-root-id'))
918
 
            state.set_path_id('', 'Asecond-root-id')
 
453
            state.set_path_id('', 'foobarbaz')
919
454
            state._validate()
920
455
            # now see that it is what we expected
921
 
            old_root_entry = (('', '', 'TREE_ROOT'),
922
 
                              [('a', '', 0, False, ''),
923
 
                               ('d', '', 0, False, 'parent-revid')])
924
 
            new_root_entry = (('', '', 'Asecond-root-id'),
925
 
                              [('d', '', 0, False, ''),
926
 
                               ('a', '', 0, False, '')])
927
 
            expected_rows = [new_root_entry, old_root_entry]
 
456
            expected_rows = [
 
457
                (('', '', 'TREE_ROOT'),
 
458
                    [('a', '', 0, False, ''),
 
459
                     ('d', '', 0, False, 'parent-revid'),
 
460
                     ]),
 
461
                (('', '', 'foobarbaz'),
 
462
                    [('d', '', 0, False, ''),
 
463
                     ('a', '', 0, False, ''),
 
464
                     ]),
 
465
                ]
928
466
            state._validate()
929
467
            self.assertEqual(expected_rows, list(state._iter_entries()))
930
 
            self.assertEqual(new_root_entry, state._get_entry(0, path_utf8=''))
931
 
            self.assertEqual(old_root_entry, state._get_entry(1, path_utf8=''))
932
 
            self.assertEqual((None, None),
933
 
                             state._get_entry(0, fileid_utf8='TREE_ROOT'))
934
 
            self.assertEqual(old_root_entry,
935
 
                             state._get_entry(1, fileid_utf8='TREE_ROOT'))
936
 
            self.assertEqual(new_root_entry,
937
 
                             state._get_entry(0, fileid_utf8='Asecond-root-id'))
938
 
            self.assertEqual((None, None),
939
 
                             state._get_entry(1, fileid_utf8='Asecond-root-id'))
940
468
            # should work across save too
941
469
            state.save()
942
470
        finally:
958
486
        finally:
959
487
            state.unlock()
960
488
 
 
489
 
961
490
    def test_set_parent_trees_no_content(self):
962
491
        # set_parent_trees is a slow but important api to support.
963
492
        tree1 = self.make_branch_and_memory_tree('tree1')
968
497
        finally:
969
498
            tree1.unlock()
970
499
        branch2 = tree1.branch.bzrdir.clone('tree2').open_branch()
971
 
        tree2 = memorytree.MemoryTree.create_on_branch(branch2)
 
500
        tree2 = MemoryTree.create_on_branch(branch2)
972
501
        tree2.lock_write()
973
502
        try:
974
503
            revid2 = tree2.commit('foo')
975
 
            root_id = tree2.get_root_id()
 
504
            root_id = tree2.inventory.root.file_id
976
505
        finally:
977
506
            tree2.unlock()
978
507
        state = dirstate.DirState.initialize('dirstate')
1006
535
            state.set_parent_trees(
1007
536
                ((revid1, tree1.branch.repository.revision_tree(revid1)),
1008
537
                 (revid2, tree2.branch.repository.revision_tree(revid2)),
1009
 
                 ('ghost-rev', tree2.branch.repository.revision_tree(
1010
 
                                   _mod_revision.NULL_REVISION))),
 
538
                 ('ghost-rev', tree2.branch.repository.revision_tree(None))),
1011
539
                ['ghost-rev'])
1012
540
            self.assertEqual([revid1, revid2, 'ghost-rev'],
1013
541
                             state.get_parent_ids())
1017
545
                [(('', '', root_id), [
1018
546
                  ('d', '', 0, False, dirstate.DirState.NULLSTAT),
1019
547
                  ('d', '', 0, False, revid1),
1020
 
                  ('d', '', 0, False, revid1)
 
548
                  ('d', '', 0, False, revid2)
1021
549
                  ])],
1022
550
                list(state._iter_entries()))
1023
551
        finally:
1038
566
        finally:
1039
567
            tree1.unlock()
1040
568
        branch2 = tree1.branch.bzrdir.clone('tree2').open_branch()
1041
 
        tree2 = memorytree.MemoryTree.create_on_branch(branch2)
 
569
        tree2 = MemoryTree.create_on_branch(branch2)
1042
570
        tree2.lock_write()
1043
571
        try:
1044
572
            tree2.put_file_bytes_non_atomic('file-id', 'new file-content')
1045
573
            revid2 = tree2.commit('foo')
1046
 
            root_id = tree2.get_root_id()
 
574
            root_id = tree2.inventory.root.file_id
1047
575
        finally:
1048
576
            tree2.unlock()
1049
577
        # check the layout in memory
1051
579
            (('', '', root_id), [
1052
580
             ('d', '', 0, False, dirstate.DirState.NULLSTAT),
1053
581
             ('d', '', 0, False, revid1.encode('utf8')),
1054
 
             ('d', '', 0, False, revid1.encode('utf8'))
 
582
             ('d', '', 0, False, revid2.encode('utf8'))
1055
583
             ]),
1056
584
            (('', 'a file', 'file-id'), [
1057
585
             ('a', '', 0, False, ''),
1089
617
            (('', '', 'TREE_ROOT'), [
1090
618
             ('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
1091
619
             ]),
1092
 
            (('', 'a file', 'a-file-id'), [
 
620
            (('', 'a file', 'a file id'), [
1093
621
             ('f', '1'*20, 19, False, dirstate.pack_stat(stat)), # current tree
1094
622
             ]),
1095
623
            ]
1096
624
        try:
1097
 
            state.add('a file', 'a-file-id', 'file', stat, '1'*20)
 
625
            state.add('a file', 'a file id', 'file', stat, '1'*20)
1098
626
            # having added it, it should be in the output of iter_entries.
1099
627
            self.assertEqual(expected_entries, list(state._iter_entries()))
1100
628
            # saving and reloading should not affect this.
1103
631
            state.unlock()
1104
632
        state = dirstate.DirState.on_file('dirstate')
1105
633
        state.lock_read()
1106
 
        self.addCleanup(state.unlock)
1107
 
        self.assertEqual(expected_entries, list(state._iter_entries()))
 
634
        try:
 
635
            self.assertEqual(expected_entries, list(state._iter_entries()))
 
636
        finally:
 
637
            state.unlock()
1108
638
 
1109
639
    def test_add_path_to_unversioned_directory(self):
1110
640
        """Adding a path to an unversioned directory should error.
1115
645
        """
1116
646
        self.build_tree(['unversioned/', 'unversioned/a file'])
1117
647
        state = dirstate.DirState.initialize('dirstate')
1118
 
        self.addCleanup(state.unlock)
1119
 
        self.assertRaises(errors.NotVersionedError, state.add,
1120
 
                          'unversioned/a file', 'a-file-id', 'file', None, None)
 
648
        try:
 
649
            self.assertRaises(errors.NotVersionedError, state.add,
 
650
                'unversioned/a file', 'a file id', 'file', None, None)
 
651
        finally:
 
652
            state.unlock()
1121
653
 
1122
654
    def test_add_directory_to_root_no_parents_all_data(self):
1123
655
        # The most trivial addition of a dir is when there are no parents and
1143
675
            state.unlock()
1144
676
        state = dirstate.DirState.on_file('dirstate')
1145
677
        state.lock_read()
1146
 
        self.addCleanup(state.unlock)
1147
678
        state._validate()
1148
 
        self.assertEqual(expected_entries, list(state._iter_entries()))
 
679
        try:
 
680
            self.assertEqual(expected_entries, list(state._iter_entries()))
 
681
        finally:
 
682
            state.unlock()
1149
683
 
1150
 
    def _test_add_symlink_to_root_no_parents_all_data(self, link_name, target):
 
684
    def test_add_symlink_to_root_no_parents_all_data(self):
1151
685
        # The most trivial addition of a symlink when there are no parents and
1152
686
        # its in the root and all data about the file is supplied
1153
 
        # bzr doesn't support fake symlinks on windows, yet.
1154
 
        self.requireFeature(tests.SymlinkFeature)
1155
 
        os.symlink(target, link_name)
1156
 
        stat = os.lstat(link_name)
 
687
        ## TODO: windows: dont fail this test. Also, how are symlinks meant to
 
688
        # be represented on windows.
 
689
        os.symlink('target', 'a link')
 
690
        stat = os.lstat('a link')
1157
691
        expected_entries = [
1158
692
            (('', '', 'TREE_ROOT'), [
1159
693
             ('d', '', 0, False, dirstate.DirState.NULLSTAT), # current tree
1160
694
             ]),
1161
 
            (('', link_name.encode('UTF-8'), 'a link id'), [
1162
 
             ('l', target.encode('UTF-8'), stat[6],
1163
 
              False, dirstate.pack_stat(stat)), # current tree
 
695
            (('', 'a link', 'a link id'), [
 
696
             ('l', 'target', 6, False, dirstate.pack_stat(stat)), # current tree
1164
697
             ]),
1165
698
            ]
1166
699
        state = dirstate.DirState.initialize('dirstate')
1167
700
        try:
1168
 
            state.add(link_name, 'a link id', 'symlink', stat,
1169
 
                      target.encode('UTF-8'))
 
701
            state.add('a link', 'a link id', 'symlink', stat, 'target')
1170
702
            # having added it, it should be in the output of iter_entries.
1171
703
            self.assertEqual(expected_entries, list(state._iter_entries()))
1172
704
            # saving and reloading should not affect this.
1175
707
            state.unlock()
1176
708
        state = dirstate.DirState.on_file('dirstate')
1177
709
        state.lock_read()
1178
 
        self.addCleanup(state.unlock)
1179
 
        self.assertEqual(expected_entries, list(state._iter_entries()))
1180
 
 
1181
 
    def test_add_symlink_to_root_no_parents_all_data(self):
1182
 
        self._test_add_symlink_to_root_no_parents_all_data('a link', 'target')
1183
 
 
1184
 
    def test_add_symlink_unicode_to_root_no_parents_all_data(self):
1185
 
        self.requireFeature(tests.UnicodeFilenameFeature)
1186
 
        self._test_add_symlink_to_root_no_parents_all_data(
1187
 
            u'\N{Euro Sign}link', u'targ\N{Euro Sign}et')
 
710
        try:
 
711
            self.assertEqual(expected_entries, list(state._iter_entries()))
 
712
        finally:
 
713
            state.unlock()
1188
714
 
1189
715
    def test_add_directory_and_child_no_parents_all_data(self):
1190
716
        # after adding a directory, we should be able to add children to it.
1198
724
            (('', 'a dir', 'a dir id'), [
1199
725
             ('d', '', 0, False, dirstate.pack_stat(dirstat)), # current tree
1200
726
             ]),
1201
 
            (('a dir', 'a file', 'a-file-id'), [
 
727
            (('a dir', 'a file', 'a file id'), [
1202
728
             ('f', '1'*20, 25, False,
1203
729
              dirstate.pack_stat(filestat)), # current tree details
1204
730
             ]),
1206
732
        state = dirstate.DirState.initialize('dirstate')
1207
733
        try:
1208
734
            state.add('a dir', 'a dir id', 'directory', dirstat, None)
1209
 
            state.add('a dir/a file', 'a-file-id', 'file', filestat, '1'*20)
 
735
            state.add('a dir/a file', 'a file id', 'file', filestat, '1'*20)
1210
736
            # added it, it should be in the output of iter_entries.
1211
737
            self.assertEqual(expected_entries, list(state._iter_entries()))
1212
738
            # saving and reloading should not affect this.
1215
741
            state.unlock()
1216
742
        state = dirstate.DirState.on_file('dirstate')
1217
743
        state.lock_read()
1218
 
        self.addCleanup(state.unlock)
1219
 
        self.assertEqual(expected_entries, list(state._iter_entries()))
 
744
        try:
 
745
            self.assertEqual(expected_entries, list(state._iter_entries()))
 
746
        finally:
 
747
            state.unlock()
1220
748
 
1221
749
    def test_add_tree_reference(self):
1222
750
        # make a dirstate and add a tree reference
1236
764
            state.unlock()
1237
765
        # now check we can read it back
1238
766
        state.lock_read()
1239
 
        self.addCleanup(state.unlock)
1240
767
        state._validate()
1241
 
        entry2 = state._get_entry(0, 'subdir-id', 'subdir')
1242
 
        self.assertEqual(entry, entry2)
1243
 
        self.assertEqual(entry, expected_entry)
1244
 
        # and lookup by id should work too
1245
 
        entry2 = state._get_entry(0, fileid_utf8='subdir-id')
1246
 
        self.assertEqual(entry, expected_entry)
 
768
        try:
 
769
            entry2 = state._get_entry(0, 'subdir-id', 'subdir')
 
770
            self.assertEqual(entry, entry2)
 
771
            self.assertEqual(entry, expected_entry)
 
772
            # and lookup by id should work too
 
773
            entry2 = state._get_entry(0, fileid_utf8='subdir-id')
 
774
            self.assertEqual(entry, expected_entry)
 
775
        finally:
 
776
            state.unlock()
1247
777
 
1248
778
    def test_add_forbidden_names(self):
1249
779
        state = dirstate.DirState.initialize('dirstate')
1253
783
        self.assertRaises(errors.BzrError,
1254
784
            state.add, '..', 'ass-id', 'directory', None, None)
1255
785
 
1256
 
    def test_set_state_with_rename_b_a_bug_395556(self):
1257
 
        # bug 395556 uncovered a bug where the dirstate ends up with a false
1258
 
        # relocation record - in a tree with no parents there should be no
1259
 
        # absent or relocated records. This then leads to further corruption
1260
 
        # when a commit occurs, as the incorrect relocation gathers an
1261
 
        # incorrect absent in tree 1, and future changes go to pot.
1262
 
        tree1 = self.make_branch_and_tree('tree1')
1263
 
        self.build_tree(['tree1/b'])
1264
 
        tree1.lock_write()
1265
 
        try:
1266
 
            tree1.add(['b'], ['b-id'])
1267
 
            root_id = tree1.get_root_id()
1268
 
            inv = tree1.inventory
1269
 
            state = dirstate.DirState.initialize('dirstate')
1270
 
            try:
1271
 
                # Set the initial state with 'b'
1272
 
                state.set_state_from_inventory(inv)
1273
 
                inv.rename('b-id', root_id, 'a')
1274
 
                # Set the new state with 'a', which currently corrupts.
1275
 
                state.set_state_from_inventory(inv)
1276
 
                expected_result1 = [('', '', root_id, 'd'),
1277
 
                                    ('', 'a', 'b-id', 'f'),
1278
 
                                   ]
1279
 
                values = []
1280
 
                for entry in state._iter_entries():
1281
 
                    values.append(entry[0] + entry[1][0][:1])
1282
 
                self.assertEqual(expected_result1, values)
1283
 
            finally:
1284
 
                state.unlock()
1285
 
        finally:
1286
 
            tree1.unlock()
1287
 
 
1288
786
 
1289
787
class TestGetLines(TestCaseWithDirState):
1290
788
 
1503
1001
            state.unlock()
1504
1002
 
1505
1003
 
1506
 
class TestIterChildEntries(TestCaseWithDirState):
1507
 
 
1508
 
    def create_dirstate_with_two_trees(self):
1509
 
        """This dirstate contains multiple files and directories.
1510
 
 
1511
 
         /        a-root-value
1512
 
         a/       a-dir
1513
 
         b/       b-dir
1514
 
         c        c-file
1515
 
         d        d-file
1516
 
         a/e/     e-dir
1517
 
         a/f      f-file
1518
 
         b/g      g-file
1519
 
         b/h\xc3\xa5  h-\xc3\xa5-file  #This is u'\xe5' encoded into utf-8
1520
 
 
1521
 
        Notice that a/e is an empty directory.
1522
 
 
1523
 
        There is one parent tree, which has the same shape with the following variations:
1524
 
        b/g in the parent is gone.
1525
 
        b/h in the parent has a different id
1526
 
        b/i is new in the parent
1527
 
        c is renamed to b/j in the parent
1528
 
 
1529
 
        :return: The dirstate, still write-locked.
1530
 
        """
1531
 
        packed_stat = 'AAAAREUHaIpFB2iKAAADAQAtkqUAAIGk'
1532
 
        null_sha = 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
1533
 
        NULL_PARENT_DETAILS = dirstate.DirState.NULL_PARENT_DETAILS
1534
 
        root_entry = ('', '', 'a-root-value'), [
1535
 
            ('d', '', 0, False, packed_stat),
1536
 
            ('d', '', 0, False, 'parent-revid'),
1537
 
            ]
1538
 
        a_entry = ('', 'a', 'a-dir'), [
1539
 
            ('d', '', 0, False, packed_stat),
1540
 
            ('d', '', 0, False, 'parent-revid'),
1541
 
            ]
1542
 
        b_entry = ('', 'b', 'b-dir'), [
1543
 
            ('d', '', 0, False, packed_stat),
1544
 
            ('d', '', 0, False, 'parent-revid'),
1545
 
            ]
1546
 
        c_entry = ('', 'c', 'c-file'), [
1547
 
            ('f', null_sha, 10, False, packed_stat),
1548
 
            ('r', 'b/j', 0, False, ''),
1549
 
            ]
1550
 
        d_entry = ('', 'd', 'd-file'), [
1551
 
            ('f', null_sha, 20, False, packed_stat),
1552
 
            ('f', 'd', 20, False, 'parent-revid'),
1553
 
            ]
1554
 
        e_entry = ('a', 'e', 'e-dir'), [
1555
 
            ('d', '', 0, False, packed_stat),
1556
 
            ('d', '', 0, False, 'parent-revid'),
1557
 
            ]
1558
 
        f_entry = ('a', 'f', 'f-file'), [
1559
 
            ('f', null_sha, 30, False, packed_stat),
1560
 
            ('f', 'f', 20, False, 'parent-revid'),
1561
 
            ]
1562
 
        g_entry = ('b', 'g', 'g-file'), [
1563
 
            ('f', null_sha, 30, False, packed_stat),
1564
 
            NULL_PARENT_DETAILS,
1565
 
            ]
1566
 
        h_entry1 = ('b', 'h\xc3\xa5', 'h-\xc3\xa5-file1'), [
1567
 
            ('f', null_sha, 40, False, packed_stat),
1568
 
            NULL_PARENT_DETAILS,
1569
 
            ]
1570
 
        h_entry2 = ('b', 'h\xc3\xa5', 'h-\xc3\xa5-file2'), [
1571
 
            NULL_PARENT_DETAILS,
1572
 
            ('f', 'h', 20, False, 'parent-revid'),
1573
 
            ]
1574
 
        i_entry = ('b', 'i', 'i-file'), [
1575
 
            NULL_PARENT_DETAILS,
1576
 
            ('f', 'h', 20, False, 'parent-revid'),
1577
 
            ]
1578
 
        j_entry = ('b', 'j', 'c-file'), [
1579
 
            ('r', 'c', 0, False, ''),
1580
 
            ('f', 'j', 20, False, 'parent-revid'),
1581
 
            ]
1582
 
        dirblocks = []
1583
 
        dirblocks.append(('', [root_entry]))
1584
 
        dirblocks.append(('', [a_entry, b_entry, c_entry, d_entry]))
1585
 
        dirblocks.append(('a', [e_entry, f_entry]))
1586
 
        dirblocks.append(('b', [g_entry, h_entry1, h_entry2, i_entry, j_entry]))
1587
 
        state = dirstate.DirState.initialize('dirstate')
1588
 
        state._validate()
1589
 
        try:
1590
 
            state._set_data(['parent'], dirblocks)
1591
 
        except:
1592
 
            state.unlock()
1593
 
            raise
1594
 
        return state, dirblocks
1595
 
 
1596
 
    def test_iter_children_b(self):
1597
 
        state, dirblocks = self.create_dirstate_with_two_trees()
1598
 
        self.addCleanup(state.unlock)
1599
 
        expected_result = []
1600
 
        expected_result.append(dirblocks[3][1][2]) # h2
1601
 
        expected_result.append(dirblocks[3][1][3]) # i
1602
 
        expected_result.append(dirblocks[3][1][4]) # j
1603
 
        self.assertEqual(expected_result,
1604
 
            list(state._iter_child_entries(1, 'b')))
1605
 
 
1606
 
    def test_iter_child_root(self):
1607
 
        state, dirblocks = self.create_dirstate_with_two_trees()
1608
 
        self.addCleanup(state.unlock)
1609
 
        expected_result = []
1610
 
        expected_result.append(dirblocks[1][1][0]) # a
1611
 
        expected_result.append(dirblocks[1][1][1]) # b
1612
 
        expected_result.append(dirblocks[1][1][3]) # d
1613
 
        expected_result.append(dirblocks[2][1][0]) # e
1614
 
        expected_result.append(dirblocks[2][1][1]) # f
1615
 
        expected_result.append(dirblocks[3][1][2]) # h2
1616
 
        expected_result.append(dirblocks[3][1][3]) # i
1617
 
        expected_result.append(dirblocks[3][1][4]) # j
1618
 
        self.assertEqual(expected_result,
1619
 
            list(state._iter_child_entries(1, '')))
1620
 
 
1621
 
 
1622
 
class TestDirstateSortOrder(tests.TestCaseWithTransport):
 
1004
class TestDirstateSortOrder(TestCaseWithTransport):
1623
1005
    """Test that DirState adds entries in the right order."""
1624
1006
 
1625
1007
    def test_add_sorting(self):
1674
1056
 
1675
1057
        # *really* cheesy way to just get an empty tree
1676
1058
        repo = self.make_repository('repo')
1677
 
        empty_tree = repo.revision_tree(_mod_revision.NULL_REVISION)
 
1059
        empty_tree = repo.revision_tree(None)
1678
1060
        state.set_parent_trees([('null:', empty_tree)], [])
1679
1061
 
1680
1062
        dirblock_names = [d[0] for d in state._dirblocks]
1684
1066
class InstrumentedDirState(dirstate.DirState):
1685
1067
    """An DirState with instrumented sha1 functionality."""
1686
1068
 
1687
 
    def __init__(self, path, sha1_provider):
1688
 
        super(InstrumentedDirState, self).__init__(path, sha1_provider)
 
1069
    def __init__(self, path):
 
1070
        super(InstrumentedDirState, self).__init__(path)
1689
1071
        self._time_offset = 0
1690
1072
        self._log = []
1691
 
        # member is dynamically set in DirState.__init__ to turn on trace
1692
 
        self._sha1_provider = sha1_provider
1693
 
        self._sha1_file = self._sha1_file_and_log
1694
1073
 
1695
1074
    def _sha_cutoff_time(self):
1696
1075
        timestamp = super(InstrumentedDirState, self)._sha_cutoff_time()
1697
1076
        self._cutoff_time = timestamp + self._time_offset
1698
1077
 
1699
 
    def _sha1_file_and_log(self, abspath):
 
1078
    def _sha1_file(self, abspath, entry):
1700
1079
        self._log.append(('sha1', abspath))
1701
 
        return self._sha1_provider.sha1(abspath)
 
1080
        return super(InstrumentedDirState, self)._sha1_file(abspath, entry)
1702
1081
 
1703
1082
    def _read_link(self, abspath, old_link):
1704
1083
        self._log.append(('read_link', abspath, old_link))
1735
1114
        self.st_ino = ino
1736
1115
        self.st_mode = mode
1737
1116
 
1738
 
    @staticmethod
1739
 
    def from_stat(st):
1740
 
        return _FakeStat(st.st_size, st.st_mtime, st.st_ctime, st.st_dev,
1741
 
            st.st_ino, st.st_mode)
1742
 
 
1743
 
 
1744
 
class TestPackStat(tests.TestCaseWithTransport):
 
1117
 
 
1118
class TestUpdateEntry(TestCaseWithDirState):
 
1119
    """Test the DirState.update_entry functions"""
 
1120
 
 
1121
    def get_state_with_a(self):
 
1122
        """Create a DirState tracking a single object named 'a'"""
 
1123
        state = InstrumentedDirState.initialize('dirstate')
 
1124
        self.addCleanup(state.unlock)
 
1125
        state.add('a', 'a-id', 'file', None, '')
 
1126
        entry = state._get_entry(0, path_utf8='a')
 
1127
        return state, entry
 
1128
 
 
1129
    def test_update_entry(self):
 
1130
        state, entry = self.get_state_with_a()
 
1131
        self.build_tree(['a'])
 
1132
        # Add one where we don't provide the stat or sha already
 
1133
        self.assertEqual(('', 'a', 'a-id'), entry[0])
 
1134
        self.assertEqual([('f', '', 0, False, dirstate.DirState.NULLSTAT)],
 
1135
                         entry[1])
 
1136
        # Flush the buffers to disk
 
1137
        state.save()
 
1138
        self.assertEqual(dirstate.DirState.IN_MEMORY_UNMODIFIED,
 
1139
                         state._dirblock_state)
 
1140
 
 
1141
        stat_value = os.lstat('a')
 
1142
        packed_stat = dirstate.pack_stat(stat_value)
 
1143
        link_or_sha1 = state.update_entry(entry, abspath='a',
 
1144
                                          stat_value=stat_value)
 
1145
        self.assertEqual('b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6',
 
1146
                         link_or_sha1)
 
1147
 
 
1148
        # The dirblock entry should be updated with the new info
 
1149
        self.assertEqual([('f', link_or_sha1, 14, False, packed_stat)],
 
1150
                         entry[1])
 
1151
        self.assertEqual(dirstate.DirState.IN_MEMORY_MODIFIED,
 
1152
                         state._dirblock_state)
 
1153
        mode = stat_value.st_mode
 
1154
        self.assertEqual([('sha1', 'a'), ('is_exec', mode, False)], state._log)
 
1155
 
 
1156
        state.save()
 
1157
        self.assertEqual(dirstate.DirState.IN_MEMORY_UNMODIFIED,
 
1158
                         state._dirblock_state)
 
1159
 
 
1160
        # If we do it again right away, we don't know if the file has changed
 
1161
        # so we will re-read the file. Roll the clock back so the file is
 
1162
        # guaranteed to look too new.
 
1163
        state.adjust_time(-10)
 
1164
 
 
1165
        link_or_sha1 = state.update_entry(entry, abspath='a',
 
1166
                                          stat_value=stat_value)
 
1167
        self.assertEqual([('sha1', 'a'), ('is_exec', mode, False),
 
1168
                          ('sha1', 'a'), ('is_exec', mode, False),
 
1169
                         ], state._log)
 
1170
        self.assertEqual('b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6',
 
1171
                         link_or_sha1)
 
1172
        self.assertEqual(dirstate.DirState.IN_MEMORY_MODIFIED,
 
1173
                         state._dirblock_state)
 
1174
        state.save()
 
1175
 
 
1176
        # However, if we move the clock forward so the file is considered
 
1177
        # "stable", it should just returned the cached value.
 
1178
        state.adjust_time(20)
 
1179
        link_or_sha1 = state.update_entry(entry, abspath='a',
 
1180
                                          stat_value=stat_value)
 
1181
        self.assertEqual('b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6',
 
1182
                         link_or_sha1)
 
1183
        self.assertEqual([('sha1', 'a'), ('is_exec', mode, False),
 
1184
                          ('sha1', 'a'), ('is_exec', mode, False),
 
1185
                         ], state._log)
 
1186
 
 
1187
    def test_update_entry_no_stat_value(self):
 
1188
        """Passing the stat_value is optional."""
 
1189
        state, entry = self.get_state_with_a()
 
1190
        state.adjust_time(-10) # Make sure the file looks new
 
1191
        self.build_tree(['a'])
 
1192
        # Add one where we don't provide the stat or sha already
 
1193
        link_or_sha1 = state.update_entry(entry, abspath='a')
 
1194
        self.assertEqual('b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6',
 
1195
                         link_or_sha1)
 
1196
        stat_value = os.lstat('a')
 
1197
        self.assertEqual([('lstat', 'a'), ('sha1', 'a'),
 
1198
                          ('is_exec', stat_value.st_mode, False),
 
1199
                         ], state._log)
 
1200
 
 
1201
    def test_update_entry_symlink(self):
 
1202
        """Update entry should read symlinks."""
 
1203
        if not osutils.has_symlinks():
 
1204
            return # PlatformDeficiency / TestSkipped
 
1205
        state, entry = self.get_state_with_a()
 
1206
        state.save()
 
1207
        self.assertEqual(dirstate.DirState.IN_MEMORY_UNMODIFIED,
 
1208
                         state._dirblock_state)
 
1209
        os.symlink('target', 'a')
 
1210
 
 
1211
        state.adjust_time(-10) # Make the symlink look new
 
1212
        stat_value = os.lstat('a')
 
1213
        packed_stat = dirstate.pack_stat(stat_value)
 
1214
        link_or_sha1 = state.update_entry(entry, abspath='a',
 
1215
                                          stat_value=stat_value)
 
1216
        self.assertEqual('target', link_or_sha1)
 
1217
        self.assertEqual([('read_link', 'a', '')], state._log)
 
1218
        # Dirblock is updated
 
1219
        self.assertEqual([('l', link_or_sha1, 6, False, packed_stat)],
 
1220
                         entry[1])
 
1221
        self.assertEqual(dirstate.DirState.IN_MEMORY_MODIFIED,
 
1222
                         state._dirblock_state)
 
1223
 
 
1224
        # Because the stat_value looks new, we should re-read the target
 
1225
        link_or_sha1 = state.update_entry(entry, abspath='a',
 
1226
                                          stat_value=stat_value)
 
1227
        self.assertEqual('target', link_or_sha1)
 
1228
        self.assertEqual([('read_link', 'a', ''),
 
1229
                          ('read_link', 'a', 'target'),
 
1230
                         ], state._log)
 
1231
        state.adjust_time(+20) # Skip into the future, all files look old
 
1232
        link_or_sha1 = state.update_entry(entry, abspath='a',
 
1233
                                          stat_value=stat_value)
 
1234
        self.assertEqual('target', link_or_sha1)
 
1235
        # There should not be a new read_link call.
 
1236
        # (this is a weak assertion, because read_link is fairly inexpensive,
 
1237
        # versus the number of symlinks that we would have)
 
1238
        self.assertEqual([('read_link', 'a', ''),
 
1239
                          ('read_link', 'a', 'target'),
 
1240
                         ], state._log)
 
1241
 
 
1242
    def test_update_entry_dir(self):
 
1243
        state, entry = self.get_state_with_a()
 
1244
        self.build_tree(['a/'])
 
1245
        self.assertIs(None, state.update_entry(entry, 'a'))
 
1246
 
 
1247
    def create_and_test_file(self, state, entry):
 
1248
        """Create a file at 'a' and verify the state finds it.
 
1249
 
 
1250
        The state should already be versioning *something* at 'a'. This makes
 
1251
        sure that state.update_entry recognizes it as a file.
 
1252
        """
 
1253
        self.build_tree(['a'])
 
1254
        stat_value = os.lstat('a')
 
1255
        packed_stat = dirstate.pack_stat(stat_value)
 
1256
 
 
1257
        link_or_sha1 = state.update_entry(entry, abspath='a')
 
1258
        self.assertEqual('b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6',
 
1259
                         link_or_sha1)
 
1260
        self.assertEqual([('f', link_or_sha1, 14, False, packed_stat)],
 
1261
                         entry[1])
 
1262
        return packed_stat
 
1263
 
 
1264
    def create_and_test_dir(self, state, entry):
 
1265
        """Create a directory at 'a' and verify the state finds it.
 
1266
 
 
1267
        The state should already be versioning *something* at 'a'. This makes
 
1268
        sure that state.update_entry recognizes it as a directory.
 
1269
        """
 
1270
        self.build_tree(['a/'])
 
1271
        stat_value = os.lstat('a')
 
1272
        packed_stat = dirstate.pack_stat(stat_value)
 
1273
 
 
1274
        link_or_sha1 = state.update_entry(entry, abspath='a')
 
1275
        self.assertIs(None, link_or_sha1)
 
1276
        self.assertEqual([('d', '', 0, False, packed_stat)], entry[1])
 
1277
 
 
1278
        return packed_stat
 
1279
 
 
1280
    def create_and_test_symlink(self, state, entry):
 
1281
        """Create a symlink at 'a' and verify the state finds it.
 
1282
 
 
1283
        The state should already be versioning *something* at 'a'. This makes
 
1284
        sure that state.update_entry recognizes it as a symlink.
 
1285
 
 
1286
        This should not be called if this platform does not have symlink
 
1287
        support.
 
1288
        """
 
1289
        os.symlink('path/to/foo', 'a')
 
1290
 
 
1291
        stat_value = os.lstat('a')
 
1292
        packed_stat = dirstate.pack_stat(stat_value)
 
1293
 
 
1294
        link_or_sha1 = state.update_entry(entry, abspath='a')
 
1295
        self.assertEqual('path/to/foo', link_or_sha1)
 
1296
        self.assertEqual([('l', 'path/to/foo', 11, False, packed_stat)],
 
1297
                         entry[1])
 
1298
        return packed_stat
 
1299
 
 
1300
    def test_update_missing_file(self):
 
1301
        state, entry = self.get_state_with_a()
 
1302
        packed_stat = self.create_and_test_file(state, entry)
 
1303
        # Now if we delete the file, update_entry should recover and
 
1304
        # return None.
 
1305
        os.remove('a')
 
1306
        self.assertIs(None, state.update_entry(entry, abspath='a'))
 
1307
        # And the record shouldn't be changed.
 
1308
        digest = 'b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6'
 
1309
        self.assertEqual([('f', digest, 14, False, packed_stat)],
 
1310
                         entry[1])
 
1311
 
 
1312
    def test_update_missing_dir(self):
 
1313
        state, entry = self.get_state_with_a()
 
1314
        packed_stat = self.create_and_test_dir(state, entry)
 
1315
        # Now if we delete the directory, update_entry should recover and
 
1316
        # return None.
 
1317
        os.rmdir('a')
 
1318
        self.assertIs(None, state.update_entry(entry, abspath='a'))
 
1319
        self.assertEqual([('d', '', 0, False, packed_stat)], entry[1])
 
1320
 
 
1321
    def test_update_missing_symlink(self):
 
1322
        if not osutils.has_symlinks():
 
1323
            return # PlatformDeficiency / TestSkipped
 
1324
        state, entry = self.get_state_with_a()
 
1325
        packed_stat = self.create_and_test_symlink(state, entry)
 
1326
        os.remove('a')
 
1327
        self.assertIs(None, state.update_entry(entry, abspath='a'))
 
1328
        # And the record shouldn't be changed.
 
1329
        self.assertEqual([('l', 'path/to/foo', 11, False, packed_stat)],
 
1330
                         entry[1])
 
1331
 
 
1332
    def test_update_file_to_dir(self):
 
1333
        """If a file changes to a directory we return None for the sha.
 
1334
        We also update the inventory record.
 
1335
        """
 
1336
        state, entry = self.get_state_with_a()
 
1337
        self.create_and_test_file(state, entry)
 
1338
        os.remove('a')
 
1339
        self.create_and_test_dir(state, entry)
 
1340
 
 
1341
    def test_update_file_to_symlink(self):
 
1342
        """File becomes a symlink"""
 
1343
        if not osutils.has_symlinks():
 
1344
            return # PlatformDeficiency / TestSkipped
 
1345
        state, entry = self.get_state_with_a()
 
1346
        self.create_and_test_file(state, entry)
 
1347
        os.remove('a')
 
1348
        self.create_and_test_symlink(state, entry)
 
1349
 
 
1350
    def test_update_dir_to_file(self):
 
1351
        """Directory becoming a file updates the entry."""
 
1352
        state, entry = self.get_state_with_a()
 
1353
        self.create_and_test_dir(state, entry)
 
1354
        os.rmdir('a')
 
1355
        self.create_and_test_file(state, entry)
 
1356
 
 
1357
    def test_update_dir_to_symlink(self):
 
1358
        """Directory becomes a symlink"""
 
1359
        if not osutils.has_symlinks():
 
1360
            return # PlatformDeficiency / TestSkipped
 
1361
        state, entry = self.get_state_with_a()
 
1362
        self.create_and_test_dir(state, entry)
 
1363
        os.rmdir('a')
 
1364
        self.create_and_test_symlink(state, entry)
 
1365
 
 
1366
    def test_update_symlink_to_file(self):
 
1367
        """Symlink becomes a file"""
 
1368
        state, entry = self.get_state_with_a()
 
1369
        self.create_and_test_symlink(state, entry)
 
1370
        os.remove('a')
 
1371
        self.create_and_test_file(state, entry)
 
1372
 
 
1373
    def test_update_symlink_to_dir(self):
 
1374
        """Symlink becomes a directory"""
 
1375
        state, entry = self.get_state_with_a()
 
1376
        self.create_and_test_symlink(state, entry)
 
1377
        os.remove('a')
 
1378
        self.create_and_test_dir(state, entry)
 
1379
 
 
1380
    def test__is_executable_win32(self):
 
1381
        state, entry = self.get_state_with_a()
 
1382
        self.build_tree(['a'])
 
1383
 
 
1384
        # Make sure we are using the win32 implementation of _is_executable
 
1385
        state._is_executable = state._is_executable_win32
 
1386
 
 
1387
        # The file on disk is not executable, but we are marking it as though
 
1388
        # it is. With _is_executable_win32 we ignore what is on disk.
 
1389
        entry[1][0] = ('f', '', 0, True, dirstate.DirState.NULLSTAT)
 
1390
 
 
1391
        stat_value = os.lstat('a')
 
1392
        packed_stat = dirstate.pack_stat(stat_value)
 
1393
 
 
1394
        state.adjust_time(-10) # Make sure everything is new
 
1395
        # Make sure it wants to kkkkkkkk
 
1396
        state.update_entry(entry, abspath='a', stat_value=stat_value)
 
1397
 
 
1398
        # The row is updated, but the executable bit stays set.
 
1399
        digest = 'b50e5406bb5e153ebbeb20268fcf37c87e1ecfb6'
 
1400
        self.assertEqual([('f', digest, 14, True, packed_stat)], entry[1])
 
1401
 
 
1402
 
 
1403
class TestPackStat(TestCaseWithTransport):
1745
1404
 
1746
1405
    def assertPackStat(self, expected, stat_value):
1747
1406
        """Check the packed and serialized form of a stat value."""
1793
1452
        self.assertPackStat('AAAbWEXm4FxF5uBmAAADCQBjLNIAAIGk', st)
1794
1453
 
1795
1454
 
1796
 
class TestBisect(TestCaseWithDirState):
 
1455
class TestBisect(TestCaseWithTransport):
1797
1456
    """Test the ability to bisect into the disk format."""
1798
1457
 
 
1458
    def create_basic_dirstate(self):
 
1459
        """Create a dirstate with a few files and directories.
 
1460
 
 
1461
            a
 
1462
            b/
 
1463
              c
 
1464
              d/
 
1465
                e
 
1466
            f
 
1467
        """
 
1468
        tree = self.make_branch_and_tree('tree')
 
1469
        paths = ['a', 'b/', 'b/c', 'b/d/', 'b/d/e', 'f']
 
1470
        file_ids = ['a-id', 'b-id', 'c-id', 'd-id', 'e-id', 'f-id']
 
1471
        self.build_tree(['tree/' + p for p in paths])
 
1472
        tree.set_root_id('TREE_ROOT')
 
1473
        tree.add([p.rstrip('/') for p in paths], file_ids)
 
1474
        tree.commit('initial', rev_id='rev-1')
 
1475
        revision_id = 'rev-1'
 
1476
        # a_packed_stat = dirstate.pack_stat(os.stat('tree/a'))
 
1477
        t = self.get_transport().clone('tree')
 
1478
        a_text = t.get_bytes('a')
 
1479
        a_sha = osutils.sha_string(a_text)
 
1480
        a_len = len(a_text)
 
1481
        # b_packed_stat = dirstate.pack_stat(os.stat('tree/b'))
 
1482
        # c_packed_stat = dirstate.pack_stat(os.stat('tree/b/c'))
 
1483
        c_text = t.get_bytes('b/c')
 
1484
        c_sha = osutils.sha_string(c_text)
 
1485
        c_len = len(c_text)
 
1486
        # d_packed_stat = dirstate.pack_stat(os.stat('tree/b/d'))
 
1487
        # e_packed_stat = dirstate.pack_stat(os.stat('tree/b/d/e'))
 
1488
        e_text = t.get_bytes('b/d/e')
 
1489
        e_sha = osutils.sha_string(e_text)
 
1490
        e_len = len(e_text)
 
1491
        # f_packed_stat = dirstate.pack_stat(os.stat('tree/f'))
 
1492
        f_text = t.get_bytes('f')
 
1493
        f_sha = osutils.sha_string(f_text)
 
1494
        f_len = len(f_text)
 
1495
        null_stat = dirstate.DirState.NULLSTAT
 
1496
        expected = {
 
1497
            '':(('', '', 'TREE_ROOT'), [
 
1498
                  ('d', '', 0, False, null_stat),
 
1499
                  ('d', '', 0, False, revision_id),
 
1500
                ]),
 
1501
            'a':(('', 'a', 'a-id'), [
 
1502
                   ('f', '', 0, False, null_stat),
 
1503
                   ('f', a_sha, a_len, False, revision_id),
 
1504
                 ]),
 
1505
            'b':(('', 'b', 'b-id'), [
 
1506
                  ('d', '', 0, False, null_stat),
 
1507
                  ('d', '', 0, False, revision_id),
 
1508
                 ]),
 
1509
            'b/c':(('b', 'c', 'c-id'), [
 
1510
                    ('f', '', 0, False, null_stat),
 
1511
                    ('f', c_sha, c_len, False, revision_id),
 
1512
                   ]),
 
1513
            'b/d':(('b', 'd', 'd-id'), [
 
1514
                    ('d', '', 0, False, null_stat),
 
1515
                    ('d', '', 0, False, revision_id),
 
1516
                   ]),
 
1517
            'b/d/e':(('b/d', 'e', 'e-id'), [
 
1518
                      ('f', '', 0, False, null_stat),
 
1519
                      ('f', e_sha, e_len, False, revision_id),
 
1520
                     ]),
 
1521
            'f':(('', 'f', 'f-id'), [
 
1522
                  ('f', '', 0, False, null_stat),
 
1523
                  ('f', f_sha, f_len, False, revision_id),
 
1524
                 ]),
 
1525
        }
 
1526
        state = dirstate.DirState.from_tree(tree, 'dirstate')
 
1527
        try:
 
1528
            state.save()
 
1529
        finally:
 
1530
            state.unlock()
 
1531
        # Use a different object, to make sure nothing is pre-cached in memory.
 
1532
        state = dirstate.DirState.on_file('dirstate')
 
1533
        state.lock_read()
 
1534
        self.addCleanup(state.unlock)
 
1535
        self.assertEqual(dirstate.DirState.NOT_IN_MEMORY,
 
1536
                         state._dirblock_state)
 
1537
        # This is code is only really tested if we actually have to make more
 
1538
        # than one read, so set the page size to something smaller.
 
1539
        # We want it to contain about 2.2 records, so that we have a couple
 
1540
        # records that we can read per attempt
 
1541
        state._bisect_page_size = 200
 
1542
        return tree, state, expected
 
1543
 
 
1544
    def create_duplicated_dirstate(self):
 
1545
        """Create a dirstate with a deleted and added entries.
 
1546
 
 
1547
        This grabs a basic_dirstate, and then removes and re adds every entry
 
1548
        with a new file id.
 
1549
        """
 
1550
        tree, state, expected = self.create_basic_dirstate()
 
1551
        # Now we will just remove and add every file so we get an extra entry
 
1552
        # per entry. Unversion in reverse order so we handle subdirs
 
1553
        tree.unversion(['f-id', 'e-id', 'd-id', 'c-id', 'b-id', 'a-id'])
 
1554
        tree.add(['a', 'b', 'b/c', 'b/d', 'b/d/e', 'f'],
 
1555
                 ['a-id2', 'b-id2', 'c-id2', 'd-id2', 'e-id2', 'f-id2'])
 
1556
 
 
1557
        # Update the expected dictionary.
 
1558
        for path in ['a', 'b', 'b/c', 'b/d', 'b/d/e', 'f']:
 
1559
            orig = expected[path]
 
1560
            path2 = path + '2'
 
1561
            # This record was deleted in the current tree
 
1562
            expected[path] = (orig[0], [dirstate.DirState.NULL_PARENT_DETAILS,
 
1563
                                        orig[1][1]])
 
1564
            new_key = (orig[0][0], orig[0][1], orig[0][2]+'2')
 
1565
            # And didn't exist in the basis tree
 
1566
            expected[path2] = (new_key, [orig[1][0],
 
1567
                                         dirstate.DirState.NULL_PARENT_DETAILS])
 
1568
 
 
1569
        # We will replace the 'dirstate' file underneath 'state', but that is
 
1570
        # okay as lock as we unlock 'state' first.
 
1571
        state.unlock()
 
1572
        try:
 
1573
            new_state = dirstate.DirState.from_tree(tree, 'dirstate')
 
1574
            try:
 
1575
                new_state.save()
 
1576
            finally:
 
1577
                new_state.unlock()
 
1578
        finally:
 
1579
            # But we need to leave state in a read-lock because we already have
 
1580
            # a cleanup scheduled
 
1581
            state.lock_read()
 
1582
        return tree, state, expected
 
1583
 
 
1584
    def create_renamed_dirstate(self):
 
1585
        """Create a dirstate with a few internal renames.
 
1586
 
 
1587
        This takes the basic dirstate, and moves the paths around.
 
1588
        """
 
1589
        tree, state, expected = self.create_basic_dirstate()
 
1590
        # Rename a file
 
1591
        tree.rename_one('a', 'b/g')
 
1592
        # And a directory
 
1593
        tree.rename_one('b/d', 'h')
 
1594
 
 
1595
        old_a = expected['a']
 
1596
        expected['a'] = (old_a[0], [('r', 'b/g', 0, False, ''), old_a[1][1]])
 
1597
        expected['b/g'] = (('b', 'g', 'a-id'), [old_a[1][0],
 
1598
                                                ('r', 'a', 0, False, '')])
 
1599
        old_d = expected['b/d']
 
1600
        expected['b/d'] = (old_d[0], [('r', 'h', 0, False, ''), old_d[1][1]])
 
1601
        expected['h'] = (('', 'h', 'd-id'), [old_d[1][0],
 
1602
                                             ('r', 'b/d', 0, False, '')])
 
1603
 
 
1604
        old_e = expected['b/d/e']
 
1605
        expected['b/d/e'] = (old_e[0], [('r', 'h/e', 0, False, ''),
 
1606
                             old_e[1][1]])
 
1607
        expected['h/e'] = (('h', 'e', 'e-id'), [old_e[1][0],
 
1608
                                                ('r', 'b/d/e', 0, False, '')])
 
1609
 
 
1610
        state.unlock()
 
1611
        try:
 
1612
            new_state = dirstate.DirState.from_tree(tree, 'dirstate')
 
1613
            try:
 
1614
                new_state.save()
 
1615
            finally:
 
1616
                new_state.unlock()
 
1617
        finally:
 
1618
            state.lock_read()
 
1619
        return tree, state, expected
 
1620
 
1799
1621
    def assertBisect(self, expected_map, map_keys, state, paths):
1800
1622
        """Assert that bisecting for paths returns the right result.
1801
1623
 
1806
1628
                      (dir, name) tuples, and sorted according to how _bisect
1807
1629
                      requires.
1808
1630
        """
1809
 
        result = state._bisect(paths)
 
1631
        dir_names = sorted(osutils.split(p) for p in paths)
 
1632
        result = state._bisect(dir_names)
1810
1633
        # For now, results are just returned in whatever order we read them.
1811
1634
        # We could sort by (dir, name, file_id) or something like that, but in
1812
1635
        # the end it would still be fairly arbitrary, and we don't want the
1813
1636
        # extra overhead if we can avoid it. So sort everything to make sure
1814
1637
        # equality is true
1815
 
        self.assertEqual(len(map_keys), len(paths))
 
1638
        assert len(map_keys) == len(dir_names)
1816
1639
        expected = {}
1817
 
        for path, keys in zip(paths, map_keys):
 
1640
        for dir_name, keys in zip(dir_names, map_keys):
1818
1641
            if keys is None:
1819
1642
                # This should not be present in the output
1820
1643
                continue
1821
 
            expected[path] = sorted(expected_map[k] for k in keys)
 
1644
            expected[dir_name] = sorted(expected_map[k] for k in keys)
1822
1645
 
1823
 
        # The returned values are just arranged randomly based on when they
1824
 
        # were read, for testing, make sure it is properly sorted.
1825
 
        for path in result:
1826
 
            result[path].sort()
 
1646
        for dir_name in result:
 
1647
            result[dir_name].sort()
1827
1648
 
1828
1649
        self.assertEqual(expected, result)
1829
1650
 
1837
1658
        :param paths: A list of directories
1838
1659
        """
1839
1660
        result = state._bisect_dirblocks(paths)
1840
 
        self.assertEqual(len(map_keys), len(paths))
 
1661
        assert len(map_keys) == len(paths)
 
1662
 
1841
1663
        expected = {}
1842
1664
        for path, keys in zip(paths, map_keys):
1843
1665
            if keys is None:
1865
1687
            dir_name_id, trees_info = entry
1866
1688
            expected[dir_name_id] = trees_info
1867
1689
 
1868
 
        result = state._bisect_recursive(paths)
 
1690
        dir_names = sorted(osutils.split(p) for p in paths)
 
1691
        result = state._bisect_recursive(dir_names)
1869
1692
 
1870
1693
        self.assertEqual(expected, result)
1871
1694
 
1880
1703
        self.assertBisect(expected, [['b/c']], state, ['b/c'])
1881
1704
        self.assertBisect(expected, [['b/d']], state, ['b/d'])
1882
1705
        self.assertBisect(expected, [['b/d/e']], state, ['b/d/e'])
1883
 
        self.assertBisect(expected, [['b-c']], state, ['b-c'])
1884
1706
        self.assertBisect(expected, [['f']], state, ['f'])
1885
1707
 
1886
1708
    def test_bisect_multi(self):
1889
1711
        # Bisect should be capable of finding multiple entries at the same time
1890
1712
        self.assertBisect(expected, [['a'], ['b'], ['f']],
1891
1713
                          state, ['a', 'b', 'f'])
 
1714
        # ('', 'f') sorts before the others
1892
1715
        self.assertBisect(expected, [['f'], ['b/d'], ['b/d/e']],
1893
 
                          state, ['f', 'b/d', 'b/d/e'])
1894
 
        self.assertBisect(expected, [['b'], ['b-c'], ['b/c']],
1895
 
                          state, ['b', 'b-c', 'b/c'])
 
1716
                          state, ['b/d', 'b/d/e', 'f'])
1896
1717
 
1897
1718
    def test_bisect_one_page(self):
1898
1719
        """Test bisect when there is only 1 page to read"""
1904
1725
        self.assertBisect(expected,[['b/c']], state, ['b/c'])
1905
1726
        self.assertBisect(expected,[['b/d']], state, ['b/d'])
1906
1727
        self.assertBisect(expected,[['b/d/e']], state, ['b/d/e'])
1907
 
        self.assertBisect(expected,[['b-c']], state, ['b-c'])
1908
1728
        self.assertBisect(expected,[['f']], state, ['f'])
1909
1729
        self.assertBisect(expected,[['a'], ['b'], ['f']],
1910
1730
                          state, ['a', 'b', 'f'])
1911
 
        self.assertBisect(expected, [['b/d'], ['b/d/e'], ['f']],
 
1731
        # ('', 'f') sorts before the others
 
1732
        self.assertBisect(expected, [['f'], ['b/d'], ['b/d/e']],
1912
1733
                          state, ['b/d', 'b/d/e', 'f'])
1913
 
        self.assertBisect(expected, [['b'], ['b/c'], ['b-c']],
1914
 
                          state, ['b', 'b/c', 'b-c'])
1915
1734
 
1916
1735
    def test_bisect_duplicate_paths(self):
1917
1736
        """When bisecting for a path, handle multiple entries."""
1925
1744
        self.assertBisect(expected, [['b/d', 'b/d2']], state, ['b/d'])
1926
1745
        self.assertBisect(expected, [['b/d/e', 'b/d/e2']],
1927
1746
                          state, ['b/d/e'])
1928
 
        self.assertBisect(expected, [['b-c', 'b-c2']], state, ['b-c'])
1929
1747
        self.assertBisect(expected, [['f', 'f2']], state, ['f'])
1930
1748
 
1931
1749
    def test_bisect_page_size_too_small(self):
1938
1756
        self.assertBisect(expected, [['b/c']], state, ['b/c'])
1939
1757
        self.assertBisect(expected, [['b/d']], state, ['b/d'])
1940
1758
        self.assertBisect(expected, [['b/d/e']], state, ['b/d/e'])
1941
 
        self.assertBisect(expected, [['b-c']], state, ['b-c'])
1942
1759
        self.assertBisect(expected, [['f']], state, ['f'])
1943
1760
 
1944
1761
    def test_bisect_missing(self):
1947
1764
        self.assertBisect(expected, [None], state, ['foo'])
1948
1765
        self.assertBisect(expected, [None], state, ['b/foo'])
1949
1766
        self.assertBisect(expected, [None], state, ['bar/foo'])
1950
 
        self.assertBisect(expected, [None], state, ['b-c/foo'])
1951
1767
 
1952
1768
        self.assertBisect(expected, [['a'], None, ['b/d']],
1953
1769
                          state, ['a', 'foo', 'b/d'])
1969
1785
    def test_bisect_dirblocks(self):
1970
1786
        tree, state, expected = self.create_duplicated_dirstate()
1971
1787
        self.assertBisectDirBlocks(expected,
1972
 
            [['', 'a', 'a2', 'b', 'b2', 'b-c', 'b-c2', 'f', 'f2']],
1973
 
            state, [''])
 
1788
            [['', 'a', 'a2', 'b', 'b2', 'f', 'f2']], state, [''])
1974
1789
        self.assertBisectDirBlocks(expected,
1975
1790
            [['b/c', 'b/c2', 'b/d', 'b/d2']], state, ['b'])
1976
1791
        self.assertBisectDirBlocks(expected,
1977
1792
            [['b/d/e', 'b/d/e2']], state, ['b/d'])
1978
1793
        self.assertBisectDirBlocks(expected,
1979
 
            [['', 'a', 'a2', 'b', 'b2', 'b-c', 'b-c2', 'f', 'f2'],
 
1794
            [['', 'a', 'a2', 'b', 'b2', 'f', 'f2'],
1980
1795
             ['b/c', 'b/c2', 'b/d', 'b/d2'],
1981
1796
             ['b/d/e', 'b/d/e2'],
1982
1797
            ], state, ['', 'b', 'b/d'])
1997
1812
        self.assertBisectRecursive(expected, ['a'], state, ['a'])
1998
1813
        self.assertBisectRecursive(expected, ['b/c'], state, ['b/c'])
1999
1814
        self.assertBisectRecursive(expected, ['b/d/e'], state, ['b/d/e'])
2000
 
        self.assertBisectRecursive(expected, ['b-c'], state, ['b-c'])
2001
1815
        self.assertBisectRecursive(expected, ['b/d', 'b/d/e'],
2002
1816
                                   state, ['b/d'])
2003
1817
        self.assertBisectRecursive(expected, ['b', 'b/c', 'b/d', 'b/d/e'],
2004
1818
                                   state, ['b'])
2005
 
        self.assertBisectRecursive(expected, ['', 'a', 'b', 'b-c', 'f', 'b/c',
 
1819
        self.assertBisectRecursive(expected, ['', 'a', 'b', 'f', 'b/c',
2006
1820
                                              'b/d', 'b/d/e'],
2007
1821
                                   state, [''])
2008
1822
 
2032
1846
                                   state, ['b'])
2033
1847
 
2034
1848
 
2035
 
class TestDirstateValidation(TestCaseWithDirState):
2036
 
 
2037
 
    def test_validate_correct_dirstate(self):
2038
 
        state = self.create_complex_dirstate()
2039
 
        state._validate()
2040
 
        state.unlock()
2041
 
        # and make sure we can also validate with a read lock
2042
 
        state.lock_read()
2043
 
        try:
2044
 
            state._validate()
2045
 
        finally:
2046
 
            state.unlock()
2047
 
 
2048
 
    def test_dirblock_not_sorted(self):
2049
 
        tree, state, expected = self.create_renamed_dirstate()
2050
 
        state._read_dirblocks_if_needed()
2051
 
        last_dirblock = state._dirblocks[-1]
2052
 
        # we're appending to the dirblock, but this name comes before some of
2053
 
        # the existing names; that's wrong
2054
 
        last_dirblock[1].append(
2055
 
            (('h', 'aaaa', 'a-id'),
2056
 
             [('a', '', 0, False, ''),
2057
 
              ('a', '', 0, False, '')]))
2058
 
        e = self.assertRaises(AssertionError,
2059
 
            state._validate)
2060
 
        self.assertContainsRe(str(e), 'not sorted')
2061
 
 
2062
 
    def test_dirblock_name_mismatch(self):
2063
 
        tree, state, expected = self.create_renamed_dirstate()
2064
 
        state._read_dirblocks_if_needed()
2065
 
        last_dirblock = state._dirblocks[-1]
2066
 
        # add an entry with the wrong directory name
2067
 
        last_dirblock[1].append(
2068
 
            (('', 'z', 'a-id'),
2069
 
             [('a', '', 0, False, ''),
2070
 
              ('a', '', 0, False, '')]))
2071
 
        e = self.assertRaises(AssertionError,
2072
 
            state._validate)
2073
 
        self.assertContainsRe(str(e),
2074
 
            "doesn't match directory name")
2075
 
 
2076
 
    def test_dirblock_missing_rename(self):
2077
 
        tree, state, expected = self.create_renamed_dirstate()
2078
 
        state._read_dirblocks_if_needed()
2079
 
        last_dirblock = state._dirblocks[-1]
2080
 
        # make another entry for a-id, without a correct 'r' pointer to
2081
 
        # the real occurrence in the working tree
2082
 
        last_dirblock[1].append(
2083
 
            (('h', 'z', 'a-id'),
2084
 
             [('a', '', 0, False, ''),
2085
 
              ('a', '', 0, False, '')]))
2086
 
        e = self.assertRaises(AssertionError,
2087
 
            state._validate)
2088
 
        self.assertContainsRe(str(e),
2089
 
            'file a-id is absent in row')
2090
 
 
2091
 
 
2092
 
class TestDirstateTreeReference(TestCaseWithDirState):
2093
 
 
2094
 
    def test_reference_revision_is_none(self):
2095
 
        tree = self.make_branch_and_tree('tree', format='dirstate-with-subtree')
2096
 
        subtree = self.make_branch_and_tree('tree/subtree',
2097
 
                            format='dirstate-with-subtree')
2098
 
        subtree.set_root_id('subtree')
2099
 
        tree.add_reference(subtree)
2100
 
        tree.add('subtree')
2101
 
        state = dirstate.DirState.from_tree(tree, 'dirstate')
2102
 
        key = ('', 'subtree', 'subtree')
2103
 
        expected = ('', [(key,
2104
 
            [('t', '', 0, False, 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx')])])
2105
 
 
2106
 
        try:
2107
 
            self.assertEqual(expected, state._find_block(key))
2108
 
        finally:
2109
 
            state.unlock()
2110
 
 
2111
 
 
2112
 
class TestDiscardMergeParents(TestCaseWithDirState):
2113
 
 
2114
 
    def test_discard_no_parents(self):
2115
 
        # This should be a no-op
2116
 
        state = self.create_empty_dirstate()
2117
 
        self.addCleanup(state.unlock)
2118
 
        state._discard_merge_parents()
2119
 
        state._validate()
2120
 
 
2121
 
    def test_discard_one_parent(self):
2122
 
        # No-op
2123
 
        packed_stat = 'AAAAREUHaIpFB2iKAAADAQAtkqUAAIGk'
2124
 
        root_entry_direntry = ('', '', 'a-root-value'), [
2125
 
            ('d', '', 0, False, packed_stat),
2126
 
            ('d', '', 0, False, packed_stat),
2127
 
            ]
2128
 
        dirblocks = []
2129
 
        dirblocks.append(('', [root_entry_direntry]))
2130
 
        dirblocks.append(('', []))
2131
 
 
2132
 
        state = self.create_empty_dirstate()
2133
 
        self.addCleanup(state.unlock)
2134
 
        state._set_data(['parent-id'], dirblocks[:])
2135
 
        state._validate()
2136
 
 
2137
 
        state._discard_merge_parents()
2138
 
        state._validate()
2139
 
        self.assertEqual(dirblocks, state._dirblocks)
2140
 
 
2141
 
    def test_discard_simple(self):
2142
 
        # No-op
2143
 
        packed_stat = 'AAAAREUHaIpFB2iKAAADAQAtkqUAAIGk'
2144
 
        root_entry_direntry = ('', '', 'a-root-value'), [
2145
 
            ('d', '', 0, False, packed_stat),
2146
 
            ('d', '', 0, False, packed_stat),
2147
 
            ('d', '', 0, False, packed_stat),
2148
 
            ]
2149
 
        expected_root_entry_direntry = ('', '', 'a-root-value'), [
2150
 
            ('d', '', 0, False, packed_stat),
2151
 
            ('d', '', 0, False, packed_stat),
2152
 
            ]
2153
 
        dirblocks = []
2154
 
        dirblocks.append(('', [root_entry_direntry]))
2155
 
        dirblocks.append(('', []))
2156
 
 
2157
 
        state = self.create_empty_dirstate()
2158
 
        self.addCleanup(state.unlock)
2159
 
        state._set_data(['parent-id', 'merged-id'], dirblocks[:])
2160
 
        state._validate()
2161
 
 
2162
 
        # This should strip of the extra column
2163
 
        state._discard_merge_parents()
2164
 
        state._validate()
2165
 
        expected_dirblocks = [('', [expected_root_entry_direntry]), ('', [])]
2166
 
        self.assertEqual(expected_dirblocks, state._dirblocks)
2167
 
 
2168
 
    def test_discard_absent(self):
2169
 
        """If entries are only in a merge, discard should remove the entries"""
2170
 
        null_stat = dirstate.DirState.NULLSTAT
2171
 
        present_dir = ('d', '', 0, False, null_stat)
2172
 
        present_file = ('f', '', 0, False, null_stat)
2173
 
        absent = dirstate.DirState.NULL_PARENT_DETAILS
2174
 
        root_key = ('', '', 'a-root-value')
2175
 
        file_in_root_key = ('', 'file-in-root', 'a-file-id')
2176
 
        file_in_merged_key = ('', 'file-in-merged', 'b-file-id')
2177
 
        dirblocks = [('', [(root_key, [present_dir, present_dir, present_dir])]),
2178
 
                     ('', [(file_in_merged_key,
2179
 
                            [absent, absent, present_file]),
2180
 
                           (file_in_root_key,
2181
 
                            [present_file, present_file, present_file]),
2182
 
                          ]),
2183
 
                    ]
2184
 
 
2185
 
        state = self.create_empty_dirstate()
2186
 
        self.addCleanup(state.unlock)
2187
 
        state._set_data(['parent-id', 'merged-id'], dirblocks[:])
2188
 
        state._validate()
2189
 
 
2190
 
        exp_dirblocks = [('', [(root_key, [present_dir, present_dir])]),
2191
 
                         ('', [(file_in_root_key,
2192
 
                                [present_file, present_file]),
2193
 
                              ]),
2194
 
                        ]
2195
 
        state._discard_merge_parents()
2196
 
        state._validate()
2197
 
        self.assertEqual(exp_dirblocks, state._dirblocks)
2198
 
 
2199
 
    def test_discard_renamed(self):
2200
 
        null_stat = dirstate.DirState.NULLSTAT
2201
 
        present_dir = ('d', '', 0, False, null_stat)
2202
 
        present_file = ('f', '', 0, False, null_stat)
2203
 
        absent = dirstate.DirState.NULL_PARENT_DETAILS
2204
 
        root_key = ('', '', 'a-root-value')
2205
 
        file_in_root_key = ('', 'file-in-root', 'a-file-id')
2206
 
        # Renamed relative to parent
2207
 
        file_rename_s_key = ('', 'file-s', 'b-file-id')
2208
 
        file_rename_t_key = ('', 'file-t', 'b-file-id')
2209
 
        # And one that is renamed between the parents, but absent in this
2210
 
        key_in_1 = ('', 'file-in-1', 'c-file-id')
2211
 
        key_in_2 = ('', 'file-in-2', 'c-file-id')
2212
 
 
2213
 
        dirblocks = [
2214
 
            ('', [(root_key, [present_dir, present_dir, present_dir])]),
2215
 
            ('', [(key_in_1,
2216
 
                   [absent, present_file, ('r', 'file-in-2', 'c-file-id')]),
2217
 
                  (key_in_2,
2218
 
                   [absent, ('r', 'file-in-1', 'c-file-id'), present_file]),
2219
 
                  (file_in_root_key,
2220
 
                   [present_file, present_file, present_file]),
2221
 
                  (file_rename_s_key,
2222
 
                   [('r', 'file-t', 'b-file-id'), absent, present_file]),
2223
 
                  (file_rename_t_key,
2224
 
                   [present_file, absent, ('r', 'file-s', 'b-file-id')]),
2225
 
                 ]),
2226
 
        ]
2227
 
        exp_dirblocks = [
2228
 
            ('', [(root_key, [present_dir, present_dir])]),
2229
 
            ('', [(key_in_1, [absent, present_file]),
2230
 
                  (file_in_root_key, [present_file, present_file]),
2231
 
                  (file_rename_t_key, [present_file, absent]),
2232
 
                 ]),
2233
 
        ]
2234
 
        state = self.create_empty_dirstate()
2235
 
        self.addCleanup(state.unlock)
2236
 
        state._set_data(['parent-id', 'merged-id'], dirblocks[:])
2237
 
        state._validate()
2238
 
 
2239
 
        state._discard_merge_parents()
2240
 
        state._validate()
2241
 
        self.assertEqual(exp_dirblocks, state._dirblocks)
2242
 
 
2243
 
    def test_discard_all_subdir(self):
2244
 
        null_stat = dirstate.DirState.NULLSTAT
2245
 
        present_dir = ('d', '', 0, False, null_stat)
2246
 
        present_file = ('f', '', 0, False, null_stat)
2247
 
        absent = dirstate.DirState.NULL_PARENT_DETAILS
2248
 
        root_key = ('', '', 'a-root-value')
2249
 
        subdir_key = ('', 'sub', 'dir-id')
2250
 
        child1_key = ('sub', 'child1', 'child1-id')
2251
 
        child2_key = ('sub', 'child2', 'child2-id')
2252
 
        child3_key = ('sub', 'child3', 'child3-id')
2253
 
 
2254
 
        dirblocks = [
2255
 
            ('', [(root_key, [present_dir, present_dir, present_dir])]),
2256
 
            ('', [(subdir_key, [present_dir, present_dir, present_dir])]),
2257
 
            ('sub', [(child1_key, [absent, absent, present_file]),
2258
 
                     (child2_key, [absent, absent, present_file]),
2259
 
                     (child3_key, [absent, absent, present_file]),
2260
 
                    ]),
2261
 
        ]
2262
 
        exp_dirblocks = [
2263
 
            ('', [(root_key, [present_dir, present_dir])]),
2264
 
            ('', [(subdir_key, [present_dir, present_dir])]),
2265
 
            ('sub', []),
2266
 
        ]
2267
 
        state = self.create_empty_dirstate()
2268
 
        self.addCleanup(state.unlock)
2269
 
        state._set_data(['parent-id', 'merged-id'], dirblocks[:])
2270
 
        state._validate()
2271
 
 
2272
 
        state._discard_merge_parents()
2273
 
        state._validate()
2274
 
        self.assertEqual(exp_dirblocks, state._dirblocks)
2275
 
 
2276
 
 
2277
 
class Test_InvEntryToDetails(tests.TestCase):
2278
 
 
2279
 
    def assertDetails(self, expected, inv_entry):
2280
 
        details = dirstate.DirState._inv_entry_to_details(inv_entry)
2281
 
        self.assertEqual(expected, details)
2282
 
        # details should always allow join() and always be a plain str when
2283
 
        # finished
2284
 
        (minikind, fingerprint, size, executable, tree_data) = details
2285
 
        self.assertIsInstance(minikind, str)
2286
 
        self.assertIsInstance(fingerprint, str)
2287
 
        self.assertIsInstance(tree_data, str)
2288
 
 
2289
 
    def test_unicode_symlink(self):
2290
 
        inv_entry = inventory.InventoryLink('link-file-id',
2291
 
                                            u'nam\N{Euro Sign}e',
2292
 
                                            'link-parent-id')
2293
 
        inv_entry.revision = 'link-revision-id'
2294
 
        target = u'link-targ\N{Euro Sign}t'
2295
 
        inv_entry.symlink_target = target
2296
 
        self.assertDetails(('l', target.encode('UTF-8'), 0, False,
2297
 
                            'link-revision-id'), inv_entry)
2298
 
 
2299
 
 
2300
 
class TestSHA1Provider(tests.TestCaseInTempDir):
2301
 
 
2302
 
    def test_sha1provider_is_an_interface(self):
2303
 
        p = dirstate.SHA1Provider()
2304
 
        self.assertRaises(NotImplementedError, p.sha1, "foo")
2305
 
        self.assertRaises(NotImplementedError, p.stat_and_sha1, "foo")
2306
 
 
2307
 
    def test_defaultsha1provider_sha1(self):
2308
 
        text = 'test\r\nwith\nall\rpossible line endings\r\n'
2309
 
        self.build_tree_contents([('foo', text)])
2310
 
        expected_sha = osutils.sha_string(text)
2311
 
        p = dirstate.DefaultSHA1Provider()
2312
 
        self.assertEqual(expected_sha, p.sha1('foo'))
2313
 
 
2314
 
    def test_defaultsha1provider_stat_and_sha1(self):
2315
 
        text = 'test\r\nwith\nall\rpossible line endings\r\n'
2316
 
        self.build_tree_contents([('foo', text)])
2317
 
        expected_sha = osutils.sha_string(text)
2318
 
        p = dirstate.DefaultSHA1Provider()
2319
 
        statvalue, sha1 = p.stat_and_sha1('foo')
2320
 
        self.assertTrue(len(statvalue) >= 10)
2321
 
        self.assertEqual(len(text), statvalue.st_size)
2322
 
        self.assertEqual(expected_sha, sha1)
 
1849
class TestBisectDirblock(TestCase):
 
1850
    """Test that bisect_dirblock() returns the expected values.
 
1851
 
 
1852
    bisect_dirblock is intended to work like bisect.bisect_left() except it
 
1853
    knows it is working on dirblocks and that dirblocks are sorted by ('path',
 
1854
    'to', 'foo') chunks rather than by raw 'path/to/foo'.
 
1855
    """
 
1856
 
 
1857
    def assertBisect(self, dirblocks, split_dirblocks, path, *args, **kwargs):
 
1858
        """Assert that bisect_split works like bisect_left on the split paths.
 
1859
 
 
1860
        :param dirblocks: A list of (path, [info]) pairs.
 
1861
        :param split_dirblocks: A list of ((split, path), [info]) pairs.
 
1862
        :param path: The path we are indexing.
 
1863
 
 
1864
        All other arguments will be passed along.
 
1865
        """
 
1866
        bisect_split_idx = dirstate.bisect_dirblock(dirblocks, path,
 
1867
                                                 *args, **kwargs)
 
1868
        split_dirblock = (path.split('/'), [])
 
1869
        bisect_left_idx = bisect.bisect_left(split_dirblocks, split_dirblock,
 
1870
                                             *args)
 
1871
        self.assertEqual(bisect_left_idx, bisect_split_idx,
 
1872
                         'bisect_split disagreed. %s != %s'
 
1873
                         ' for key %s'
 
1874
                         % (bisect_left_idx, bisect_split_idx, path)
 
1875
                         )
 
1876
 
 
1877
    def paths_to_dirblocks(self, paths):
 
1878
        """Convert a list of paths into dirblock form.
 
1879
 
 
1880
        Also, ensure that the paths are in proper sorted order.
 
1881
        """
 
1882
        dirblocks = [(path, []) for path in paths]
 
1883
        split_dirblocks = [(path.split('/'), []) for path in paths]
 
1884
        self.assertEqual(sorted(split_dirblocks), split_dirblocks)
 
1885
        return dirblocks, split_dirblocks
 
1886
 
 
1887
    def test_simple(self):
 
1888
        """In the simple case it works just like bisect_left"""
 
1889
        paths = ['', 'a', 'b', 'c', 'd']
 
1890
        dirblocks, split_dirblocks = self.paths_to_dirblocks(paths)
 
1891
        for path in paths:
 
1892
            self.assertBisect(dirblocks, split_dirblocks, path)
 
1893
        self.assertBisect(dirblocks, split_dirblocks, '_')
 
1894
        self.assertBisect(dirblocks, split_dirblocks, 'aa')
 
1895
        self.assertBisect(dirblocks, split_dirblocks, 'bb')
 
1896
        self.assertBisect(dirblocks, split_dirblocks, 'cc')
 
1897
        self.assertBisect(dirblocks, split_dirblocks, 'dd')
 
1898
        self.assertBisect(dirblocks, split_dirblocks, 'a/a')
 
1899
        self.assertBisect(dirblocks, split_dirblocks, 'b/b')
 
1900
        self.assertBisect(dirblocks, split_dirblocks, 'c/c')
 
1901
        self.assertBisect(dirblocks, split_dirblocks, 'd/d')
 
1902
 
 
1903
    def test_involved(self):
 
1904
        """This is where bisect_left diverges slightly."""
 
1905
        paths = ['', 'a',
 
1906
                 'a/a', 'a/a/a', 'a/a/z', 'a/a-a', 'a/a-z',
 
1907
                 'a/z', 'a/z/a', 'a/z/z', 'a/z-a', 'a/z-z',
 
1908
                 'a-a', 'a-z',
 
1909
                 'z', 'z/a/a', 'z/a/z', 'z/a-a', 'z/a-z',
 
1910
                 'z/z', 'z/z/a', 'z/z/z', 'z/z-a', 'z/z-z',
 
1911
                 'z-a', 'z-z',
 
1912
                ]
 
1913
        dirblocks, split_dirblocks = self.paths_to_dirblocks(paths)
 
1914
        for path in paths:
 
1915
            self.assertBisect(dirblocks, split_dirblocks, path)
 
1916
 
 
1917
    def test_involved_cached(self):
 
1918
        """This is where bisect_left diverges slightly."""
 
1919
        paths = ['', 'a',
 
1920
                 'a/a', 'a/a/a', 'a/a/z', 'a/a-a', 'a/a-z',
 
1921
                 'a/z', 'a/z/a', 'a/z/z', 'a/z-a', 'a/z-z',
 
1922
                 'a-a', 'a-z',
 
1923
                 'z', 'z/a/a', 'z/a/z', 'z/a-a', 'z/a-z',
 
1924
                 'z/z', 'z/z/a', 'z/z/z', 'z/z-a', 'z/z-z',
 
1925
                 'z-a', 'z-z',
 
1926
                ]
 
1927
        cache = {}
 
1928
        dirblocks, split_dirblocks = self.paths_to_dirblocks(paths)
 
1929
        for path in paths:
 
1930
            self.assertBisect(dirblocks, split_dirblocks, path, cache=cache)
 
1931