提交 b8248942 编写于 作者: A Aaron Xiao 提交者: Calvin Miao

Cyber: Add segmentation args for python record writer.

上级 b1d4b47a
......@@ -108,6 +108,18 @@ class PyRecordReader {
class PyRecordWriter {
public:
PyRecordWriter() {}
PyRecordWriter(const uint64_t file_segmentation_size_kb,
const uint64_t file_segmentation_interval_sec) {
if (file_segmentation_size_kb > 0) {
recored_writer_.SetSizeOfFileSegmentation(file_segmentation_size_kb);
}
if (file_segmentation_interval_sec > 0) {
recored_writer_.SetIntervalOfFileSegmentation(
file_segmentation_interval_sec);
}
}
~PyRecordWriter() {}
bool Open(const std::string& path) { return recored_writer_.Open(path); }
......
......@@ -112,6 +112,11 @@ class RecordWriter(object):
def __init__(self):
self.record_writer = _CYBER_RECORD.new_PyRecordWriter()
def __init__(self, file_segmentation_size_kb,
file_segmentation_interval_sec):
self.record_writer = _CYBER_RECORD.new_PyRecordWriter(
file_segmentation_size_kb, file_segmentation_interval_sec)
def __del__(self):
_CYBER_RECORD.delete_PyRecordWriter(self.record_writer)
......
......@@ -59,6 +59,7 @@ void test_read(const std::string &readfile) {
AINFO << "reader msg count = " << count;
}
int main(int argc, char *argv[]) {
apollo::cyber::Init("cyber_python");
test_write(TEST_RECORD_FILE);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册