MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-29 20:28:52 +02:00
Code Issues Releases Wiki Activity

ircd::db: Additional compaction log related.

Browse source
This commit is contained in:
Jason Volk 2020-09-16 09:44:22 -07:00
parent 0675a621f1
commit bd3d34adb2
1 changed files with 20 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
ircd/db.cc
View file

@ -2935,9 +2935,9 @@ ircd::db::database::events::OnFlushBegin(rocksdb::DB *const db,
const rocksdb::FlushJobInfo &info) const rocksdb::FlushJobInfo &info)
noexcept noexcept
{ {
log::info log::debug
{ {
log, "[%s] job:%d ctx:%lu flush start '%s' :%s", log, "[%s] job:%d ctx:%lu flushed start '%s' :%s",
d->name, d->name,
info.job_id, info.job_id,
info.thread_id, info.thread_id,
@ -2956,7 +2956,7 @@ noexcept
char pbuf[2][48]; char pbuf[2][48];
log::info log::info
{ {
log, "[%s] job:%d ctx:%lu flush ended seq[%lu -> %lu] idxs:%lu blks:%lu keys:%lu deletes:%lu data[%s] '%s' `%s'", log, "[%s] job:%d ctx:%lu flushed seq[%lu -> %lu] idxs:%lu blks:%lu keys:%lu deletes:%lu data[%s] '%s' `%s'",
d->name, d->name,
info.job_id, info.job_id,
info.thread_id, info.thread_id,
@ -2986,13 +2986,23 @@ noexcept
log::level::ERROR log::level::ERROR
}; };
char prebuf[128];
const string_view prefix
{
fmt::sprintf
{
prebuf, "[%s] job:%d ctx:%lu compact",
d->name,
info.job_id,
info.thread_id,
}
};
log::logf log::logf
{ {
log, level, log, level,
"[%s] job:%d ctx:%lu compct done level[%d -> %d] files[%zu -> %zu] %s '%s' (%d): %s", "%s lev[%d -> %d] files[%zu -> %zu] %s '%s' (%d): %s",
d->name, prefix,
info.job_id,
info.thread_id,
info.base_input_level, info.base_input_level,
info.output_level, info.output_level,
info.input_files.size(), info.input_files.size(),
@ -3010,12 +3020,10 @@ noexcept
char pbuf[8][48]; char pbuf[8][48];
size_t i(0); size_t i(0);
log::logf log::info
{ {
log, log::level::DEBUG, log, "%s key[%zu -> %zu (%zu)] %s -> %s | falloc:%s write:%s rsync:%s fsync:%s total:%s",
"[%s] job:%d compacted keys[in:%zu out:%zu upd:%zu] bytes[%s -> %s] falloc:%s write:%s rsync:%s fsync:%s total:%s", prefix,
d->name,
info.job_id,
info.stats.num_input_records, info.stats.num_input_records,
info.stats.num_output_records, info.stats.num_output_records,
info.stats.num_records_replaced, info.stats.num_records_replaced,