diff options
Diffstat (limited to 'jstests/sharding/merge_chunks_test_with_md_ops.js')
-rw-r--r-- | jstests/sharding/merge_chunks_test_with_md_ops.js | 74 |
1 files changed, 36 insertions, 38 deletions
diff --git a/jstests/sharding/merge_chunks_test_with_md_ops.js b/jstests/sharding/merge_chunks_test_with_md_ops.js index ddcdfbaf0c2..591413a109c 100644 --- a/jstests/sharding/merge_chunks_test_with_md_ops.js +++ b/jstests/sharding/merge_chunks_test_with_md_ops.js @@ -1,57 +1,55 @@ // Tests that merging chunks does not prevent cluster from doing other metadata ops (function() { -'use strict'; + 'use strict'; -var st = new ShardingTest({ shards: 2 }); + var st = new ShardingTest({shards: 2}); -var mongos = st.s0; -var admin = mongos.getDB("admin"); -var shards = mongos.getCollection("config.shards").find().toArray(); -var coll = mongos.getCollection("foo.bar"); + var mongos = st.s0; + var admin = mongos.getDB("admin"); + var shards = mongos.getCollection("config.shards").find().toArray(); + var coll = mongos.getCollection("foo.bar"); -assert.commandWorked(admin.runCommand({ enableSharding: coll.getDB() + "" })); -st.ensurePrimaryShard(coll.getDB() + "", shards[0]._id); -assert.commandWorked(admin.runCommand({ shardCollection: coll + "", key: { _id: 1 } })); + assert.commandWorked(admin.runCommand({enableSharding: coll.getDB() + ""})); + st.ensurePrimaryShard(coll.getDB() + "", shards[0]._id); + assert.commandWorked(admin.runCommand({shardCollection: coll + "", key: {_id: 1}})); -st.printShardingStatus(); + st.printShardingStatus(); -// Split and merge the first chunk repeatedly -jsTest.log("Splitting and merging repeatedly..."); + // Split and merge the first chunk repeatedly + jsTest.log("Splitting and merging repeatedly..."); -for (var i = 0; i < 5; i++) { - assert.commandWorked(admin.runCommand({ split: coll + "", middle: { _id: i } })); - assert.commandWorked(admin.runCommand({ mergeChunks: coll + "", - bounds: [ { _id: MinKey }, { _id: MaxKey } ] })); - printjson(mongos.getDB("config").chunks.find().toArray()); -} + for (var i = 0; i < 5; i++) { + assert.commandWorked(admin.runCommand({split: coll + "", middle: {_id: i}})); + assert.commandWorked( + admin.runCommand({mergeChunks: coll + "", bounds: [{_id: MinKey}, {_id: MaxKey}]})); + printjson(mongos.getDB("config").chunks.find().toArray()); + } -// Move the first chunk to the other shard -jsTest.log("Moving to another shard..."); + // Move the first chunk to the other shard + jsTest.log("Moving to another shard..."); -assert.commandWorked(admin.runCommand({ moveChunk: coll + "", - find: { _id: 0 }, - to: shards[1]._id })); + assert.commandWorked( + admin.runCommand({moveChunk: coll + "", find: {_id: 0}, to: shards[1]._id})); -// Split and merge the chunk repeatedly -jsTest.log("Splitting and merging repeatedly (again)..."); + // Split and merge the chunk repeatedly + jsTest.log("Splitting and merging repeatedly (again)..."); -for (var i = 0; i < 5; i++) { - assert.commandWorked(admin.runCommand({ split: coll + "", middle: { _id: i } })); - assert.commandWorked(admin.runCommand({ mergeChunks: coll + "", - bounds: [{ _id: MinKey }, { _id: MaxKey }] })); - printjson(mongos.getDB("config").chunks.find().toArray()); -} + for (var i = 0; i < 5; i++) { + assert.commandWorked(admin.runCommand({split: coll + "", middle: {_id: i}})); + assert.commandWorked( + admin.runCommand({mergeChunks: coll + "", bounds: [{_id: MinKey}, {_id: MaxKey}]})); + printjson(mongos.getDB("config").chunks.find().toArray()); + } -// Move the chunk back to the original shard -jsTest.log("Moving to original shard..."); + // Move the chunk back to the original shard + jsTest.log("Moving to original shard..."); -assert.commandWorked(admin.runCommand({ moveChunk: coll + "", - find: { _id: 0 }, - to: shards[0]._id })); + assert.commandWorked( + admin.runCommand({moveChunk: coll + "", find: {_id: 0}, to: shards[0]._id})); -st.printShardingStatus(); + st.printShardingStatus(); -st.stop(); + st.stop(); })(); |