DownloadMonitor.cpp [plain text]
#include "config.h"
#include "DownloadMonitor.h"
#include "Download.h"
#include "Logging.h"
#undef RELEASE_LOG_IF_ALLOWED
#define RELEASE_LOG_IF_ALLOWED(fmt, ...) RELEASE_LOG_IF(m_download.isAlwaysOnLoggingAllowed(), Network, "%p - DownloadMonitor::" fmt, this, ##__VA_ARGS__)
namespace WebKit {
constexpr uint64_t operator"" _kbps(unsigned long long kilobytesPerSecond)
{
return kilobytesPerSecond * 1024;
}
struct ThroughputInterval {
Seconds time;
uint64_t bytesPerSecond;
};
static const ThroughputInterval throughputIntervals[] = {
{ 1_min, 1_kbps },
{ 5_min, 2_kbps },
{ 10_min, 4_kbps },
{ 15_min, 8_kbps },
{ 20_min, 16_kbps },
{ 25_min, 32_kbps },
{ 30_min, 64_kbps },
{ 45_min, 96_kbps },
{ 60_min, 128_kbps }
};
static Seconds timeUntilNextInterval(size_t currentInterval)
{
RELEASE_ASSERT(currentInterval + 1 < WTF_ARRAY_LENGTH(throughputIntervals));
return throughputIntervals[currentInterval + 1].time - throughputIntervals[currentInterval].time;
}
DownloadMonitor::DownloadMonitor(Download& download)
: m_download(download)
{
}
double DownloadMonitor::measuredThroughputRate() const
{
uint64_t bytes { 0 };
for (const auto& timestamp : m_timestamps)
bytes += timestamp.bytesReceived;
if (!bytes)
return 0;
ASSERT(!m_timestamps.isEmpty());
Seconds timeDifference = m_timestamps.last().time.secondsSinceEpoch() - m_timestamps.first().time.secondsSinceEpoch();
double seconds = timeDifference.seconds();
if (!seconds)
return 0;
return bytes / seconds;
}
void DownloadMonitor::downloadReceivedBytes(uint64_t bytesReceived)
{
if (m_timestamps.size() > timestampCapacity - 1) {
ASSERT(m_timestamps.size() == timestampCapacity);
m_timestamps.removeFirst();
}
m_timestamps.append({ MonotonicTime::now(), bytesReceived });
}
void DownloadMonitor::applicationWillEnterForeground()
{
RELEASE_LOG_IF_ALLOWED("applicationWillEnterForeground (id = %" PRIu64 ")", m_download.downloadID().toUInt64());
m_timer.stop();
m_interval = 0;
}
void DownloadMonitor::applicationDidEnterBackground()
{
RELEASE_LOG_IF_ALLOWED("applicationDidEnterBackground (id = %" PRIu64 ")", m_download.downloadID().toUInt64());
ASSERT(!m_timer.isActive());
ASSERT(!m_interval);
m_timer.startOneShot(throughputIntervals[0].time / testSpeedMultiplier());
}
uint32_t DownloadMonitor::testSpeedMultiplier() const
{
return m_download.testSpeedMultiplier();
}
void DownloadMonitor::timerFired()
{
downloadReceivedBytes(0);
RELEASE_ASSERT(m_interval < WTF_ARRAY_LENGTH(throughputIntervals));
if (measuredThroughputRate() < throughputIntervals[m_interval].bytesPerSecond) {
RELEASE_LOG_IF_ALLOWED("timerFired: cancelling download (id = %" PRIu64 ")", m_download.downloadID().toUInt64());
m_download.cancel([](auto&) { }, Download::IgnoreDidFailCallback::No);
} else if (m_interval + 1 < WTF_ARRAY_LENGTH(throughputIntervals)) {
RELEASE_LOG_IF_ALLOWED("timerFired: sufficient throughput rate (id = %" PRIu64 ")", m_download.downloadID().toUInt64());
m_timer.startOneShot(timeUntilNextInterval(m_interval++) / testSpeedMultiplier());
} else
RELEASE_LOG_IF_ALLOWED("timerFired: Download reached threshold to not be terminated (id = %" PRIu64 ")", m_download.downloadID().toUInt64());
}
}