summaryrefslogtreecommitdiff
path: root/jstests/sharding/sharding_balance3.js
diff options
context:
space:
mode:
authorJonathan Abrahams <jonathan@mongodb.com>2016-03-09 12:17:50 -0500
committerJonathan Abrahams <jonathan@mongodb.com>2016-03-09 12:18:14 -0500
commit4ae691e8edc87d0e3cfb633bb91c328426be007b (patch)
tree52079a593f54382ca13a2e741633eab1b6271893 /jstests/sharding/sharding_balance3.js
parenta025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff)
downloadmongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/sharding/sharding_balance3.js')
-rw-r--r--jstests/sharding/sharding_balance3.js127
1 files changed, 64 insertions, 63 deletions
diff --git a/jstests/sharding/sharding_balance3.js b/jstests/sharding/sharding_balance3.js
index 51e5765b19e..876709ace4a 100644
--- a/jstests/sharding/sharding_balance3.js
+++ b/jstests/sharding/sharding_balance3.js
@@ -1,68 +1,69 @@
-// Simple test to make sure things get balanced
+// Simple test to make sure things get balanced
(function() {
-var s = new ShardingTest({ name: "slow_sharding_balance3",
- shards: 2,
- mongos: 1,
- other: { chunkSize: 1, enableBalancer : true } });
-
-s.adminCommand( { enablesharding : "test" } );
-s.ensurePrimaryShard('test', 'shard0001');
-
-s.config.settings.find().forEach( printjson );
-
-db = s.getDB( "test" );
-
-bigString = "";
-while ( bigString.length < 10000 )
- bigString += "asdasdasdasdadasdasdasdasdasdasdasdasda";
-
-inserted = 0;
-num = 0;
-var bulk = db.foo.initializeUnorderedBulkOp();
-while ( inserted < ( 40 * 1024 * 1024 ) ){
- bulk.insert({ _id: num++, s: bigString });
- inserted += bigString.length;
-}
-assert.writeOK(bulk.execute());
-
-s.adminCommand( { shardcollection : "test.foo" , key : { _id : 1 } } );
-assert.lt( 20 , s.config.chunks.count() , "setup2" );
-
-function diff1(){
- var x = s.chunkCounts( "foo" );
- printjson( x );
- return Math.max( x.shard0000 , x.shard0001 ) - Math.min( x.shard0000 , x.shard0001 );
-}
-
-assert.lt( 10 , diff1() );
-
-// Wait for balancer to kick in.
-var initialDiff = diff1();
-assert.soon(function() {
- return diff1() != initialDiff;
- }, "Balancer did not kick in");
-
-print("* A");
-print( "disabling the balancer" );
-s.config.settings.update( { _id : "balancer" }, { $set : { stopped : true } } , true );
-s.config.settings.find().forEach( printjson );
-print("* B");
-
-
-print( diff1() );
-
-var currDiff = diff1();
-var waitTime = 0;
-var startTime = Date.now();
-while ( waitTime < ( 1000 * 60 ) ) {
- // Wait for 60 seconds to ensure balancer did not run
- assert.eq( currDiff, diff1(), "balance with stopped flag should not have happened" );
- sleep( 5000 );
- waitTime = Date.now() - startTime;
-}
-
-s.stop();
+ var s = new ShardingTest({
+ name: "slow_sharding_balance3",
+ shards: 2,
+ mongos: 1,
+ other: {chunkSize: 1, enableBalancer: true}
+ });
+
+ s.adminCommand({enablesharding: "test"});
+ s.ensurePrimaryShard('test', 'shard0001');
+
+ s.config.settings.find().forEach(printjson);
+
+ db = s.getDB("test");
+
+ bigString = "";
+ while (bigString.length < 10000)
+ bigString += "asdasdasdasdadasdasdasdasdasdasdasdasda";
+
+ inserted = 0;
+ num = 0;
+ var bulk = db.foo.initializeUnorderedBulkOp();
+ while (inserted < (40 * 1024 * 1024)) {
+ bulk.insert({_id: num++, s: bigString});
+ inserted += bigString.length;
+ }
+ assert.writeOK(bulk.execute());
+
+ s.adminCommand({shardcollection: "test.foo", key: {_id: 1}});
+ assert.lt(20, s.config.chunks.count(), "setup2");
+
+ function diff1() {
+ var x = s.chunkCounts("foo");
+ printjson(x);
+ return Math.max(x.shard0000, x.shard0001) - Math.min(x.shard0000, x.shard0001);
+ }
+
+ assert.lt(10, diff1());
+
+ // Wait for balancer to kick in.
+ var initialDiff = diff1();
+ assert.soon(function() {
+ return diff1() != initialDiff;
+ }, "Balancer did not kick in");
+
+ print("* A");
+ print("disabling the balancer");
+ s.config.settings.update({_id: "balancer"}, {$set: {stopped: true}}, true);
+ s.config.settings.find().forEach(printjson);
+ print("* B");
+
+ print(diff1());
+
+ var currDiff = diff1();
+ var waitTime = 0;
+ var startTime = Date.now();
+ while (waitTime < (1000 * 60)) {
+ // Wait for 60 seconds to ensure balancer did not run
+ assert.eq(currDiff, diff1(), "balance with stopped flag should not have happened");
+ sleep(5000);
+ waitTime = Date.now() - startTime;
+ }
+
+ s.stop();
})();