Skip to content

Commit

Permalink
Refs #21295: Uncrustify
Browse files Browse the repository at this point in the history
Signed-off-by: elianalf <62831776+elianalf@users.noreply.github.com>
  • Loading branch information
elianalf committed Jul 12, 2024
1 parent 2e3b03d commit 02dc073
Show file tree
Hide file tree
Showing 8 changed files with 43 additions and 32 deletions.
26 changes: 14 additions & 12 deletions include/fastdds/rtps/builtin/data/ParticipantBuiltinTopicData.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -31,23 +31,25 @@ namespace rtps {
struct ParticipantBuiltinTopicData
{
//! Constructor from ParticipantBuiltinTopicData
ParticipantBuiltinTopicData(const ParticipantBuiltinTopicData& pdata)
: key(pdata.key)
, user_data(pdata.user_data)
, guid(pdata.guid)
, properties(pdata.properties)
, participant_name(pdata.participant_name)
, metatraffic_locators(pdata.metatraffic_locators)
, default_locators(pdata.default_locators)
, lease_duration(pdata.lease_duration)
, vendor_id(pdata.vendor_id)
, domain_id(pdata.domain_id)
ParticipantBuiltinTopicData(
const ParticipantBuiltinTopicData& pdata)
: key(pdata.key)
, user_data(pdata.user_data)
, guid(pdata.guid)
, properties(pdata.properties)
, participant_name(pdata.participant_name)
, metatraffic_locators(pdata.metatraffic_locators)
, default_locators(pdata.default_locators)
, lease_duration(pdata.lease_duration)
, vendor_id(pdata.vendor_id)
, domain_id(pdata.domain_id)
{
}

//! Default constructor
ParticipantBuiltinTopicData()
{}
{
}

//! Builtin topic Key
BuiltinTopicKey_t key;
Expand Down
24 changes: 12 additions & 12 deletions src/cpp/rtps/builtin/data/ProxyDataConverters.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -44,27 +44,27 @@ static void from_proxy_to_builtin(
builtin_key_value[0] = 0;
builtin_key_value[1] = 0;
builtin_key_value[2] = static_cast<uint32_t>(entity_id.value[0]) << 24
| static_cast<uint32_t>(entity_id.value[1]) << 16
| static_cast<uint32_t>(entity_id.value[2]) << 8
| static_cast<uint32_t>(entity_id.value[3]);
| static_cast<uint32_t>(entity_id.value[1]) << 16
| static_cast<uint32_t>(entity_id.value[2]) << 8
| static_cast<uint32_t>(entity_id.value[3]);
}

static void from_proxy_to_builtin(
const GuidPrefix_t& guid_prefix,
BuiltinTopicKeyValue& dds_key)
{
dds_key[0] = static_cast<uint32_t>(guid_prefix.value[0]) << 24
| static_cast<uint32_t>(guid_prefix.value[1]) << 16
| static_cast<uint32_t>(guid_prefix.value[2]) << 8
| static_cast<uint32_t>(guid_prefix.value[3]);
| static_cast<uint32_t>(guid_prefix.value[1]) << 16
| static_cast<uint32_t>(guid_prefix.value[2]) << 8
| static_cast<uint32_t>(guid_prefix.value[3]);
dds_key[1] = static_cast<uint32_t>(guid_prefix.value[4]) << 24
| static_cast<uint32_t>(guid_prefix.value[5]) << 16
| static_cast<uint32_t>(guid_prefix.value[6]) << 8
| static_cast<uint32_t>(guid_prefix.value[7]);
| static_cast<uint32_t>(guid_prefix.value[5]) << 16
| static_cast<uint32_t>(guid_prefix.value[6]) << 8
| static_cast<uint32_t>(guid_prefix.value[7]);
dds_key[2] = static_cast<uint32_t>(guid_prefix.value[8]) << 24
| static_cast<uint32_t>(guid_prefix.value[9]) << 16
| static_cast<uint32_t>(guid_prefix.value[10]) << 8
| static_cast<uint32_t>(guid_prefix.value[11]);
| static_cast<uint32_t>(guid_prefix.value[9]) << 16
| static_cast<uint32_t>(guid_prefix.value[10]) << 8
| static_cast<uint32_t>(guid_prefix.value[11]);
}

void from_proxy_to_builtin(
Expand Down
2 changes: 1 addition & 1 deletion src/cpp/rtps/builtin/discovery/participant/PDP.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1340,7 +1340,7 @@ void PDP::actions_on_remote_participant_removed(

bool should_be_ignored = false;
listener->on_participant_discovery(mp_RTPSParticipant->getUserRTPSParticipant(), reason,
std::move(info), should_be_ignored);
std::move(info), should_be_ignored);
}

{
Expand Down
6 changes: 4 additions & 2 deletions test/blackbox/api/dds-pim/PubSubReader.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -1686,7 +1686,8 @@ class PubSubReader
}

void setOnDiscoveryFunction(
std::function<bool(const eprosima::fastdds::rtps::ParticipantBuiltinTopicData&, eprosima::fastdds::rtps::PARTICIPANT_DISCOVERY_STATUS)> f)
std::function<bool(const eprosima::fastdds::rtps::ParticipantBuiltinTopicData&,
eprosima::fastdds::rtps::PARTICIPANT_DISCOVERY_STATUS)> f)
{
onDiscovery_ = f;
}
Expand Down Expand Up @@ -2126,7 +2127,8 @@ class PubSubReader
std::string participant_profile_ = "";
std::string datareader_profile_ = "";

std::function<bool(const eprosima::fastdds::rtps::ParticipantBuiltinTopicData& info, eprosima::fastdds::rtps::PARTICIPANT_DISCOVERY_STATUS status)> onDiscovery_;
std::function<bool(const eprosima::fastdds::rtps::ParticipantBuiltinTopicData& info,
eprosima::fastdds::rtps::PARTICIPANT_DISCOVERY_STATUS status)> onDiscovery_;
std::function<bool(const eprosima::fastdds::rtps::WriterDiscoveryInfo& info)> onEndpointDiscovery_;

//! True to take data from history. On False, read_ is checked.
Expand Down
6 changes: 4 additions & 2 deletions test/blackbox/common/BlackboxTestsDiscovery.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -891,7 +891,8 @@ TEST_P(Discovery, PubSubAsReliableHelloworldParticipantDiscovery)
ASSERT_TRUE(writer.isInitialized());

int count = 0;
reader.setOnDiscoveryFunction([&writer, &count](const ParticipantBuiltinTopicData& info, PARTICIPANT_DISCOVERY_STATUS status) -> bool
reader.setOnDiscoveryFunction([&writer, &count](const ParticipantBuiltinTopicData& info,
PARTICIPANT_DISCOVERY_STATUS status) -> bool
{
if (info.guid == writer.participant_guid())
{
Expand Down Expand Up @@ -936,7 +937,8 @@ TEST_P(Discovery, PubSubAsReliableHelloworldUserData)

ASSERT_TRUE(writer.isInitialized());

reader.setOnDiscoveryFunction([&writer](const ParticipantBuiltinTopicData& info, PARTICIPANT_DISCOVERY_STATUS /*status*/) -> bool
reader.setOnDiscoveryFunction([&writer](const ParticipantBuiltinTopicData& info,
PARTICIPANT_DISCOVERY_STATUS /*status*/) -> bool
{
if (info.guid == writer.participant_guid())
{
Expand Down
3 changes: 2 additions & 1 deletion test/blackbox/common/BlackboxTestsSecurity.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2724,7 +2724,8 @@ TEST_P(Security, BuiltinAuthenticationAndCryptoPlugin_user_data)
sub_property_policy.properties().emplace_back("rtps.endpoint.submessage_protection_kind", "ENCRYPT");
sub_property_policy.properties().emplace_back("rtps.endpoint.payload_protection_kind", "ENCRYPT");

reader.setOnDiscoveryFunction([&writer](const ParticipantBuiltinTopicData& info, PARTICIPANT_DISCOVERY_STATUS /*status*/) -> bool
reader.setOnDiscoveryFunction([&writer](const ParticipantBuiltinTopicData& info,
PARTICIPANT_DISCOVERY_STATUS /*status*/) -> bool
{
if (info.guid == writer.participant_guid())
{
Expand Down
4 changes: 3 additions & 1 deletion test/blackbox/common/DDSBlackboxTestsTransportSHMUDP.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,9 @@ static void shm_metatraffic_test(
PubSubWriter<HelloWorldPubSubType> writer(topic_name + "/" + value);
PubSubReader<HelloWorldPubSubType> reader(topic_name + "/" + value);

auto discovery_checker = [unicast, multicast](const eprosima::fastdds::rtps::ParticipantBuiltinTopicData& info, eprosima::fastdds::rtps::PARTICIPANT_DISCOVERY_STATUS /*status*/)
auto discovery_checker =
[unicast, multicast](const eprosima::fastdds::rtps::ParticipantBuiltinTopicData& info,
eprosima::fastdds::rtps::PARTICIPANT_DISCOVERY_STATUS /*status*/)
{
check_shm_locators(info, unicast, multicast);
return true;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,9 @@ class MockParticipantListener : public RTPSParticipantListener
on_participant_discovery_mock(participant, status, info, should_be_ignored);
}

MOCK_METHOD4(on_participant_discovery_mock, void (RTPSParticipant*, PARTICIPANT_DISCOVERY_STATUS, const ParticipantBuiltinTopicData&, bool&));
MOCK_METHOD4(on_participant_discovery_mock,
void (RTPSParticipant*, PARTICIPANT_DISCOVERY_STATUS, const ParticipantBuiltinTopicData&,
bool&));

#if HAVE_SECURITY
void onParticipantAuthentication(
Expand Down

0 comments on commit 02dc073

Please sign in to comment.