tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Reload CDN config with each layer change.

Browse Source
This commit is contained in:
levlam 2021-07-09 02:31:42 +03:00
parent 23b0a91e88
commit 0967fe0672
2 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
td/telegram/net/PublicRsaKeyWatchdog.cpp
View File

@ -9,8 +9,8 @@
#include "td/telegram/Global.h" #include "td/telegram/Global.h"
#include "td/telegram/net/NetQueryCreator.h" #include "td/telegram/net/NetQueryCreator.h"
#include "td/telegram/TdDb.h" #include "td/telegram/TdDb.h"
#include "td/telegram/telegram_api.h" #include "td/telegram/telegram_api.h"
#include "td/telegram/Version.h"
#include "td/mtproto/RSA.h" #include "td/mtproto/RSA.h"
@ -47,7 +47,14 @@ void PublicRsaKeyWatchdog::start_up() {
flood_control_.add_limit(2, 60); flood_control_.add_limit(2, 60);
flood_control_.add_limit(3, 2 * 60); flood_control_.add_limit(3, 2 * 60);
sync(BufferSlice(G()->td_db()->get_binlog_pmc()->get("cdn_config"))); string version = G()->td_db()->get_binlog_pmc()->get("cdn_config_version");
current_version_ = to_string(MTPROTO_LAYER);
if (version != current_version_) {
G()->td_db()->get_binlog_pmc()->erase("cdn_config" + version);
} else {
sync(BufferSlice(G()->td_db()->get_binlog_pmc()->get("cdn_config" + version)));
}
CHECK(keys_.empty());
} }
void PublicRsaKeyWatchdog::loop() { void PublicRsaKeyWatchdog::loop() {
@ -84,7 +91,8 @@ void PublicRsaKeyWatchdog::on_result(NetQueryPtr net_query) {
} }
auto buf = net_query->move_as_ok(); auto buf = net_query->move_as_ok();
G()->td_db()->get_binlog_pmc()->set("cdn_config", buf.as_slice().str()); G()->td_db()->get_binlog_pmc()->set("cdn_config_version", current_version_);
G()->td_db()->get_binlog_pmc()->set("cdn_config" + current_version_, buf.as_slice().str());
sync(std::move(buf)); sync(std::move(buf));
} }
@ -100,9 +108,13 @@ void PublicRsaKeyWatchdog::sync(BufferSlice cdn_config_serialized) {
return; return;
} }
cdn_config_ = r_keys.move_as_ok(); cdn_config_ = r_keys.move_as_ok();
LOG(INFO) << "Receive " << to_string(cdn_config_); if (keys_.empty()) {
for (auto &key : keys_) { LOG(INFO) << "Load " << to_string(cdn_config_);
sync_key(key); } else {
LOG(INFO) << "Receive " << to_string(cdn_config_);
for (auto &key : keys_) {
sync_key(key);
}
} }
} }

1
td/telegram/net/PublicRsaKeyWatchdog.h
View File

@ -36,6 +36,7 @@ class PublicRsaKeyWatchdog final : public NetActor {
tl_object_ptr<telegram_api::cdnConfig> cdn_config_; tl_object_ptr<telegram_api::cdnConfig> cdn_config_;
FloodControlStrict flood_control_; FloodControlStrict flood_control_;
bool has_query_{false}; bool has_query_{false};
string current_version_;
void start_up() final; void start_up() final;
void loop() final; void loop() final;