summaryrefslogtreecommitdiff
path: root/jstests/core/txns/commit_and_abort_large_unprepared_transactions.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/core/txns/commit_and_abort_large_unprepared_transactions.js')
-rw-r--r--jstests/core/txns/commit_and_abort_large_unprepared_transactions.js81
1 files changed, 40 insertions, 41 deletions
diff --git a/jstests/core/txns/commit_and_abort_large_unprepared_transactions.js b/jstests/core/txns/commit_and_abort_large_unprepared_transactions.js
index 2ddda9ed3f3..feb09ef4656 100644
--- a/jstests/core/txns/commit_and_abort_large_unprepared_transactions.js
+++ b/jstests/core/txns/commit_and_abort_large_unprepared_transactions.js
@@ -5,45 +5,44 @@
*/
(function() {
- "use strict";
-
- const dbName = "test";
- const collName = "large_unprepared_transactions";
- const testDB = db.getSiblingDB(dbName);
- const testColl = testDB.getCollection(collName);
-
- // As we are not able to send a single request larger than 16MB, we insert two documents
- // of 10MB each to create a "large" transaction.
- const kSize10MB = 10 * 1024 * 1024;
- function createLargeDocument(id) {
- return {_id: id, longString: new Array(kSize10MB).join("a")};
- }
-
- testColl.drop({writeConcern: {w: "majority"}});
- assert.commandWorked(
- testDB.createCollection(testColl.getName(), {writeConcern: {w: "majority"}}));
-
- const session = db.getMongo().startSession({causalConsistency: false});
- const sessionDB = session.getDatabase(dbName);
- const sessionColl = sessionDB.getCollection(collName);
-
- // Test committing an unprepared large transaction with two 10MB inserts.
- let doc1 = createLargeDocument(1);
- let doc2 = createLargeDocument(2);
- session.startTransaction();
- assert.commandWorked(sessionColl.insert(doc1));
- assert.commandWorked(sessionColl.insert(doc2));
-
- assert.commandWorked(session.commitTransaction_forTesting());
- assert.sameMembers(sessionColl.find().toArray(), [doc1, doc2]);
-
- // Test aborting an unprepared large transaction with two 10MB inserts.
- let doc3 = createLargeDocument(3);
- let doc4 = createLargeDocument(4);
- session.startTransaction();
- assert.commandWorked(sessionColl.insert(doc3));
- assert.commandWorked(sessionColl.insert(doc4));
-
- assert.commandWorked(session.abortTransaction_forTesting());
- assert.sameMembers(sessionColl.find({_id: {$gt: 2}}).toArray(), []);
+"use strict";
+
+const dbName = "test";
+const collName = "large_unprepared_transactions";
+const testDB = db.getSiblingDB(dbName);
+const testColl = testDB.getCollection(collName);
+
+// As we are not able to send a single request larger than 16MB, we insert two documents
+// of 10MB each to create a "large" transaction.
+const kSize10MB = 10 * 1024 * 1024;
+function createLargeDocument(id) {
+ return {_id: id, longString: new Array(kSize10MB).join("a")};
+}
+
+testColl.drop({writeConcern: {w: "majority"}});
+assert.commandWorked(testDB.createCollection(testColl.getName(), {writeConcern: {w: "majority"}}));
+
+const session = db.getMongo().startSession({causalConsistency: false});
+const sessionDB = session.getDatabase(dbName);
+const sessionColl = sessionDB.getCollection(collName);
+
+// Test committing an unprepared large transaction with two 10MB inserts.
+let doc1 = createLargeDocument(1);
+let doc2 = createLargeDocument(2);
+session.startTransaction();
+assert.commandWorked(sessionColl.insert(doc1));
+assert.commandWorked(sessionColl.insert(doc2));
+
+assert.commandWorked(session.commitTransaction_forTesting());
+assert.sameMembers(sessionColl.find().toArray(), [doc1, doc2]);
+
+// Test aborting an unprepared large transaction with two 10MB inserts.
+let doc3 = createLargeDocument(3);
+let doc4 = createLargeDocument(4);
+session.startTransaction();
+assert.commandWorked(sessionColl.insert(doc3));
+assert.commandWorked(sessionColl.insert(doc4));
+
+assert.commandWorked(session.abortTransaction_forTesting());
+assert.sameMembers(sessionColl.find({_id: {$gt: 2}}).toArray(), []);
}());