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