diff --git a/selfdrive/loggerd/loggerd.cc b/selfdrive/loggerd/loggerd.cc index e747a8ce48..40d414748c 100644 --- a/selfdrive/loggerd/loggerd.cc +++ b/selfdrive/loggerd/loggerd.cc @@ -312,8 +312,7 @@ void encoder_thread(bool is_streaming, bool raw_clips, int cam_idx) { eidx.setSegmentNum(out_segment); eidx.setSegmentId(out_id); - auto words = capnp::messageToFlatArray(msg); - auto bytes = words.asBytes(); + auto bytes = msg.toBytes(); if (idx_sock->send((char*)bytes.begin(), bytes.size()) < 0) { printf("err sending encodeIdx pkt: %s\n", strerror(errno)); @@ -343,8 +342,7 @@ void encoder_thread(bool is_streaming, bool raw_clips, int cam_idx) { eidx.setSegmentNum(out_segment); eidx.setSegmentId(out_id); - auto words = capnp::messageToFlatArray(msg); - auto bytes = words.asBytes(); + auto bytes = msg.toBytes(); if (lh) { lh_log(lh, bytes.begin(), bytes.size(), false); } @@ -518,8 +516,7 @@ static void bootlog() { std::string lastPmsg = util::read_file("/sys/fs/pstore/pmsg-ramoops-0"); boot.setLastPmsg(capnp::Data::Reader((const kj::byte*)lastPmsg.data(), lastPmsg.size())); - auto words = capnp::messageToFlatArray(msg); - auto bytes = words.asBytes(); + auto bytes = msg.toBytes(); logger_log(&s.logger, bytes.begin(), bytes.size(), false); }