blob: d6fb9ec9b8b17f4b9342761d1450c5c9c1350718 (
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
65
66
67
|
/**
* Test that the validate command properly limits the index entry inconsistencies reported when
* there is corruption on an index with a long name.
*
* @tags: [
* requires_persistence,
* requires_wiredtiger,
* ]
*/
(function() {
"use strict";
load("jstests/disk/libs/wt_file_helper.js");
// 64 * 1024 * 1024 = 64MB worth of index names ensures that we test against the maximum BSONObj
// size lmit.
const kNumDocs = 64;
const kIndexNameLength = 1024 * 1024;
const baseName = "validate_with_long_index_name";
const dbpath = MongoRunner.dataPath + baseName + "/";
const indexName = "a".repeat(kIndexNameLength);
let conn = MongoRunner.runMongod({dbpath: dbpath});
let coll = conn.getDB("test").getCollection("corrupt");
function insertDocsAndBuildIndex() {
const bulk = coll.initializeUnorderedBulkOp();
for (let i = 0; i < kNumDocs; i++) {
bulk.insert({_id: i});
}
bulk.execute();
coll.createIndex({a: 1}, {name: indexName});
}
insertDocsAndBuildIndex();
let uri = getUriForIndex(coll, indexName);
conn = truncateUriAndRestartMongod(uri, conn);
coll = conn.getDB("test").getCollection("corrupt");
const missingIndexEntries = "Detected " + kNumDocs + " missing index entries.";
const missingSizeLimitations =
"Not all missing index entry inconsistencies are listed due to size limitations.";
let res = coll.validate();
assert.commandWorked(res);
assert(!res.valid);
assert.contains(missingIndexEntries, res.warnings);
assert.contains(missingSizeLimitations, res.errors);
coll.drop();
insertDocsAndBuildIndex();
uri = getUriForColl(coll);
conn = truncateUriAndRestartMongod(uri, conn);
coll = conn.getDB("test").getCollection("corrupt");
const extraIndexEntries = "Detected " + 2 * kNumDocs + " extra index entries.";
const extraSizeLimitations =
"Not all extra index entry inconsistencies are listed due to size limitations.";
res = coll.validate();
assert.commandWorked(res);
assert(!res.valid);
assert.contains(extraIndexEntries, res.warnings);
assert.contains(extraSizeLimitations, res.errors);
MongoRunner.stopMongod(conn, null, {skipValidation: true});
})();
|