Skip to content

Commit 649fb3b

Browse files
cferreiragonzmergify[bot]
authored andcommitted
Improve PDPClients initialization (#5459)
* Refs #21433: Add Test Signed-off-by: cferreiragonz <[email protected]> * Refs #21433: Avoid using multicast metatraffic for CLIENTS & SUPER_CLIENTS Signed-off-by: cferreiragonz <[email protected]> * Refs #21433: Typo Signed-off-by: cferreiragonz <[email protected]> --------- Signed-off-by: cferreiragonz <[email protected]> (cherry picked from commit 451847c)
1 parent 28552ce commit 649fb3b

File tree

3 files changed

+30
-4
lines changed

3 files changed

+30
-4
lines changed

src/cpp/rtps/builtin/discovery/participant/PDPClient.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,7 @@ ParticipantProxyData* PDPClient::createParticipantProxyData(
205205
ParticipantProxyData* pdata = add_participant_proxy_data(participant_data.m_guid, is_server, &participant_data);
206206
if (pdata != nullptr)
207207
{
208-
// Clients only assert its server lifeliness, other clients liveliness is provided
208+
// Clients only assert its server liveliness, other clients liveliness is provided
209209
// through server's PDP discovery data
210210
if (is_server)
211211
{

src/cpp/rtps/participant/RTPSParticipantImpl.cpp

+7-3
Original file line numberDiff line numberDiff line change
@@ -2848,9 +2848,13 @@ void RTPSParticipantImpl::get_default_metatraffic_locators(
28482848
{
28492849
uint32_t metatraffic_multicast_port = att.port.getMulticastPort(domain_id_);
28502850

2851-
m_network_Factory.getDefaultMetatrafficMulticastLocators(att.builtin.metatrafficMulticastLocatorList,
2852-
metatraffic_multicast_port);
2853-
m_network_Factory.NormalizeLocators(att.builtin.metatrafficMulticastLocatorList);
2851+
if (m_att.builtin.discovery_config.discoveryProtocol != DiscoveryProtocol::CLIENT &&
2852+
m_att.builtin.discovery_config.discoveryProtocol != DiscoveryProtocol::SUPER_CLIENT)
2853+
{
2854+
m_network_Factory.getDefaultMetatrafficMulticastLocators(att.builtin.metatrafficMulticastLocatorList,
2855+
metatraffic_multicast_port);
2856+
m_network_Factory.NormalizeLocators(att.builtin.metatrafficMulticastLocatorList);
2857+
}
28542858

28552859
m_network_Factory.getDefaultMetatrafficUnicastLocators(att.builtin.metatrafficUnicastLocatorList,
28562860
metatraffic_unicast_port_);

test/unittest/dds/participant/ParticipantTests.cpp

+22
Original file line numberDiff line numberDiff line change
@@ -862,6 +862,28 @@ TEST(ParticipantTests, SimpleParticipantRemoteServerListConfiguration)
862862
EXPECT_EQ(ReturnCode_t::RETCODE_OK, DomainParticipantFactory::get_instance()->delete_participant(participant));
863863
}
864864

865+
/**
866+
* Test that checks a CLIENT participant is not initialized with builtin metatrafficMulticastLocators.
867+
*/
868+
TEST(ParticipantTests, NoBuiltinMetatrafficMulticastForClients)
869+
{
870+
DomainParticipantQos qos;
871+
qos.wire_protocol().builtin.discovery_config.discoveryProtocol = fastdds::rtps::DiscoveryProtocol::CLIENT;
872+
DomainParticipant* participant = DomainParticipantFactory::get_instance()->create_participant(
873+
(uint32_t)GET_PID() % 230, qos);
874+
ASSERT_NE(nullptr, participant);
875+
876+
fastdds::rtps::RTPSParticipantAttributes attributes;
877+
get_rtps_attributes(participant, attributes);
878+
EXPECT_EQ(attributes.builtin.discovery_config.discoveryProtocol, fastdds::rtps::DiscoveryProtocol::CLIENT);
879+
EXPECT_EQ(attributes.builtin.metatrafficMulticastLocatorList.size(), 0);
880+
881+
DomainParticipantQos result_qos = participant->get_qos();
882+
EXPECT_EQ(RETCODE_OK, participant->set_qos(result_qos));
883+
884+
EXPECT_EQ(RETCODE_OK, DomainParticipantFactory::get_instance()->delete_participant(participant));
885+
}
886+
865887

866888
/**
867889
* Test that a SIMPLE participant is transformed into a CLIENT if the variable ROS_SUPER_CLIENT is false and into a SUPERCLIENT if it's true.

0 commit comments

Comments
 (0)