diff options
Diffstat (limited to 'jstests/replsets/rollback_fake_cmd.js')
-rw-r--r-- | jstests/replsets/rollback_fake_cmd.js | 35 |
1 files changed, 24 insertions, 11 deletions
diff --git a/jstests/replsets/rollback_fake_cmd.js b/jstests/replsets/rollback_fake_cmd.js index b624a8ea80e..175359121f8 100644 --- a/jstests/replsets/rollback_fake_cmd.js +++ b/jstests/replsets/rollback_fake_cmd.js @@ -23,12 +23,14 @@ var name = "rollback_fake_cmd"; 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], priority: 3 }, - { "_id": 1, "host": nodes[1] }, - { "_id": 2, "host": nodes[2], arbiterOnly: true}] - }); +replTest.initiate({ + "_id": name, + "members": [ + {"_id": 0, "host": nodes[0], priority: 3}, + {"_id": 1, "host": nodes[1]}, + {"_id": 2, "host": nodes[2], arbiterOnly: true} + ] +}); var a_conn = conns[0]; var b_conn = conns[1]; var AID = replTest.getNodeId(a_conn); @@ -40,7 +42,10 @@ replTest.waitForState(replTest.nodes[0], ReplSetTest.State.PRIMARY, 60 * 1000); var master = replTest.getPrimary(); assert(master === conns[0], "conns[0] assumed to be master"); assert(a_conn.host === master.host, "a_conn assumed to be master"); -var options = {writeConcern: {w: 2, wtimeout: 60000}, upsert: true}; +var options = { + writeConcern: {w: 2, wtimeout: 60000}, + upsert: true +}; assert.writeOK(a_conn.getDB(name).foo.insert({x: 1}, options)); // shut down master @@ -49,13 +54,18 @@ replTest.stop(AID); // insert a fake oplog entry with a nonexistent command master = replTest.getPrimary(); assert(b_conn.host === master.host, "b_conn assumed to be master"); -options = {writeConcern: {w: 1, wtimeout: 60000}, upsert: true}; +options = { + writeConcern: {w: 1, wtimeout: 60000}, + upsert: true +}; // another insert to set minvalid ahead assert.writeOK(b_conn.getDB(name).foo.insert({x: 123})); var oplog_entry = b_conn.getDB("local").oplog.rs.find().sort({$natural: -1})[0]; oplog_entry.ts = Timestamp(oplog_entry.ts.t, oplog_entry.ts.i + 1); oplog_entry.op = "c"; -oplog_entry.o = {fake_command_name: 1}; +oplog_entry.o = { + fake_command_name: 1 +}; assert.writeOK(b_conn.getDB("local").oplog.rs.insert(oplog_entry)); jsTestLog('inserted oplog entry with invalid command: ' + tojson(oplog_entry)); @@ -66,7 +76,10 @@ master = replTest.getPrimary(); assert(a_conn.host === master.host, "a_conn assumed to be master"); // do a write so that B will have to roll back -options = {writeConcern: {w: 1, wtimeout: 60000}, upsert: true}; +options = { + writeConcern: {w: 1, wtimeout: 60000}, + upsert: true +}; assert.writeOK(a_conn.getDB(name).foo.insert({x: 2}, options)); // restart B, which should rollback and log a message about not rolling back the nonexistent cmd @@ -77,4 +90,4 @@ assert.soon(function() { return rawMongoProgramOutput().match(msg); }, "Did not see a log entry about skipping the nonexistent command during rollback"); -replTest.stopSet(undefined, undefined, { allowedExitCodes: [ MongoRunner.EXIT_ABRUPT ] }); +replTest.stopSet(undefined, undefined, {allowedExitCodes: [MongoRunner.EXIT_ABRUPT]}); |