VladislavOstapov/terminal-web-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

фикс: бесконечное обновление кеша из-за ошибки в логике цикла обновления

Browse Source
This commit is contained in:
Vladislav Ostapov 2025-05-06 14:37:19 +03:00
parent 9444fc7ebc
commit 17cdd69207
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/terminal_api_driver.cpp
View File

@ -15,6 +15,8 @@
typedef boost::property_tree::ptree::path_type json_path;
static constexpr const char* DEFAULT_QOS_CLASSES = R"({"rt1":[],"rt2":[],"rt3":[],"cd":[]})";
// пороговое значение сна
static constexpr int64_t SLEEP_THRESHOLD = 10;
// static int calculateSubnetMask(const std::string& subnet_mask) {
// int mask = 0;
@ -463,7 +465,7 @@ private:
bool checkNeedUpdate(int64_t now) const {
if (periodMs < 0) return false;
// тут нет смысла спать меньше чем на 20мс, поэтому можно разрешить чтение на некоторое время раньше
return now - lastUpdate >= (periodMs - 20);
return now - lastUpdate >= (periodMs - SLEEP_THRESHOLD);
}
int64_t getNextUpdate(int64_t now) const {
@ -543,18 +545,20 @@ private:
auto now = TIME_NOW();
for (auto& u: updaters) {
if (u.checkNeedUpdate(now)) {
// выравнивание таймингов (-20ms...+50ms)
if (u.lastUpdate + u.periodMs + 50 < now) {
u.lastUpdate += u.periodMs;
auto targetTime = u.lastUpdate + u.periodMs;
if (targetTime + SLEEP_THRESHOLD <= now && targetTime - SLEEP_THRESHOLD >= now) {
u.lastUpdate = targetTime;
} else {
u.lastUpdate = now;
}
u.callback();
now = TIME_NOW();
}
if (u.periodMs >= 0) {
sleepTime = std::min(sleepTime, u.getNextUpdate(now));
}
}
if (sleepTime > 0) {
boost::this_thread::sleep_for(boost::chrono::duration(boost::chrono::milliseconds(sleepTime)));