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

Delete unneded refs from set_typing_query_.

Browse Source
This commit is contained in:
levlam 2021-09-17 12:33:59 +03:00
parent a0c234a468
commit d3e8029533
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
td/telegram/MessagesManager.cpp
View File

@ -3687,6 +3687,7 @@ class SendScreenshotNotificationQuery final : public Td::ResultHandler {
class SetTypingQuery final : public Td::ResultHandler {
Promise<Unit> promise_;
DialogId dialog_id_;
int32 generation_ = 0;
public:
explicit SetTypingQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
@ -3704,6 +3705,7 @@ class SetTypingQuery final : public Td::ResultHandler {
auto net_query = G()->net_query_creator().create(telegram_api::messages_setTyping(
flags, std::move(input_peer), message_id.get_server_message_id().get(), std::move(action)));
auto result = net_query.get_weak();
generation_ = result.generation();
send_query(std::move(net_query));
return result;
}
@ -3715,8 +3717,9 @@ class SetTypingQuery final : public Td::ResultHandler {
}
// ignore result
promise_.set_value(Unit());
send_closure_later(G()->messages_manager(), &MessagesManager::after_set_typing_query, dialog_id_, generation_);
}
void on_error(uint64 id, Status status) final {
@ -3728,6 +3731,8 @@ class SetTypingQuery final : public Td::ResultHandler {
LOG(INFO) << "Receive error for set typing: " << status;
}
promise_.set_error(std::move(status));
send_closure_later(G()->messages_manager(), &MessagesManager::after_set_typing_query, dialog_id_, generation_);
}
};
@ -30604,6 +30609,14 @@ void MessagesManager::send_dialog_action(DialogId dialog_id, MessageId top_threa
->send(dialog_id, std::move(input_peer), top_thread_message_id, action.get_input_send_message_action());
}
void MessagesManager::after_set_typing_query(DialogId dialog_id, int32 generation) {
auto it = set_typing_query_.find(dialog_id);
CHECK(it != set_typing_query_.end());
if (!it->second.is_alive() || it->second.generation() == generation) {
set_typing_query_.erase(it);
}
}
void MessagesManager::on_send_dialog_action_timeout(DialogId dialog_id) {
LOG(INFO) << "Receive send_chat_action timeout in " << dialog_id;
Dialog *d = get_dialog(dialog_id);

2
td/telegram/MessagesManager.h
View File

@ -467,6 +467,8 @@ class MessagesManager final : public Actor {
void send_dialog_action(DialogId dialog_id, MessageId top_thread_message_id, DialogAction action,
Promise<Unit> &&promise);
void after_set_typing_query(DialogId dialog_id, int32 generation);
vector<DialogListId> get_dialog_lists_to_add_dialog(DialogId dialog_id);
void add_dialog_to_list(DialogId dialog_id, DialogListId dialog_list_id, Promise<Unit> &&promise);