summaryrefslogtreecommitdiff
path: root/protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h
diff options
context:
space:
mode:
Diffstat (limited to 'protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h')
-rw-r--r--protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h15
1 files changed, 7 insertions, 8 deletions
diff --git a/protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h b/protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h
index e67f9fbc93..325196b34c 100644
--- a/protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h
+++ b/protocols/Telegram/tdlib/td/tdnet/td/net/NetStats.h
@@ -1,5 +1,5 @@
//
-// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2018
+// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2022
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
@@ -10,7 +10,6 @@
#include "td/utils/common.h"
#include "td/utils/format.h"
-#include "td/utils/logging.h"
#include "td/utils/StringBuilder.h"
#include "td/utils/Time.h"
@@ -87,12 +86,12 @@ class NetStats {
}
// do it before get_callback
- void set_callback(std::unique_ptr<Callback> callback) {
+ void set_callback(unique_ptr<Callback> callback) {
impl_->set_callback(std::move(callback));
}
private:
- class Impl : public NetStatsCallback {
+ class Impl final : public NetStatsCallback {
public:
NetStatsData get_stats() const {
NetStatsData res;
@@ -102,7 +101,7 @@ class NetStats {
});
return res;
}
- void set_callback(std::unique_ptr<Callback> callback) {
+ void set_callback(unique_ptr<Callback> callback) {
callback_ = std::move(callback);
}
@@ -114,7 +113,7 @@ class NetStats {
std::atomic<uint64> write_size{0};
};
SchedulerLocalStorage<LocalNetStats> local_net_stats_;
- std::unique_ptr<Callback> callback_;
+ unique_ptr<Callback> callback_;
void on_read(uint64 size) final {
auto &stats = local_net_stats_.get();
@@ -131,8 +130,8 @@ class NetStats {
void on_change(LocalNetStats &stats, uint64 size) {
stats.unsync_size += size;
- auto now = Time::now_cached();
- if (stats.unsync_size > 10000 || now - stats.last_update > 5 * 60) {
+ auto now = Time::now();
+ if (stats.unsync_size > 10000 || now - stats.last_update > 300) {
stats.unsync_size = 0;
stats.last_update = now;
callback_->on_stats_updated();