41 const std::string& restored_output_dir);
51 bool GetNextValidRecord(std::string* record_path)
const;
52 void RestoreMessage(
const uint64_t message_time);
54 const std::string& message)
const;
55 void ProcessRestoreRecord(
const std::string& record_path);
56 double GetDuration(
const std::string& record_file);
58 std::shared_ptr<cyber::record::Recorder> recorder_ =
nullptr;
59 std::shared_ptr<cyber::Node> smart_recorder_node_ =
nullptr;
60 std::shared_ptr<cyber::Writer<SmartRecorderStatus>> recorder_status_writer_ =
62 std::vector<std::string> record_files_;
63 std::string default_output_filename_;
64 std::string restore_path_;
65 uint32_t reused_record_num_ = 0;
66 uint64_t restore_reader_time_ = 0;
67 double max_backward_time_ = 30.0;
68 double min_restore_chunk_ = 5.0;
69 bool is_terminating_ =
false;
70 const int recorder_wait_time_ = 5000;