rename event types

Author: Mauro Passerino

rclcpp/include/rclcpp/client.hpp

@@ -160,7 +160,7 @@ class ClientBase
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const;
+    rmw_listener_cb_t executor_callback) const;
 
   RCLCPP_PUBLIC
   void

rclcpp/include/rclcpp/executors/events_executor.hpp

@@ -26,7 +26,7 @@
 #include "rclcpp/executors/timers_manager.hpp"
 #include "rclcpp/node.hpp"
 
-#include "rmw/executor_event_types.h"
+#include "rmw/listener_event_types.h"
 
 namespace rclcpp
 {
@@ -176,13 +176,13 @@ class EventsExecutor : public rclcpp::Executor
 
   // Event queue implementation is a deque only to
   // facilitate the removal of events from expired entities.
-  using EventQueue = std::deque<ExecutorEvent>;
+  using EventQueue = std::deque<rmw_listener_event_t>;
 
   // Executor callback: Push new events into the queue and trigger cv.
   // This function is called by the DDS entities when an event happened,
   // like a subscription receiving a message.
   static void
-  push_event(const void * executor_ptr, ExecutorEvent event)
+  push_event(const void * executor_ptr, rmw_listener_event_t event)
   {
     // Cast executor_ptr to this (need to remove constness)
     auto this_executor = const_cast<executors::EventsExecutor *>(
@@ -217,7 +217,7 @@ class EventsExecutor : public rclcpp::Executor
       event_queue_.erase(
         std::remove_if(
           event_queue_.begin(), event_queue_.end(),
-          [&entity](ExecutorEvent event) {return event.entity == entity;}), event_queue_.end());
+          [&entity](rmw_listener_event_t event) {return event.entity == entity;}), event_queue_.end());
     }
 
     // Remove events associated with this entity from the local event queue
@@ -226,7 +226,7 @@ class EventsExecutor : public rclcpp::Executor
       execution_event_queue_.erase(
         std::remove_if(
           execution_event_queue_.begin(), execution_event_queue_.end(),
-          [&entity](ExecutorEvent event) {
+          [&entity](rmw_listener_event_t event) {
             return event.entity == entity;
           }), execution_event_queue_.end());
     }
@@ -240,7 +240,7 @@ class EventsExecutor : public rclcpp::Executor
   // Execute a single event
   RCLCPP_PUBLIC
   void
-  execute_event(const ExecutorEvent & event);
+  execute_event(const rmw_listener_event_t & event);
 
   // We use two instances of EventQueue to allow threads to push events while we execute them
   EventQueue event_queue_;

rclcpp/include/rclcpp/executors/events_executor_notify_waitable.hpp

@@ -64,7 +64,7 @@ class EventsExecutorNotifyWaitable final : public EventWaitable
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const override
+    rmw_listener_cb_t executor_callback) const override
   {
     for (auto gc : notify_guard_conditions_) {
       rcl_ret_t ret = rcl_guard_condition_set_events_executor_callback(

rclcpp/include/rclcpp/experimental/subscription_intra_process_base.hpp

@@ -74,7 +74,7 @@ class SubscriptionIntraProcessBase : public rclcpp::Waitable
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const override;
+    rmw_listener_cb_t executor_callback) const override;
 
 protected:
   std::recursive_mutex reentrant_mutex_;

rclcpp/include/rclcpp/qos_event.hpp

@@ -110,7 +110,7 @@ class QOSEventHandlerBase : public Waitable
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const override;
+    rmw_listener_cb_t executor_callback) const override;
 
 protected:
   rcl_event_t event_handle_;

rclcpp/include/rclcpp/service.hpp

@@ -130,7 +130,7 @@ class ServiceBase
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const;
+    rmw_listener_cb_t executor_callback) const;
 
   RCLCPP_PUBLIC
   void

rclcpp/include/rclcpp/subscription_base.hpp

@@ -273,7 +273,7 @@ class SubscriptionBase : public std::enable_shared_from_this<SubscriptionBase>
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const;
+    rmw_listener_cb_t executor_callback) const;
 
   RCLCPP_PUBLIC
   void

rclcpp/include/rclcpp/waitable.hpp

@@ -176,7 +176,7 @@ class Waitable
   void
   set_events_executor_callback(
     const rclcpp::executors::EventsExecutor * executor,
-    EventsExecutorCallback executor_callback) const;
+    rmw_listener_cb_t executor_callback) const;
 
   RCLCPP_PUBLIC
   void

rclcpp/src/rclcpp/client.cpp

@@ -205,7 +205,7 @@ ClientBase::exchange_in_use_by_wait_set_state(bool in_use_state)
 void
 ClientBase::set_events_executor_callback(
   const rclcpp::executors::EventsExecutor * executor,
-  EventsExecutorCallback executor_callback) const
+  rmw_listener_cb_t executor_callback) const
 {
   rcl_ret_t ret = rcl_client_set_events_executor_callback(
     executor,

rclcpp/src/rclcpp/executors/events_executor.cpp

@@ -189,7 +189,7 @@ EventsExecutor::spin_once_impl(std::chrono::nanoseconds timeout)
   // When condition variable is notified, check this predicate to proceed
   auto has_event_predicate = [this]() {return !event_queue_.empty();};
 
-  ExecutorEvent event;
+  rmw_listener_event_t event;
   bool has_event = false;
 
   {
@@ -255,15 +255,15 @@ void
 EventsExecutor::consume_all_events(EventQueue & event_queue)
 {
   while (!event_queue.empty()) {
-    ExecutorEvent event = event_queue.front();
+    rmw_listener_event_t event = event_queue.front();
     event_queue.pop_front();
 
     this->execute_event(event);
   }
 }
 
 void
-EventsExecutor::execute_event(const ExecutorEvent & event)
+EventsExecutor::execute_event(const rmw_listener_event_t & event)
 {
   switch (event.type) {
     case SUBSCRIPTION_EVENT: