diff options
author | clang-format-7.0.1 <adam.martin@10gen.com> | 2019-07-26 18:20:35 -0400 |
---|---|---|
committer | ADAM David Alan Martin <adam.martin@10gen.com> | 2019-07-27 11:02:23 -0400 |
commit | 134a4083953270e8a11430395357fb70a29047ad (patch) | |
tree | dd428e1230e31d92b20b393dfdc17ffe7fa79cb6 /jstests/sharding/multi_mongos2.js | |
parent | 1e46b5049003f427047e723ea5fab15b5a9253ca (diff) | |
download | mongo-134a4083953270e8a11430395357fb70a29047ad.tar.gz |
SERVER-41772 Apply clang-format 7.0.1 to the codebase
Diffstat (limited to 'jstests/sharding/multi_mongos2.js')
-rw-r--r-- | jstests/sharding/multi_mongos2.js | 108 |
1 files changed, 54 insertions, 54 deletions
diff --git a/jstests/sharding/multi_mongos2.js b/jstests/sharding/multi_mongos2.js index f98a9c69778..fad2106aad5 100644 --- a/jstests/sharding/multi_mongos2.js +++ b/jstests/sharding/multi_mongos2.js @@ -1,57 +1,57 @@ // This tests sharding an existing collection that both shards are aware of (SERVER-2828) (function() { - 'use strict'; - - var st = new ShardingTest({shards: 2, mongos: 2}); - - assert.commandWorked(st.s0.adminCommand({enablesharding: "test"})); - st.ensurePrimaryShard('test', st.shard1.shardName); - - // "test.foo" - sharded (by mongos 0) - assert.commandWorked(st.s0.adminCommand({shardcollection: "test.foo", key: {num: 1}})); - st.configRS.awaitLastOpCommitted(); - - // "test.existing" - unsharded - assert.writeOK(st.s0.getDB('test').existing.insert({_id: 1})); - assert.eq(1, st.s0.getDB('test').existing.count({_id: 1})); - assert.eq(1, st.s1.getDB('test').existing.count({_id: 1})); - - // "test.existing" - unsharded to sharded (by mongos 1) - assert.commandWorked(st.s1.adminCommand({shardcollection: "test.existing", key: {_id: 1}})); - st.configRS.awaitLastOpCommitted(); - assert.commandWorked(st.s1.adminCommand({split: "test.existing", middle: {_id: 5}})); - assert.commandWorked( - st.s1.adminCommand({moveChunk: "test.existing", find: {_id: 1}, to: st.shard0.shardName})); - - assert.eq(1, st.s0.getDB('test').existing.count({_id: 1})); // SERVER-2828 - assert.eq(1, st.s1.getDB('test').existing.count({_id: 1})); - - // Test stats - assert.writeOK(st.s0.getDB('test').existing2.insert({_id: 1})); - assert.eq(1, st.s0.getDB('test').existing2.count({_id: 1})); - assert.eq(1, st.s1.getDB('test').existing2.count({_id: 1})); - - assert.commandWorked(st.s1.adminCommand({shardcollection: "test.existing2", key: {_id: 1}})); - st.configRS.awaitLastOpCommitted(); - assert.eq(true, st.s1.getDB('test').existing2.stats().sharded); - - assert.commandWorked(st.s1.adminCommand({split: "test.existing2", middle: {_id: 5}})); - { - var res = st.s0.getDB('test').existing2.stats(); - printjson(res); - assert.eq(true, res.sharded); // SERVER-2828 - } - - // Test admin commands - assert.writeOK(st.s0.getDB('test').existing3.insert({_id: 1})); - assert.eq(1, st.s0.getDB('test').existing3.count({_id: 1})); - assert.eq(1, st.s1.getDB('test').existing3.count({_id: 1})); - assert.writeOK(st.s1.adminCommand({shardcollection: "test.existing3", key: {_id: 1}})); - st.configRS.awaitLastOpCommitted(); - - assert.commandWorked(st.s1.adminCommand({split: "test.existing3", middle: {_id: 5}})); - assert.commandWorked( - st.s0.adminCommand({moveChunk: "test.existing3", find: {_id: 1}, to: st.shard0.shardName})); - - st.stop(); +'use strict'; + +var st = new ShardingTest({shards: 2, mongos: 2}); + +assert.commandWorked(st.s0.adminCommand({enablesharding: "test"})); +st.ensurePrimaryShard('test', st.shard1.shardName); + +// "test.foo" - sharded (by mongos 0) +assert.commandWorked(st.s0.adminCommand({shardcollection: "test.foo", key: {num: 1}})); +st.configRS.awaitLastOpCommitted(); + +// "test.existing" - unsharded +assert.writeOK(st.s0.getDB('test').existing.insert({_id: 1})); +assert.eq(1, st.s0.getDB('test').existing.count({_id: 1})); +assert.eq(1, st.s1.getDB('test').existing.count({_id: 1})); + +// "test.existing" - unsharded to sharded (by mongos 1) +assert.commandWorked(st.s1.adminCommand({shardcollection: "test.existing", key: {_id: 1}})); +st.configRS.awaitLastOpCommitted(); +assert.commandWorked(st.s1.adminCommand({split: "test.existing", middle: {_id: 5}})); +assert.commandWorked( + st.s1.adminCommand({moveChunk: "test.existing", find: {_id: 1}, to: st.shard0.shardName})); + +assert.eq(1, st.s0.getDB('test').existing.count({_id: 1})); // SERVER-2828 +assert.eq(1, st.s1.getDB('test').existing.count({_id: 1})); + +// Test stats +assert.writeOK(st.s0.getDB('test').existing2.insert({_id: 1})); +assert.eq(1, st.s0.getDB('test').existing2.count({_id: 1})); +assert.eq(1, st.s1.getDB('test').existing2.count({_id: 1})); + +assert.commandWorked(st.s1.adminCommand({shardcollection: "test.existing2", key: {_id: 1}})); +st.configRS.awaitLastOpCommitted(); +assert.eq(true, st.s1.getDB('test').existing2.stats().sharded); + +assert.commandWorked(st.s1.adminCommand({split: "test.existing2", middle: {_id: 5}})); +{ + var res = st.s0.getDB('test').existing2.stats(); + printjson(res); + assert.eq(true, res.sharded); // SERVER-2828 +} + +// Test admin commands +assert.writeOK(st.s0.getDB('test').existing3.insert({_id: 1})); +assert.eq(1, st.s0.getDB('test').existing3.count({_id: 1})); +assert.eq(1, st.s1.getDB('test').existing3.count({_id: 1})); +assert.writeOK(st.s1.adminCommand({shardcollection: "test.existing3", key: {_id: 1}})); +st.configRS.awaitLastOpCommitted(); + +assert.commandWorked(st.s1.adminCommand({split: "test.existing3", middle: {_id: 5}})); +assert.commandWorked( + st.s0.adminCommand({moveChunk: "test.existing3", find: {_id: 1}, to: st.shard0.shardName})); + +st.stop(); })(); |