commit 98360e205391122df3d9f986bb99c6836dff88d4
author Brian Silverman <bsilver16384@gmail.com> Tue Apr 28 16:51:20 2020 -0700
committer Brian Silverman <bsilver16384@gmail.com> Tue Apr 28 16:58:43 2020 -0700
tree b445878c3595a42035d26999e9ef1f08331af0f4
parent 20f6a905249754e0f7283e79a76182dc6d535db1

Keep track of how many bytes DetachedBufferWriter writes

Change-Id: If7b932934d77b615ae2bf712c58eb24ac3253512

aos/events/logging/logfile_utils.cc

diff --git a/aos/events/logging/logfile_utils.cc b/aos/events/logging/logfile_utils.cc
index 5388df7..d455bf5 100644
--- a/aos/events/logging/logfile_utils.cc
+++ b/aos/events/logging/logfile_utils.cc
@@ -62,6 +62,7 @@
 
   PCHECK(written == static_cast<ssize_t>(n.iov_len))
       << ": Wrote " << written << " expected " << n.iov_len;
+  written_size_ += written;
 }
 
 void DetachedBufferWriter::QueueSizedFlatbuffer(
@@ -96,6 +97,7 @@
 
   PCHECK(written == static_cast<ssize_t>(queued_size_))
       << ": Wrote " << written << " expected " << queued_size_;
+  written_size_ += written;
 
   queued_size_ = 0;
   queue_.clear();
@@ -417,8 +419,7 @@
   bool was_emplaced = false;
   while (true) {
     // Stop if we have enough.
-    if (newest_timestamp() >
-            time_to_queue_ + max_out_of_order_duration() &&
+    if (newest_timestamp() > time_to_queue_ + max_out_of_order_duration() &&
         was_emplaced) {
       VLOG(1) << "Done queueing on " << this << ", queued to "
               << newest_timestamp() << " with requeue time " << time_to_queue_;