Add NodeEventLoopFactory
This lets us create event loops on separate nodes which can't
communicate with each other. Next step is to add a message proxy
between them, then teach the logger to replay onto multiple nodes.
Change-Id: I06b2836365aea13d696535c52a78ca0c862a7b1e
diff --git a/aos/events/logging/log_cat.cc b/aos/events/logging/log_cat.cc
index 1d1dd8b..80ec8e7 100644
--- a/aos/events/logging/log_cat.cc
+++ b/aos/events/logging/log_cat.cc
@@ -31,7 +31,7 @@
reader.Register();
std::unique_ptr<aos::EventLoop> printer_event_loop =
- reader.event_loop_factory()->MakeEventLoop("printer");
+ reader.event_loop_factory()->MakeEventLoop("printer", reader.node());
printer_event_loop->SkipTimingReport();
bool found_channel = false;
@@ -66,7 +66,7 @@
<< aos::FlatbufferToJson(
channel->schema(),
static_cast<const uint8_t *>(message))
- << '\n';
+ << std::endl;
} else {
std::cout << context.realtime_event_time << " ("
<< context.monotonic_event_time << ") "
@@ -75,7 +75,7 @@
<< aos::FlatbufferToJson(
channel->schema(),
static_cast<const uint8_t *>(message))
- << '\n';
+ << std::endl;
}
});
found_channel = true;