summaryrefslogtreecommitdiff
path: root/jstests/sharding/multi_mongos2.js
diff options
context:
space:
mode:
authorclang-format-7.0.1 <adam.martin@10gen.com>2019-07-26 18:20:35 -0400
committerADAM David Alan Martin <adam.martin@10gen.com>2019-07-27 11:02:23 -0400
commit134a4083953270e8a11430395357fb70a29047ad (patch)
treedd428e1230e31d92b20b393dfdc17ffe7fa79cb6 /jstests/sharding/multi_mongos2.js
parent1e46b5049003f427047e723ea5fab15b5a9253ca (diff)
downloadmongo-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.js108
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();
})();