summaryrefslogtreecommitdiff
path: root/jstests/replsets/read_majority_two_arbs.js
diff options
context:
space:
mode:
authorclang-format-7.0.1 <adam.martin@10gen.com>2019-07-26 18:20:35 -0400
committerADAM David Alan Martin <adam.martin@10gen.com>2019-07-27 11:02:23 -0400
commit134a4083953270e8a11430395357fb70a29047ad (patch)
treedd428e1230e31d92b20b393dfdc17ffe7fa79cb6 /jstests/replsets/read_majority_two_arbs.js
parent1e46b5049003f427047e723ea5fab15b5a9253ca (diff)
downloadmongo-134a4083953270e8a11430395357fb70a29047ad.tar.gz
SERVER-41772 Apply clang-format 7.0.1 to the codebase
Diffstat (limited to 'jstests/replsets/read_majority_two_arbs.js')
-rw-r--r--jstests/replsets/read_majority_two_arbs.js107
1 files changed, 53 insertions, 54 deletions
diff --git a/jstests/replsets/read_majority_two_arbs.js b/jstests/replsets/read_majority_two_arbs.js
index d2aeea89280..f49ebe71dd7 100644
--- a/jstests/replsets/read_majority_two_arbs.js
+++ b/jstests/replsets/read_majority_two_arbs.js
@@ -6,68 +6,67 @@
load("jstests/replsets/rslib.js"); // For startSetIfSupportsReadMajority.
(function() {
- "use strict";
+"use strict";
- function log(arg) {
- jsTest.log(tojson(arg));
- }
+function log(arg) {
+ jsTest.log(tojson(arg));
+}
- // Set up a set and grab things for later.
- var name = "read_majority_two_arbs";
- var replTest =
- new ReplSetTest({name: name, nodes: 3, nodeOptions: {enableMajorityReadConcern: ''}});
+// Set up a set and grab things for later.
+var name = "read_majority_two_arbs";
+var replTest =
+ new ReplSetTest({name: name, nodes: 3, nodeOptions: {enableMajorityReadConcern: ''}});
- if (!startSetIfSupportsReadMajority(replTest)) {
- jsTest.log("skipping test since storage engine doesn't support committed reads");
- replTest.stopSet();
- return;
- }
+if (!startSetIfSupportsReadMajority(replTest)) {
+ jsTest.log("skipping test since storage engine doesn't support committed reads");
+ replTest.stopSet();
+ return;
+}
- var nodes = replTest.nodeList();
- var config = {
- "_id": name,
- "members": [
- {"_id": 0, "host": nodes[0]},
- {"_id": 1, "host": nodes[1], arbiterOnly: true},
- {"_id": 2, "host": nodes[2], arbiterOnly: true}
- ]
- };
+var nodes = replTest.nodeList();
+var config = {
+ "_id": name,
+ "members": [
+ {"_id": 0, "host": nodes[0]},
+ {"_id": 1, "host": nodes[1], arbiterOnly: true},
+ {"_id": 2, "host": nodes[2], arbiterOnly: true}
+ ]
+};
- replTest.initiate(config);
+replTest.initiate(config);
- var primary = replTest.getPrimary();
- var db = primary.getDB(name);
- var t = db[name];
+var primary = replTest.getPrimary();
+var db = primary.getDB(name);
+var t = db[name];
- function doRead(readConcern) {
- readConcern.maxTimeMS = 3000;
- var res = assert.commandWorked(t.runCommand('find', readConcern));
- var docs = (new DBCommandCursor(db, res)).toArray();
- assert.gt(docs.length, 0, "no docs returned!");
- return docs[0].state;
- }
+function doRead(readConcern) {
+ readConcern.maxTimeMS = 3000;
+ var res = assert.commandWorked(t.runCommand('find', readConcern));
+ var docs = (new DBCommandCursor(db, res)).toArray();
+ assert.gt(docs.length, 0, "no docs returned!");
+ return docs[0].state;
+}
- function doDirtyRead() {
- log("doing dirty read");
- var ret = doRead({"readConcern": {"level": "local"}});
- log("done doing dirty read.");
- return ret;
- }
+function doDirtyRead() {
+ log("doing dirty read");
+ var ret = doRead({"readConcern": {"level": "local"}});
+ log("done doing dirty read.");
+ return ret;
+}
- function doCommittedRead() {
- log("doing committed read");
- var ret = doRead({"readConcern": {"level": "majority"}});
- log("done doing committed read.");
- return ret;
- }
+function doCommittedRead() {
+ log("doing committed read");
+ var ret = doRead({"readConcern": {"level": "majority"}});
+ log("done doing committed read.");
+ return ret;
+}
- jsTest.log("doing write");
- assert.writeOK(
- t.save({_id: 1, state: 0}, {writeConcern: {w: "majority", wtimeout: 10 * 1000}}));
- jsTest.log("doing read");
- assert.eq(doDirtyRead(), 0);
- jsTest.log("doing committed read");
- assert.eq(doCommittedRead(), 0);
- jsTest.log("stopping replTest; test completed successfully");
- replTest.stopSet();
+jsTest.log("doing write");
+assert.writeOK(t.save({_id: 1, state: 0}, {writeConcern: {w: "majority", wtimeout: 10 * 1000}}));
+jsTest.log("doing read");
+assert.eq(doDirtyRead(), 0);
+jsTest.log("doing committed read");
+assert.eq(doCommittedRead(), 0);
+jsTest.log("stopping replTest; test completed successfully");
+replTest.stopSet();
}());