diff options
Diffstat (limited to 'jstests/replsets/rollback3.js')
| -rw-r--r--[-rwxr-xr-x] | jstests/replsets/rollback3.js | 106 |
1 files changed, 63 insertions, 43 deletions
diff --git a/jstests/replsets/rollback3.js b/jstests/replsets/rollback3.js index 9abac9c3639..740f9caa383 100755..100644 --- a/jstests/replsets/rollback3.js +++ b/jstests/replsets/rollback3.js @@ -2,7 +2,7 @@ * Basic test of a succesful replica set rollback for DDL operations. * * This tests sets up a 3 node set, data-bearing nodes A and B and an arbiter. - * + * * 1. A is elected PRIMARY and receives several writes, which are propagated to B. * 2. A is isolated from the rest of the set and B is elected PRIMARY. * 3. B receives several operations, which will later be undone during rollback. @@ -13,7 +13,7 @@ */ load("jstests/replsets/rslib.js"); -(function () { +(function() { "use strict"; // helper function for verifying contents at the end of the test var checkFinalResults = function(db) { @@ -33,16 +33,18 @@ load("jstests/replsets/rslib.js"); }; var name = "rollback2js"; - var replTest = new ReplSetTest({ name: name, nodes: 3, useBridge: true }); + var replTest = new ReplSetTest({name: name, nodes: 3, useBridge: true}); 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} + ] + }); // Make sure we have a master and that that master is node A replTest.waitForState(replTest.nodes[0], ReplSetTest.State.PRIMARY, 60 * 1000); @@ -61,42 +63,48 @@ load("jstests/replsets/rslib.js"); var b = b_conn.getDB("foo"); // initial data for both nodes - assert.writeOK(a.b.insert({ x: 1 })); - a.b.ensureIndex({ x: 1 }); - assert.writeOK(a.oldname.insert({ y: 1 })); - assert.writeOK(a.oldname.insert({ y: 2 })); - a.oldname.ensureIndex({ y: 1 },true); - assert.writeOK(a.bar.insert({ q:0})); - assert.writeOK(a.bar.insert({ q: 1, a: "foo" })); - assert.writeOK(a.bar.insert({ q: 2, a: "foo", x: 1 })); - assert.writeOK(a.bar.insert({ q: 3, bb: 9, a: "foo" })); - assert.writeOK(a.bar.insert({ q: 40333333, a: 1 })); + assert.writeOK(a.b.insert({x: 1})); + a.b.ensureIndex({x: 1}); + assert.writeOK(a.oldname.insert({y: 1})); + assert.writeOK(a.oldname.insert({y: 2})); + a.oldname.ensureIndex({y: 1}, true); + assert.writeOK(a.bar.insert({q: 0})); + assert.writeOK(a.bar.insert({q: 1, a: "foo"})); + assert.writeOK(a.bar.insert({q: 2, a: "foo", x: 1})); + assert.writeOK(a.bar.insert({q: 3, bb: 9, a: "foo"})); + assert.writeOK(a.bar.insert({q: 40333333, a: 1})); for (var i = 0; i < 200; i++) { - assert.writeOK(a.bar.insert({ i: i })); + assert.writeOK(a.bar.insert({i: i})); } - assert.writeOK(a.bar.insert({ q: 40, a: 2 })); - assert.writeOK(a.bar.insert({ q: 70, txt: 'willremove' })); - a.createCollection("kap", { capped: true, size: 5000 }); - assert.writeOK(a.kap.insert({ foo: 1 })); + assert.writeOK(a.bar.insert({q: 40, a: 2})); + assert.writeOK(a.bar.insert({q: 70, txt: 'willremove'})); + a.createCollection("kap", {capped: true, size: 5000}); + assert.writeOK(a.kap.insert({foo: 1})); replTest.awaitReplication(); // isolate A and wait for B to become master conns[0].disconnect(conns[1]); conns[0].disconnect(conns[2]); - assert.soon(function () { try { return B.isMaster().ismaster; } catch(e) { return false; } }); - + assert.soon(function() { + try { + return B.isMaster().ismaster; + } catch (e) { + return false; + } + }); + // do operations on B and B alone, these will be rolled back - assert.writeOK(b.bar.insert({ q: 4 })); - assert.writeOK(b.bar.update({ q: 3 }, { q: 3, rb: true })); - assert.writeOK(b.bar.remove({ q: 40 })); // multi remove test - assert.writeOK(b.bar.update({ q: 2 }, { q: 39, rb: true })); + assert.writeOK(b.bar.insert({q: 4})); + assert.writeOK(b.bar.update({q: 3}, {q: 3, rb: true})); + assert.writeOK(b.bar.remove({q: 40})); // multi remove test + assert.writeOK(b.bar.update({q: 2}, {q: 39, rb: true})); // rolling back a delete will involve reinserting the item(s) - assert.writeOK(b.bar.remove({ q: 1 })); - assert.writeOK(b.bar.update({ q: 0 }, { $inc: { y: 1} })); - assert.writeOK(b.kap.insert({ foo: 2 })); - assert.writeOK(b.kap2.insert({ foo: 2 })); + assert.writeOK(b.bar.remove({q: 1})); + assert.writeOK(b.bar.update({q: 0}, {$inc: {y: 1}})); + assert.writeOK(b.kap.insert({foo: 2})); + assert.writeOK(b.kap2.insert({foo: 2})); // create a collection (need to roll back the whole thing) - assert.writeOK(b.newcoll.insert({ a: true })); + assert.writeOK(b.newcoll.insert({a: true})); // create a new empty collection (need to roll back the whole thing) b.createCollection("abc"); // drop a collection - we'll need all its data back! @@ -107,22 +115,34 @@ load("jstests/replsets/rslib.js"); b.oldname.renameCollection("newname"); b.newname.renameCollection("fooname"); assert(b.fooname.count() > 0, "count rename"); - // test roll back (drop) a whole database + // test roll back (drop) a whole database var abc = b.getSisterDB("abc"); - assert.writeOK(abc.foo.insert({ x: 1 })); - assert.writeOK(abc.bar.insert({ y: 999 })); + assert.writeOK(abc.foo.insert({x: 1})); + assert.writeOK(abc.bar.insert({y: 999})); // isolate B, bring A back into contact with the arbiter, then wait for A to become master // insert new data into A so that B will need to rollback when it reconnects to A conns[1].disconnect(conns[2]); - assert.soon(function () { try { return !B.isMaster().ismaster; } catch(e) { return false; } }); + assert.soon(function() { + try { + return !B.isMaster().ismaster; + } catch (e) { + return false; + } + }); conns[0].reconnect(conns[2]); - assert.soon(function () { try { return A.isMaster().ismaster; } catch(e) { return false; } }); + assert.soon(function() { + try { + return A.isMaster().ismaster; + } catch (e) { + return false; + } + }); assert(a.bar.count() >= 1, "count check"); - assert.writeOK(a.bar.insert({ txt: 'foo' })); - assert.writeOK(a.bar.remove({ q: 70 })); - assert.writeOK(a.bar.update({ q: 0 }, { $inc: { y: 33} })); + assert.writeOK(a.bar.insert({txt: 'foo'})); + assert.writeOK(a.bar.remove({q: 70})); + assert.writeOK(a.bar.update({q: 0}, {$inc: {y: 33}})); // A is 1 2 3 7 8 // B is 1 2 3 4 5 6 |