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

Make on_server_pong private.

Browse Source
This commit is contained in:
levlam 2021-01-16 02:59:03 +03:00
parent 7a94cac200
commit 35c4562fc5
2 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
td/telegram/UpdatesManager.cpp
View File

@ -108,7 +108,13 @@ class GetUpdatesStateQuery : public Td::ResultHandler {
};
class PingServerQuery : public Td::ResultHandler {
Promise<tl_object_ptr<telegram_api::updates_state>> promise_;
public:
explicit PingServerQuery(Promise<tl_object_ptr<telegram_api::updates_state>> &&promise)
: promise_(std::move(promise)) {
}
void send() {
send_query(G()->net_query_creator().create(telegram_api::updates_getState()));
}
@ -119,14 +125,11 @@ class PingServerQuery : public Td::ResultHandler {
return on_error(id, result_ptr.move_as_error());
}
auto state = result_ptr.move_as_ok();
CHECK(state->get_id() == telegram_api::updates_state::ID);
td->updates_manager_->on_server_pong(std::move(state));
promise_.set_value(result_ptr.move_as_ok());
}
void on_error(uint64 id, Status status) override {
status.ignore();
td->updates_manager_->on_server_pong(nullptr);
promise_.set_error(std::move(status));
}
};
@ -1135,7 +1138,11 @@ void UpdatesManager::init_state() {
}
void UpdatesManager::ping_server() {
td_->create_handler<PingServerQuery>()->send();
auto promise = PromiseCreator::lambda([](Result<tl_object_ptr<telegram_api::updates_state>> result) {
auto state = result.is_ok() ? result.move_as_ok() : nullptr;
send_closure(G()->updates_manager(), &UpdatesManager::on_server_pong, std::move(state));
});
td_->create_handler<PingServerQuery>(std::move(promise))->send();
}
void UpdatesManager::on_server_pong(tl_object_ptr<telegram_api::updates_state> &&state) {

4
td/telegram/UpdatesManager.h
View File

@ -113,8 +113,6 @@ class UpdatesManager : public Actor {
void ping_server();
void on_server_pong(tl_object_ptr<telegram_api::updates_state> &&state);
bool running_get_difference() const {
return running_get_difference_;
}
@ -225,6 +223,8 @@ class UpdatesManager : public Actor {
void on_get_updates_state(tl_object_ptr<telegram_api::updates_state> &&state, const char *source);
void on_server_pong(tl_object_ptr<telegram_api::updates_state> &&state);
void on_get_difference(tl_object_ptr<telegram_api::updates_Difference> &&difference_ptr);
void process_get_difference_updates(vector<tl_object_ptr<telegram_api::Message>> &&new_messages,