19#include "cyber/proto/record.pb.h"
28using ::apollo::cyber::record::RecordMessage;
29using ::apollo::cyber::record::RecordReader;
30using ::apollo::cyber::record::RecordWriter;
42 writer.SetSizeOfFileSegmentation(0);
43 writer.SetIntervalOfFileSegmentation(0);
44 writer.Open(writefile);
46 for (uint32_t i = 0; i < 100; ++i) {
47 auto msg = std::make_shared<RawMessage>(
"abc" + std::to_string(i));
54 RecordReader reader(readfile);
55 RecordMessage message;
63 for (i = 0; i < msg_count; ++i) {
64 if (reader.ReadMessage(&message)) {
65 AINFO <<
"msg[" << i <<
"]-> "
66 <<
"channel name: " << message.channel_name
67 <<
"; content: " << message.content
68 <<
"; msg time: " << message.time;
71 AERROR <<
"read msg[" << i <<
"] failed";
74 AINFO <<
"static msg=================";
75 AINFO <<
"MSG validmsg:totalcount: " << valid <<
":" << msg_count;
78int main(
int argc,
char *argv[]) {
bool Init(const char *binary_name, const std::string &dag_info)
int main(int argc, char *argv[])
const char CHANNEL_NAME_1[]
const char MESSAGE_TYPE_1[]
const char CHANNEL_NAME_2[]
void test_read(const std::string &readfile)
void test_write(const std::string &writefile)
const char MESSAGE_TYPE_2[]