commit 300f2f6f39716385d311669cd09710bf2770be51
author Austin Schuh <austin.linux@gmail.com> Mon May 27 13:49:23 2019 -0700
committer Austin Schuh <austin.linux@gmail.com> Wed May 29 20:45:44 2019 -0700
tree db5713a3e24d073d3624c0e2eeea063e8d587ddb
parent 01a9f2aada8524f2e3ebd39dd561fa939717d602

Convert vision_status to event loops

Change-Id: I06c329f3fe42d2dbfa7da90d598c93eacdf746c7

y2018/vision/vision_status.cc

diff --git a/y2018/vision/vision_status.cc b/y2018/vision/vision_status.cc
index cfdae2e..3d3faf5 100644
--- a/y2018/vision/vision_status.cc
+++ b/y2018/vision/vision_status.cc
@@ -1,9 +1,10 @@
 #include <netdb.h>
 
+#include "aos/events/shm-event-loop.h"
+#include "aos/init.h"
 #include "aos/logging/logging.h"
 #include "aos/logging/queue_logging.h"
 #include "aos/time/time.h"
-#include "aos/init.h"
 #include "aos/vision/events/udp.h"
 #include "y2018/vision.pb.h"
 #include "y2018/vision/vision.q.h"
@@ -17,12 +18,16 @@
   ::aos::events::RXUdpSocket video_rx(5001);
   char data[65507];
   ::y2018::VisionStatus status;
+  ::aos::ShmEventLoop event_loop;
+  ::aos::Sender<::y2018::vision::VisionStatus> vision_status_sender_ =
+      event_loop.MakeSender<::y2018::vision::VisionStatus>(
+          ".y2018.vision.vision_status");
 
   while (true) {
     const ssize_t rx_size = video_rx.Recv(data, sizeof(data));
     if (rx_size > 0) {
       status.ParseFromArray(data, rx_size);
-      auto new_vision_status = vision_status.MakeMessage();
+      auto new_vision_status = vision_status_sender_.MakeMessage();
       new_vision_status->high_frame_count = status.high_frame_count();
       new_vision_status->low_frame_count = status.low_frame_count();
       LOG_STRUCT(DEBUG, "vision", *new_vision_status);