commit 6f255b27ef4bb73dd795b73ad9c89aa663d3bcd1
author James Kuszmaul <james.kuszmaul@bluerivertech.com> Mon Nov 06 13:46:54 2023 -0800
committer James Kuszmaul <jabukuszmaul+collab@gmail.com> Tue Jan 09 12:36:01 2024 -0800
tree 3eaf5dd17421fbe02f8796f986554af41d6f099a
parent b1c1105b6c9e860a92cdd29e57c6366d3c1be6ba

Convert ping/pong examples to new flatbuffer API

This serves as a demonstration of how to use the new API.

Change-Id: Icfd5c0f77eae456001416a6deb02cb2946d40070
Signed-off-by: James Kuszmaul <james.kuszmaul@bluerivertech.com>

aos/events/ping_lib.cc

diff --git a/aos/events/ping_lib.cc b/aos/events/ping_lib.cc
index 56dde2f..23de0db 100644
--- a/aos/events/ping_lib.cc
+++ b/aos/events/ping_lib.cc
@@ -3,8 +3,8 @@
 #include "gflags/gflags.h"
 #include "glog/logging.h"
 
-#include "aos/events/ping_generated.h"
-#include "aos/events/pong_generated.h"
+#include "aos/events/ping_static.h"
+#include "aos/events/pong_static.h"
 #include "aos/json_to_flatbuffer.h"
 
 DEFINE_int32(sleep_us, 10000, "Time to sleep between pings");
@@ -15,7 +15,7 @@
 
 Ping::Ping(EventLoop *event_loop, std::string_view channel_name)
     : event_loop_(event_loop),
-      sender_(event_loop_->MakeSender<examples::Ping>(channel_name)) {
+      sender_(event_loop_->MakeSender<examples::PingStatic>(channel_name)) {
   timer_handle_ = event_loop_->AddTimer([this]() { SendPing(); });
   timer_handle_->set_name("ping");
 
@@ -38,12 +38,12 @@
                  << FLAGS_sleep_us << "us.";
   }
   ++count_;
-  aos::Sender<examples::Ping>::Builder builder = sender_.MakeBuilder();
-  examples::Ping::Builder ping_builder = builder.MakeBuilder<examples::Ping>();
-  ping_builder.add_value(count_);
-  ping_builder.add_send_time(
-      event_loop_->monotonic_now().time_since_epoch().count());
-  builder.CheckOk(builder.Send(ping_builder.Finish()));
+  aos::Sender<examples::PingStatic>::StaticBuilder builder =
+      sender_.MakeStaticBuilder();
+  examples::PingStatic *ping = builder.get();
+  ping->set_value(count_);
+  ping->set_send_time(event_loop_->monotonic_now().time_since_epoch().count());
+  builder.CheckOk(builder.Send());
   VLOG(2) << "Sending ping";
 }