Skip to content

Commit db23697

Browse files
elianalfelianalf
committed
Refs #21129: Migrate fastrtps namespace to fastdds
Signed-off-by: elianalf <62831776+elianalf@users.noreply.github.com>
1 parent 211ed1e commit db23697

15 files changed

Lines changed: 42 additions & 46 deletions

‎examples/HelloWorldExampleDS/HelloWorldPubSubTypes.cxx‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@
2525
#include "HelloWorldPubSubTypes.h"
2626
#include "HelloWorldCdrAux.hpp"
2727

28-
using SerializedPayload_t = eprosima::fastrtps::rtps::SerializedPayload_t;
29-
using InstanceHandle_t = eprosima::fastrtps::rtps::InstanceHandle_t;
28+
using SerializedPayload_t = eprosima::fastdds::rtps::SerializedPayload_t;
29+
using InstanceHandle_t = eprosima::fastdds::rtps::InstanceHandle_t;
3030
using DataRepresentationId_t = eprosima::fastdds::dds::DataRepresentationId_t;
3131

3232

‎examples/HelloWorldExampleDS/HelloWorldPubSubTypes.h‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -56,18 +56,18 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
5656

5757
eProsima_user_DllExport bool serialize(
5858
void* data,
59-
eprosima::fastrtps::rtps::SerializedPayload_t* payload) override
59+
eprosima::fastdds::rtps::SerializedPayload_t* payload) override
6060
{
6161
return serialize(data, payload, eprosima::fastdds::dds::DEFAULT_DATA_REPRESENTATION);
6262
}
6363

6464
eProsima_user_DllExport bool serialize(
6565
void* data,
66-
eprosima::fastrtps::rtps::SerializedPayload_t* payload,
66+
eprosima::fastdds::rtps::SerializedPayload_t* payload,
6767
eprosima::fastdds::dds::DataRepresentationId_t data_representation) override;
6868

6969
eProsima_user_DllExport bool deserialize(
70-
eprosima::fastrtps::rtps::SerializedPayload_t* payload,
70+
eprosima::fastdds::rtps::SerializedPayload_t* payload,
7171
void* data) override;
7272

7373
eProsima_user_DllExport std::function<uint32_t()> getSerializedSizeProvider(
@@ -82,7 +82,7 @@ class HelloWorldPubSubType : public eprosima::fastdds::dds::TopicDataType
8282

8383
eProsima_user_DllExport bool getKey(
8484
void* data,
85-
eprosima::fastrtps::rtps::InstanceHandle_t* ihandle,
85+
eprosima::fastdds::rtps::InstanceHandle_t* ihandle,
8686
bool force_md5 = false) override;
8787

8888
eProsima_user_DllExport void* createData() override;

‎examples/HelloWorldExampleDS/HelloWorldPublisher.cpp‎

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -33,10 +33,8 @@
3333
#include <fastdds/dds/publisher/qos/DataWriterQos.hpp>
3434
#include <fastdds/utils/IPLocator.h>
3535

36-
using namespace eprosima::fastdds;
37-
using namespace eprosima::fastdds::rtps;
3836
using namespace eprosima::fastdds::dds;
39-
using namespace eprosima::fastrtps::rtps;
37+
using namespace eprosima::fastdds::rtps;
4038

4139
HelloWorldPublisher::HelloWorldPublisher()
4240
: mp_participant(nullptr)
@@ -98,7 +96,7 @@ bool HelloWorldPublisher::init(
9896

9997
participant_qos.wire_protocol().builtin.discovery_config.discoveryProtocol = DiscoveryProtocol_t::CLIENT;
10098
participant_qos.wire_protocol().participant_id = 2;
101-
participant_qos.wire_protocol().builtin.discovery_config.leaseDuration = eprosima::fastrtps::c_TimeInfinite;
99+
participant_qos.wire_protocol().builtin.discovery_config.leaseDuration = eprosima::fastdds::c_TimeInfinite;
102100
participant_qos.name("Participant_pub");
103101

104102
mp_participant = DomainParticipantFactory::get_instance()->create_participant(0, participant_qos);
@@ -115,7 +113,7 @@ bool HelloWorldPublisher::init(
115113
TopicQos topic_qos = TOPIC_QOS_DEFAULT;
116114

117115
topic_qos.history().depth = 30;
118-
topic_qos.history().kind = KEEP_LAST_HISTORY_QOS;
116+
topic_qos.history().kind = eprosima::fastdds::KEEP_LAST_HISTORY_QOS;
119117
topic_qos.resource_limits().max_samples = 50;
120118
topic_qos.resource_limits().allocated_samples = 20;
121119

@@ -124,7 +122,7 @@ bool HelloWorldPublisher::init(
124122

125123
datawriter_qos.reliable_writer_qos().times.heartbeatPeriod.seconds = 2;
126124
datawriter_qos.reliable_writer_qos().times.heartbeatPeriod.nanosec = 0;
127-
datawriter_qos.reliability().kind = RELIABLE_RELIABILITY_QOS;
125+
datawriter_qos.reliability().kind = eprosima::fastdds::RELIABLE_RELIABILITY_QOS;
128126

129127
mp_publisher = mp_participant->create_publisher(publisher_qos);
130128

‎examples/HelloWorldExampleDS/HelloWorldServer.cpp‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@
2727
#include <fastdds/rtps/transport/TCPv6TransportDescriptor.h>
2828
#include <fastdds/utils/IPLocator.h>
2929

30-
using namespace eprosima::fastrtps;
31-
using namespace eprosima::fastrtps::rtps;
30+
using namespace eprosima::fastdds;
31+
using namespace eprosima::fastdds::rtps;
3232

3333
using namespace eprosima::fastdds;
3434
using namespace eprosima::fastdds::dds;

‎examples/HelloWorldExampleDS/HelloWorldSubscriber.cpp‎

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,6 @@
3232
#include <fastdds/dds/subscriber/qos/DataReaderQos.hpp>
3333
#include <fastdds/utils/IPLocator.h>
3434

35-
using namespace eprosima::fastdds;
36-
using namespace eprosima::fastrtps::rtps;
3735
using namespace eprosima::fastdds::rtps;
3836
using namespace eprosima::fastdds::dds;
3937

@@ -94,7 +92,7 @@ bool HelloWorldSubscriber::init(
9492

9593
participant_qos.wire_protocol().builtin.discovery_config.discoveryProtocol = DiscoveryProtocol_t::CLIENT;
9694
participant_qos.wire_protocol().participant_id = 3;
97-
participant_qos.wire_protocol().builtin.discovery_config.leaseDuration = eprosima::fastrtps::c_TimeInfinite;
95+
participant_qos.wire_protocol().builtin.discovery_config.leaseDuration = eprosima::fastdds::c_TimeInfinite;
9896
participant_qos.name("Participant_sub");
9997

10098
mp_participant = DomainParticipantFactory::get_instance()->create_participant(0, participant_qos);
@@ -111,15 +109,15 @@ bool HelloWorldSubscriber::init(
111109
TopicQos topic_qos = TOPIC_QOS_DEFAULT;
112110

113111
topic_qos.history().depth = 30;
114-
topic_qos.history().kind = KEEP_LAST_HISTORY_QOS;
112+
topic_qos.history().kind = eprosima::fastdds::KEEP_LAST_HISTORY_QOS;
115113
topic_qos.resource_limits().max_samples = 50;
116114
topic_qos.resource_limits().allocated_samples = 20;
117115

118116
SubscriberQos subscriber_qos = SUBSCRIBER_QOS_DEFAULT;
119117
DataReaderQos datareader_qos = DATAREADER_QOS_DEFAULT;
120118

121-
datareader_qos.reliability().kind = RELIABLE_RELIABILITY_QOS;
122-
datareader_qos.durability().kind = TRANSIENT_LOCAL_DURABILITY_QOS;
119+
datareader_qos.reliability().kind = eprosima::fastdds::RELIABLE_RELIABILITY_QOS;
120+
datareader_qos.durability().kind = eprosima::fastdds::TRANSIENT_LOCAL_DURABILITY_QOS;
123121

124122
mp_subscriber = mp_participant->create_subscriber(subscriber_qos);
125123

‎examples/HelloWorldExampleDS/HelloWorld_main.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ const option::Descriptor usage[] = {
115115
/*static*/ const std::regex Arg::ipv4(R"(^((?:[0-9]{1,3}\.){3}[0-9]{1,3})?:?(?:(\d+))?$)");
116116
/*static*/ const std::regex Arg::ipv6(R"(^\[?((?:[0-9a-fA-F]{0,4}\:){7}[0-9a-fA-F]{0,4})?(?:\]:)?(?:(\d+))?$)");
117117

118-
using namespace eprosima::fastrtps::rtps;
118+
using namespace eprosima::fastdds::rtps;
119119
using namespace eprosima::fastdds::dds;
120120

121121
int main(int argc, char** argv)

‎include/DiscoveryItem.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ class XMLDocument;
3434
namespace eprosima {
3535
namespace discovery_server {
3636

37-
typedef fastrtps::rtps::GUID_t GUID_t;
37+
typedef fastdds::rtps::GUID_t GUID_t;
3838

3939
//! common discovery info
4040
struct DiscoveryItem

‎include/DiscoveryServerManager.h‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,9 @@
3232

3333
#include "DiscoveryItem.h"
3434

35-
using namespace eprosima::fastrtps;
3635
using namespace eprosima::fastdds;
37-
using namespace eprosima::fastrtps::rtps;
36+
using namespace eprosima::fastdds;
37+
using namespace eprosima::fastdds::rtps;
3838
using namespace eprosima::fastdds::rtps;
3939
using namespace eprosima::fastdds::dds;
4040

@@ -43,14 +43,14 @@ class XMLElement;
4343
} // namespace tinyxml2
4444

4545
namespace eprosima {
46-
namespace fastrtps {
46+
namespace fastdds {
4747
namespace rtps {
4848

4949
class PDP;
5050
class BuiltinProtocols;
5151

5252
} // namespace rtps
53-
} // namespace fastrtps
53+
} // namespace fastdds
5454

5555
namespace discovery_server {
5656

‎include/LateJoiner.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
namespace eprosima {
3131
namespace discovery_server {
3232

33-
using eprosima::fastrtps::rtps::GUID_t;
33+
using eprosima::fastdds::rtps::GUID_t;
3434

3535
class DelayedParticipantDestruction;
3636

‎resources/static_types/HelloWorldPubSubTypes.cxx‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@
2525
#include "HelloWorldPubSubTypes.h"
2626
#include "HelloWorldCdrAux.hpp"
2727

28-
using SerializedPayload_t = eprosima::fastrtps::rtps::SerializedPayload_t;
29-
using InstanceHandle_t = eprosima::fastrtps::rtps::InstanceHandle_t;
28+
using SerializedPayload_t = eprosima::fastdds::rtps::SerializedPayload_t;
29+
using InstanceHandle_t = eprosima::fastdds::rtps::InstanceHandle_t;
3030
using DataRepresentationId_t = eprosima::fastdds::dds::DataRepresentationId_t;
3131

3232

0 commit comments

Comments
 (0)