diff --git a/cyber/blocker/intra_reader.h b/cyber/blocker/intra_reader.h index 7336577e7f5..43b94b78e0b 100644 --- a/cyber/blocker/intra_reader.h +++ b/cyber/blocker/intra_reader.h @@ -196,7 +196,7 @@ auto IntraReader::End() const -> Iterator { template void IntraReader::OnMessage(const MessagePtr& msg_ptr) { - this->second_to_lastest_recv_time_sec_ = this->latest_recv_time_sec_; + this->second_to_latest_recv_time_sec_ = this->latest_recv_time_sec_; this->latest_recv_time_sec_ = apollo::cyber::Time::Now().ToSecond(); if (msg_callback_ != nullptr) { msg_callback_(msg_ptr); diff --git a/cyber/node/reader.h b/cyber/node/reader.h index 83f4fb5dcb7..c8f034729c5 100644 --- a/cyber/node/reader.h +++ b/cyber/node/reader.h @@ -208,7 +208,7 @@ class Reader : public ReaderBase { protected: double latest_recv_time_sec_ = -1.0; - double second_to_lastest_recv_time_sec_ = -1.0; + double second_to_latest_recv_time_sec_ = -1.0; uint32_t pending_queue_size_; private: @@ -244,7 +244,7 @@ Reader::~Reader() { template void Reader::Enqueue(const std::shared_ptr& msg) { - second_to_lastest_recv_time_sec_ = latest_recv_time_sec_; + second_to_latest_recv_time_sec_ = latest_recv_time_sec_; latest_recv_time_sec_ = Time::Now().ToSecond(); blocker_->Publish(msg); } @@ -361,11 +361,11 @@ double Reader::GetDelaySec() const { if (latest_recv_time_sec_ < 0) { return -1.0; } - if (second_to_lastest_recv_time_sec_ < 0) { + if (second_to_latest_recv_time_sec_ < 0) { return Time::Now().ToSecond() - latest_recv_time_sec_; } return std::max((Time::Now().ToSecond() - latest_recv_time_sec_), - (latest_recv_time_sec_ - second_to_lastest_recv_time_sec_)); + (latest_recv_time_sec_ - second_to_latest_recv_time_sec_)); } template