diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/sharding/sharding_balance3.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-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.js | 127 |
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(); })(); |