Add event callbacks & get actual qos (#228)

* Add event callbacks & get actual qos

Signed-off-by: Pablo Garrido <pablogs9@gmail.com>

* Update

Signed-off-by: Pablo Garrido <pablogs9@gmail.com>

* Includes

Signed-off-by: Pablo Garrido <pablogs9@gmail.com>

* Uncrus

Signed-off-by: Pablo Garrido <pablogs9@gmail.com>

Author: pablogs9

rmw_microxrcedds_c/CMakeLists.txt

@@ -189,6 +189,7 @@ set(SRCS
   src/types.c
   src/utils.c
   src/callbacks.c
+  src/rmw_event_callbacks.c
   src/rmw_uxrce_transports.c
   src/rmw_microros/continous_serialization.c
   src/rmw_microros/init_options.c

rmw_microxrcedds_c/src/rmw_client.c

@@ -237,3 +237,29 @@ rmw_destroy_client(
 
   return result_ret;
 }
+
+rmw_ret_t
+rmw_client_request_publisher_get_actual_qos(
+  const rmw_client_t * client,
+  rmw_qos_profile_t * qos)
+{
+  (void) qos;
+
+  rmw_uxrce_client_t * custom_client = (rmw_uxrce_client_t *)client->data;
+  qos = &custom_client->qos;
+
+  return RMW_RET_OK;
+}
+
+rmw_ret_t
+rmw_client_response_subscription_get_actual_qos(
+  const rmw_client_t * client,
+  rmw_qos_profile_t * qos)
+{
+  (void) qos;
+
+  rmw_uxrce_client_t * custom_client = (rmw_uxrce_client_t *)client->data;
+  qos = &custom_client->qos;
+
+  return RMW_RET_OK;
+}

rmw_microxrcedds_c/src/rmw_event_callbacks.c

@@ -0,0 +1,72 @@
+// Copyright 2020 Proyectos y Sistemas de Mantenimiento SL (eProsima).
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include <rmw/rmw.h>
+#include "./rmw_microros_internal/error_handling_internal.h"
+
+rmw_ret_t
+rmw_subscription_set_on_new_message_callback(
+  rmw_subscription_t * subscription,
+  rmw_event_callback_t callback,
+  const void * user_data)
+{
+  (void) subscription;
+  (void) callback;
+  (void) user_data;
+
+  RMW_UROS_TRACE_MESSAGE("function not implemented");
+  return RMW_RET_UNSUPPORTED;
+}
+
+rmw_ret_t
+rmw_service_set_on_new_request_callback(
+  rmw_service_t * service,
+  rmw_event_callback_t callback,
+  const void * user_data)
+{
+  (void) service;
+  (void) callback;
+  (void) user_data;
+
+  RMW_UROS_TRACE_MESSAGE("function not implemented");
+  return RMW_RET_UNSUPPORTED;
+}
+
+rmw_ret_t
+rmw_client_set_on_new_response_callback(
+  rmw_client_t * client,
+  rmw_event_callback_t callback,
+  const void * user_data)
+{
+  (void) client;
+  (void) callback;
+  (void) user_data;
+
+  RMW_UROS_TRACE_MESSAGE("function not implemented");
+  return RMW_RET_UNSUPPORTED;
+}
+
+rmw_ret_t
+rmw_event_set_callback(
+  rmw_event_t * event,
+  rmw_event_callback_t callback,
+  const void * user_data)
+{
+  (void) event;
+  (void) callback;
+  (void) user_data;
+
+  RMW_UROS_TRACE_MESSAGE("function not implemented");
+  return RMW_RET_UNSUPPORTED;
+}

rmw_microxrcedds_c/src/rmw_publisher.c

@@ -281,7 +281,7 @@ rmw_publisher_get_actual_qos(
   const rmw_publisher_t * publisher,
   rmw_qos_profile_t * qos)
 {
-  (void)qos;
+  (void) qos;
 
   rmw_uxrce_publisher_t * custom_publisher = (rmw_uxrce_publisher_t *)publisher->data;
   qos = &custom_publisher->qos;

rmw_microxrcedds_c/src/rmw_service.c

@@ -236,3 +236,29 @@ rmw_destroy_service(
 
   return result_ret;
 }
+
+rmw_ret_t
+rmw_service_response_publisher_get_actual_qos(
+  const rmw_service_t * service,
+  rmw_qos_profile_t * qos)
+{
+  (void) qos;
+
+  rmw_uxrce_service_t * custom_service = (rmw_uxrce_service_t *)service->data;
+  qos = &custom_service->qos;
+
+  return RMW_RET_OK;
+}
+
+rmw_ret_t
+rmw_service_request_subscription_get_actual_qos(
+  const rmw_service_t * service,
+  rmw_qos_profile_t * qos)
+{
+  (void) qos;
+
+  rmw_uxrce_service_t * custom_service = (rmw_uxrce_service_t *)service->data;
+  qos = &custom_service->qos;
+
+  return RMW_RET_OK;
+}

rmw_microxrcedds_c/src/rmw_subscription.c

@@ -276,7 +276,7 @@ rmw_subscription_get_actual_qos(
   const rmw_subscription_t * subscription,
   rmw_qos_profile_t * qos)
 {
-  (void)qos;
+  (void) qos;
 
   rmw_uxrce_subscription_t * custom_subscription = (rmw_uxrce_subscription_t *)subscription->data;
   qos = &custom_subscription->qos;