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

SequenceDispatcher: bugfixes

Browse Source
This commit is contained in:
Arseny Smirnov 2022-02-01 17:05:23 +03:00
parent da4d6318fc
commit 7c9d698023
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
td/telegram/SequenceDispatcher.cpp
View File

@ -314,7 +314,7 @@ class MultiSequenceDispatcherNewImpl final : public MultiSequenceDispatcherNew {
bool check_timeout(TaskId task_id) {
auto &node = *scheduler_.get_task_extra(task_id);
NetQueryPtr &net_query = node.net_query;
if (net_query->is_ready()) {
if (net_query.empty() || net_query->is_ready()) {
return false;
}
net_query->total_timeout_ += node.total_timeout;
@ -340,9 +340,9 @@ class MultiSequenceDispatcherNewImpl final : public MultiSequenceDispatcherNew {
auto tl_constructor = query->tl_constructor();
scheduler_.for_each_dependent(task_id, [&](TaskId child_task_id) {
auto &child_node = *scheduler_.get_task_extra(child_task_id);
if (node.net_query_ref->tl_constructor() == tl_constructor) {
node.total_timeout += query->last_timeout_;
node.last_timeout = query->last_timeout_;
if (child_node.net_query_ref->tl_constructor() == tl_constructor) {
child_node.total_timeout += query->last_timeout_;
child_node.last_timeout = query->last_timeout_;
to_check_timeout.push_back(child_task_id);
}
});

2
td/telegram/SequenceDispatcher.h
View File

@ -100,6 +100,6 @@ class MultiSequenceDispatcherNew : public NetQueryCallback {
static ActorOwn<MultiSequenceDispatcherNew> create(Slice name);
};
using MultiSequenceDispatcher = MultiSequenceDispatcherOld;
using MultiSequenceDispatcher = MultiSequenceDispatcherNew;
} // namespace td

2
tdutils/td/utils/ChainScheduler.h
View File

@ -17,6 +17,7 @@
#include <functional>
#include <map>
#include <set>
namespace td {
@ -342,6 +343,7 @@ void ChainScheduler<ExtraT>::pause_task(TaskId task_id) {
CHECK(task);
inactivate_task(task_id, true);
task->state = Task::State::Paused;
flush_try_start_task();
}
template <class ExtraT>