summaryrefslogtreecommitdiff
path: root/jstests/sharding/geo_near_random2.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/geo_near_random2.js')
-rw-r--r--jstests/sharding/geo_near_random2.js96
1 files changed, 48 insertions, 48 deletions
diff --git a/jstests/sharding/geo_near_random2.js b/jstests/sharding/geo_near_random2.js
index 0b874e5aafe..43b89b77392 100644
--- a/jstests/sharding/geo_near_random2.js
+++ b/jstests/sharding/geo_near_random2.js
@@ -5,54 +5,54 @@
load("jstests/libs/geo_near_random.js");
(function() {
- 'use strict';
-
- var testName = "geo_near_random2";
- var s = new ShardingTest({shards: 3});
-
- var db = s.getDB("test");
-
- var test = new GeoNearRandomTest(testName, db);
-
- assert.commandWorked(s.s0.adminCommand({enablesharding: 'test'}));
- s.ensurePrimaryShard('test', s.shard1.shardName);
- assert.commandWorked(s.s0.adminCommand({shardcollection: ('test.' + testName), key: {_id: 1}}));
-
- test.insertPts(5000);
- var shardList = [s.shard0.shardName, s.shard1.shardName, s.shard2.shardName];
- for (var i = (test.nPts / 10); i < test.nPts; i += (test.nPts / 10)) {
- assert.commandWorked(s.s0.adminCommand({split: ('test.' + testName), middle: {_id: i}}));
- try {
- assert.commandWorked(s.s0.adminCommand({
- moveChunk: ('test.' + testName),
- find: {_id: i - 1},
- to: shardList[i % 3],
- _waitForDelete: true
- }));
- } catch (e) {
- // ignore this error
- if (!e.message.match(/that chunk is already on that shard/)) {
- throw e;
- }
+'use strict';
+
+var testName = "geo_near_random2";
+var s = new ShardingTest({shards: 3});
+
+var db = s.getDB("test");
+
+var test = new GeoNearRandomTest(testName, db);
+
+assert.commandWorked(s.s0.adminCommand({enablesharding: 'test'}));
+s.ensurePrimaryShard('test', s.shard1.shardName);
+assert.commandWorked(s.s0.adminCommand({shardcollection: ('test.' + testName), key: {_id: 1}}));
+
+test.insertPts(5000);
+var shardList = [s.shard0.shardName, s.shard1.shardName, s.shard2.shardName];
+for (var i = (test.nPts / 10); i < test.nPts; i += (test.nPts / 10)) {
+ assert.commandWorked(s.s0.adminCommand({split: ('test.' + testName), middle: {_id: i}}));
+ try {
+ assert.commandWorked(s.s0.adminCommand({
+ moveChunk: ('test.' + testName),
+ find: {_id: i - 1},
+ to: shardList[i % 3],
+ _waitForDelete: true
+ }));
+ } catch (e) {
+ // ignore this error
+ if (!e.message.match(/that chunk is already on that shard/)) {
+ throw e;
}
}
-
- // Turn balancer back on, for actual tests
- // s.startBalancer(); // SERVER-13365
-
- var opts = {sphere: 0, nToTest: test.nPts * 0.01};
- test.testPt([0, 0], opts);
- test.testPt(test.mkPt(), opts);
- test.testPt(test.mkPt(), opts);
- test.testPt(test.mkPt(), opts);
- test.testPt(test.mkPt(), opts);
-
- opts.sphere = 1;
- test.testPt([0, 0], opts);
- test.testPt(test.mkPt(0.8), opts);
- test.testPt(test.mkPt(0.8), opts);
- test.testPt(test.mkPt(0.8), opts);
- test.testPt(test.mkPt(0.8), opts);
-
- s.stop();
+}
+
+// Turn balancer back on, for actual tests
+// s.startBalancer(); // SERVER-13365
+
+var opts = {sphere: 0, nToTest: test.nPts * 0.01};
+test.testPt([0, 0], opts);
+test.testPt(test.mkPt(), opts);
+test.testPt(test.mkPt(), opts);
+test.testPt(test.mkPt(), opts);
+test.testPt(test.mkPt(), opts);
+
+opts.sphere = 1;
+test.testPt([0, 0], opts);
+test.testPt(test.mkPt(0.8), opts);
+test.testPt(test.mkPt(0.8), opts);
+test.testPt(test.mkPt(0.8), opts);
+test.testPt(test.mkPt(0.8), opts);
+
+s.stop();
})();