#include "config.h"
#include "VNodeTracker.h"
#include "Logging.h"
#include <wtf/NeverDestroyed.h>
#include <wtf/RunLoop.h>
namespace WebCore {
VNodeTracker& VNodeTracker::singleton()
{
static NeverDestroyed<VNodeTracker> vnodeTracker;
return vnodeTracker;
}
VNodeTracker::VNodeTracker()
: m_pressureWarningTimer(*this, &VNodeTracker::pressureWarningTimerFired)
, m_lastWarningTime(std::chrono::steady_clock::now())
{
platformInitialize();
LOG(MemoryPressure, "Using following vnode limits for this process: soft=%u, hard=%u", m_softVNodeLimit, m_hardVNodeLimit);
}
void VNodeTracker::checkPressureState()
{
ASSERT(m_pressureHandler);
if (m_vnodeCounter.value() <= m_softVNodeLimit)
return;
if (!m_pressureWarningTimer.isActive())
m_pressureWarningTimer.startOneShot(nextPressureWarningInterval());
}
void VNodeTracker::pressureWarningTimerFired()
{
if (m_vnodeCounter.value() <= m_softVNodeLimit)
return;
m_lastWarningTime = std::chrono::steady_clock::now();
unsigned vnodeCount = m_vnodeCounter.value();
auto critical = vnodeCount > m_hardVNodeLimit ? Critical::Yes : Critical::No;
m_pressureHandler(critical);
LOG(MemoryPressure, "vnode pressure handler freed %d vnodes out of %u (critical pressure: %s)", vnodeCount - m_vnodeCounter.value(), vnodeCount, critical == Critical::Yes ? "Yes" : "No");
}
std::chrono::milliseconds VNodeTracker::nextPressureWarningInterval() const
{
static const auto minimumWarningInterval = std::chrono::seconds { 30 };
auto timeSinceLastWarning = std::chrono::steady_clock::now() - m_lastWarningTime;
if (timeSinceLastWarning < minimumWarningInterval)
return std::chrono::duration_cast<std::chrono::milliseconds>(minimumWarningInterval - timeSinceLastWarning);
return std::chrono::milliseconds { 0 };
}
#if !PLATFORM(COCOA)
void VNodeTracker::platformInitialize()
{
}
#endif
}