blob: 16374adeb24d73d06f8b53b80db059f5daec964b (
plain)
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
56
57
58
59
|
// SERVER-15539
'use strict';
load('jstests/libs/parallelTester.js');
function client1() {
Random.setRandomSeed();
for(var i = 0; i < 1000; i++) {
db.remove_during_mr.remove({rand: {$gte: Random.rand()}}, {justOne: true});
}
}
function client2() {
function mapper() {
emit(this.key, 1);
}
function reducer() {
return {};
}
for(var i = 0; i < 1000; i++) {
var options = {
out: {replace: 'bar'},
sort: {_id: -1}
};
db.remove_during_mr.mapReduce(mapper, reducer, options);
}
}
// prepare some basic data for the collection
db.remove_during_mr.drop();
Random.setRandomSeed();
var bulk = db.remove_during_mr.initializeUnorderedBulkOp();
for (var i = 0; i < 3000; i++) {
bulk.insert({i: i, key: Random.randInt(), rand: Random.rand()});
}
bulk.execute();
var threads = [];
for (var i = 0; i < 20; i++) {
var t;
if (i % 2 === 0) {
t = new ScopedThread(client1);
} else {
t = new ScopedThread(client2);
}
threads.push(t);
t.start();
}
threads.forEach(function(t) {
t.join();
});
|