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

SequenceDispatcher: calculate session_rand from first chain id

Browse Source
This commit is contained in:
Arseny Smirnov 2022-01-28 17:49:26 +03:00
parent c202974d47
commit cab16967d0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
td/telegram/SequenceDispatcher.cpp
View File

@ -282,6 +282,9 @@ class MultiSequenceDispatcherNewImpl final : public MultiSequenceDispatcherNew {
public: public:
void send_with_callback(NetQueryPtr query, ActorShared<NetQueryCallback> callback, td::Span<uint64> chains) final { void send_with_callback(NetQueryPtr query, ActorShared<NetQueryCallback> callback, td::Span<uint64> chains) final {
CHECK(all_of(chains, [](auto chain_id) {return chain_id != 0;})); CHECK(all_of(chains, [](auto chain_id) {return chain_id != 0;}));
if (!chains.empty()) {
query->set_session_rand(static_cast<uint32>(chains[0] >> 10));
}
Node node; Node node;
node.net_query = std::move(query); node.net_query = std::move(query);
node.net_query->debug("Waiting at SequenceDispatcher"); node.net_query->debug("Waiting at SequenceDispatcher");
@ -368,7 +371,6 @@ class MultiSequenceDispatcherNewImpl final : public MultiSequenceDispatcherNew {
query->last_timeout_ = 0; // TODO: flood query->last_timeout_ = 0; // TODO: flood
VLOG(net_query) << "Send " << query; VLOG(net_query) << "Send " << query;
query->debug("send to Td::send_with_callback"); query->debug("send to Td::send_with_callback");
query->set_session_rand(123); // TODO: chain_rand
G()->net_query_dispatcher().dispatch_with_callback(std::move(query), G()->net_query_dispatcher().dispatch_with_callback(std::move(query),
actor_shared(this, task.task_id)); actor_shared(this, task.task_id));
} }