ResponsivenessTimer.cpp [plain text]
#include "config.h"
#include "ResponsivenessTimer.h"
namespace WebKit {
static const Seconds responsivenessTimeout { 3_s };
ResponsivenessTimer::ResponsivenessTimer(ResponsivenessTimer::Client& client)
: m_client(client)
, m_timer(RunLoop::main(), this, &ResponsivenessTimer::timerFired)
{
}
ResponsivenessTimer::~ResponsivenessTimer() = default;
void ResponsivenessTimer::invalidate()
{
m_timer.stop();
m_restartFireTime = MonotonicTime();
m_waitingForTimer = false;
m_useLazyStop = false;
}
void ResponsivenessTimer::timerFired()
{
if (!m_waitingForTimer)
return;
if (m_restartFireTime) {
MonotonicTime now = MonotonicTime::now();
MonotonicTime restartFireTime = m_restartFireTime;
m_restartFireTime = MonotonicTime();
if (restartFireTime > now) {
m_timer.startOneShot(restartFireTime - now);
return;
}
}
m_waitingForTimer = false;
m_useLazyStop = false;
if (!m_isResponsive)
return;
auto protectedClient = makeRef(m_client);
if (!m_client.mayBecomeUnresponsive()) {
m_waitingForTimer = true;
m_timer.startOneShot(responsivenessTimeout);
return;
}
m_client.willChangeIsResponsive();
m_isResponsive = false;
m_client.didChangeIsResponsive();
m_client.didBecomeUnresponsive();
}
void ResponsivenessTimer::start()
{
if (m_waitingForTimer)
return;
m_waitingForTimer = true;
m_useLazyStop = false;
if (m_timer.isActive()) {
m_restartFireTime = MonotonicTime::now() + responsivenessTimeout;
} else {
m_restartFireTime = MonotonicTime();
m_timer.startOneShot(responsivenessTimeout);
}
}
void ResponsivenessTimer::startWithLazyStop()
{
if (!m_waitingForTimer) {
start();
m_useLazyStop = true;
}
}
void ResponsivenessTimer::stop()
{
if (!m_isResponsive) {
auto protectedClient = makeRef(m_client);
m_client.willChangeIsResponsive();
m_isResponsive = true;
m_client.didChangeIsResponsive();
m_client.didBecomeResponsive();
}
m_waitingForTimer = false;
if (m_useLazyStop)
m_useLazyStop = false;
else
m_timer.stop();
}
void ResponsivenessTimer::processTerminated()
{
invalidate();
}
}