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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
/**
* Copyright (C) 2020-present MongoDB, Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details.
*
* You should have received a copy of the Server Side Public License
* along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>.
*
* As a special exception, the copyright holders give permission to link the
* code of portions of this program with the OpenSSL library under certain
* conditions as described in each individual source file and distribute
* linked combinations including the program with the OpenSSL library. You
* must comply with the Server Side Public License in all respects for
* all of the code used other than as permitted herein. If you modify file(s)
* with this exception, you may extend this exception to your version of the
* file(s), but you are not obligated to do so. If you do not wish to do so,
* delete this exception statement from your version. If you delete this
* exception statement from all source files in the program, then also delete
* it in the license file.
*/
#define MONGO_LOGV2_DEFAULT_COMPONENT ::mongo::logv2::LogComponent::kStorage
#include "mongo/platform/basic.h"
#include "mongo/dbtests/storage_debug_util.h"
#include "mongo/db/catalog/validate_results.h"
#include "mongo/db/db_raii.h"
#include "mongo/db/index/index_access_method.h"
#include "mongo/db/storage/key_string.h"
#include "mongo/logv2/log.h"
namespace mongo {
namespace StorageDebugUtil {
void printCollectionAndIndexTableEntries(OperationContext* opCtx, const NamespaceString& nss) {
invariant(!opCtx->lockState()->isLocked());
AutoGetCollection coll(opCtx, nss, MODE_IS);
LOGV2(51807, "Dumping collection table and index tables' entries for debugging...");
// Iterate and print the collection table (record store) documents.
RecordStore* rs = coll->getRecordStore();
auto rsCursor = rs->getCursor(opCtx);
boost::optional<Record> rec = rsCursor->next();
LOGV2(51808, "[Debugging] Collection table entries:");
while (rec) {
LOGV2(51809,
"[Debugging](record) {record_id}, Value: {record_data}",
"record_id"_attr = rec->id,
"record_data"_attr = rec->data.toBson());
rec = rsCursor->next();
}
// Iterate and print each index's table of documents.
const auto indexCatalog = coll->getIndexCatalog();
const auto it = indexCatalog->getIndexIterator(opCtx, /*includeUnfinished*/ false);
while (it->more()) {
const auto indexCatalogEntry = it->next();
const auto indexDescriptor = indexCatalogEntry->descriptor();
const auto iam = indexCatalogEntry->accessMethod();
auto indexCursor = iam->newCursor(opCtx, /*forward*/ true);
const BSONObj& keyPattern = indexDescriptor->keyPattern();
const KeyString::Version version = iam->getSortedDataInterface()->getKeyStringVersion();
const auto ordering = Ordering::make(keyPattern);
KeyString::Builder firstKeyString(
version, BSONObj(), ordering, KeyString::Discriminator::kExclusiveBefore);
LOGV2(51810,
"[Debugging] {keyPattern_str} index table entries:",
"keyPattern_str"_attr = keyPattern);
for (auto keyStringEntry = indexCursor->seekForKeyString(firstKeyString.getValueCopy());
keyStringEntry;
keyStringEntry = indexCursor->nextKeyString()) {
auto keyString = KeyString::toBsonSafe(keyStringEntry->keyString.getBuffer(),
keyStringEntry->keyString.getSize(),
ordering,
keyStringEntry->keyString.getTypeBits());
KeyString::logKeyString(keyStringEntry->loc,
keyStringEntry->keyString,
keyPattern,
keyString,
"[Debugging](index)");
}
}
}
void printValidateResults(const ValidateResults& results) {
BSONObjBuilder resultObj;
results.appendToResultObj(&resultObj, /*debugging=*/true);
LOGV2(51812, "Results", "results"_attr = resultObj.done());
}
} // namespace StorageDebugUtil
} // namespace mongo
|
