diff options
Diffstat (limited to 'jstests/slow1/initial_sync_many_dbs.js')
-rw-r--r-- | jstests/slow1/initial_sync_many_dbs.js | 92 |
1 files changed, 46 insertions, 46 deletions
diff --git a/jstests/slow1/initial_sync_many_dbs.js b/jstests/slow1/initial_sync_many_dbs.js index 0d9d1273679..03eea70525e 100644 --- a/jstests/slow1/initial_sync_many_dbs.js +++ b/jstests/slow1/initial_sync_many_dbs.js @@ -3,58 +3,58 @@ */ (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; - } +// 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 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})); - } +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(); +// 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.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(); +replSet.stopSet(); })(); |