From 2d22f4d13ea1fd3d856203ceed0a885f33edd884 Mon Sep 17 00:00:00 2001 From: levlam Date: Wed, 10 Jun 2020 01:38:00 +0300 Subject: [PATCH] Minor improvements. GitOrigin-RevId: e86b66d0cd5b78a02ce401c40a2c2fffc1bb5a3c --- td/telegram/net/NetQuery.cpp | 16 ++++++++-------- td/telegram/net/NetQuery.h | 4 ++-- td/telegram/net/Session.cpp | 10 +++++----- tdutils/test/List.cpp | 2 ++ 4 files changed, 17 insertions(+), 15 deletions(-) diff --git a/td/telegram/net/NetQuery.cpp b/td/telegram/net/NetQuery.cpp index 2e817e542..ccb78df28 100644 --- a/td/telegram/net/NetQuery.cpp +++ b/td/telegram/net/NetQuery.cpp @@ -77,14 +77,14 @@ void dump_pending_network_queries() { LOG(WARNING) << "..."; was_gap = false; } - auto nq = &cur->get_data_unsafe(); - LOG(WARNING) << tag("id", nq->my_id_) << *static_cast(cur) - << /*tag("total_flood", format::as_time(nq->total_timeout_)) <<*/ " " - << tag("since start", format::as_time(Time::now_cached() - nq->start_timestamp_)) - << tag("state", nq->debug_str_) - << tag("since state", format::as_time(Time::now_cached() - nq->debug_timestamp_)) - << tag("resend_cnt", nq->debug_resend_cnt_) << tag("fail_cnt", nq->debug_send_failed_cnt_) - << tag("ack", nq->debug_ack) << tag("unknown", nq->debug_unknown); + const NetQueryDebug &debug = cur->get_data_unsafe(); + LOG(WARNING) << tag("id", debug.my_id_) << *static_cast(cur) + << /*tag("total_flood", format::as_time(debug.total_timeout_)) <<*/ " " + << tag("since start", format::as_time(Time::now_cached() - debug.start_timestamp_)) + << tag("state", debug.debug_str_) + << tag("since state", format::as_time(Time::now_cached() - debug.debug_timestamp_)) + << tag("resend_cnt", debug.debug_resend_cnt_) << tag("fail_cnt", debug.debug_send_failed_cnt_) + << tag("ack", debug.debug_ack_) << tag("unknown", debug.debug_unknown_); } else { was_gap = true; } diff --git a/td/telegram/net/NetQuery.h b/td/telegram/net/NetQuery.h index 091d4b4ce..4505380a0 100644 --- a/td/telegram/net/NetQuery.h +++ b/td/telegram/net/NetQuery.h @@ -48,8 +48,8 @@ struct NetQueryDebug { double debug_timestamp_ = 0; int32 debug_cnt_ = 0; int32 debug_send_failed_cnt_ = 0; - int debug_ack = 0; - bool debug_unknown = false; + int debug_ack_ = 0; + bool debug_unknown_ = false; }; extern TsList net_query_list_; diff --git a/td/telegram/net/Session.cpp b/td/telegram/net/Session.cpp index 7c5663b48..b72c203d4 100644 --- a/td/telegram/net/Session.cpp +++ b/td/telegram/net/Session.cpp @@ -619,7 +619,7 @@ void Session::on_message_ack_impl_inner(uint64 id, int32 type, bool in_container it->second.ack = true; { auto lock = it->second.query->lock(); - it->second.query->get_data_unsafe().debug_ack |= type; + it->second.query->get_data_unsafe().debug_ack_ |= type; } it->second.query->quick_ack_promise_.set_value(Unit()); if (!in_container) { @@ -657,7 +657,7 @@ void Session::cleanup_container(uint64 message_id, Query *query) { void Session::mark_as_known(uint64 id, Query *query) { { auto lock = query->query->lock(); - query->query->get_data_unsafe().debug_unknown = false; + query->query->get_data_unsafe().debug_unknown_ = false; } if (!query->unknown) { return; @@ -673,7 +673,7 @@ void Session::mark_as_known(uint64 id, Query *query) { void Session::mark_as_unknown(uint64 id, Query *query) { { auto lock = query->query->lock(); - query->query->get_data_unsafe().debug_unknown = true; + query->query->get_data_unsafe().debug_unknown_ = true; } if (query->unknown) { return; @@ -941,8 +941,8 @@ void Session::connection_send_query(ConnectionInfo *info, NetQueryPtr &&net_quer LOG_CHECK(sent_queries_.find(message_id) == sent_queries_.end()) << message_id; { auto lock = net_query->lock(); - net_query->get_data_unsafe().debug_unknown = false; - net_query->get_data_unsafe().debug_ack = 0; + net_query->get_data_unsafe().debug_unknown_ = false; + net_query->get_data_unsafe().debug_ack_ = 0; } if (!net_query->cancel_slot_.empty()) { LOG(DEBUG) << "Set event for net_query cancellation " << tag("message_id", format::as_hex(message_id)); diff --git a/tdutils/test/List.cpp b/tdutils/test/List.cpp index f39ce98dc..5056d5f83 100644 --- a/tdutils/test/List.cpp +++ b/tdutils/test/List.cpp @@ -6,12 +6,14 @@ // #include "td/utils/common.h" #include "td/utils/List.h" +#include "td/utils/port/thread.h" #include "td/utils/Random.h" #include "td/utils/tests.h" #include "td/utils/TsList.h" #include #include +#include struct Data { td::uint64 value{0};