Add multinode maps and type specific maps.
This lets us do things like remap timing reports per node and handle
them correctly. And also only map the timing reports and not everything
on /aos. This also becomes more interesting when AOS_LOG logs, and we
have a starter which publishes statistics.
Change-Id: I2147e3b722b472d4480c86e7c8acda938aa3d1d2
diff --git a/aos/events/event_loop.h b/aos/events/event_loop.h
index 4cbb07b..bd0c4d4 100644
--- a/aos/events/event_loop.h
+++ b/aos/events/event_loop.h
@@ -312,8 +312,9 @@
// sent to the provided channel.
template <typename T>
Fetcher<T> MakeFetcher(const std::string_view channel_name) {
- const Channel *channel = configuration::GetChannel(
- configuration_, channel_name, T::GetFullyQualifiedName(), name());
+ const Channel *channel =
+ configuration::GetChannel(configuration_, channel_name,
+ T::GetFullyQualifiedName(), name(), node());
CHECK(channel != nullptr)
<< ": Channel { \"name\": \"" << channel_name << "\", \"type\": \""
<< T::GetFullyQualifiedName() << "\" } not found in config.";
@@ -335,8 +336,9 @@
// the provided channel.
template <typename T>
Sender<T> MakeSender(const std::string_view channel_name) {
- const Channel *channel = configuration::GetChannel(
- configuration_, channel_name, T::GetFullyQualifiedName(), name());
+ const Channel *channel =
+ configuration::GetChannel(configuration_, channel_name,
+ T::GetFullyQualifiedName(), name(), node());
CHECK(channel != nullptr)
<< ": Channel { \"name\": \"" << channel_name << "\", \"type\": \""
<< T::GetFullyQualifiedName() << "\" } not found in config.";