summaryrefslogtreecommitdiff
path: root/jstests/slow1/mr_during_migrate.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/slow1/mr_during_migrate.js
parent1e46b5049003f427047e723ea5fab15b5a9253ca (diff)
downloadmongo-134a4083953270e8a11430395357fb70a29047ad.tar.gz
SERVER-41772 Apply clang-format 7.0.1 to the codebase
Diffstat (limited to 'jstests/slow1/mr_during_migrate.js')
-rw-r--r--jstests/slow1/mr_during_migrate.js152
1 files changed, 76 insertions, 76 deletions
diff --git a/jstests/slow1/mr_during_migrate.js b/jstests/slow1/mr_during_migrate.js
index c5d7b772efb..06d79c46e92 100644
--- a/jstests/slow1/mr_during_migrate.js
+++ b/jstests/slow1/mr_during_migrate.js
@@ -2,111 +2,111 @@
// @tags: [requires_sharding]
(function() {
- 'use strict';
+'use strict';
- var st = new ShardingTest({shards: 10, mongos: 2, verbose: 2});
+var st = new ShardingTest({shards: 10, mongos: 2, verbose: 2});
- var mongos = st.s0;
- var admin = mongos.getDB("admin");
- var coll = st.s.getCollection(jsTest.name() + ".coll");
+var mongos = st.s0;
+var admin = mongos.getDB("admin");
+var coll = st.s.getCollection(jsTest.name() + ".coll");
- var numDocs = 1024 * 1024;
- var dataSize = 1024; // bytes, must be power of 2
+var numDocs = 1024 * 1024;
+var dataSize = 1024; // bytes, must be power of 2
- var data = "x";
- while (data.length < dataSize)
- data += data;
+var data = "x";
+while (data.length < dataSize)
+ data += data;
- var bulk = coll.initializeUnorderedBulkOp();
- for (var i = 0; i < numDocs; i++) {
- bulk.insert({_id: i, data: data});
- }
- assert.writeOK(bulk.execute());
+var bulk = coll.initializeUnorderedBulkOp();
+for (var i = 0; i < numDocs; i++) {
+ bulk.insert({_id: i, data: data});
+}
+assert.writeOK(bulk.execute());
- // Make sure everything got inserted
- assert.eq(numDocs, coll.find().itcount());
+// Make sure everything got inserted
+assert.eq(numDocs, coll.find().itcount());
- jsTest.log("Inserted " + sh._dataFormat(dataSize * numDocs) + " of data.");
+jsTest.log("Inserted " + sh._dataFormat(dataSize * numDocs) + " of data.");
- // Shard collection
- st.shardColl(coll, {_id: 1}, false);
+// Shard collection
+st.shardColl(coll, {_id: 1}, false);
- st.printShardingStatus();
+st.printShardingStatus();
- jsTest.log("Sharded collection now initialized, starting migrations...");
+jsTest.log("Sharded collection now initialized, starting migrations...");
- var checkMigrate = function() {
- print("Result of migrate : ");
- printjson(this);
- };
+var checkMigrate = function() {
+ print("Result of migrate : ");
+ printjson(this);
+};
- // Creates a number of migrations of random chunks to diff shard servers
- var ops = [];
- for (var i = 0; i < st._connections.length; i++) {
- ops.push({
- op: "command",
- ns: "admin",
- command: {
- moveChunk: "" + coll,
- find: {_id: {"#RAND_INT": [0, numDocs]}},
- to: st._connections[i].shardName,
- _waitForDelete: true
- },
- showResult: true
- });
- }
+// Creates a number of migrations of random chunks to diff shard servers
+var ops = [];
+for (var i = 0; i < st._connections.length; i++) {
+ ops.push({
+ op: "command",
+ ns: "admin",
+ command: {
+ moveChunk: "" + coll,
+ find: {_id: {"#RAND_INT": [0, numDocs]}},
+ to: st._connections[i].shardName,
+ _waitForDelete: true
+ },
+ showResult: true
+ });
+}
- // TODO: Also migrate output collection
+// TODO: Also migrate output collection
- jsTest.log("Starting migrations now...");
+jsTest.log("Starting migrations now...");
- var bid = benchStart({ops: ops, host: st.s.host, parallel: 1, handleErrors: false});
+var bid = benchStart({ops: ops, host: st.s.host, parallel: 1, handleErrors: false});
- //#######################
- // Tests during migration
+//#######################
+// Tests during migration
- var numTests = 5;
+var numTests = 5;
- for (var t = 0; t < numTests; t++) {
- jsTest.log("Test #" + t);
+for (var t = 0; t < numTests; t++) {
+ jsTest.log("Test #" + t);
- var mongos = st.s1; // use other mongos so we get stale shard versions
- var coll = mongos.getCollection(coll + "");
- var outputColl = mongos.getCollection(coll + "_output");
+ var mongos = st.s1; // use other mongos so we get stale shard versions
+ var coll = mongos.getCollection(coll + "");
+ var outputColl = mongos.getCollection(coll + "_output");
- var numTypes = 32;
- var map = function() {
- emit(this._id % 32 /* must be hardcoded */, {c: 1});
- };
+ var numTypes = 32;
+ var map = function() {
+ emit(this._id % 32 /* must be hardcoded */, {c: 1});
+ };
- var reduce = function(k, vals) {
- var total = 0;
- for (var i = 0; i < vals.length; i++)
- total += vals[i].c;
- return {c: total};
- };
+ var reduce = function(k, vals) {
+ var total = 0;
+ for (var i = 0; i < vals.length; i++)
+ total += vals[i].c;
+ return {c: total};
+ };
- printjson(coll.find({_id: 0}).itcount());
+ printjson(coll.find({_id: 0}).itcount());
- jsTest.log("Starting new mapReduce run #" + t);
+ jsTest.log("Starting new mapReduce run #" + t);
- // assert.eq( coll.find().itcount(), numDocs )
+ // assert.eq( coll.find().itcount(), numDocs )
- coll.getMongo().getDB("admin").runCommand({setParameter: 1, traceExceptions: true});
+ coll.getMongo().getDB("admin").runCommand({setParameter: 1, traceExceptions: true});
- printjson(coll.mapReduce(
- map, reduce, {out: {replace: outputColl.getName(), db: outputColl.getDB() + ""}}));
+ printjson(coll.mapReduce(
+ map, reduce, {out: {replace: outputColl.getName(), db: outputColl.getDB() + ""}}));
- jsTest.log("MapReduce run #" + t + " finished.");
+ jsTest.log("MapReduce run #" + t + " finished.");
- assert.eq(outputColl.find().itcount(), numTypes);
+ assert.eq(outputColl.find().itcount(), numTypes);
- outputColl.find().forEach(function(x) {
- assert.eq(x.value.c, numDocs / numTypes);
- });
- }
+ outputColl.find().forEach(function(x) {
+ assert.eq(x.value.c, numDocs / numTypes);
+ });
+}
- printjson(benchFinish(bid));
+printjson(benchFinish(bid));
- st.stop();
+st.stop();
})();