1 files changed, 87 insertions, 87 deletions
diff --git a/jstests/core/txns/kill_op_on_txn_expiry.js b/jstests/core/txns/kill_op_on_txn_expiry.js
index 298b5d0926e..dde4930bfae 100644
--- a/jstests/core/txns/kill_op_on_txn_expiry.js
+++ b/jstests/core/txns/kill_op_on_txn_expiry.js
@@ -1,95 +1,95 @@
 // Test that ongoing operations in a transaction are interrupted when the transaction expires.
 // @tags: [uses_transactions]
 (function() {
-    "use strict";
-
-    load('jstests/libs/parallelTester.js');
-    load("jstests/libs/check_log.js");
-
-    const dbName = "test";
-    const collName = "kill_op_on_txn_expiry";
-    const testDB = db.getSiblingDB(dbName);
-    const testColl = testDB[collName];
-
-    testDB.runCommand({drop: collName, writeConcern: {w: "majority"}});
+"use strict";
+
+load('jstests/libs/parallelTester.js');
+load("jstests/libs/check_log.js");
+
+const dbName = "test";
+const collName = "kill_op_on_txn_expiry";
+const testDB = db.getSiblingDB(dbName);
+const testColl = testDB[collName];
+
+testDB.runCommand({drop: collName, writeConcern: {w: "majority"}});
+assert.commandWorked(testDB.createCollection(testColl.getName(), {writeConcern: {w: "majority"}}));
+
+const sessionOptions = {
+    causalConsistency: false
+};
+const session = db.getMongo().startSession(sessionOptions);
+const sessionDb = session.getDatabase(dbName);
+const sessionColl = sessionDb[collName];
+
+// Need the original 'transactionLifetimeLimitSeconds' value so that we can reset it back at the
+// end of the test.
+const res =
+    assert.commandWorked(db.adminCommand({getParameter: 1, transactionLifetimeLimitSeconds: 1}));
+const originalTransactionLifetimeLimitSeconds = res.transactionLifetimeLimitSeconds;
+
+// Decrease transactionLifetimeLimitSeconds so it expires faster
+jsTest.log("Decrease transactionLifetimeLimitSeconds from " +
+           originalTransactionLifetimeLimitSeconds + " to 30 seconds.");
+assert.commandWorked(db.adminCommand({setParameter: 1, transactionLifetimeLimitSeconds: 30}));
+
+try {
+    jsTestLog("Starting transaction");
+
+    let txnNumber = 0;
+    assert.commandWorked(testColl.runCommand({
+        insert: collName,
+        documents: [{_id: 0}],
+        txnNumber: NumberLong(txnNumber),
+        startTransaction: true,
+        autocommit: false,
+        lsid: session.getSessionId(),
+    }));
+
+    jsTestLog("Enabling fail point to block batch inserts");
     assert.commandWorked(
-        testDB.createCollection(testColl.getName(), {writeConcern: {w: "majority"}}));
-
-    const sessionOptions = {causalConsistency: false};
-    const session = db.getMongo().startSession(sessionOptions);
-    const sessionDb = session.getDatabase(dbName);
-    const sessionColl = sessionDb[collName];
-
-    // Need the original 'transactionLifetimeLimitSeconds' value so that we can reset it back at the
-    // end of the test.
-    const res = assert.commandWorked(
-        db.adminCommand({getParameter: 1, transactionLifetimeLimitSeconds: 1}));
-    const originalTransactionLifetimeLimitSeconds = res.transactionLifetimeLimitSeconds;
-
-    // Decrease transactionLifetimeLimitSeconds so it expires faster
-    jsTest.log("Decrease transactionLifetimeLimitSeconds from " +
-               originalTransactionLifetimeLimitSeconds + " to 30 seconds.");
-    assert.commandWorked(db.adminCommand({setParameter: 1, transactionLifetimeLimitSeconds: 30}));
-
-    try {
-        jsTestLog("Starting transaction");
-
-        let txnNumber = 0;
-        assert.commandWorked(testColl.runCommand({
+        testDB.adminCommand({configureFailPoint: "hangDuringBatchInsert", mode: "alwaysOn"}));
+    // Clear ramlog so checkLog can't find log messages from previous times this fail point was
+    // enabled.
+    assert.commandWorked(testDB.adminCommand({clearLog: 'global'}));
+
+    jsTestLog("Starting insert operation in parallel thread");
+    let workerThread = new ScopedThread((sessionId, txnNumber, dbName, collName) => {
+        // Deserialize the session ID from its string representation.
+        sessionId = eval("(" + sessionId + ")");
+
+        let coll = db.getSiblingDB(dbName).getCollection(collName);
+        assert.commandFailedWithCode(coll.runCommand({
             insert: collName,
-            documents: [{_id: 0}],
+            documents: [{_id: 1}],
             txnNumber: NumberLong(txnNumber),
-            startTransaction: true,
             autocommit: false,
-            lsid: session.getSessionId(),
-        }));
-
-        jsTestLog("Enabling fail point to block batch inserts");
-        assert.commandWorked(
-            testDB.adminCommand({configureFailPoint: "hangDuringBatchInsert", mode: "alwaysOn"}));
-        // Clear ramlog so checkLog can't find log messages from previous times this fail point was
-        // enabled.
-        assert.commandWorked(testDB.adminCommand({clearLog: 'global'}));
-
-        jsTestLog("Starting insert operation in parallel thread");
-        let workerThread = new ScopedThread((sessionId, txnNumber, dbName, collName) => {
-            // Deserialize the session ID from its string representation.
-            sessionId = eval("(" + sessionId + ")");
-
-            let coll = db.getSiblingDB(dbName).getCollection(collName);
-            assert.commandFailedWithCode(coll.runCommand({
-                insert: collName,
-                documents: [{_id: 1}],
-                txnNumber: NumberLong(txnNumber),
-                autocommit: false,
-                lsid: sessionId
-            }),
-                                         ErrorCodes.ExceededTimeLimit);
-
-        }, tojson(session.getSessionId()), txnNumber, dbName, collName);
-        workerThread.start();
-
-        jsTestLog("Wait for insert to be blocked");
-        checkLog.contains(db.getMongo(), "hangDuringBatchInsert fail point enabled");
-
-        jsTestLog("Wait for the transaction to expire");
-        checkLog.contains(db.getMongo(), "Aborting transaction with txnNumber " + txnNumber);
-
-        jsTestLog("Disabling fail point to enable insert to proceed and detect that the session " +
-                  "has been killed");
-        assert.commandWorked(
-            testDB.adminCommand({configureFailPoint: "hangDuringBatchInsert", mode: "off"}));
-
-        workerThread.join();
-        assert(!workerThread.hasFailed());
-    } finally {
-        // Must ensure that the transactionLifetimeLimitSeconds is reset so that it does not impact
-        // other tests in the suite.
-        assert.commandWorked(db.adminCommand({
-            setParameter: 1,
-            transactionLifetimeLimitSeconds: originalTransactionLifetimeLimitSeconds
-        }));
-    }
-
-    session.endSession();
+            lsid: sessionId
+        }),
+                                     ErrorCodes.ExceededTimeLimit);
+    }, tojson(session.getSessionId()), txnNumber, dbName, collName);
+    workerThread.start();
+
+    jsTestLog("Wait for insert to be blocked");
+    checkLog.contains(db.getMongo(), "hangDuringBatchInsert fail point enabled");
+
+    jsTestLog("Wait for the transaction to expire");
+    checkLog.contains(db.getMongo(), "Aborting transaction with txnNumber " + txnNumber);
+
+    jsTestLog("Disabling fail point to enable insert to proceed and detect that the session " +
+              "has been killed");
+    assert.commandWorked(
+        testDB.adminCommand({configureFailPoint: "hangDuringBatchInsert", mode: "off"}));
+
+    workerThread.join();
+    assert(!workerThread.hasFailed());
+} finally {
+    // Must ensure that the transactionLifetimeLimitSeconds is reset so that it does not impact
+    // other tests in the suite.
+    assert.commandWorked(db.adminCommand({
+        setParameter: 1,
+        transactionLifetimeLimitSeconds: originalTransactionLifetimeLimitSeconds
+    }));
+}
+
+session.endSession();
 }());