summaryrefslogtreecommitdiff
path: root/jstests/sharding/advance_logical_time_with_valid_signature.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/advance_logical_time_with_valid_signature.js')
-rw-r--r--jstests/sharding/advance_logical_time_with_valid_signature.js58
1 files changed, 29 insertions, 29 deletions
diff --git a/jstests/sharding/advance_logical_time_with_valid_signature.js b/jstests/sharding/advance_logical_time_with_valid_signature.js
index bc9f8d86353..fccd047f6fd 100644
--- a/jstests/sharding/advance_logical_time_with_valid_signature.js
+++ b/jstests/sharding/advance_logical_time_with_valid_signature.js
@@ -3,42 +3,42 @@
* cluster time.
*/
(function() {
- "use strict";
+"use strict";
- // Setup 2 mongos processes with mongobridge.
- let st = new ShardingTest({shards: 1, mongos: 2, useBridge: true});
+// Setup 2 mongos processes with mongobridge.
+let st = new ShardingTest({shards: 1, mongos: 2, useBridge: true});
- // Sever outgoing communications from the second mongos.
- st.s0.disconnect(st.s1);
- st._configServers.forEach(function(configSvr) {
- configSvr.disconnect(st.s1);
- });
+// Sever outgoing communications from the second mongos.
+st.s0.disconnect(st.s1);
+st._configServers.forEach(function(configSvr) {
+ configSvr.disconnect(st.s1);
+});
- st._rsObjects.forEach(function(rsNodes) {
- rsNodes.nodes.forEach(function(conn) {
- conn.disconnect(st.s1);
- });
+st._rsObjects.forEach(function(rsNodes) {
+ rsNodes.nodes.forEach(function(conn) {
+ conn.disconnect(st.s1);
});
+});
- let connectedDB = st.s0.getDB("test");
- let disconnectedDB = st.s1.getDB("test");
+let connectedDB = st.s0.getDB("test");
+let disconnectedDB = st.s1.getDB("test");
- // Send an insert to the connected mongos to advance its cluster time.
- let res = assert.commandWorked(connectedDB.runCommand({insert: "foo", documents: [{x: 1}]}));
+// Send an insert to the connected mongos to advance its cluster time.
+let res = assert.commandWorked(connectedDB.runCommand({insert: "foo", documents: [{x: 1}]}));
- // Get logicalTime metadata from the connected mongos's response and send it in an isMaster
- // command to the disconnected mongos. isMaster does not require mongos to contact any other
- // servers, so the command should succeed.
- let lt = res.$clusterTime;
- res = assert.commandWorked(
- disconnectedDB.runCommand({isMaster: 1, $clusterTime: lt}),
- "expected the disconnected mongos to accept cluster time: " + tojson(lt));
+// Get logicalTime metadata from the connected mongos's response and send it in an isMaster
+// command to the disconnected mongos. isMaster does not require mongos to contact any other
+// servers, so the command should succeed.
+let lt = res.$clusterTime;
+res =
+ assert.commandWorked(disconnectedDB.runCommand({isMaster: 1, $clusterTime: lt}),
+ "expected the disconnected mongos to accept cluster time: " + tojson(lt));
- // Verify cluster time response from the disconnected mongos matches what was passed.
- assert.eq(lt,
- res.$clusterTime,
- "expected the disconnected mongos to send cluster time: " + tojson(lt) +
- ", received: " + tojson(res.$clusterTime));
+// Verify cluster time response from the disconnected mongos matches what was passed.
+assert.eq(lt,
+ res.$clusterTime,
+ "expected the disconnected mongos to send cluster time: " + tojson(lt) +
+ ", received: " + tojson(res.$clusterTime));
- st.stop();
+st.stop();
})();