summaryrefslogtreecommitdiff
path: root/jstests/sharding/split_with_force_small.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/split_with_force_small.js')
-rw-r--r--jstests/sharding/split_with_force_small.js64
1 files changed, 33 insertions, 31 deletions
diff --git a/jstests/sharding/split_with_force_small.js b/jstests/sharding/split_with_force_small.js
index 86fb4667132..ad14f8642cb 100644
--- a/jstests/sharding/split_with_force_small.js
+++ b/jstests/sharding/split_with_force_small.js
@@ -2,68 +2,70 @@
// Tests autosplit locations with force : true, for small collections
//
-var options = { chunkSize: 1, // MB
- mongosOptions : { noAutoSplit : "" }
- };
+var options = {
+ chunkSize: 1, // MB
+ mongosOptions: {noAutoSplit: ""}
+};
-var st = new ShardingTest({ shards : 1, mongos : 1, other : options });
+var st = new ShardingTest({shards: 1, mongos: 1, other: options});
st.stopBalancer();
var mongos = st.s0;
-var admin = mongos.getDB( "admin" );
-var config = mongos.getDB( "config" );
-var shardAdmin = st.shard0.getDB( "admin" );
-var coll = mongos.getCollection( "foo.bar" );
+var admin = mongos.getDB("admin");
+var config = mongos.getDB("config");
+var shardAdmin = st.shard0.getDB("admin");
+var coll = mongos.getCollection("foo.bar");
-assert( admin.runCommand({ enableSharding : coll.getDB() + "" }).ok );
-assert( admin.runCommand({ shardCollection : coll + "", key : { _id : 1 } }).ok );
-assert( admin.runCommand({ split : coll + "", middle : { _id : 0 } }).ok );
+assert(admin.runCommand({enableSharding: coll.getDB() + ""}).ok);
+assert(admin.runCommand({shardCollection: coll + "", key: {_id: 1}}).ok);
+assert(admin.runCommand({split: coll + "", middle: {_id: 0}}).ok);
-jsTest.log( "Insert a bunch of data into the low chunk of a collection," +
- " to prevent relying on stats." );
+jsTest.log("Insert a bunch of data into the low chunk of a collection," +
+ " to prevent relying on stats.");
var data128k = "x";
-for ( var i = 0; i < 7; i++ ) data128k += data128k;
+for (var i = 0; i < 7; i++)
+ data128k += data128k;
var bulk = coll.initializeUnorderedBulkOp();
-for ( var i = 0; i < 1024; i++ ) {
- bulk.insert({ _id : -(i + 1) });
+for (var i = 0; i < 1024; i++) {
+ bulk.insert({_id: -(i + 1)});
}
assert.writeOK(bulk.execute());
-jsTest.log( "Insert 32 docs into the high chunk of a collection" );
+jsTest.log("Insert 32 docs into the high chunk of a collection");
bulk = coll.initializeUnorderedBulkOp();
-for ( var i = 0; i < 32; i++ ) {
- bulk.insert({ _id : i });
+for (var i = 0; i < 32; i++) {
+ bulk.insert({_id: i});
}
assert.writeOK(bulk.execute());
-jsTest.log( "Split off MaxKey chunk..." );
+jsTest.log("Split off MaxKey chunk...");
-assert( admin.runCommand({ split : coll + "", middle : { _id : 32 } }).ok );
+assert(admin.runCommand({split: coll + "", middle: {_id: 32}}).ok);
-jsTest.log( "Keep splitting chunk multiple times..." );
+jsTest.log("Keep splitting chunk multiple times...");
st.printShardingStatus();
-for ( var i = 0; i < 5; i++ ) {
- assert( admin.runCommand({ split : coll + "", find : { _id : 0 } }).ok );
+for (var i = 0; i < 5; i++) {
+ assert(admin.runCommand({split: coll + "", find: {_id: 0}}).ok);
st.printShardingStatus();
}
// Make sure we can't split further than 5 (2^5) times
-assert( !admin.runCommand({ split : coll + "", find : { _id : 0 } }).ok );
+assert(!admin.runCommand({split: coll + "", find: {_id: 0}}).ok);
-var chunks = config.chunks.find({ 'min._id' : { $gte : 0, $lt : 32 } }).sort({ min : 1 }).toArray();
-printjson( chunks );
+var chunks = config.chunks.find({'min._id': {$gte: 0, $lt: 32}}).sort({min: 1}).toArray();
+printjson(chunks);
// Make sure the chunks grow by 2x (except the first)
var nextSize = 1;
-for ( var i = 0; i < chunks.size; i++ ) {
- assert.eq( coll.count({ _id : { $gte : chunks[i].min._id, $lt : chunks[i].max._id } }),
- nextSize );
- if ( i != 0 ) nextSize += nextSize;
+for (var i = 0; i < chunks.size; i++) {
+ assert.eq(coll.count({_id: {$gte: chunks[i].min._id, $lt: chunks[i].max._id}}), nextSize);
+ if (i != 0)
+ nextSize += nextSize;
}
st.stop();