diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/replsets/rollback_collMod_PowerOf2Sizes.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/replsets/rollback_collMod_PowerOf2Sizes.js')
-rw-r--r-- | jstests/replsets/rollback_collMod_PowerOf2Sizes.js | 138 |
1 files changed, 74 insertions, 64 deletions
diff --git a/jstests/replsets/rollback_collMod_PowerOf2Sizes.js b/jstests/replsets/rollback_collMod_PowerOf2Sizes.js index bf7799895f9..deab19b2f09 100644 --- a/jstests/replsets/rollback_collMod_PowerOf2Sizes.js +++ b/jstests/replsets/rollback_collMod_PowerOf2Sizes.js @@ -7,78 +7,88 @@ // run on ephemeral storage engines. // @tags: [requires_persistence] (function() { -"use strict"; + "use strict"; -function getOptions(conn) { - return conn.getDB(name).foo.exists().options; -} + function getOptions(conn) { + return conn.getDB(name).foo.exists().options; + } -// Set up a set and grab things for later. -var name = "rollback_collMod_PowerOf2Sizes"; -var replTest = new ReplSetTest({name: name, nodes: 3}); -var nodes = replTest.nodeList(); -var conns = replTest.startSet(); -replTest.initiate({"_id": name, - "members": [ - { "_id": 0, "host": nodes[0] }, - { "_id": 1, "host": nodes[1] }, - { "_id": 2, "host": nodes[2], arbiterOnly: true}] - }); -// Get master and do an initial write. -var master = replTest.getPrimary(); -var a_conn = master; -var slaves = replTest.liveNodes.slaves; -var b_conn = slaves[0]; -var AID = replTest.getNodeId(a_conn); -var BID = replTest.getNodeId(b_conn); + // Set up a set and grab things for later. + var name = "rollback_collMod_PowerOf2Sizes"; + var replTest = new ReplSetTest({name: name, nodes: 3}); + var nodes = replTest.nodeList(); + var conns = replTest.startSet(); + replTest.initiate({ + "_id": name, + "members": [ + {"_id": 0, "host": nodes[0]}, + {"_id": 1, "host": nodes[1]}, + {"_id": 2, "host": nodes[2], arbiterOnly: true} + ] + }); + // Get master and do an initial write. + var master = replTest.getPrimary(); + var a_conn = master; + var slaves = replTest.liveNodes.slaves; + var b_conn = slaves[0]; + var AID = replTest.getNodeId(a_conn); + var BID = replTest.getNodeId(b_conn); -// Create collection with custom options. -var originalCollectionOptions = {flags: 0, - validator: {x: {$exists: 1}}, - validationLevel: "moderate", - validationAction: "warn"}; -assert.commandWorked(a_conn.getDB(name).createCollection('foo', originalCollectionOptions)); + // Create collection with custom options. + var originalCollectionOptions = { + flags: 0, + validator: {x: {$exists: 1}}, + validationLevel: "moderate", + validationAction: "warn" + }; + assert.commandWorked(a_conn.getDB(name).createCollection('foo', originalCollectionOptions)); -var options = {writeConcern: {w: 2, wtimeout: 60000}, upsert: true}; -assert.writeOK(a_conn.getDB(name).foo.insert({x: 1}, options)); + var options = { + writeConcern: {w: 2, wtimeout: 60000}, + upsert: true + }; + assert.writeOK(a_conn.getDB(name).foo.insert({x: 1}, options)); -assert.eq(getOptions(a_conn), originalCollectionOptions); -assert.eq(getOptions(b_conn), originalCollectionOptions); + assert.eq(getOptions(a_conn), originalCollectionOptions); + assert.eq(getOptions(b_conn), originalCollectionOptions); -// Stop the slave so it never sees the collMod. -replTest.stop(BID); + // Stop the slave so it never sees the collMod. + replTest.stop(BID); -// Run the collMod only on A. -assert.commandWorked(a_conn.getDB(name).runCommand({collMod: "foo", - usePowerOf2Sizes: false, - noPadding: true, - validator: {a: 1}, - validationLevel: "moderate", - validationAction: "warn"})); -assert.eq(getOptions(a_conn), {flags: 2, - validator: {a: 1}, - validationLevel: "moderate", - validationAction: "warn"}); + // Run the collMod only on A. + assert.commandWorked(a_conn.getDB(name).runCommand({ + collMod: "foo", + usePowerOf2Sizes: false, + noPadding: true, + validator: {a: 1}, + validationLevel: "moderate", + validationAction: "warn" + })); + assert.eq( + getOptions(a_conn), + {flags: 2, validator: {a: 1}, validationLevel: "moderate", validationAction: "warn"}); -// Shut down A and fail over to B. -replTest.stop(AID); -replTest.restart(BID); -master = replTest.getPrimary(); -assert.eq(b_conn.host, master.host, "b_conn assumed to be master"); -b_conn = master; + // Shut down A and fail over to B. + replTest.stop(AID); + replTest.restart(BID); + master = replTest.getPrimary(); + assert.eq(b_conn.host, master.host, "b_conn assumed to be master"); + b_conn = master; -// Do a write on B so that A will have to roll back. -options = {writeConcern: {w: 1, wtimeout: 60000}, upsert: true}; -assert.writeOK(b_conn.getDB(name).foo.insert({x: 2}, options)); + // Do a write on B so that A will have to roll back. + options = { + writeConcern: {w: 1, wtimeout: 60000}, + upsert: true + }; + assert.writeOK(b_conn.getDB(name).foo.insert({x: 2}, options)); -// Restart A, which should rollback the collMod before becoming primary. -replTest.restart(AID); -try { - b_conn.adminCommand({replSetStepDown: 60, secondaryCatchUpPeriodSecs: 60}); -} -catch (e) { - // Ignore network disconnect. -} -replTest.waitForState(a_conn, ReplSetTest.State.PRIMARY); -assert.eq(getOptions(a_conn), originalCollectionOptions); + // Restart A, which should rollback the collMod before becoming primary. + replTest.restart(AID); + try { + b_conn.adminCommand({replSetStepDown: 60, secondaryCatchUpPeriodSecs: 60}); + } catch (e) { + // Ignore network disconnect. + } + replTest.waitForState(a_conn, ReplSetTest.State.PRIMARY); + assert.eq(getOptions(a_conn), originalCollectionOptions); }()); |