Refs #20342: Uncrustify

Signed-off-by: cferreiragonz <[email protected]>
eProsima · Mar 11, 2024 · 02e2919 · 02e2919
1 parent 5de9ef4
commit 02e2919
Show file tree

Hide file tree

Showing 9 changed files with 47 additions and 19 deletions.
diff --git a/include/fastdds/rtps/messages/RTPSMessageGroup.h b/include/fastdds/rtps/messages/RTPSMessageGroup.h
@@ -289,8 +289,8 @@ class RTPSMessageGroup
             bool is_big_submessage);
 
     bool check_space(
-        CDRMessage_t* msg,
-        const uint32_t length);
+            CDRMessage_t* msg,
+            const uint32_t length);
 
 
     /**

diff --git a/include/fastdds/rtps/network/NetworkBuffer.hpp b/include/fastdds/rtps/network/NetworkBuffer.hpp
@@ -38,16 +38,40 @@ struct NetworkBuffer final
     //! Number of bytes to use starting at @c buffer.
     size_t size;
 
-    NetworkBuffer(const void* ptr, size_t s) : buffer(ptr), size(s) {}
+    NetworkBuffer(
+            const void* ptr,
+            size_t s)
+        : buffer(ptr)
+        , size(s)
+    {
+    }
 
-    NetworkBuffer() : buffer(nullptr), size(0) {}
+    NetworkBuffer()
+        : buffer(nullptr)
+        , size(0)
+    {
+    }
 
-    NetworkBuffer(const fastrtps::rtps::octet* ptr, size_t s) : buffer(ptr), size(s) {}
+    NetworkBuffer(
+            const fastrtps::rtps::octet* ptr,
+            size_t s)
+        : buffer(ptr)
+        , size(s)
+    {
+    }
 
-    NetworkBuffer(const NetworkBuffer& copy) : buffer(copy.buffer), size(copy.size) {}
+    NetworkBuffer(
+            const NetworkBuffer& copy)
+        : buffer(copy.buffer)
+        , size(copy.size)
+    {
+    }
 
-    NetworkBuffer& operator=(const NetworkBuffer& copy) {
-        if (this != &copy) {
+    NetworkBuffer& operator =(
+            const NetworkBuffer& copy)
+    {
+        if (this != &copy)
+        {
             buffer = copy.buffer;
             size = copy.size;
         }

diff --git a/include/fastdds/rtps/transport/SenderResource.h b/include/fastdds/rtps/transport/SenderResource.h
@@ -62,8 +62,8 @@ class SenderResource
             LocatorsIterator* destination_locators_end,
             const std::chrono::steady_clock::time_point& max_blocking_time_point)
     {
-            return send_buffers_lambda_(buffers, total_bytes, destination_locators_begin, destination_locators_end,
-                        max_blocking_time_point);
+        return send_buffers_lambda_(buffers, total_bytes, destination_locators_begin, destination_locators_end,
+                       max_blocking_time_point);
     }
 
     /**

diff --git a/src/cpp/rtps/messages/RTPSMessageGroup.cpp b/src/cpp/rtps/messages/RTPSMessageGroup.cpp
@@ -536,7 +536,8 @@ bool RTPSMessageGroup::add_data(
 
     // Check limitation
     uint32_t data_size = change.serializedPayload.length;
-    if (data_exceeds_limitation(data_size, sent_bytes_limitation_, current_sent_bytes_, header_msg_->length + buffers_bytes_))
+    if (data_exceeds_limitation(data_size, sent_bytes_limitation_, current_sent_bytes_,
+            header_msg_->length + buffers_bytes_))
     {
         flush_and_reset();
         throw limit_exceeded();
@@ -644,7 +645,8 @@ bool RTPSMessageGroup::add_data_frag(
     uint32_t fragment_size = fragment_number < change.getFragmentCount() ? change.getFragmentSize() :
             change.serializedPayload.length - fragment_start;
     // Check limitation
-    if (data_exceeds_limitation(fragment_size, sent_bytes_limitation_, current_sent_bytes_, header_msg_->length + buffers_bytes_))
+    if (data_exceeds_limitation(fragment_size, sent_bytes_limitation_, current_sent_bytes_,
+            header_msg_->length + buffers_bytes_))
     {
         flush_and_reset();
         throw limit_exceeded();

diff --git a/src/cpp/rtps/messages/submessages/DataMsg.hpp b/src/cpp/rtps/messages/submessages/DataMsg.hpp
@@ -467,7 +467,7 @@ bool RTPSMessageCreator::addSubmessageDataFrag(
     // TODO(Ricardo) This should be on cachechange.
     // Align submessage to rtps alignment (4).
     submessage_size = uint16_t(msg->pos - position_size_count_size);
-    for (; 0 != (submessage_size& 3); ++submessage_size)
+    for (; 0 != (submessage_size & 3); ++submessage_size)
     {
         if (copy_data)
         {

diff --git a/src/cpp/rtps/reader/StatefulReader.cpp b/src/cpp/rtps/reader/StatefulReader.cpp
@@ -1644,5 +1644,6 @@ bool StatefulReader::send_sync_nts(
         const Locators& locators_end,
         std::chrono::steady_clock::time_point& max_blocking_time_point)
 {
-    return mp_RTPSParticipant->sendSync(buffers, total_bytes, m_guid, locators_begin, locators_end, max_blocking_time_point);
+    return mp_RTPSParticipant->sendSync(buffers, total_bytes, m_guid, locators_begin, locators_end,
+                   max_blocking_time_point);
 }
diff --git a/src/cpp/rtps/transport/shared_mem/SharedMemTransport.h b/src/cpp/rtps/transport/shared_mem/SharedMemTransport.h
@@ -253,9 +253,9 @@ class SharedMemTransport : public TransportInterface
      * @param max_blocking_time_point Maximum time this function will block.
      */
     std::shared_ptr<SharedMemManager::Buffer> copy_to_shared_buffer(
-        const std::list<NetworkBuffer>& buffers,
-        const uint32_t total_bytes,
-        const std::chrono::steady_clock::time_point& max_blocking_time_point);
+            const std::list<NetworkBuffer>& buffers,
+            const uint32_t total_bytes,
+            const std::chrono::steady_clock::time_point& max_blocking_time_point);
 
     bool send(
             const std::shared_ptr<SharedMemManager::Buffer>& buffer,

diff --git a/src/cpp/rtps/transport/shared_mem/test_SharedMemTransport.cpp b/src/cpp/rtps/transport/shared_mem/test_SharedMemTransport.cpp
@@ -50,7 +50,7 @@ TransportInterface* test_SharedMemTransportDescriptor::create_transport() const
 
 bool test_SharedMemTransport::send(
         const std::list<NetworkBuffer>& buffers,
-            uint32_t total_bytes,
+        uint32_t total_bytes,
         fastrtps::rtps::LocatorsIterator* destination_locators_begin,
         fastrtps::rtps::LocatorsIterator* destination_locators_end,
         const std::chrono::steady_clock::time_point& max_blocking_time_point)

diff --git a/src/cpp/statistics/rtps/messages/RTPSStatisticsMessages.hpp b/src/cpp/statistics/rtps/messages/RTPSStatisticsMessages.hpp
@@ -172,7 +172,8 @@ inline bool is_statistics_buffer(
         const NetworkBuffer& stat_buffer)
 {
     return statistics_submessage_length == stat_buffer.size &&
-           FASTDDS_STATISTICS_NETWORK_SUBMESSAGE == static_cast<const eprosima::fastrtps::rtps::octet*>(stat_buffer.buffer)[0];
+           FASTDDS_STATISTICS_NETWORK_SUBMESSAGE ==
+           static_cast<const eprosima::fastrtps::rtps::octet*>(stat_buffer.buffer)[0];
 }
 
 #endif // FASTDDS_STATISTICS