Apollo 10.0
自动驾驶开放平台
regular_interval_trigger.cc
浏览该文件的文档.
1/******************************************************************************
2 * Copyright 2019 The Apollo Authors. All Rights Reserved.
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 *****************************************************************************/
16
18
19#include "cyber/common/log.h"
20
21namespace apollo {
22namespace data {
23
27
29 if (!trigger_obj_->enabled()) {
30 return;
31 }
32 if (current_recording_time_ == 0) {
33 current_recording_time_ = msg.time;
34 return;
35 }
36 if (msg.time - current_recording_time_ >
37 SecondsToNanoSeconds(recording_interval_)) {
38 current_recording_time_ = msg.time;
39 AINFO << "regular interval trigger is pulled: " << msg.time;
40 TriggerIt(msg.time);
41 }
42}
43
44} // namespace data
45} // namespace apollo
void Pull(const cyber::record::RecordMessage &msg) override
uint64_t SecondsToNanoSeconds(const double seconds) const
std::unique_ptr< Trigger > trigger_obj_
void TriggerIt(const uint64_t msg_time) const
#define AINFO
Definition log.h:42
class register implement
Definition arena_queue.h:37
Basic data struct of record message.
uint64_t time
The time (nanosecond) of the message.