void
BeesReporter::start()
{
- // One thread per active report stanza, named "report_<section>". Each
+ // One thread per active report stanza, named "rep_<section>". Each
// thread owns a single report and just sleeps for its interval between
// writes, so a report whose target filesystem stalls blocks only its
// own thread, not the others. (A stuck target was already reachable
if (!m_reports[i].active || m_reports[i].filename.empty()) {
continue;
}
- auto thread = make_shared<BeesThread>("report_" + m_reports[i].name);
+ auto thread = make_shared<BeesThread>("rep_" + m_reports[i].name);
thread->exec([this, i]() {
catch_all([this, i]() {
run_one(i);
while (true) {
catch_all([&]() {
BEESNOTE("writing report '" << cfg.name << "'");
+ BEESTRACE("writing report '" << cfg.name << "'");
write_report(cfg);
});
unique_lock<mutex> lock(m_mutex);
+ BEESNOTE("waiting " << cfg.interval_s << "s to write report '" << cfg.name << "'");
if (m_condvar.wait_for(lock, interval, [this]() { return m_stop; })) {
break;
}