diff options
Diffstat (limited to 'jstests/sharding/geo_near_random2.js')
-rw-r--r-- | jstests/sharding/geo_near_random2.js | 96 |
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(); })(); |