diff options
Diffstat (limited to 'jstests/replsets/rollback_transactions_count.js')
-rw-r--r-- | jstests/replsets/rollback_transactions_count.js | 90 |
1 files changed, 45 insertions, 45 deletions
diff --git a/jstests/replsets/rollback_transactions_count.js b/jstests/replsets/rollback_transactions_count.js index f965211284a..1aa7ceeef1c 100644 --- a/jstests/replsets/rollback_transactions_count.js +++ b/jstests/replsets/rollback_transactions_count.js @@ -5,62 +5,62 @@ * @tags: [uses_transactions] */ (function() { - "use strict"; +"use strict"; - load("jstests/replsets/libs/rollback_test.js"); +load("jstests/replsets/libs/rollback_test.js"); - const testName = "rollback_transactions_count"; - const dbName = testName; - const collName = "txnCollName"; +const testName = "rollback_transactions_count"; +const dbName = testName; +const collName = "txnCollName"; - const rollbackTest = new RollbackTest(testName); - const primary = rollbackTest.getPrimary(); +const rollbackTest = new RollbackTest(testName); +const primary = rollbackTest.getPrimary(); - const session1 = primary.startSession(); - const sessionDb1 = session1.getDatabase(dbName); - const sessionColl1 = sessionDb1[collName]; - assert.commandWorked(sessionColl1.insert({a: 1})); - session1.startTransaction(); - assert.commandWorked(sessionColl1.insert({b: 1})); - assert.commandWorked(session1.commitTransaction_forTesting()); +const session1 = primary.startSession(); +const sessionDb1 = session1.getDatabase(dbName); +const sessionColl1 = sessionDb1[collName]; +assert.commandWorked(sessionColl1.insert({a: 1})); +session1.startTransaction(); +assert.commandWorked(sessionColl1.insert({b: 1})); +assert.commandWorked(session1.commitTransaction_forTesting()); - rollbackTest.awaitLastOpCommitted(); - assert.commandWorked( - primary.adminCommand({configureFailPoint: 'disableSnapshotting', mode: 'alwaysOn'})); +rollbackTest.awaitLastOpCommitted(); +assert.commandWorked( + primary.adminCommand({configureFailPoint: 'disableSnapshotting', mode: 'alwaysOn'})); - const session2 = primary.startSession(); - const sessionDb2 = session2.getDatabase(dbName); - const sessionColl2 = sessionDb2[collName]; - session2.startTransaction(); - assert.commandWorked(sessionColl2.insert({c: 1})); - assert.commandWorked(session2.commitTransaction_forTesting()); +const session2 = primary.startSession(); +const sessionDb2 = session2.getDatabase(dbName); +const sessionColl2 = sessionDb2[collName]; +session2.startTransaction(); +assert.commandWorked(sessionColl2.insert({c: 1})); +assert.commandWorked(session2.commitTransaction_forTesting()); - rollbackTest.transitionToRollbackOperations(); +rollbackTest.transitionToRollbackOperations(); - session2.startTransaction(); - assert.commandWorked(sessionColl2.insert({d: 1})); - assert.commandWorked(session2.commitTransaction_forTesting()); +session2.startTransaction(); +assert.commandWorked(sessionColl2.insert({d: 1})); +assert.commandWorked(session2.commitTransaction_forTesting()); - const session3 = primary.startSession(); - const sessionDb3 = session3.getDatabase(dbName); - const sessionColl3 = sessionDb3[collName]; - session3.startTransaction(); - assert.commandWorked(sessionColl3.insert({e: 1})); - assert.commandWorked(session3.commitTransaction_forTesting()); +const session3 = primary.startSession(); +const sessionDb3 = session3.getDatabase(dbName); +const sessionColl3 = sessionDb3[collName]; +session3.startTransaction(); +assert.commandWorked(sessionColl3.insert({e: 1})); +assert.commandWorked(session3.commitTransaction_forTesting()); - assert.eq(sessionColl1.find().itcount(), 5); +assert.eq(sessionColl1.find().itcount(), 5); - rollbackTest.transitionToSyncSourceOperationsBeforeRollback(); - rollbackTest.transitionToSyncSourceOperationsDuringRollback(); - try { - rollbackTest.transitionToSteadyStateOperations(); - } finally { - assert.commandWorked( - primary.adminCommand({configureFailPoint: 'disableSnapshotting', mode: 'off'})); - } +rollbackTest.transitionToSyncSourceOperationsBeforeRollback(); +rollbackTest.transitionToSyncSourceOperationsDuringRollback(); +try { + rollbackTest.transitionToSteadyStateOperations(); +} finally { + assert.commandWorked( + primary.adminCommand({configureFailPoint: 'disableSnapshotting', mode: 'off'})); +} - assert.eq(sessionColl1.find().itcount(), 3); - assert.eq(primary.getDB('config')['transactions'].find().itcount(), 2); +assert.eq(sessionColl1.find().itcount(), 3); +assert.eq(primary.getDB('config')['transactions'].find().itcount(), 2); - rollbackTest.stop(); +rollbackTest.stop(); })(); |