diff options
Diffstat (limited to 'jstests/replsets/tags2.js')
-rw-r--r-- | jstests/replsets/tags2.js | 112 |
1 files changed, 56 insertions, 56 deletions
diff --git a/jstests/replsets/tags2.js b/jstests/replsets/tags2.js index 7ee2fe81031..361b6204c08 100644 --- a/jstests/replsets/tags2.js +++ b/jstests/replsets/tags2.js @@ -1,60 +1,60 @@ // Change a write concern mode from 2 to 3 servers (function() { - "use strict"; - - var host = getHostName(); - var replTest = new ReplSetTest({nodes: 4}); - var nodes = replTest.startSet(); - var ports = replTest.ports; - var conf = { - _id: replTest.name, - members: [ - {_id: 0, host: host + ":" + ports[0], tags: {"backup": "A"}}, - {_id: 1, host: host + ":" + ports[1], tags: {"backup": "B"}}, - {_id: 2, host: host + ":" + ports[2], tags: {"backup": "C"}}, - {_id: 3, host: host + ":" + ports[3], tags: {"backup": "D"}, arbiterOnly: true} - ], - settings: {getLastErrorModes: {backedUp: {backup: 2}}} - }; - - print("arbiters can't have tags"); - var result = nodes[0].getDB("admin").runCommand({replSetInitiate: conf}); - printjson(result); - assert.eq(result.ok, 0); - - conf.members.pop(); - replTest.stop(3); - replTest.remove(3); - replTest.initiate(conf); - - replTest.awaitReplication(); - - var master = replTest.getPrimary(); - var db = master.getDB("test"); - var wtimeout = ReplSetTest.kDefaultTimeoutMS; - - assert.writeOK(db.foo.insert({x: 1}, {writeConcern: {w: 'backedUp', wtimeout: wtimeout}})); - - var nextVersion = replTest.getReplSetConfigFromNode().version + 1; - conf.version = nextVersion; - conf.settings.getLastErrorModes.backedUp.backup = 3; - master.getDB("admin").runCommand({replSetReconfig: conf}); - replTest.awaitReplication(); - - master = replTest.getPrimary(); - var db = master.getDB("test"); - assert.writeOK(db.foo.insert({x: 2}, {writeConcern: {w: 'backedUp', wtimeout: wtimeout}})); - - nextVersion++; - conf.version = nextVersion; - conf.members[0].priorty = 3; - conf.members[2].priorty = 0; - master.getDB("admin").runCommand({replSetReconfig: conf}); - - master = replTest.getPrimary(); - var db = master.getDB("test"); - assert.writeOK(db.foo.insert({x: 3}, {writeConcern: {w: 'backedUp', wtimeout: wtimeout}})); - - replTest.stopSet(); +"use strict"; + +var host = getHostName(); +var replTest = new ReplSetTest({nodes: 4}); +var nodes = replTest.startSet(); +var ports = replTest.ports; +var conf = { + _id: replTest.name, + members: [ + {_id: 0, host: host + ":" + ports[0], tags: {"backup": "A"}}, + {_id: 1, host: host + ":" + ports[1], tags: {"backup": "B"}}, + {_id: 2, host: host + ":" + ports[2], tags: {"backup": "C"}}, + {_id: 3, host: host + ":" + ports[3], tags: {"backup": "D"}, arbiterOnly: true} + ], + settings: {getLastErrorModes: {backedUp: {backup: 2}}} +}; + +print("arbiters can't have tags"); +var result = nodes[0].getDB("admin").runCommand({replSetInitiate: conf}); +printjson(result); +assert.eq(result.ok, 0); + +conf.members.pop(); +replTest.stop(3); +replTest.remove(3); +replTest.initiate(conf); + +replTest.awaitReplication(); + +var master = replTest.getPrimary(); +var db = master.getDB("test"); +var wtimeout = ReplSetTest.kDefaultTimeoutMS; + +assert.writeOK(db.foo.insert({x: 1}, {writeConcern: {w: 'backedUp', wtimeout: wtimeout}})); + +var nextVersion = replTest.getReplSetConfigFromNode().version + 1; +conf.version = nextVersion; +conf.settings.getLastErrorModes.backedUp.backup = 3; +master.getDB("admin").runCommand({replSetReconfig: conf}); +replTest.awaitReplication(); + +master = replTest.getPrimary(); +var db = master.getDB("test"); +assert.writeOK(db.foo.insert({x: 2}, {writeConcern: {w: 'backedUp', wtimeout: wtimeout}})); + +nextVersion++; +conf.version = nextVersion; +conf.members[0].priorty = 3; +conf.members[2].priorty = 0; +master.getDB("admin").runCommand({replSetReconfig: conf}); + +master = replTest.getPrimary(); +var db = master.getDB("test"); +assert.writeOK(db.foo.insert({x: 3}, {writeConcern: {w: 'backedUp', wtimeout: wtimeout}})); + +replTest.stopSet(); }()); |