diff options
Diffstat (limited to 'jstests/sharding/jumbo1.js')
-rw-r--r-- | jstests/sharding/jumbo1.js | 33 |
1 files changed, 16 insertions, 17 deletions
diff --git a/jstests/sharding/jumbo1.js b/jstests/sharding/jumbo1.js index 594c8165ab2..1e8a3a9fdb2 100644 --- a/jstests/sharding/jumbo1.js +++ b/jstests/sharding/jumbo1.js @@ -1,40 +1,39 @@ (function() { - 'use strict'; - var s = new ShardingTest({shards: 2, mongos: 1, other: {chunkSize: 1}}); + var s = new ShardingTest({name: "jumbo1", shards: 2, mongos: 1, other: {chunkSize: 1}}); - assert.commandWorked(s.s0.adminCommand({enablesharding: "test"})); + s.adminCommand({enablesharding: "test"}); s.ensurePrimaryShard('test', 'shard0001'); - assert.commandWorked(s.s0.adminCommand({shardcollection: "test.foo", key: {x: 1}})); + s.adminCommand({shardcollection: "test.foo", key: {x: 1}}); - var db = s.getDB("test"); + db = s.getDB("test"); - var big = ""; - while (big.length < 10000) { + big = ""; + while (big.length < 10000) big += "."; - } - var x = 0; + x = 0; var bulk = db.foo.initializeUnorderedBulkOp(); - for (; x < 500; x++) { + for (; x < 500; x++) bulk.insert({x: x, big: big}); - } - for (var i = 0; i < 500; i++) { + for (i = 0; i < 500; i++) bulk.insert({x: x, big: big}); - } - for (; x < 2000; x++) { + for (; x < 2000; x++) bulk.insert({x: x, big: big}); - } assert.writeOK(bulk.execute()); s.printShardingStatus(true); - assert.commandWorked(s.s0.adminCommand({moveChunk: 'test.foo', find: {x: 0}, to: 'shard0000'})); + + res = sh.moveChunk("test.foo", {x: 0}, "shard0001"); + if (!res.ok) + res = sh.moveChunk("test.foo", {x: 0}, "shard0000"); + s.printShardingStatus(true); - s.startBalancer(); + sh.setBalancerState(true); function diff1() { var x = s.chunkCounts("foo"); |