void CheckerComponent::ResultTimerHandler(void)
{
- Log(LogDebug, "checker", "ResultTimerHandler entered.");
-
std::ostringstream msgbuf;
{
msgbuf << "Pending checkables: " << m_PendingCheckables.size() << "; Idle checkables: " << m_IdleCheckables.size() << "; Checks/s: " << CIB::GetActiveChecksStatistics(5) / 5.0;
}
- Log(LogInformation, "checker", msgbuf.str());
+ Log(LogDebug, "checker", msgbuf.str());
}
void CheckerComponent::ObjectHandler(const DynamicObject::Ptr& object)
*/
void StatusDataWriter::StatusTimerHandler(void)
{
- Log(LogInformation, "compat", "Writing status.dat file");
+ double start = Utility::GetTime();
String statuspath = GetStatusPath();
String statuspathtmp = statuspath + ".tmp"; /* XXX make this a global definition */
<< boost::errinfo_file_name(statuspathtmp));
}
- Log(LogInformation, "compat", "Finished writing status.dat file");
+ Log(LogInformation, "compat", "Writing status.dat file took " + Utility::FormatDuration(Utility::GetTime() - start));
}
-
m_Process = pi.hProcess;
m_FD = outReadPipe;
- Log(LogDebug, "base", "Running command '" + m_Arguments +
+ Log(LogInformation, "base", "Running command '" + m_Arguments +
"': PID " + Convert::ToString(pi.dwProcessId));
#else /* _WIN32 */
// parent process
- Log(LogDebug, "base", "Running command '" + boost::algorithm::join(m_Arguments, " ") +
+ Log(LogInformation, "base", "Running command '" + boost::algorithm::join(m_Arguments, " ") +
"': PID " + Convert::ToString(m_Process));
m_Arguments.clear();
<< (long)(total_avg_latency * 1000 / (sizeof(m_Queues) / sizeof(m_Queues[0]))) << "ms"
<< "; Threads: " << total_alive
<< "; Pool utilization: " << (total_utilization / (sizeof(m_Queues) / sizeof(m_Queues[0]))) << "%";
- Log(LogInformation, "base", msgbuf.str());
+ Log(LogDebug, "base", msgbuf.str());
}
}
}
tokens.push_back(Convert::ToString(seconds) + (seconds != 1 ? " seconds" : " second"));
}
+ if (tokens.size() == 0) {
+ int milliseconds = floor(duration * 1000);
+ if (milliseconds >= 1)
+ tokens.push_back(Convert::ToString(milliseconds) + (milliseconds != 1 ? " milliseconds" : " millisecond"));
+ else
+ tokens.push_back("less than 1 millisecond");
+ }
+
return NaturalJoin(tokens);
}
{
boost::mutex::scoped_lock lock(m_Mutex);
- Log(LogInformation, "base", "WQ #" + Convert::ToString(m_ID) + " items: " + Convert::ToString(m_Items.size()));
+ Log(LogDebug, "base", "WQ #" + Convert::ToString(m_ID) + " items: " + Convert::ToString(m_Items.size()));
}
void WorkQueue::WorkerThreadProc(void)