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
|
// TODO: remove test after we deprecate SyncClusterConnection
//
// This test involves restarting a standalone shard, so cannot be run on ephemeral storage engines.
// A restarted standalone will lose all data when using an ephemeral storage engine.
// @tags: [requires_persistence]
var test = new SyncCCTest("sync1");
if (test.conn.writeMode() == 'commands') {
jsTest.log('Skipping test not compatible with write commands');
} else {
db = test.conn.getDB("test");
t = db.sync1;
t.save({x: 1});
assert.eq(1, t.find().itcount(), "A1");
assert.eq(1, t.find().count(), "A2");
t.save({x: 2});
assert.eq(2, t.find().itcount(), "A3");
assert.eq(2, t.find().count(), "A4");
test.checkHashes("test", "A3");
test.tempKill();
assert.throws(function() {
t.save({x: 3});
}, null, "B1");
// It's ok even for some of the mongod to be unreachable for read-only cmd
assert.eq(2, t.find({}).count());
// It's NOT ok for some of the mongod to be unreachable for write cmd
assert.throws(function() {
t.getDB().runCommand({profile: 1});
});
assert.eq(2, t.find().itcount(), "B2");
test.tempStart();
test.checkHashes("test", "B3");
// Trying killing the second mongod
test.tempKill(1);
assert.throws(function() {
t.save({x: 3});
});
// It's ok even for some of the mongod to be unreachable for read-only cmd
assert.eq(2, t.find({}).count());
// It's NOT ok for some of the mongod to be unreachable for write cmd
assert.throws(function() {
t.getDB().runCommand({profile: 1});
});
assert.eq(2, t.find().itcount());
test.tempStart(1);
assert.eq(2, t.find().itcount(), "C1");
assert.soon(function() {
try {
t.remove({x: 1});
return true;
} catch (e) {
print(e);
}
return false;
});
t.find().forEach(printjson);
assert.eq(1, t.find().itcount(), "C2");
test.stop();
}
|
