1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
// This tests 1% of all points using $near and $nearSphere
(function() {
load("jstests/libs/geo_near_random.js");
var testName = "geo_near_random2";
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(5000);
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
opts = {sphere: 0, nToTest: test.nPts * 0.01, 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);
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();
})();
|
