ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-01-06 19:24:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx-chk: refine output (bootid, steady/weak, kv-kind).

Browse Source 
Change-Id: Ia2474f7bb9a25adf761a561d0704362dca930796
This commit is contained in:
Leonid Yuriev 2020-09-26 01:50:11 +03:00
parent 6eaa838e3e
commit 5d582b1b3a
1 changed files with 51 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
src/mdbx_chk.c
View File

@ -120,9 +120,9 @@ static void MDBX_PRINTF_ARGS(1, 2) print(const char *msg, ...) {
static void va_log(MDBX_log_level_t level, const char *msg, va_list args) { static void va_log(MDBX_log_level_t level, const char *msg, va_list args) {
static const char *const prefixes[] = { static const char *const prefixes[] = {
"!!!fatal: ", " ! " /* error */, " ~ " /* warning */, "!!!fatal: ", " ! " /* error */, " ~ " /* warning */,
" " /* notice */, " //" /* verbose */, " ///" /* debug */, " " /* notice */, " // " /* verbose */, " //// " /* debug */,
" ////" /* trace */ " ////// " /* trace */
}; };
FILE *out = stdout; FILE *out = stdout;
@ -703,7 +703,7 @@ static int process_db(MDBX_dbi dbi_handle, char *dbi_name, visitor *handler,
} }
if (!silent && verbose) { if (!silent && verbose) {
print(" - key-value kind: %s => %s", db_flags2keymode(flags), print(" - key-value kind: %s-key => %s-value", db_flags2keymode(flags),
db_flags2valuemode(flags)); db_flags2valuemode(flags));
if (verbose > 1) { if (verbose > 1) {
print(", flags:"); print(", flags:");
@ -893,23 +893,12 @@ static void usage(char *prog) {
exit(EXIT_INTERRUPTED); exit(EXIT_INTERRUPTED);
} }
const char *meta_synctype(uint64_t sign) {
switch (sign) {
case MDBX_DATASIGN_NONE:
return "no-sync/legacy";
case MDBX_DATASIGN_WEAK:
return "weak";
default:
return "steady";
}
}
static __inline bool meta_ot(txnid_t txn_a, uint64_t sign_a, txnid_t txn_b, static __inline bool meta_ot(txnid_t txn_a, uint64_t sign_a, txnid_t txn_b,
uint64_t sign_b, const bool roolback2steady) { uint64_t sign_b, const bool wanna_steady) {
if (txn_a == txn_b) if (txn_a == txn_b)
return SIGN_IS_STEADY(sign_b); return SIGN_IS_STEADY(sign_b);
if (roolback2steady && SIGN_IS_STEADY(sign_a) != SIGN_IS_STEADY(sign_b)) if (wanna_steady && SIGN_IS_STEADY(sign_a) != SIGN_IS_STEADY(sign_b))
return SIGN_IS_STEADY(sign_b); return SIGN_IS_STEADY(sign_b);
return txn_a < txn_b; return txn_a < txn_b;
@ -926,72 +915,73 @@ static __inline bool meta_eq(txnid_t txn_a, uint64_t sign_a, txnid_t txn_b,
return true; return true;
} }
static __inline int meta_recent(const bool roolback2steady) { static __inline int meta_recent(const bool wanna_steady) {
if (meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign, if (meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign,
envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, roolback2steady)) envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, wanna_steady))
return meta_ot(envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, return meta_ot(envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign,
envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, wanna_steady)
roolback2steady)
? 1 ? 1
: 2; : 2;
else
return meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign, return meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign,
envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, roolback2steady) envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, wanna_steady)
? 2 ? 2
: 0; : 0;
} }
static __inline int meta_tail(int head) { static __inline int meta_tail(int head) {
switch (head) {
if (head == 0) case 0:
return meta_ot(envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, return meta_ot(envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign,
envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, true) envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, true)
? 1 ? 1
: 2; : 2;
if (head == 1) case 1:
return meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign, return meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign,
envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, true) envinfo.mi_meta2_txnid, envinfo.mi_meta2_sign, true)
? 0 ? 0
: 2; : 2;
if (head == 2) case 2:
return meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign, return meta_ot(envinfo.mi_meta0_txnid, envinfo.mi_meta0_sign,
envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, true) envinfo.mi_meta1_txnid, envinfo.mi_meta1_sign, true)
? 0 ? 0
: 1; : 1;
assert(false); default:
return -1; assert(false);
return -1;
}
} }
static int meta_steady(void) { return meta_recent(true); }
static int meta_head(void) { return meta_recent(false); } static int meta_head(void) { return meta_recent(false); }
void verbose_meta(int num, txnid_t txnid, uint64_t sign, uint64_t bootid_x, void verbose_meta(int num, txnid_t txnid, uint64_t sign, uint64_t bootid_x,
uint64_t bootid_y) { uint64_t bootid_y) {
print(" - meta-%d: %s %" PRIu64, num, meta_synctype(sign), txnid); const bool have_bootid = (bootid_x | bootid_y) != 0;
bool stay = true;
const bool bootid_match = bootid_x == envinfo.mi_bootid.current.x && const bool bootid_match = bootid_x == envinfo.mi_bootid.current.x &&
bootid_y == envinfo.mi_bootid.current.y && bootid_y == envinfo.mi_bootid.current.y;
(bootid_x | bootid_y) != 0;
print(" - meta-%d: ", num);
switch (sign) {
case MDBX_DATASIGN_NONE:
print("no-sync/legacy");
break;
case MDBX_DATASIGN_WEAK:
print("weak-%s", bootid_match ? (have_bootid ? "intact (same boot-id)"
: "unknown (no boot-id")
: "dead");
break;
default:
print("steady");
break;
}
print(" txn#%" PRIu64, txnid);
const int steady = meta_steady();
const int head = meta_head(); const int head = meta_head();
if (num == steady && num == head) { if (num == head)
print(", head"); print(", head");
stay = false; else if (num == meta_tail(head))
} else if (num == steady) {
print(", head-steady");
stay = false;
} else if (num == head) {
print(", head-weak%s", bootid_match ? "-intact (same boot-id)" : "");
stay = false;
}
if (num == meta_tail(head)) {
print(", tail"); print(", tail");
stay = false; else
}
if (stay)
print(", stay"); print(", stay");
if (stuck_meta >= 0) { if (stuck_meta >= 0) {
@ -1243,6 +1233,14 @@ int main(int argc, char *argv[]) {
error("mdbx_env_info failed, error %d %s\n", rc, mdbx_strerror(rc)); error("mdbx_env_info failed, error %d %s\n", rc, mdbx_strerror(rc));
goto bailout; goto bailout;
} }
if (verbose) {
print(" - current boot-id ");
if (envinfo.mi_bootid.current.x | envinfo.mi_bootid.current.y)
print("%016" PRIx64 "-%016" PRIx64 "\n", envinfo.mi_bootid.current.x,
envinfo.mi_bootid.current.y);
else
print("unavailable\n");
}
rc = mdbx_env_stat_ex(env, txn, &envstat, sizeof(envstat)); rc = mdbx_env_stat_ex(env, txn, &envstat, sizeof(envstat));
if (rc) { if (rc) {