From eb06c935326aa36be5852b3bdc2c9a024df3aaca Mon Sep 17 00:00:00 2001 From: levlam Date: Wed, 30 Aug 2023 18:13:35 +0300 Subject: [PATCH] Simplify NetQuery creation. --- td/telegram/net/NetQuery.cpp | 8 +++----- td/telegram/net/NetQuery.h | 8 ++++---- td/telegram/net/NetQueryCreator.cpp | 5 ++--- 3 files changed, 9 insertions(+), 12 deletions(-) diff --git a/td/telegram/net/NetQuery.cpp b/td/telegram/net/NetQuery.cpp index f757df143..d77360a7f 100644 --- a/td/telegram/net/NetQuery.cpp +++ b/td/telegram/net/NetQuery.cpp @@ -34,10 +34,9 @@ void NetQuery::debug(string state, bool may_be_lost) { } } -NetQuery::NetQuery(State state, uint64 id, BufferSlice &&query, BufferSlice &&answer, DcId dc_id, Type type, - AuthFlag auth_flag, GzipFlag gzip_flag, int32 tl_constructor, int32 total_timeout_limit, - NetQueryStats *stats, vector chain_ids) - : state_(state) +NetQuery::NetQuery(uint64 id, BufferSlice &&query, DcId dc_id, Type type, AuthFlag auth_flag, GzipFlag gzip_flag, + int32 tl_constructor, int32 total_timeout_limit, NetQueryStats *stats, vector chain_ids) + : state_(State::Query) , type_(type) , auth_flag_(auth_flag) , gzip_flag_(gzip_flag) @@ -45,7 +44,6 @@ NetQuery::NetQuery(State state, uint64 id, BufferSlice &&query, BufferSlice &&an , status_() , id_(id) , query_(std::move(query)) - , answer_(std::move(answer)) , tl_constructor_(tl_constructor) , total_timeout_limit_(total_timeout_limit) { CHECK(id_ != 0); diff --git a/td/telegram/net/NetQuery.h b/td/telegram/net/NetQuery.h index 9f9bde2c0..6035e7900 100644 --- a/td/telegram/net/NetQuery.h +++ b/td/telegram/net/NetQuery.h @@ -46,10 +46,11 @@ class NetQueryCallback : public Actor { }; class NetQuery final : public TsListNode { + enum class State : int8 { Empty, Query, OK, Error }; + public: NetQuery() = default; - enum class State : int8 { Empty, Query, OK, Error }; enum class Type : int8 { Common, Upload, Download, DownloadSmall }; enum class AuthFlag : int8 { Off, On }; enum class GzipFlag : int8 { Off, On }; @@ -343,9 +344,8 @@ class NetQuery final : public TsListNode { Promise<> quick_ack_promise_; // for Session and to be set by caller bool need_resend_on_503_ = true; // for NetQueryDispatcher and to be set by caller - NetQuery(State state, uint64 id, BufferSlice &&query, BufferSlice &&answer, DcId dc_id, Type type, AuthFlag auth_flag, - GzipFlag gzip_flag, int32 tl_constructor, int32 total_timeout_limit, NetQueryStats *stats, - vector chain_ids); + NetQuery(uint64 id, BufferSlice &&query, DcId dc_id, Type type, AuthFlag auth_flag, GzipFlag gzip_flag, + int32 tl_constructor, int32 total_timeout_limit, NetQueryStats *stats, vector chain_ids); }; inline StringBuilder &operator<<(StringBuilder &stream, const NetQuery &net_query) { diff --git a/td/telegram/net/NetQueryCreator.cpp b/td/telegram/net/NetQueryCreator.cpp index 1b45bdfaa..38c59968a 100644 --- a/td/telegram/net/NetQueryCreator.cpp +++ b/td/telegram/net/NetQueryCreator.cpp @@ -81,9 +81,8 @@ NetQueryPtr NetQueryCreator::create(uint64 id, const telegram_api::Function &fun } } - auto query = - object_pool_.create(NetQuery::State::Query, id, std::move(slice), BufferSlice(), dc_id, type, auth_flag, - gzip_flag, tl_constructor, total_timeout_limit, net_query_stats_.get(), std::move(chain_ids)); + auto query = object_pool_.create(id, std::move(slice), dc_id, type, auth_flag, gzip_flag, tl_constructor, + total_timeout_limit, net_query_stats_.get(), std::move(chain_ids)); query->set_cancellation_token(query.generation()); return query; }