blob: 0d9d1273679ce8aed1cee7c4ab2d139b16a55f30 (
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
/**
* Runs initial sync on a node with many databases.
*/
(function() {
// Skip this test if running with --nojournal and WiredTiger.
if (jsTest.options().noJournal &&
(!jsTest.options().storageEngine || jsTest.options().storageEngine === "wiredTiger")) {
print("Skipping test because running WiredTiger without journaling isn't a valid" +
" replica set configuration");
return;
}
var name = 'initial_sync_many_dbs';
var num_dbs = 32;
var max_colls = 32;
var num_docs = 2;
var replSet = new ReplSetTest({
name: name,
nodes: 1,
});
replSet.startSet();
replSet.initiate();
var primary = replSet.getPrimary();
jsTestLog('Seeding primary with ' + num_dbs + ' databases with up to ' + max_colls +
' collections each. Each collection will contain ' + num_docs + ' documents');
for (var i = 0; i < num_dbs; i++) {
var dbname = name + '_db' + i;
for (var j = 0; j < (i % max_colls + 1); j++) {
var collname = name + '_coll' + j;
var coll = primary.getDB(dbname)[collname];
for (var k = 0; k < num_docs; k++) {
assert.writeOK(coll.insert({_id: k}));
}
}
}
// Add a secondary that will initial sync from the primary.
jsTestLog('Adding node to replica set to trigger initial sync process');
replSet.add();
replSet.reInitiate();
replSet.awaitSecondaryNodes(30 * 60 * 1000);
var secondary = replSet.getSecondary();
jsTestLog('New node has transitioned to secondary. Checking collection sizes');
for (var i = 0; i < num_dbs; i++) {
var dbname = name + '_db' + i;
for (var j = 0; j < (i % max_colls + 1); j++) {
var collname = name + '_coll' + j;
var coll = secondary.getDB(dbname)[collname];
assert.eq(num_docs,
coll.find().itcount(),
'collection size inconsistent with primary after initial sync: ' +
coll.getFullName());
}
}
replSet.stopSet();
})();
|
