NetworkStateNotifier.cpp [plain text]
#include "config.h"
#include "NetworkStateNotifier.h"
#include <wtf/NeverDestroyed.h>
#if USE(WEB_THREAD)
#include "WebCoreThread.h"
#endif
namespace WebCore {
static const Seconds updateStateSoonInterval { 2_s };
static bool shouldSuppressThreadSafetyCheck()
{
#if USE(WEB_THREAD)
return WebThreadIsEnabled();
#else
return false;
#endif
}
NetworkStateNotifier& NetworkStateNotifier::singleton()
{
RELEASE_ASSERT(shouldSuppressThreadSafetyCheck() || isMainThread());
static NeverDestroyed<NetworkStateNotifier> networkStateNotifier;
return networkStateNotifier;
}
NetworkStateNotifier::NetworkStateNotifier()
: m_updateStateTimer([] {
singleton().updateState();
})
{
}
bool NetworkStateNotifier::onLine()
{
if (!m_isOnLine)
updateState();
return m_isOnLine.valueOr(true);
}
void NetworkStateNotifier::addListener(WTF::Function<void(bool)>&& listener)
{
ASSERT(listener);
if (m_listeners.isEmpty())
startObserving();
m_listeners.append(WTFMove(listener));
}
void NetworkStateNotifier::updateState()
{
auto wasOnLine = m_isOnLine;
updateStateWithoutNotifying();
if (m_isOnLine == wasOnLine)
return;
for (auto& listener : m_listeners)
listener(m_isOnLine.value());
}
void NetworkStateNotifier::updateStateSoon()
{
m_updateStateTimer.startOneShot(updateStateSoonInterval);
}
}