summaryrefslogtreecommitdiff
path: root/jstests/sharding/geo_near_random1.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/geo_near_random1.js')
-rw-r--r--jstests/sharding/geo_near_random1.js76
1 files changed, 41 insertions, 35 deletions
diff --git a/jstests/sharding/geo_near_random1.js b/jstests/sharding/geo_near_random1.js
index bff63ca2b18..0229c84555c 100644
--- a/jstests/sharding/geo_near_random1.js
+++ b/jstests/sharding/geo_near_random1.js
@@ -1,46 +1,52 @@
// This tests all points using $near
(function() {
-load("jstests/libs/geo_near_random.js");
-
-var testName = "geo_near_random1";
-var s = new ShardingTest({ name: testName, shards: 3 });
-
-db = s.getDB("test"); // global db
-
-var test = new GeoNearRandomTest(testName);
-
-s.adminCommand({enablesharding:'test'});
-s.ensurePrimaryShard('test', 'shard0001');
-s.adminCommand({shardcollection: ('test.' + testName), key: {_id:1} });
-
-test.insertPts(50);
-
-for (var i = (test.nPts/10); i < test.nPts; i+= (test.nPts/10)){
- s.adminCommand({split: ('test.' + testName), middle: {_id: i} });
- try {
- s.adminCommand({ moveChunk: ('test.' + testName), find: { _id: i-1 },
- to: ('shard000' + (i%3)), _waitForDelete: true });
- } catch (e) {
- // ignore this error
- if (! e.message.match(/that chunk is already on that shard/)){
- throw e;
+ load("jstests/libs/geo_near_random.js");
+
+ var testName = "geo_near_random1";
+ var s = new ShardingTest({name: testName, shards: 3});
+
+ db = s.getDB("test"); // global db
+
+ var test = new GeoNearRandomTest(testName);
+
+ s.adminCommand({enablesharding: 'test'});
+ s.ensurePrimaryShard('test', 'shard0001');
+ s.adminCommand({shardcollection: ('test.' + testName), key: {_id: 1}});
+
+ test.insertPts(50);
+
+ for (var i = (test.nPts / 10); i < test.nPts; i += (test.nPts / 10)) {
+ s.adminCommand({split: ('test.' + testName), middle: {_id: i}});
+ try {
+ s.adminCommand({
+ moveChunk: ('test.' + testName),
+ find: {_id: i - 1},
+ to: ('shard000' + (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
+ // Turn balancer back on, for actual tests
+ // s.startBalancer() // SERVER-13365
-printShardingSizes();
+ printShardingSizes();
-var opts = {sharded: true};
-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);
+ var opts = {
+ sharded: true
+ };
+ 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);
-s.stop();
+ s.stop();
})();