| Austin Schuh | 6b9c415 | 2019-11-29 12:45:24 -0800 | [diff] [blame^] | 1 | #include "aos/events/pong_lib.h" |
| 2 | |
| 3 | #include "aos/events/event_loop.h" |
| 4 | #include "aos/events/pong_generated.h" |
| 5 | #include "aos/events/ping_generated.h" |
| 6 | #include "glog/logging.h" |
| 7 | |
| 8 | namespace aos { |
| 9 | |
| 10 | Pong::Pong(EventLoop *event_loop) |
| 11 | : event_loop_(event_loop), |
| 12 | sender_(event_loop_->MakeSender<examples::Pong>("/test")) { |
| 13 | event_loop_->MakeWatcher("/test", [this](const examples::Ping &ping) { |
| 14 | aos::Sender<examples::Pong>::Builder msg = sender_.MakeBuilder(); |
| 15 | examples::Pong::Builder builder = msg.MakeBuilder<examples::Pong>(); |
| 16 | builder.add_value(ping.value()); |
| 17 | builder.add_initial_send_time(ping.send_time()); |
| 18 | CHECK(msg.Send(builder.Finish())); |
| 19 | }); |
| 20 | |
| 21 | event_loop_->SetRuntimeRealtimePriority(5); |
| 22 | } |
| 23 | |
| 24 | } // namespace aos |