blob: 0d1b0413425034e6242a9002bc6c3e7007352629 (
plain)
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
|
// this tests that members will stay in RECOVERING state on startup if they have not reached
// their stored minvalid
// @tags: [
// requires_replication,
// ]
var name = "minvalid";
var replTest = new ReplSetTest({name: name, nodes: 1, oplogSize: 1});
var host = getHostName();
var nodes = replTest.startSet();
replTest.initiate();
var primary = replTest.getPrimary();
var mdb = primary.getDB("foo");
print("1: initial insert");
mdb.foo.save({a: 1000});
print("2. get last op");
var local = primary.getDB("local");
var lastOp = local.oplog.rs.find().sort({$natural: -1}).limit(1).next();
printjson(lastOp);
print("3: change minvalid");
// Set the 'minvalid' to a high enough opTime that it won't conflict with any oplogs written on
// stepUp by any PrimaryOnlyServices.
assert.commandWorked(local.replset.minvalid.update(
{}, {$set: {ts: new Timestamp(lastOp.ts.t, lastOp.ts.i + 1000)}}, {upsert: true}));
printjson(local.replset.minvalid.findOne());
print("4: restart");
replTest.restart(0);
print("5: make sure it stays in recovering");
var timeout = (new Date()).getTime() + 30000;
while ((new Date().getTime()) < timeout) {
var status = replTest.nodes[0].getDB("admin").runCommand({hello: 1});
assert(!status.secondary && !status.primary, tojson(status));
sleep(2000);
}
replTest.stopSet(15);
|
