Refs #23432. Pass transport_priority to UDPTransportInterface::send().

Signed-off-by: Miguel Company <miguelcompany@eprosima.com>

Author: MiguelCompany

src/cpp/rtps/transport/UDPSenderResource.hpp

@@ -46,16 +46,17 @@ class UDPSenderResource : public SenderResource
                     transport.SenderResourceHasBeenClosed(socket_);
                 };
 
-        send_buffers_lambda_ = [this, &transport](
+        send_lambda_ = [this, &transport](
             const std::vector<NetworkBuffer>& buffers,
             uint32_t total_bytes,
             LocatorsIterator* destination_locators_begin,
             LocatorsIterator* destination_locators_end,
-            const std::chrono::steady_clock::time_point& max_blocking_time_point) -> bool
+            const std::chrono::steady_clock::time_point& max_blocking_time_point,
+            int32_t transport_priority) -> bool
                 {
                     return transport.send(buffers, total_bytes, socket_, destination_locators_begin,
                                    destination_locators_end, only_multicast_purpose_, whitelisted_,
-                                   max_blocking_time_point);
+                                   max_blocking_time_point, transport_priority);
                 };
     }
 

src/cpp/rtps/transport/UDPTransportInterface.cpp

@@ -506,7 +506,8 @@ bool UDPTransportInterface::send(
         fastdds::rtps::LocatorsIterator* destination_locators_end,
         bool only_multicast_purpose,
         bool whitelisted,
-        const std::chrono::steady_clock::time_point& max_blocking_time_point)
+        const std::chrono::steady_clock::time_point& max_blocking_time_point,
+        int32_t /* transport_priority */)
 {
     fastdds::rtps::LocatorsIterator& it = *destination_locators_begin;
 

src/cpp/rtps/transport/UDPTransportInterface.h

@@ -134,6 +134,7 @@ class UDPTransportInterface : public TransportInterface
      * @param only_multicast_purpose multicast network interface
      * @param whitelisted network interface included in the user whitelist
      * @param max_blocking_time_point maximum blocking time.
+     * @param transport_priority Transport priority to be used for the send operation.
      *
      * @pre Open the output channel of each remote locator by invoking \ref OpenOutputChannel function.
      */
@@ -145,7 +146,8 @@ class UDPTransportInterface : public TransportInterface
             LocatorsIterator* destination_locators_end,
             bool only_multicast_purpose,
             bool whitelisted,
-            const std::chrono::steady_clock::time_point& max_blocking_time_point);
+            const std::chrono::steady_clock::time_point& max_blocking_time_point,
+            int32_t transport_priority);
 
     /**
      * Performs the locator selection algorithm for this transport.

src/cpp/rtps/transport/test_UDPv4Transport.cpp

@@ -152,7 +152,8 @@ bool test_UDPv4Transport::send(
         fastdds::rtps::LocatorsIterator* destination_locators_end,
         bool only_multicast_purpose,
         bool whitelisted,
-        const std::chrono::steady_clock::time_point& max_blocking_time_point)
+        const std::chrono::steady_clock::time_point& max_blocking_time_point,
+        int32_t /* transport_priority */)
 {
     fastdds::rtps::LocatorsIterator& it = *destination_locators_begin;
 

src/cpp/rtps/transport/test_UDPv4Transport.h

@@ -48,7 +48,8 @@ class test_UDPv4Transport : public UDPv4Transport
             LocatorsIterator* destination_locators_end,
             bool only_multicast_purpose,
             bool whitelisted,
-            const std::chrono::steady_clock::time_point& max_blocking_time_point) override;
+            const std::chrono::steady_clock::time_point& max_blocking_time_point,
+            int32_t transport_priority) override;
 
     virtual LocatorList NormalizeLocator(
             const Locator& locator) override;