Refs #20352: Fix Windows build

Signed-off-by: cferreiragonz <carlosferreira@eprosima.com>
eProsima · Mar 14, 2024 · 6752776 · 6752776
1 parent 1250df9
commit 6752776
Show file tree

Hide file tree

Showing 7 changed files with 21 additions and 12 deletions.
diff --git a/include/fastdds/rtps/network/NetworkBuffer.hpp b/include/fastdds/rtps/network/NetworkBuffer.hpp
@@ -19,9 +19,12 @@
 #ifndef _FASTDDS_RTPS_NETWORK_NETWORKBUFFER_HPP
 #define _FASTDDS_RTPS_NETWORK_NETWORKBUFFER_HPP
 
-#include <cstdint>  // uint32_t
-#include <cstdlib>  // size_t
-#include <asio.hpp>
+#include <cstdint>
+
+namespace asio {
+// Forward declaration of asio::const_buffer
+class const_buffer;
+} // namespace asio
 
 namespace eprosima {
 namespace fastdds {
@@ -36,11 +39,11 @@ struct NetworkBuffer final
     //! Pointer to the buffer where the data is stored.
     const void* buffer;
     //! Number of bytes to use starting at @c buffer.
-    size_t size;
+    uint32_t size;
 
     NetworkBuffer(
             const void* ptr,
-            size_t s)
+            uint32_t s)
         : buffer(ptr)
         , size(s)
     {
@@ -54,7 +57,7 @@ struct NetworkBuffer final
 
     NetworkBuffer(
             const fastrtps::rtps::octet* ptr,
-            size_t s)
+            uint32_t s)
         : buffer(ptr)
         , size(s)
     {
@@ -79,9 +82,7 @@ struct NetworkBuffer final
     }
 
     //! Conversion operator to asio::const_buffer.
-    operator asio::const_buffer() const {
-        return asio::const_buffer(buffer, size);
-    }
+    operator asio::const_buffer() const;
 };
 
 }  // namespace rtps

diff --git a/include/fastdds/rtps/transport/TransportInterface.h b/include/fastdds/rtps/transport/TransportInterface.h
@@ -27,7 +27,6 @@
 #include <fastdds/rtps/transport/SenderResource.h>
 #include <fastdds/rtps/transport/TransportDescriptorInterface.h>
 #include <fastdds/rtps/transport/TransportReceiverInterface.h>
-#include <fastdds/rtps/network/NetworkBuffer.hpp>
 
 namespace eprosima {
 namespace fastdds {

diff --git a/src/cpp/rtps/transport/ChannelResource.h b/src/cpp/rtps/transport/ChannelResource.h
@@ -19,7 +19,6 @@
 
 #include <fastdds/dds/log/Log.hpp>
 #include <fastdds/rtps/common/CDRMessage_t.h>
-#include <fastdds/rtps/network/NetworkBuffer.hpp>
 
 #include <utils/thread.hpp>
 

diff --git a/src/cpp/rtps/transport/TCPChannelResource.h b/src/cpp/rtps/transport/TCPChannelResource.h
@@ -152,7 +152,7 @@ class TCPChannelResource : public ChannelResource
             const fastrtps::rtps::octet* header,
             size_t header_size,
             const fastrtps::rtps::octet* data,
-            size_t data_size,
+            uint32_t data_size,
             asio::error_code& ec)
     {
         NetworkBuffer buffers(data, data_size);

diff --git a/src/cpp/rtps/transport/UDPTransportInterface.cpp b/src/cpp/rtps/transport/UDPTransportInterface.cpp
@@ -542,6 +542,12 @@ bool UDPTransportInterface::send(
     return success;
 }
 
+//! NetworkBuffer conversion operator to asio::const_buffer.
+NetworkBuffer::operator asio::const_buffer() const
+{
+    return asio::const_buffer(buffer, size);
+}
+
 /**
  * Invalidate all selector entries containing certain multicast locator.
  *

diff --git a/src/cpp/rtps/transport/test_UDPv4Transport.cpp b/src/cpp/rtps/transport/test_UDPv4Transport.cpp
@@ -494,6 +494,7 @@ bool test_UDPv4Transport::log_drop(
         const std::list<NetworkBuffer>& buffers,
         uint32_t size)
 {
+    static_cast<void>(size);
     if (test_UDPv4Transport_DropLog.size() < test_UDPv4Transport_DropLogLength)
     {
         vector<octet> message;

diff --git a/test/mock/rtps/StatefulReader/fastdds/rtps/reader/StatefulReader.h b/test/mock/rtps/StatefulReader/fastdds/rtps/reader/StatefulReader.h
@@ -15,10 +15,13 @@
 #ifndef _FASTDDS_RTPS_READER_STATEFULREADER_H_
 #define _FASTDDS_RTPS_READER_STATEFULREADER_H_
 
+#include <list>
+
 #include <fastdds/rtps/attributes/ReaderAttributes.h>
 #include <fastdds/rtps/common/Guid.h>
 #include <fastdds/rtps/reader/RTPSReader.h>
 #include <fastdds/rtps/resources/ResourceEvent.h>
+#include <fastdds/rtps/network/NetworkBuffer.hpp>
 
 namespace eprosima {
 namespace fastrtps {