Expose time to on_logged_period in the AOS logger
This lets us know what time the logger just finished writing so we can
use that info in any callbacks.
Change-Id: Ic94f6bc60a9270111d5d5e2327dbadd85e8e01f5
Signed-off-by: James Kuszmaul <james.kuszmaul@bluerivertech.com>
diff --git a/aos/events/logging/multinode_logger_test.cc b/aos/events/logging/multinode_logger_test.cc
index 677fc72..f010466 100644
--- a/aos/events/logging/multinode_logger_test.cc
+++ b/aos/events/logging/multinode_logger_test.cc
@@ -3016,13 +3016,14 @@
StartLogger(&pi1_logger);
aos::monotonic_clock::time_point last_rotation_time =
pi1_logger.event_loop->monotonic_now();
- pi1_logger.logger->set_on_logged_period([&] {
- const auto now = pi1_logger.event_loop->monotonic_now();
- if (now > last_rotation_time + std::chrono::seconds(5)) {
- pi1_logger.logger->Rotate();
- last_rotation_time = now;
- }
- });
+ pi1_logger.logger->set_on_logged_period(
+ [&](aos::monotonic_clock::time_point) {
+ const auto now = pi1_logger.event_loop->monotonic_now();
+ if (now > last_rotation_time + std::chrono::seconds(5)) {
+ pi1_logger.logger->Rotate();
+ last_rotation_time = now;
+ }
+ });
event_loop_factory_.RunFor(chrono::milliseconds(10000));
}
@@ -4216,18 +4217,19 @@
StartLogger(&pi1_logger, logfile_base1_);
aos::monotonic_clock::time_point last_rotation_time =
pi1_logger.event_loop->monotonic_now();
- pi1_logger.logger->set_on_logged_period([&] {
- const auto now = pi1_logger.event_loop->monotonic_now();
- if (now > last_rotation_time + std::chrono::seconds(5)) {
- pi1_logger.AppendAllFilenames(&filenames);
- std::unique_ptr<MultiNodeFilesLogNamer> namer =
- pi1_logger.MakeLogNamer(logfile_base2_);
- pi1_logger.log_namer = namer.get();
+ pi1_logger.logger->set_on_logged_period(
+ [&](aos::monotonic_clock::time_point) {
+ const auto now = pi1_logger.event_loop->monotonic_now();
+ if (now > last_rotation_time + std::chrono::seconds(5)) {
+ pi1_logger.AppendAllFilenames(&filenames);
+ std::unique_ptr<MultiNodeFilesLogNamer> namer =
+ pi1_logger.MakeLogNamer(logfile_base2_);
+ pi1_logger.log_namer = namer.get();
- pi1_logger.logger->RestartLogging(std::move(namer));
- last_rotation_time = now;
- }
- });
+ pi1_logger.logger->RestartLogging(std::move(namer));
+ last_rotation_time = now;
+ }
+ });
event_loop_factory_.RunFor(chrono::milliseconds(7000));