blob: d4ea12aa8f6339bf97246b11079b8da9e48d290a (
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
60
61
62
63
64
|
// @tags: [
// requires_fastcount,
// requires_non_retryable_writes,
// uses_multiple_connections,
// uses_parallel_shell,
// ]
// Test removal of Records that have been reused since the remove operation began. SERVER-5198
(function() {
"use strict";
const t = db.jstests_removeb;
t.drop();
t.createIndex({a: 1});
// Make the index multikey to trigger cursor dedup checking.
t.insert({a: [-1, -2]});
t.remove({});
const insertDocs = function(collection, nDocs) {
print("Bulk inserting " + nDocs + " documents");
const bulk = collection.initializeUnorderedBulkOp();
for (let i = 0; i < nDocs; ++i) {
bulk.insert({a: i});
}
assert.commandWorked(bulk.execute());
print("Bulk insert " + nDocs + " documents completed");
};
insertDocs(t, 20000);
const p = startParallelShell(function() {
// Wait until the remove operation (below) begins running.
while (db.jstests_removeb.count() === 20000) {
}
// Insert documents with increasing 'a' values. These inserted documents may
// reuse Records freed by the remove operation in progress and will be
// visited by the remove operation if it has not completed.
for (let i = 20000; i < 40000; i += 100) {
const bulk = db.jstests_removeb.initializeUnorderedBulkOp();
for (let j = 0; j < 100; ++j) {
bulk.insert({a: i + j});
}
assert.commandWorked(bulk.execute());
if (i % 1000 === 0) {
print(i - 20000 + " of second set of 20000 documents inserted");
}
}
});
// Remove using the a:1 index in ascending direction.
var res = t.remove({a: {$gte: 0}});
assert(!res.hasWriteError(), 'The remove operation failed.');
p();
t.drop();
})();
|
