Changeset 186:bf8a796dc6b6 in finroc_plugins_data_ports

Timestamp:

08.02.2022 07:36:55 (16 months ago)

Author:

Max Reichardt <mreichardt@…>

Branch:

17.03

Phase:

public

Tags:

tip

Message:

Adds extended destination buffer pointer type to tConversionConnector - providing additional settings with respect to published buffer to conversion operations (makes it possible, for example, to set output buffer timestamp if input buffer contains multiple).

Location:

common

Files:

• tConversionConnector.cpp (modified) (3 diffs)
• tConversionConnector.h (modified) (1 diff)

common/tConversionConnector.cpp

@@ -72 +72 @@
 tConversionConnector::tConversionConnector(core::tAbstractPort& source_port, core::tAbstractPort& destination_port, const core::tConnectOptions& connect_options) :
   tConnector(source_port, destination_port, connect_options, conversion_operation),
-  conversion_operation(connect_options.conversion_operations.Compile(false, source_port.GetDataType(), destination_port.GetDataType()))
+  conversion_operation(connect_options.conversion_operations.Compile(false, source_port.GetDataType(), destination_port.GetDataType(), typeid(tDestinationPointer)))
 {
   static_assert(sizeof(destination_port_generic_memory) == sizeof(tGenericPort), "Adjust array size");
@@ -82 +82 @@
 {}
 
-void tConversionConnector::Publish(const rrlib::rtti::tGenericObject& input_data, const rrlib::time::tTimestamp& timestamp, tChangeStatus change_constant) const
+void tConversionConnector::Publish(const rrlib::rtti::tGenericObject& input_data, const rrlib::time::tTimestamp& input_timestamp, tChangeStatus change_constant) const
 {
   try
@@ -88 +88 @@
     tGenericPort& generic_port = const_cast<tGenericPort&>(reinterpret_cast<const tGenericPort&>(destination_port_generic_memory[0]));
     tPortDataPointer<rrlib::rtti::tGenericObject> buffer = generic_port.GetUnusedBuffer();
-    buffer.SetTimestamp(timestamp);
-    conversion_operation.Convert(input_data, *buffer);
-    generic_port.BrowserPublish(buffer, true, change_constant);
+    rrlib::time::tTimestamp timestamp = input_timestamp;
+    bool skip = false;
+    tDestinationPointer destination_pointer(*buffer, timestamp, skip);
+    conversion_operation.Convert(input_data, destination_pointer);
+    if (!skip)
+    {
+      buffer.SetTimestamp(timestamp);
+      generic_port.BrowserPublish(buffer, true, change_constant);
+    }
   }
   catch (const std::exception& e)

common/tConversionConnector.h

@@ -96 +96 @@
 
 
+  /*! Destination Pointer used in tConversionConnector
+   *
+   * Provides additional settings with respect to published buffer to conversion operations
+   */
+  class tDestinationPointer : public rrlib::rtti::tTypedPointer
+  {
+  public:
+
+    tDestinationPointer(const tTypedPointer& pointer, rrlib::time::tTimestamp& timestamp, bool& skip) :
+      tTypedPointer(pointer),
+      timestamp(timestamp),
+      skip(skip)
+    {}
+
+    // Convenience constructor for use in conversion operation implementations' first conversion function
+    tDestinationPointer(const tTypedPointer& pointer, const tDestinationPointer& share_additional_settings_with) :
+      tDestinationPointer(pointer, share_additional_settings_with.timestamp, share_additional_settings_with.skip)
+    {}
+
+
+    /*!
+     * \return Destination timestamp
+     */
+    rrlib::time::tTimestamp& Timestamp() const
+    {
+      return timestamp;
+    }
+
+    /*!
+     * \return Whether to skip converting this value
+     */
+    bool& Skip() const
+    {
+      return skip;
+    }
+
+  private:
+
+    /*! Destination timestamp (set to timestamp input data buffer by default) */
+    rrlib::time::tTimestamp& timestamp;
+
+    /*! Whether to skip converting this value (without printing a warning; similar but somewhat more efficient than throwing tSilentConversionException) */
+    bool& skip;
+  };
+
   class tSilentConversionException : public std::exception
-{};
+  {
+  };
 
 //----------------------------------------------------------------------