1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
/**
* This checks rollback, which shouldn't happen unless we have reached minvalid.
* 1. make 3-member set w/arb (2)
* 2. shut down slave
* 3. do writes to master
* 4. modify master's minvalid
* 5. shut down master
* 6. start up slave
* 7. writes on former slave (now primary)
* 8. start up master
* 9. check master does not rollback
*
* If all data-bearing nodes in a replica set are using an ephemeral storage engine, the set will
* not be able to survive a scenario where all data-bearing nodes are down simultaneously. In such a
* scenario, none of the members will have any data, and upon restart will each look for a member to
* initial sync from, so no primary will be elected. This test induces such a scenario, so cannot be
* run on ephemeral storage engines.
* @tags: [requires_persistence]
*/
print("1. make 3-member set w/arb (2)");
var name = "minvalid";
var replTest = new ReplSetTest({name: name, nodes: 3, oplogSize:1});
var host = getHostName();
var nodes = replTest.startSet();
replTest.initiate({_id : name, members : [
{_id : 0, host : host+":"+replTest.ports[0]},
{_id : 1, host : host+":"+replTest.ports[1]},
{_id : 2, host : host+":"+replTest.ports[2], arbiterOnly : true}
]});
var slaves = replTest.liveNodes.slaves;
var master = replTest.getPrimary();
var masterId = replTest.getNodeId(master);
var slave = slaves[0];
var slaveId = replTest.getNodeId(slave);
var mdb = master.getDB("foo");
mdb.foo.save({a: 1000});
replTest.awaitReplication();
print("2: shut down slave");
replTest.stop(slaveId);
print("3: write to master");
assert.writeOK(mdb.foo.insert({a: 1001}, { writeConcern: { w: 1 } }));
print("4: modify master's minvalid");
var local = master.getDB("local");
var lastOp = local.oplog.rs.find().sort({$natural:-1}).limit(1).next();
printjson(lastOp);
// Overwrite minvalid document to simulate an inconsistent state (as might result from a server
// crash.
local.replset.minvalid.update({},{ ts:new Timestamp(lastOp.ts.t, lastOp.ts.i+1) }, {upsert: true});
printjson(local.replset.minvalid.findOne());
print("5: shut down master");
replTest.stop(masterId);
print("6: start up slave");
replTest.restart(slaveId);
print("7: writes on former slave");
master = replTest.getPrimary();
mdb1 = master.getDB("foo");
mdb1.foo.save({a:1002});
print("8: start up former master");
clearRawMongoProgramOutput();
replTest.restart(masterId);
print("9: check former master does not roll back");
assert.soon(function(){
return rawMongoProgramOutput().match("need to rollback, but in inconsistent state");
});
replTest.stopSet(undefined, undefined, { allowedExitCodes: [ MongoRunner.EXIT_ABRUPT ] });
|
