summaryrefslogtreecommitdiff
path: root/jstests/slow1/sharding_multiple_collections.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/slow1/sharding_multiple_collections.js')
-rw-r--r--jstests/slow1/sharding_multiple_collections.js100
1 files changed, 50 insertions, 50 deletions
diff --git a/jstests/slow1/sharding_multiple_collections.js b/jstests/slow1/sharding_multiple_collections.js
index ee58da80400..f6570d08a69 100644
--- a/jstests/slow1/sharding_multiple_collections.js
+++ b/jstests/slow1/sharding_multiple_collections.js
@@ -1,70 +1,70 @@
// @tags: [requires_sharding]
(function() {
- 'use strict';
+'use strict';
- var s = new ShardingTest({shards: 2, mongos: 1, other: {chunkSize: 1, enableBalancer: true}});
+var s = new ShardingTest({shards: 2, mongos: 1, other: {chunkSize: 1, enableBalancer: true}});
- assert.commandWorked(s.s0.adminCommand({enablesharding: "test"}));
- s.ensurePrimaryShard('test', s.shard1.shardName);
+assert.commandWorked(s.s0.adminCommand({enablesharding: "test"}));
+s.ensurePrimaryShard('test', s.shard1.shardName);
- var S = "";
- while (S.length < 500) {
- S += "123123312312";
- }
+var S = "";
+while (S.length < 500) {
+ S += "123123312312";
+}
- var N = 100000;
+var N = 100000;
- var db = s.getDB("test");
- var bulk = db.foo.initializeUnorderedBulkOp();
- var bulk2 = db.bar.initializeUnorderedBulkOp();
- for (i = 0; i < N; i++) {
- bulk.insert({_id: i, s: S});
- bulk2.insert({_id: i, s: S, s2: S});
- }
- assert.writeOK(bulk.execute());
- assert.writeOK(bulk2.execute());
+var db = s.getDB("test");
+var bulk = db.foo.initializeUnorderedBulkOp();
+var bulk2 = db.bar.initializeUnorderedBulkOp();
+for (i = 0; i < N; i++) {
+ bulk.insert({_id: i, s: S});
+ bulk2.insert({_id: i, s: S, s2: S});
+}
+assert.writeOK(bulk.execute());
+assert.writeOK(bulk2.execute());
- s.printShardingStatus();
+s.printShardingStatus();
- function mytest(coll, i, loopNumber) {
- try {
- var x = coll.find({_id: i}).explain();
- } catch (e) {
- // Ignore stale shard version exceptions, since there are many migrations happening, and
- // mongos may not be able to complete the find within the stale version retries limit.
- if (e.message.contains("stale config")) {
- return;
- }
- throw e;
- }
- if (x)
+function mytest(coll, i, loopNumber) {
+ try {
+ var x = coll.find({_id: i}).explain();
+ } catch (e) {
+ // Ignore stale shard version exceptions, since there are many migrations happening, and
+ // mongos may not be able to complete the find within the stale version retries limit.
+ if (e.message.contains("stale config")) {
return;
- throw Error("can't find " + i + " in " + coll.getName() + " on loopNumber: " + loopNumber +
- " explain: " + tojson(x));
+ }
+ throw e;
}
+ if (x)
+ return;
+ throw Error("can't find " + i + " in " + coll.getName() + " on loopNumber: " + loopNumber +
+ " explain: " + tojson(x));
+}
- for (var loopNumber = 0;; loopNumber++) {
- for (var i = 0; i < N; i++) {
- mytest(db.foo, i, loopNumber);
- mytest(db.bar, i, loopNumber);
- if (i % 1000 == 0)
- print(i);
- }
+for (var loopNumber = 0;; loopNumber++) {
+ for (var i = 0; i < N; i++) {
+ mytest(db.foo, i, loopNumber);
+ mytest(db.bar, i, loopNumber);
+ if (i % 1000 == 0)
+ print(i);
+ }
- s.printShardingStatus();
+ s.printShardingStatus();
- if (loopNumber == 0) {
- assert.commandWorked(s.s0.adminCommand({shardcollection: "test.foo", key: {_id: 1}}));
- assert.commandWorked(s.s0.adminCommand({shardcollection: "test.bar", key: {_id: 1}}));
- }
+ if (loopNumber == 0) {
+ assert.commandWorked(s.s0.adminCommand({shardcollection: "test.foo", key: {_id: 1}}));
+ assert.commandWorked(s.s0.adminCommand({shardcollection: "test.bar", key: {_id: 1}}));
+ }
- assert(loopNumber < 1000, "taking too long");
+ assert(loopNumber < 1000, "taking too long");
- if (s.chunkDiff("foo") < 12 && s.chunkDiff("bar") < 12) {
- break;
- }
+ if (s.chunkDiff("foo") < 12 && s.chunkDiff("bar") < 12) {
+ break;
}
+}
- s.stop();
+s.stop();
})();