1 files changed, 67 insertions, 68 deletions
diff --git a/jstests/sharding/transactions_expiration.js b/jstests/sharding/transactions_expiration.js
index 65178dd1c30..e337a81632c 100644
--- a/jstests/sharding/transactions_expiration.js
+++ b/jstests/sharding/transactions_expiration.js
@@ -5,75 +5,74 @@
 // @tags: [uses_transactions, uses_multi_shard_transaction]
 
 (function() {
-    "use strict";
+"use strict";
 
-    let st = new ShardingTest({shards: 2});
+let st = new ShardingTest({shards: 2});
 
-    assert.commandWorked(st.s.adminCommand({enableSharding: 'test'}));
-    st.ensurePrimaryShard('test', st.shard0.name);
-    assert.commandWorked(st.s.adminCommand({shardCollection: 'test.user', key: {x: 1}}));
-    assert.commandWorked(st.s.adminCommand({split: 'test.user', middle: {x: 0}}));
+assert.commandWorked(st.s.adminCommand({enableSharding: 'test'}));
+st.ensurePrimaryShard('test', st.shard0.name);
+assert.commandWorked(st.s.adminCommand({shardCollection: 'test.user', key: {x: 1}}));
+assert.commandWorked(st.s.adminCommand({split: 'test.user', middle: {x: 0}}));
+assert.commandWorked(st.s.adminCommand({moveChunk: 'test.user', find: {x: 0}, to: st.shard1.name}));
+
+let lowerTxnTimeout = (conn) => {
     assert.commandWorked(
-        st.s.adminCommand({moveChunk: 'test.user', find: {x: 0}, to: st.shard1.name}));
-
-    let lowerTxnTimeout = (conn) => {
-        assert.commandWorked(
-            conn.getDB('admin').runCommand({setParameter: 1, transactionLifetimeLimitSeconds: 1}));
-    };
-
-    st.rs0.nodes.forEach(lowerTxnTimeout);
-    st.rs1.nodes.forEach(lowerTxnTimeout);
-
-    let testDB = st.s.getDB('test');
-
-    // Create the collections in the shards outside the transactions.
-    assert.commandWorked(testDB.runCommand(
-        {insert: 'user', documents: [{x: -1}, {x: 1}], writeConcern: {w: 'majority'}}));
-
-    const session = st.s.startSession();
-    const sessionDb = session.getDatabase('test');
-
-    let txnNumber = 0;
-
-    assert.commandWorked(sessionDb.runCommand({
-        insert: 'user',
-        documents: [{x: -10}, {x: 10}],
-        txnNumber: NumberLong(txnNumber),
-        startTransaction: true,
-        autocommit: false,
-    }));
-
-    // We can deterministically wait for the transaction to be aborted by waiting for currentOp
-    // to cease reporting the inactive transaction: the transaction should disappear from the
-    // currentOp results once aborted.
-    assert.soon(
-        function() {
-            const sessionFilter = {
-                active: false,
-                opid: {$exists: false},
-                desc: "inactive transaction",
-                "transaction.parameters.txnNumber": NumberLong(txnNumber),
-                "lsid.id": session.getSessionId().id
-            };
-
-            const priConn = st.rs0.getPrimary();
-            const res = priConn.getDB("admin").aggregate(
-                [{$currentOp: {allUsers: true, idleSessions: true}}, {$match: sessionFilter}]);
-
-            return (res.itcount() == 0);
-        },
-        "currentOp reports that the idle transaction still exists, it has not been " +
-            "aborted as expected.");
-
-    assert.commandFailedWithCode(sessionDb.runCommand({
-        insert: 'user',
-        documents: [{x: -100}, {x: 100}],
-        txnNumber: NumberLong(txnNumber),
-        autocommit: false,
-    }),
-                                 ErrorCodes.NoSuchTransaction);
-
-    session.endSession();
-
-    st.stop();
+        conn.getDB('admin').runCommand({setParameter: 1, transactionLifetimeLimitSeconds: 1}));
+};
+
+st.rs0.nodes.forEach(lowerTxnTimeout);
+st.rs1.nodes.forEach(lowerTxnTimeout);
+
+let testDB = st.s.getDB('test');
+
+// Create the collections in the shards outside the transactions.
+assert.commandWorked(testDB.runCommand(
+    {insert: 'user', documents: [{x: -1}, {x: 1}], writeConcern: {w: 'majority'}}));
+
+const session = st.s.startSession();
+const sessionDb = session.getDatabase('test');
+
+let txnNumber = 0;
+
+assert.commandWorked(sessionDb.runCommand({
+    insert: 'user',
+    documents: [{x: -10}, {x: 10}],
+    txnNumber: NumberLong(txnNumber),
+    startTransaction: true,
+    autocommit: false,
+}));
+
+// We can deterministically wait for the transaction to be aborted by waiting for currentOp
+// to cease reporting the inactive transaction: the transaction should disappear from the
+// currentOp results once aborted.
+assert.soon(
+    function() {
+        const sessionFilter = {
+            active: false,
+            opid: {$exists: false},
+            desc: "inactive transaction",
+            "transaction.parameters.txnNumber": NumberLong(txnNumber),
+            "lsid.id": session.getSessionId().id
+        };
+
+        const priConn = st.rs0.getPrimary();
+        const res = priConn.getDB("admin").aggregate(
+            [{$currentOp: {allUsers: true, idleSessions: true}}, {$match: sessionFilter}]);
+
+        return (res.itcount() == 0);
+    },
+    "currentOp reports that the idle transaction still exists, it has not been " +
+        "aborted as expected.");
+
+assert.commandFailedWithCode(sessionDb.runCommand({
+    insert: 'user',
+    documents: [{x: -100}, {x: 100}],
+    txnNumber: NumberLong(txnNumber),
+    autocommit: false,
+}),
+                             ErrorCodes.NoSuchTransaction);
+
+session.endSession();
+
+st.stop();
 }());