WebSQLiteDatabaseTracker.cpp [plain text]
#include "config.h"
#include "WebSQLiteDatabaseTracker.h"
#include "NetworkProcess.h"
#include "NetworkProcessProxyMessages.h"
#include "WebProcess.h"
#include "WebProcessProxyMessages.h"
#include <WebCore/SQLiteDatabaseTracker.h>
namespace WebKit {
using namespace WebCore;
WebSQLiteDatabaseTracker::WebSQLiteDatabaseTracker(IsHoldingLockedFilesHandler&& isHoldingLockedFilesHandler)
: m_isHoldingLockedFilesHandler(WTFMove(isHoldingLockedFilesHandler))
, m_hysteresis([this](PAL::HysteresisState state) { setIsHoldingLockedFiles(state == PAL::HysteresisState::Started); })
{
ASSERT(RunLoop::isMain());
SQLiteDatabaseTracker::setClient(this);
}
WebSQLiteDatabaseTracker::~WebSQLiteDatabaseTracker()
{
ASSERT(RunLoop::isMain());
SQLiteDatabaseTracker::setClient(nullptr);
if (m_hysteresis.state() == PAL::HysteresisState::Started)
setIsHoldingLockedFiles(false);
}
void WebSQLiteDatabaseTracker::setIsSuspended(bool isSuspended)
{
ASSERT(RunLoop::isMain());
m_isSuspended = isSuspended;
}
void WebSQLiteDatabaseTracker::willBeginFirstTransaction()
{
RunLoop::main().dispatch([weakThis = makeWeakPtr(*this)] {
if (weakThis)
weakThis->m_hysteresis.start();
});
}
void WebSQLiteDatabaseTracker::didFinishLastTransaction()
{
RunLoop::main().dispatch([weakThis = makeWeakPtr(*this)] {
if (weakThis)
weakThis->m_hysteresis.stop();
});
}
void WebSQLiteDatabaseTracker::setIsHoldingLockedFiles(bool isHoldingLockedFiles)
{
ASSERT(RunLoop::isMain());
if (m_isSuspended)
return;
m_isHoldingLockedFilesHandler(isHoldingLockedFiles);
}
}