diff options
Diffstat (limited to 'jstests/replsets/tags_with_reconfig.js')
-rw-r--r-- | jstests/replsets/tags_with_reconfig.js | 45 |
1 files changed, 24 insertions, 21 deletions
diff --git a/jstests/replsets/tags_with_reconfig.js b/jstests/replsets/tags_with_reconfig.js index 8f1e01ce176..512a55fe771 100644 --- a/jstests/replsets/tags_with_reconfig.js +++ b/jstests/replsets/tags_with_reconfig.js @@ -3,35 +3,40 @@ // time. This would cause us to update stale items in the cache when secondaries // reported their progress to a primary. - // Start a replica set with 3 nodes var host = getHostName(); -var replTest = new ReplSetTest({ name: "tags_with_reconfig", nodes: 3 }); +var replTest = new ReplSetTest({name: "tags_with_reconfig", nodes: 3}); var nodes = replTest.startSet(); var ports = replTest.ports; // Set tags and getLastErrorModes -var conf = {_id : "tags_with_reconfig", version: 1, members : [ - {_id : 0, host : host+":"+ports[0], tags : {"dc" : "bbb"}}, - {_id : 1, host : host+":"+ports[1], tags : {"dc" : "bbb"}}, - {_id : 2, host : host+":"+ports[2], tags : {"dc" : "ccc"}}], - settings : {getLastErrorModes : { - anydc : {dc : 1}, - alldc : {dc : 2}, }} }; - - -replTest.initiate( conf ); +var conf = { + _id: "tags_with_reconfig", + version: 1, + members: [ + {_id: 0, host: host + ":" + ports[0], tags: {"dc": "bbb"}}, + {_id: 1, host: host + ":" + ports[1], tags: {"dc": "bbb"}}, + {_id: 2, host: host + ":" + ports[2], tags: {"dc": "ccc"}} + ], + settings: { + getLastErrorModes: { + anydc: {dc: 1}, + alldc: {dc: 2}, + } + } +}; + +replTest.initiate(conf); replTest.awaitReplication(); - master = replTest.getPrimary(); var db = master.getDB("test"); // Insert a document with write concern : anydc -assert.writeOK(db.foo.insert({ x: 1 }, { writeConcern: { w: 'anydc', wtimeout: 20000 }})); +assert.writeOK(db.foo.insert({x: 1}, {writeConcern: {w: 'anydc', wtimeout: 20000}})); // Insert a document with write concern : alldc -assert.writeOK(db.foo.insert({ x: 2 }, { writeConcern: { w: 'alldc', wtimeout: 20000 }})); +assert.writeOK(db.foo.insert({x: 2}, {writeConcern: {w: 'alldc', wtimeout: 20000}})); // Add a new tag to the replica set var config = master.getDB("local").system.replset.findOne(); @@ -41,9 +46,8 @@ config.version++; config.members[0].tags.newtag = "newtag"; try { - master.getDB("admin").runCommand({replSetReconfig : config}); -} -catch(e) { + master.getDB("admin").runCommand({replSetReconfig: config}); +} catch (e) { print(e); } @@ -53,14 +57,13 @@ replTest.awaitReplication(); var config = master.getDB("local").system.replset.findOne(); printjson(config); - master = replTest.getPrimary(); var db = master.getDB("test"); // Insert a document with write concern : anydc -assert.writeOK(db.foo.insert({ x: 3 }, { writeConcern: { w: 'anydc', wtimeout: 20000 }})); +assert.writeOK(db.foo.insert({x: 3}, {writeConcern: {w: 'anydc', wtimeout: 20000}})); // Insert a document with write concern : alldc -assert.writeOK(db.foo.insert({ x: 4 }, { writeConcern: { w: 'alldc', wtimeout: 20000 }})); +assert.writeOK(db.foo.insert({x: 4}, {writeConcern: {w: 'alldc', wtimeout: 20000}})); replTest.stopSet(); |