blob: 213efd8b1fd5bb08b82a304a2385f2f310101711 (
plain)
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();
})();
|