Uncrustify

Signed-off-by: Carlos Ferreira González <carlosferreira@eprosima.com>

Author: cferreiragonz

include/fastdds/rtps/messages/CDRMessage.hpp

@@ -648,7 +648,7 @@ inline bool CDRMessage::add_string(
     bool valid = CDRMessage::addUInt32(msg, str_siz);
     valid &= CDRMessage::addData(msg, (unsigned char*) in_str, str_siz);
     octet oc = '\0';
-    for (; str_siz& 3; ++str_siz)
+    for (; str_siz & 3; ++str_siz)
     {
         valid &= CDRMessage::addOctet(msg, oc);
     }

src/cpp/fastdds/domain/DomainParticipantFactory.cpp

@@ -170,7 +170,8 @@ DomainParticipant* DomainParticipantFactory::create_participant(
     DomainParticipant* dom_part = new DomainParticipant(mask);
     DomainParticipantImpl* dom_part_impl = new DomainParticipantImpl(dom_part, did, pqos, listen);
 #else
-    eprosima::fastdds::statistics::dds::DomainParticipant* dom_part = new eprosima::fastdds::statistics::dds::DomainParticipant(mask);
+    eprosima::fastdds::statistics::dds::DomainParticipant* dom_part =
+            new eprosima::fastdds::statistics::dds::DomainParticipant(mask);
     eprosima::fastdds::statistics::dds::DomainParticipantImpl* dom_part_impl =
             new eprosima::fastdds::statistics::dds::DomainParticipantImpl(dom_part, did, pqos, listen);
 #endif // FASTDDS_STATISTICS

test/blackbox/common/BlackboxTestsDiscovery.cpp

@@ -1007,7 +1007,7 @@ TEST_P(Discovery, PubSubAsReliableHelloworldEndpointUserData)
 }
 
 //! Auxiliar method for discovering participants tests
-template <typename ParticipantConfigurator>
+template<typename ParticipantConfigurator>
 static void discoverParticipantsTest(
         bool avoid_multicast,
         size_t n_participants,

test/blackbox/common/DDSBlackboxTestsDataReader.cpp

@@ -329,7 +329,8 @@ TEST(DDSDataReader, GetFirstUntakenInfoReturnsTheFirstValidChange)
     eprosima::fastdds::dds::SampleInfo info;
     for (size_t i = 0; i < 3; i++)
     {
-        ASSERT_NE(eprosima::fastrtps::types::ReturnCode_t::RETCODE_OK, reader.get_native_reader().get_first_untaken_info(
+        ASSERT_NE(eprosima::fastrtps::types::ReturnCode_t::RETCODE_OK,
+                reader.get_native_reader().get_first_untaken_info(
                     &info));
         std::this_thread::sleep_for(std::chrono::milliseconds(500));
     }

test/blackbox/common/DDSBlackboxTestsDataWriter.cpp

@@ -468,7 +468,8 @@ class TestsDataWriterQosCommonUtils
         qos.resource_limits().max_samples = 1000;
         qos.transport_priority().value = 1;
         qos.ownership().kind = eprosima::fastdds::dds::EXCLUSIVE_OWNERSHIP_QOS;
-        qos.representation().m_value.push_back(eprosima::fastdds::dds::DataRepresentationId_t::XCDR2_DATA_REPRESENTATION);
+        qos.representation().m_value.push_back(
+            eprosima::fastdds::dds::DataRepresentationId_t::XCDR2_DATA_REPRESENTATION);
         qos.history().kind = eprosima::fastdds::dds::KEEP_ALL_HISTORY_QOS;
         qos.lifespan().duration = {5, 0};
     }

test/blackbox/common/DDSBlackboxTestsMonitorService.cpp

@@ -201,8 +201,8 @@ class MonitorServiceParticipant
 
         writer_stat_guids_.push_back(statistics::to_statistics_type(writers_.back()->guid()));
 
-        std::cout << "Created datawriter " << writers_.back()->guid() << " for topic " <<
-            topics_.back()->get_name() << std::endl;
+        std::cout << "Created datawriter " << writers_.back()->guid() << " for topic "
+                  << topics_.back()->get_name() << std::endl;
     }
 
     void create_and_add_reader(
@@ -224,8 +224,8 @@ class MonitorServiceParticipant
 
         reader_stat_guids_.push_back(statistics::to_statistics_type(readers_.back()->guid()));
 
-        std::cout << "Created datareader " << readers_.back()->guid() << " for topic " <<
-            topics_.back()->get_name() << std::endl;
+        std::cout << "Created datareader " << readers_.back()->guid() << " for topic "
+                  << topics_.back()->get_name() << std::endl;
     }
 
     bool delete_writer()
@@ -348,8 +348,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[OFFERED_DEADLINE_MISSED_IDX];
             }
 
-            std::cout << "on_offered_deadline_missed() " << writer->guid() << " total_count " << status.total_count <<
-                std::endl;
+            std::cout << "on_offered_deadline_missed() " << writer->guid() << " total_count " << status.total_count
+                      << std::endl;
         }
 
         void on_offered_incompatible_qos (
@@ -361,8 +361,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[OFFERED_INCOMPATIBLE_QOS_IDX];
             }
 
-            std::cout << "on_offered_incompatible_qos " << writer->guid() << " total_count " << status.total_count <<
-                std::endl;
+            std::cout << "on_offered_incompatible_qos " << writer->guid() << " total_count " << status.total_count
+                      << std::endl;
         }
 
         void on_liveliness_lost (
@@ -386,8 +386,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[PUBLICATION_MATCHED_IDX];
             }
 
-            std::cout << "on_publication_matched " << writer->guid() << " total_count " << status.total_count <<
-                std::endl;
+            std::cout << "on_publication_matched " << writer->guid() << " total_count " << status.total_count
+                      << std::endl;
         }
 
         void on_requested_deadline_missed (
@@ -399,8 +399,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[REQUESTED_DEADLINE_MISSED_IDX];
             }
 
-            std::cout << "on_requested_deadline_missed" << reader->guid() << " total_count " << status.total_count <<
-                std::endl;
+            std::cout << "on_requested_deadline_missed" << reader->guid() << " total_count " << status.total_count
+                      << std::endl;
         }
 
         void on_requested_incompatible_qos (
@@ -412,8 +412,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[REQUESTED_INCOMPATIBLE_QOS_IDX];
             }
 
-            std::cout << "on_requested_incompatible_qos" << reader->guid() << " total_count " << status.total_count <<
-                std::endl;
+            std::cout << "on_requested_incompatible_qos" << reader->guid() << " total_count " << status.total_count
+                      << std::endl;
         }
 
         void on_liveliness_changed (
@@ -425,8 +425,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[LIVELINESS_CHANGED_IDX];
             }
 
-            std::cout << "on_liveliness_changed " << reader->guid() << " not_alive_count " << status.not_alive_count <<
-                std::endl;
+            std::cout << "on_liveliness_changed " << reader->guid() << " not_alive_count " << status.not_alive_count
+                      << std::endl;
         }
 
         void on_subscription_matched (
@@ -438,8 +438,8 @@ class MonitorServiceParticipant
                 ++cb_counters_[SUBSCRIPTION_MATCHED_IDX];
             }
 
-            std::cout << "on_subscription_matched " << reader->guid() << " total_count " << status.total_count <<
-                std::endl;
+            std::cout << "on_subscription_matched " << reader->guid() << " total_count " << status.total_count
+                      << std::endl;
         }
 
         void on_sample_lost (
@@ -687,13 +687,13 @@ struct ProxySampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                data.local_entity() == elem.local_entity();
+                                       data.local_entity() == elem.local_entity();
                             });
 
             if (it == total_msgs.end())
             {
-                std::cout << "Unexpected proxy " << statistics::to_fastdds_type(data.local_entity()) <<
-                    data.status_kind() << std::endl;
+                std::cout << "Unexpected proxy " << statistics::to_fastdds_type(data.local_entity())
+                          << data.status_kind() << std::endl;
                 return;
             }
 
@@ -756,7 +756,7 @@ struct ProxySampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                data.local_entity() == elem.local_entity();
+                                       data.local_entity() == elem.local_entity();
                             });
 
             std::cout << "Received unregistration of instance "
@@ -792,8 +792,8 @@ struct ConnectionListSampleValidator : public SampleValidator
 
             for (auto& connection : data.value().connection_list())
             {
-                std::cout << "Received Connection: \n\tMode: " << connection.mode() <<
-                    "\n\tGuid " << statistics::to_fastdds_type(connection.guid()) << "\n\t"
+                std::cout << "Received Connection: \n\tMode: " << connection.mode()
+                          << "\n\tGuid " << statistics::to_fastdds_type(connection.guid()) << "\n\t"
                           << "Announced Locators: ";
                 for (auto& locator : connection.used_locators())
                 {
@@ -844,9 +844,10 @@ struct ConnectionListSampleValidator : public SampleValidator
                                                         EPROSIMA_LOG_ERROR(BBTestsMonitorService,
                                                         "Locator not found in sample msg "
                                                             << statistics::to_fastdds_type(total_msgs_elem_connection.
-                                                                announced_locators()[i]) <<
-                                                            " for local entity " <<
-                                                            statistics::to_fastdds_type(total_msgs_elem.local_entity()));
+                                                                announced_locators()[i])
+                                                            << " for local entity "
+                                                            << statistics::to_fastdds_type(
+                                                            total_msgs_elem.local_entity()));
                                                         same_locators = false;
                                                         break;
                                                     }
@@ -903,9 +904,9 @@ struct IncompatibleQoSSampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                (data.local_entity() == elem.local_entity()) &&
-                                (data.value().incompatible_qos_status().last_policy_id()
-                                == elem.value().incompatible_qos_status().last_policy_id());
+                                       (data.local_entity() == elem.local_entity()) &&
+                                       (data.value().incompatible_qos_status().last_policy_id()
+                                       == elem.value().incompatible_qos_status().last_policy_id());
                             });
 
             if (assert_on_non_expected_msgs_)
@@ -942,9 +943,9 @@ struct LivelinessLostSampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                (data.local_entity() == elem.local_entity()) &&
-                                (data.value().liveliness_lost_status().total_count()
-                                == elem.value().liveliness_lost_status().total_count());
+                                       (data.local_entity() == elem.local_entity()) &&
+                                       (data.value().liveliness_lost_status().total_count()
+                                       == elem.value().liveliness_lost_status().total_count());
                             });
 
             if (assert_on_non_expected_msgs_)
@@ -981,9 +982,9 @@ struct LivelinessChangedSampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                (data.local_entity() == elem.local_entity()) &&
-                                (data.value().liveliness_changed_status().not_alive_count()
-                                >= elem.value().liveliness_changed_status().not_alive_count());
+                                       (data.local_entity() == elem.local_entity()) &&
+                                       (data.value().liveliness_changed_status().not_alive_count()
+                                       >= elem.value().liveliness_changed_status().not_alive_count());
                             });
 
             std::cout << "Received Liveliness Changed on local_entity "
@@ -1025,9 +1026,9 @@ struct DeadlineMissedSampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                (data.local_entity() == elem.local_entity()) &&
-                                (data.value().deadline_missed_status().total_count()
-                                >= elem.value().deadline_missed_status().total_count());
+                                       (data.local_entity() == elem.local_entity()) &&
+                                       (data.value().deadline_missed_status().total_count()
+                                       >= elem.value().deadline_missed_status().total_count());
                             });
 
             std::cout << "Received Deadline Missed on local_entity "
@@ -1064,8 +1065,8 @@ struct SampleLostSampleValidator : public SampleValidator
                             [&](const MonitorServiceType::type& elem)
                             {
                                 return (data.status_kind() == elem.status_kind()) &&
-                                (data.local_entity() == elem.local_entity()) &&
-                                (data.value().sample_lost_status().total_count() >= 1);
+                                       (data.local_entity() == elem.local_entity()) &&
+                                       (data.value().sample_lost_status().total_count() >= 1);
                             });
 
             std::cout << "Received Sample Lost on local_entity "

test/blackbox/common/DDSBlackboxTestsPersistence.cpp

@@ -74,9 +74,9 @@ class PersistenceLargeData : public testing::TestWithParam<communication_type>
         std::ostringstream ss;
         std::string test_case_name(info->test_case_name());
         std::string test_name(info->name());
-        ss <<
-            test_case_name.replace(test_case_name.find_first_of('/'), 1, "_") << "_" <<
-            test_name.replace(test_name.find_first_of('/'), 1, "_")  << "_" << GET_PID() << ".db";
+        ss
+            << test_case_name.replace(test_case_name.find_first_of('/'), 1, "_") << "_"
+            << test_name.replace(test_name.find_first_of('/'), 1, "_")  << "_" << GET_PID() << ".db";
         db_file_name_ = ss.str();
 
     }