jstests/replsets/rollback_capped_deletions.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

/**
 * Tests that capped collections get the correct fastcounts after rollback.
 */
(function() {
    'use strict';

    load('jstests/replsets/libs/rollback_test.js');

    const testName = 'rollback_capped_deletions';
    const dbName = testName;
    const collName = 'cappedCollName';

    const rollbackTest = new RollbackTest(testName);
    const primary = rollbackTest.getPrimary();
    const testDb = primary.getDB(dbName);

    assert.commandWorked(testDb.runCommand({
        'create': collName,
        'capped': true,
        'size': 40,
    }));
    const coll = testDb.getCollection(collName);
    assert.commandWorked(coll.insert({a: 1}));

    rollbackTest.awaitLastOpCommitted();
    assert.commandWorked(
        primary.adminCommand({configureFailPoint: 'disableSnapshotting', mode: 'alwaysOn'}));

    assert.commandWorked(coll.insert({bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb: 1}));
    assert.commandWorked(coll.insert({cccccccccccccccccccccccccccccccccccccccccccc: 1}));
    assert.commandWorked(coll.insert({dddddddddddddddddddddddddddddddddddddddddddd: 1}));
    assert.commandWorked(coll.insert({eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee: 1}));

    rollbackTest.transitionToRollbackOperations();

    assert.commandWorked(coll.insert({ffffffffffffffffffffffffffffffffffffffffffff: 1}));

    rollbackTest.transitionToSyncSourceOperationsBeforeRollback();
    rollbackTest.transitionToSyncSourceOperationsDuringRollback();
    try {
        rollbackTest.transitionToSteadyStateOperations();
    } finally {
        assert.commandWorked(
            primary.adminCommand({configureFailPoint: 'disableSnapshotting', mode: 'off'}));
    }

    rollbackTest.stop();
})();