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

Improve logging on too old update.

Browse Source
This commit is contained in:
levlam 2021-08-22 13:16:10 +03:00
parent e66ee3eeae
commit 7faf7aeba7
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
td/mtproto/SessionConnection.cpp
View File

@ -304,8 +304,7 @@ Status SessionConnection::on_packet(const MsgInfo &info, uint64 req_msg_id, cons
if (req_msg_id != 0) { if (req_msg_id != 0) {
callback_->on_message_result_error(req_msg_id, rpc_error.error_code_, rpc_error.error_message_.str()); callback_->on_message_result_error(req_msg_id, rpc_error.error_code_, rpc_error.error_message_.str());
} else { } else {
LOG(ERROR) << "Receive rpc_error as update: [" << rpc_error.error_code_ << "][" << rpc_error.error_message_ LOG(ERROR) << "Receive rpc_error as update: [" << rpc_error.error_code_ << "][" << rpc_error.error_message_ << "]";
<< "]";
} }
return Status::OK(); return Status::OK();
} }
@ -499,12 +498,15 @@ Status SessionConnection::on_slice_packet(const MsgInfo &info, Slice packet) {
auto status = auth_data_->check_update(info.message_id); auto status = auth_data_->check_update(info.message_id);
if (status.is_error()) { if (status.is_error()) {
if (status.code() == 2) { if (status.code() == 2) {
LOG(WARNING) << "Receive too old update: " << status; LOG(WARNING) << "Receive too old update from " << get_name() << " created in " << (Time::now() - created_at_)
<< " in container " << container_id_ << " from session " << auth_data_->get_session_id()
<< " with message_id " << info.message_id << ", main_message_id = " << main_message_id_
<< ", seq_no = " << info.seq_no << " and original size " << info.size << ": " << status;
callback_->on_session_failed(Status::Error("Receive too old update")); callback_->on_session_failed(Status::Error("Receive too old update"));
return status; return status;
} }
VLOG(mtproto) << "Skip update " << info.message_id << " from " << get_name() << " created in " VLOG(mtproto) << "Skip update " << info.message_id << " of size " << info.size << " with seq_no " << info.seq_no
<< (Time::now() - created_at_) << ": " << status; << " from " << get_name() << " created in " << (Time::now() - created_at_) << ": " << status;
return Status::OK(); return Status::OK();
} else { } else {
VLOG(mtproto) << "Got update from " << get_name() << " created in " << (Time::now() - created_at_) VLOG(mtproto) << "Got update from " << get_name() << " created in " << (Time::now() - created_at_)