PerActivityStateCPUUsageSampler.cpp [plain text]
#include "config.h"
#include "PerActivityStateCPUUsageSampler.h"
#include "Logging.h"
#include "WebProcessPool.h"
#include "WebProcessProxy.h"
#include <WebCore/DiagnosticLoggingKeys.h>
#include <wtf/DecimalNumber.h>
namespace WebKit {
static const int64_t microsecondsPerSecond = 1000000;
using namespace WebCore;
static const std::chrono::minutes loggingInterval { 60 };
PerActivityStateCPUUsageSampler::PerActivityStateCPUUsageSampler(WebProcessPool& processPool)
: m_processPool(processPool)
, m_loggingTimer(RunLoop::main(), this, &PerActivityStateCPUUsageSampler::loggingTimerFired)
{
m_lastCPUTime = monotonicallyIncreasingTime();
m_loggingTimer.startRepeating(loggingInterval);
}
PerActivityStateCPUUsageSampler::~PerActivityStateCPUUsageSampler()
{
}
void PerActivityStateCPUUsageSampler::reportWebContentCPUTime(int64_t cpuTime, ActivityStateForCPUSampling activityState)
{
auto result = m_cpuTimeInActivityState.add(activityState, cpuTime);
if (!result.isNewEntry)
result.iterator->value += cpuTime;
}
static inline String loggingKeyForActivityState(ActivityStateForCPUSampling state)
{
switch (state) {
case ActivityStateForCPUSampling::NonVisible:
return DiagnosticLoggingKeys::nonVisibleStateKey();
case ActivityStateForCPUSampling::VisibleNonActive:
return DiagnosticLoggingKeys::visibleNonActiveStateKey();
case ActivityStateForCPUSampling::VisibleAndActive:
return DiagnosticLoggingKeys::visibleAndActiveStateKey();
}
}
static String toStringRoundingSignificantFigures(double value, unsigned significantFigures)
{
DecimalNumber decimal(value, RoundingSignificantFigures, significantFigures);
NumberToLStringBuffer buffer;
unsigned length = decimal.toStringDecimal(buffer, WTF::NumberToStringBufferLength);
return String(buffer, length);
}
void PerActivityStateCPUUsageSampler::loggingTimerFired()
{
auto* page = pageForLogging();
if (!page) {
m_cpuTimeInActivityState.clear();
return;
}
double currentCPUTime = monotonicallyIncreasingTime();
int64_t cpuTimeDelta = (currentCPUTime - m_lastCPUTime) * microsecondsPerSecond;
for (auto& pair : m_cpuTimeInActivityState) {
double cpuUsage = static_cast<double>(pair.value * 100.) / cpuTimeDelta;
String activityStateKey = loggingKeyForActivityState(pair.key);
page->logDiagnosticMessageWithValue(DiagnosticLoggingKeys::cpuUsageKey(), activityStateKey, toStringRoundingSignificantFigures(cpuUsage, 2), false);
RELEASE_LOG(PerformanceLogging, "WebContent processes used %.1f%% CPU in %s state", cpuUsage, activityStateKey.utf8().data());
}
m_cpuTimeInActivityState.clear();
m_lastCPUTime = currentCPUTime;
}
WebPageProxy* PerActivityStateCPUUsageSampler::pageForLogging() const
{
for (auto& webProcess : m_processPool.processes()) {
if (!webProcess->pageCount())
continue;
return *webProcess->pages().begin();
}
return nullptr;
}
}