mirror of
https://github.com/matrix-construct/construct
synced 2024-06-02 10:08:56 +02:00
ircd::db::env: Add debuglog msg for job queued.
ircd::db::env: Create a dedicated logger. ircd::db::env: Improve debuglog msgs.
This commit is contained in:
parent
4dc114bf94
commit
e9c42b7c63
|
@ -11,6 +11,12 @@
|
|||
#include <RB_INC_FCNTL_H
|
||||
#include "db.h"
|
||||
|
||||
decltype(ircd::db::database::env::log)
|
||||
ircd::db::database::env::log
|
||||
{
|
||||
"db.env"
|
||||
};
|
||||
|
||||
//
|
||||
// env::env
|
||||
//
|
||||
|
@ -4064,6 +4070,18 @@ ircd::db::database::env::state::pool::operator()(task &&task)
|
|||
assert(task._id == 0);
|
||||
task._id = ++taskctr;
|
||||
tasks.emplace_back(std::move(task));
|
||||
|
||||
log::debug
|
||||
{
|
||||
log, "'%s': pool:%s queue:%zu QUEUE task:%lu func:%p arg:%p",
|
||||
this->d.name,
|
||||
ctx::name(p),
|
||||
tasks.size(),
|
||||
tasks.back()._id,
|
||||
tasks.back().func,
|
||||
tasks.back().arg,
|
||||
};
|
||||
|
||||
p([this]
|
||||
{
|
||||
if(tasks.empty())
|
||||
|
@ -4075,7 +4093,7 @@ ircd::db::database::env::state::pool::operator()(task &&task)
|
|||
|
||||
log::debug
|
||||
{
|
||||
log, "'%s': pool:%s queue:%zu starting task:%lu func:%p arg:%p",
|
||||
log, "'%s': pool:%s queue:%zu ENTER task:%lu func:%p arg:%p",
|
||||
this->d.name,
|
||||
ctx::name(p),
|
||||
tasks.size(),
|
||||
|
@ -4097,7 +4115,7 @@ ircd::db::database::env::state::pool::operator()(task &&task)
|
|||
|
||||
log::debug
|
||||
{
|
||||
log, "'%s': pool:%s queue:%zu finished task:%zu func:%p arg:%p",
|
||||
log, "'%s': pool:%s queue:%zu LEAVE task:%zu func:%p arg:%p",
|
||||
this->d.name,
|
||||
ctx::name(p),
|
||||
tasks.size(),
|
||||
|
|
|
@ -34,6 +34,8 @@ struct ircd::db::database::env final
|
|||
using ThreadStatus = rocksdb::ThreadStatus;
|
||||
using ThreadStatusUpdater = rocksdb::ThreadStatusUpdater;
|
||||
|
||||
static ircd::log::log log;
|
||||
|
||||
database &d;
|
||||
Env &defaults
|
||||
{
|
||||
|
|
Loading…
Reference in a new issue