Mirrors/nekoray
1
0
Fork 0
mirror of https://github.com/MatsuriDayo/nekoray.git synced 2025-12-18 13:04:37 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: traffic stats time

Browse Source
This commit is contained in:
arm64v8a
2022-11-16 15:07:10 +09:00
parent 23fe07c351
commit deab99af73
2 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
db/TrafficData.hpp
View File

@@ -13,6 +13,8 @@ namespace NekoRay::traffic {
long long downlink_rate = 0; long long downlink_rate = 0;
long long uplink_rate = 0; long long uplink_rate = 0;
long long last_update;
explicit TrafficData(std::string tag) { explicit TrafficData(std::string tag) {
this->tag = std::move(tag); this->tag = std::move(tag);
_add(new configItem("dl", &downlink, itemType::integer64)); _add(new configItem("dl", &downlink, itemType::integer64));

11
db/TrafficLooper.cpp
View File

@@ -8,11 +8,17 @@
namespace NekoRay::traffic { namespace NekoRay::traffic {
TrafficLooper *trafficLooper = new TrafficLooper; TrafficLooper *trafficLooper = new TrafficLooper;
QElapsedTimer trafficLooper_timer;
std::unique_ptr<TrafficData> TrafficLooper::update_stats(TrafficData *item) { std::unique_ptr<TrafficData> TrafficLooper::update_stats(TrafficData *item) {
#ifndef NKR_NO_GRPC #ifndef NKR_NO_GRPC
auto interval = dataStore->traffic_loop_interval; // last update
if (interval == 0) return nullptr; auto now = trafficLooper_timer.elapsed();
auto interval = now - item->last_update;
item->last_update = now;
if (interval <= 0) return nullptr;
// query
auto uplink = NekoRay::rpc::defaultClient->QueryStats(item->tag, "uplink"); auto uplink = NekoRay::rpc::defaultClient->QueryStats(item->tag, "uplink");
auto downlink = NekoRay::rpc::defaultClient->QueryStats(item->tag, "downlink"); auto downlink = NekoRay::rpc::defaultClient->QueryStats(item->tag, "downlink");
@@ -63,6 +69,7 @@ namespace NekoRay::traffic {
} }
void TrafficLooper::loop() { void TrafficLooper::loop() {
trafficLooper_timer.start();
while (true) { while (true) {
auto sleep_ms = dataStore->traffic_loop_interval; auto sleep_ms = dataStore->traffic_loop_interval;
auto user_disabled = sleep_ms == 0; auto user_disabled = sleep_ms == 0;