summaryrefslogtreecommitdiff
path: root/jstests/replsets/rollback_transactions_count.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/rollback_transactions_count.js')
-rw-r--r--jstests/replsets/rollback_transactions_count.js90
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();
})();