[core] new-pub-sub-matching

ecal/core/include/ecal/config/publisher.h

@@ -89,9 +89,11 @@
 #pragma once
 
 #include <ecal/ecal_os.h>
+#include <ecal/ecal_tlayer.h>
 #include <ecal/types/ecal_custom_data_types.h>
 
 #include <cstddef>
+#include <vector>
 
 namespace eCAL
 {
@@ -133,12 +135,16 @@ namespace eCAL
     {
       ECAL_API Configuration();
 
-      SHM::Configuration   shm;
-      UDP::Configuration   udp;
-      TCP::Configuration   tcp;
+      SHM::Configuration       shm;
+      UDP::Configuration       udp;
+      TCP::Configuration       tcp;
 
-      bool                 share_topic_type;                            //!< share topic type via registration
-      bool                 share_topic_description;                     //!< share topic description via registration
+      using LayerPriorityVector = std::vector<TLayer::eTransportLayer>;
+      LayerPriorityVector      layer_priority_local  = { TLayer::tlayer_shm, TLayer::tlayer_udp_mc, TLayer::tlayer_tcp };
+      LayerPriorityVector      layer_priority_remote = {                     TLayer::tlayer_udp_mc, TLayer::tlayer_tcp };
+
+      bool                     share_topic_type;                        //!< share topic type via registration
+      bool                     share_topic_description;                 //!< share topic description via registration
     };
   }
 }

ecal/core/include/ecal/ecal_publisher.h

@@ -24,16 +24,16 @@
 
 #pragma once
 
-#include <cstddef>
 #include <ecal/ecal_callback.h>
 #include <ecal/ecal_deprecate.h>
 #include <ecal/ecal_os.h>
 #include <ecal/ecal_payload_writer.h>
-#include <ecal/config/publisher.h>
 #include <ecal/ecal_config.h>
 #include <ecal/ecal_types.h>
+#include <ecal/config/publisher.h>
 
 #include <chrono>
+#include <cstddef>
 #include <memory>
 #include <string>
 

ecal/core/include/ecal/ecal_subscriber.h

@@ -103,7 +103,7 @@ namespace eCAL
      * @brief Constructor.
      * 
      * @param topic_name_      Unique topic name.
-     * @param data_type_info_  Topic data type information (encoding, type, descriptor).
+     * @param config_          Optional configuration parameters.
     **/
     ECAL_API explicit CSubscriber(const std::string& topic_name_, const Subscriber::Configuration& config_ = {});
 

ecal/core/include/ecal/msg/subscriber.h

@@ -254,12 +254,13 @@ namespace eCAL
     * @brief  Constructor.
     *
     * @param topic_name_  Unique topic name.
+    * @param config_      Optional configuration parameters.
     **/
-    CMessageSubscriber(const std::string& topic_name_) : CSubscriber()
+    CMessageSubscriber(const std::string& topic_name_, const Subscriber::Configuration& config_ = {}) : CSubscriber()
       , m_deserializer()
     {
       SDataTypeInformation topic_info = m_deserializer.GetDataTypeInformation();
-      CSubscriber::Create(topic_name_, topic_info);
+      CSubscriber::Create(topic_name_, topic_info, config_);
     }
 
     ~CMessageSubscriber() noexcept
@@ -418,7 +419,4 @@ namespace eCAL
     MsgReceiveCallbackT  m_cb_callback;
     Deserializer         m_deserializer;
   };
-
-
-
 }

ecal/core/src/ecal_global_accessors.cpp

@@ -21,10 +21,12 @@
  * @brief  eCAL core functions
 **/
 
+#include "ecal/config/configuration.h"
+
 #include "ecal_global_accessors.h"
 #include "ecal_def.h"
 #include "ecal_globals.h"
-#include "ecal/config/configuration.h"
+
 #include <atomic>
 #include <string>
 

ecal/core/src/ecal_process.cpp

@@ -1,6 +1,6 @@
 /* ========================= eCAL LICENSE =================================
  *
- * Copyright (C) 2016 - 2019 Continental Corporation
+ * Copyright (C) 2016 - 2024 Continental Corporation
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

ecal/core/src/pubsub/ecal_pubgate.cpp

@@ -129,18 +129,18 @@ namespace eCAL
     CDataWriter::SLayerStates layer_states;
     for (const auto& layer : ecal_topic.tlayer)
     {
-      if (layer.confirmed)
+      if (layer.enabled)
       {
         switch (layer.type)
         {
         case TLayer::tlayer_udp_mc:
-          layer_states.udp = true;
+          layer_states.udp.read_enabled = true;
           break;
         case TLayer::tlayer_shm:
-          layer_states.shm = true;
+          layer_states.shm.read_enabled = true;
           break;
         case TLayer::tlayer_tcp:
-          layer_states.tcp = true;
+          layer_states.tcp.read_enabled = true;
           break;
         default:
           break;

ecal/core/src/pubsub/ecal_publisher.cpp

@@ -1,6 +1,6 @@
 /* ========================= eCAL LICENSE =================================
  *
- * Copyright (C) 2016 - 2019 Continental Corporation
+ * Copyright (C) 2016 - 2024 Continental Corporation
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

ecal/core/src/pubsub/ecal_subgate.cpp

@@ -166,7 +166,7 @@ namespace eCAL
       const auto& ecal_sample_content = ecal_sample.content;
       for (const auto& reader : readers_to_apply)
       {
-        applied_size = reader->AddSample(
+        applied_size = reader->ApplySample(
           ecal_sample.topic.tid,
           payload_addr,
           payload_size,
@@ -207,7 +207,7 @@ namespace eCAL
 
     for (const auto& reader : readers_to_apply)
     {
-      applied_size = reader->AddSample(topic_id_, buf_, len_, id_, clock_, time_, hash_, layer_);
+      applied_size = reader->ApplySample(topic_id_, buf_, len_, id_, clock_, time_, hash_, layer_);
     }
 
     return (applied_size > 0);
@@ -232,18 +232,18 @@ namespace eCAL
     CDataReader::SLayerStates layer_states;
     for (const auto& layer : ecal_topic.tlayer)
     {
-      if (layer.confirmed)
+      if (layer.enabled)
       {
         switch (layer.type)
         {
         case TLayer::tlayer_udp_mc:
-          layer_states.udp = true;
+          layer_states.udp.write_enabled = true;
           break;
         case TLayer::tlayer_shm:
-          layer_states.shm = true;
+          layer_states.shm.write_enabled = true;
           break;
         case TLayer::tlayer_tcp:
-          layer_states.tcp = true;
+          layer_states.tcp.write_enabled = true;
           break;
         default:
           break;

ecal/core/src/pubsub/ecal_subscriber.cpp

@@ -81,7 +81,7 @@ namespace eCAL
     if (topic_name_.empty()) return(false);
 
     // create datareader
-    m_datareader = std::make_shared<CDataReader>(topic_name_, data_type_info_);
+    m_datareader = std::make_shared<CDataReader>(topic_name_, data_type_info_, config_);
 
     // register datareader
     g_subgate()->Register(topic_name_, m_datareader);
@@ -143,7 +143,7 @@ namespace eCAL
   bool CSubscriber::ReceiveBuffer(std::string& buf_, long long* time_ /* = nullptr */, int rcv_timeout_ /* = 0 */) const
   {
     if (!m_created) return(false);
-    return(m_datareader->Receive(buf_, time_, rcv_timeout_));
+    return(m_datareader->Read(buf_, time_, rcv_timeout_));
   }
 
   bool CSubscriber::AddReceiveCallback(ReceiveCallbackT callback_)