Skip to content

Commit 4f27402

Browse files
pengweisongpengweisong
committed
add more table in meta dump
1 parent ce21b2d commit 4f27402

File tree

2 files changed

+84
-13
lines changed

2 files changed

+84
-13
lines changed

‎src/common/utils/MetaKeyUtils.cpp

+4-1
Original file line numberDiff line numberDiff line change
@@ -1247,7 +1247,10 @@ GraphSpaceID MetaKeyUtils::parseLocalIdSpace(folly::StringPiece rawData) {
12471247
}
12481248

12491249
/**
1250-
* diskPartsKey = kDiskPartsTable + len(serialized(hostAddr)) + serialized(hostAddr) + path
1250+
* diskPartsKey = kDiskPartsTable +
1251+
* len(serialized(hostAddr)) + serialized(hostAddr) +
1252+
* space id +
1253+
* disk path
12511254
*/
12521255

12531256
HostAddr MetaKeyUtils::parseDiskPartsHost(const folly::StringPiece& rawData) {

‎src/tools/meta-dump/MetaDumpTool.cpp

+80-12
Original file line numberDiff line numberDiff line change
@@ -31,10 +31,12 @@ class MetaDumper {
3131
if (!iter) {
3232
return Status::Error("Init iterator failed");
3333
}
34+
3435
std::string prefix;
3536
{
36-
LOG(INFO) << "Space info";
37-
prefix = "__spaces__";
37+
LOG(INFO) << "------------------------------------------\n\n";
38+
LOG(INFO) << "Space info:";
39+
prefix = MetaKeyUtils::spacePrefix();
3840
iter->Seek(rocksdb::Slice(prefix));
3941
while (iter->Valid() && iter->key().starts_with(prefix)) {
4042
auto key = folly::StringPiece(iter->key().data(), iter->key().size());
@@ -52,8 +54,9 @@ class MetaDumper {
5254
}
5355
}
5456
{
55-
LOG(INFO) << "Partition info";
56-
prefix = "__parts__";
57+
LOG(INFO) << "------------------------------------------\n\n";
58+
LOG(INFO) << "Partition info::";
59+
prefix = MetaKeyUtils::partPrefix();
5760
iter->Seek(rocksdb::Slice(prefix));
5861
while (iter->Valid() && iter->key().starts_with(prefix)) {
5962
auto key = folly::StringPiece(iter->key().data(), iter->key().size());
@@ -71,8 +74,21 @@ class MetaDumper {
7174
}
7275
}
7376
{
74-
LOG(INFO) << "Host info";
75-
prefix = "__hosts__";
77+
LOG(INFO) << "------------------------------------------\n\n";
78+
LOG(INFO) << "Registered machine info:";
79+
prefix = MetaKeyUtils::machinePrefix();
80+
iter->Seek(rocksdb::Slice(prefix));
81+
while (iter->Valid() && iter->key().starts_with(prefix)) {
82+
auto key = folly::StringPiece(iter->key().data(), iter->key().size());
83+
auto machine = MetaKeyUtils::parseMachineKey(key);
84+
LOG(INFO) << folly::sformat("registered machine: {}", machine.toString());
85+
iter->Next();
86+
}
87+
}
88+
{
89+
LOG(INFO) << "------------------------------------------\n\n";
90+
LOG(INFO) << "Host info:";
91+
prefix = MetaKeyUtils::hostPrefix();
7692
iter->Seek(rocksdb::Slice(prefix));
7793
while (iter->Valid() && iter->key().starts_with(prefix)) {
7894
auto key = folly::StringPiece(iter->key().data(), iter->key().size());
@@ -87,7 +103,55 @@ class MetaDumper {
87103
}
88104
}
89105
{
90-
LOG(INFO) << "Tag info";
106+
LOG(INFO) << "------------------------------------------\n\n";
107+
LOG(INFO) << "Host directories info:";
108+
prefix = MetaKeyUtils::hostDirPrefix();
109+
iter->Seek(rocksdb::Slice(prefix));
110+
while (iter->Valid() && iter->key().starts_with(prefix)) {
111+
auto key = folly::StringPiece(iter->key().data(), iter->key().size());
112+
auto val = folly::StringPiece(iter->value().data(), iter->value().size());
113+
auto addr = MetaKeyUtils::parseHostDirKey(key);
114+
auto dir = MetaKeyUtils::parseHostDir(val);
115+
116+
std::string dataDirs = "";
117+
for (auto d : dir.get_data()) {
118+
dataDirs += d + ", ";
119+
}
120+
LOG(INFO) << folly::sformat("host addr: {}, data dirs: {}, root dir: {}",
121+
addr.toString(),
122+
dataDirs,
123+
dir.get_root());
124+
iter->Next();
125+
}
126+
}
127+
{
128+
LOG(INFO) << "------------------------------------------\n\n";
129+
LOG(INFO) << "Disk partitions info:";
130+
prefix = MetaKeyUtils::diskPartsPrefix();
131+
iter->Seek(rocksdb::Slice(prefix));
132+
while (iter->Valid() && iter->key().starts_with(prefix)) {
133+
auto key = folly::StringPiece(iter->key().data(), iter->key().size());
134+
auto val = folly::StringPiece(iter->value().data(), iter->value().size());
135+
auto addr = MetaKeyUtils::parseDiskPartsHost(key);
136+
auto spaceId = MetaKeyUtils::parseDiskPartsSpace(key);
137+
auto diskPath = MetaKeyUtils::parseDiskPartsPath(key);
138+
auto parts = MetaKeyUtils::parseDiskPartsVal(val);
139+
140+
std::string partsStr = "";
141+
for (auto p : parts.get_part_list()) {
142+
partsStr += (std::to_string(p) + ", ");
143+
}
144+
LOG(INFO) << folly::sformat("host addr: {}, data dir: {}, space id: {}, parts: {}",
145+
addr.toString(),
146+
diskPath,
147+
spaceId,
148+
partsStr);
149+
iter->Next();
150+
}
151+
}
152+
{
153+
LOG(INFO) << "------------------------------------------\n\n";
154+
LOG(INFO) << "Tag info:";
91155
prefix = "__tags__";
92156
iter->Seek(rocksdb::Slice(prefix));
93157
while (iter->Valid() && iter->key().starts_with(prefix)) {
@@ -100,7 +164,8 @@ class MetaDumper {
100164
}
101165
}
102166
{
103-
LOG(INFO) << "Edge info";
167+
LOG(INFO) << "------------------------------------------\n\n";
168+
LOG(INFO) << "Edge info:";
104169
prefix = "__edges__";
105170
iter->Seek(rocksdb::Slice(prefix));
106171
while (iter->Valid() && iter->key().starts_with(prefix)) {
@@ -113,7 +178,8 @@ class MetaDumper {
113178
}
114179
}
115180
{
116-
LOG(INFO) << "Index info";
181+
LOG(INFO) << "------------------------------------------\n\n";
182+
LOG(INFO) << "Index info:";
117183
prefix = "__indexes__";
118184
iter->Seek(rocksdb::Slice(prefix));
119185
while (iter->Valid() && iter->key().starts_with(prefix)) {
@@ -125,7 +191,8 @@ class MetaDumper {
125191
}
126192
}
127193
{
128-
LOG(INFO) << "Leader info";
194+
LOG(INFO) << "------------------------------------------\n\n";
195+
LOG(INFO) << "Leader info:";
129196
prefix = "__leader_terms__";
130197
HostAddr host;
131198
TermID term;
@@ -152,8 +219,9 @@ class MetaDumper {
152219
}
153220
}
154221
{
155-
LOG(INFO) << "Zone info";
156-
prefix = "__zones__";
222+
LOG(INFO) << "------------------------------------------\n\n";
223+
LOG(INFO) << "Zone info:";
224+
prefix = MetaKeyUtils::zonePrefix();
157225
iter->Seek(rocksdb::Slice(prefix));
158226
while (iter->Valid() && iter->key().starts_with(prefix)) {
159227
auto key = folly::StringPiece(iter->key().data(), iter->key().size());

0 commit comments

Comments
 (0)