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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/**
* Test killing the secondary during initially sync
*
* 1. Bring up set
* 2. Insert some data
* 4. Make sure synced
* 5. Freeze #2
* 6. Bring up #3
* 7. Kill #2 in the middle of syncing
* 8. Eventually it should become a secondary
* 9. Bring #2 back up
* 10. Insert some stuff
* 11. Everyone happy eventually
*/
load("jstests/replsets/rslib.js");
var basename = "jstests_initsync1";
print("1. Bring up set");
var replTest = new ReplSetTest( {name: basename, nodes: 2} );
var conns = replTest.startSet();
replTest.initiate();
var master = replTest.getMaster();
var foo = master.getDB("foo");
var admin = master.getDB("admin");
var slave1 = replTest.liveNodes.slaves[0];
var admin_s1 = slave1.getDB("admin");
var local_s1 = slave1.getDB("local");
print("2. Insert some data");
for (var i=0; i<10000; i++) {
foo.bar.insert({date : new Date(), x : i, str : "all the talk on the market"});
}
print("total in foo: "+foo.bar.count());
print("4. Make sure synced");
replTest.awaitReplication();
print("5. Freeze #2");
admin_s1.runCommand({replSetFreeze:999999});
print("6. Bring up #3");
var ports = allocatePorts( 3 );
var basePath = "/data/db/" + basename;
var hostname = getHostName();
var slave2 = startMongodTest (ports[2], basename, false, {replSet : basename, oplogSize : 2} )
var local_s2 = slave2.getDB("local");
var admin_s2 = slave2.getDB("admin");
var config = replTest.getReplSetConfig();
config.version = 2;
config.members.push({_id:2, host:hostname+":"+ports[2]});
try {
admin.runCommand({replSetReconfig:config});
}
catch(e) {
print(e);
}
reconnect(slave1);
reconnect(slave2);
wait(function() {
var config2 = local_s1.system.replset.findOne();
var config3 = local_s2.system.replset.findOne();
printjson(config2);
printjson(config3);
return config2.version == config.version &&
(config3 && config3.version == config.version);
});
wait(function() {
var status = admin_s2.runCommand({replSetGetStatus:1});
printjson(status);
return status.members &&
(status.members[2].state == 3 || status.members[2].state == 2);
});
print("7. Kill #2 in the middle of syncing");
replTest.stop(1);
print("8. Eventually it should become a secondary");
print("if initial sync has started, this will cause it to fail and sleep for 5 minutes");
wait(function() {
var status = admin_s2.runCommand({replSetGetStatus:1});
occasionally(function() { printjson(status); });
return status.members[2].state == 2;
}, 350);
print("9. Bring #2 back up");
replTest.start(1, {}, true);
reconnect(slave1);
wait(function() {
var status = admin_s1.runCommand({replSetGetStatus:1});
printjson(status);
return status.ok == 1 && status.members &&
status.members[1].state == 2 || status.members[1].state == 1;
});
print("10. Insert some stuff");
master = replTest.getMaster();
for (var i=0; i<10000; i++) {
master.getDB("foo").bar.insert({date : new Date(), x : i, str : "all the talk on the market"});
}
print("11. Everyone happy eventually");
replTest.awaitReplication(300000);
print("12. Build index in background");
master.getDB("foo").bar.ensureIndex({x : 1}, {background : true});
assert.soon(function() {
return replTest.liveNodes.slaves[0].getDB("foo").runCommand({count: 1}).ok == 1;
});
print("13. Check hbmsg");
master.getDB("admin").runCommand({replSetTest:1, sethbmsg:"foo bar baz"});
var status = master.getDB("admin").runCommand({replSetGetStatus:1});
printjson(status);
assert.eq(status.members[0].errmsg, "foo bar baz");
|
