@@ -59,16 +59,13 @@ DdsReplayer::DdsReplayer(
59
59
, dyn_publisher_(nullptr )
60
60
{
61
61
// Create Discovery Database
62
- discovery_database_ =
63
- std::make_shared<DiscoveryDatabase>();
62
+ discovery_database_ = std::make_shared<DiscoveryDatabase>();
64
63
65
64
// Create Payload Pool
66
- payload_pool_ =
67
- std::make_shared<FastPayloadPool>();
65
+ payload_pool_ = std::make_shared<FastPayloadPool>();
68
66
69
67
// Create Thread Pool
70
- thread_pool_ =
71
- std::make_shared<SlotThreadPool>(configuration.n_threads );
68
+ thread_pool_ = std::make_shared<SlotThreadPool>(configuration.n_threads );
72
69
73
70
// Create MCAP Reader Participant
74
71
mcap_reader_participant_ = std::make_shared<McapReaderParticipant>(
@@ -127,13 +124,13 @@ DdsReplayer::DdsReplayer(
127
124
}
128
125
}
129
126
130
- // Create the internal communication (built-in) topics
131
- const auto & internal_topic = utils::Heritable<DistributedTopic>::make_heritable (type_object_topic ());
132
- configuration.ddspipe_configuration .builtin_topics .insert (internal_topic);
133
-
134
- // Generate builtin-topics list by combining information from YAML and MCAP files
127
+ // Generate builtin-topics from the topics in the MCAP file
135
128
configuration.ddspipe_configuration .builtin_topics = generate_builtin_topics_ (configuration, input_file);
136
129
130
+ // Create an internal topic to transmit the dynamic types
131
+ configuration.ddspipe_configuration .builtin_topics .insert (
132
+ utils::Heritable<DistributedTopic>::make_heritable (type_object_topic ()));
133
+
137
134
// Create DDS Pipe
138
135
pipe_ = std::make_unique<DdsPipe>(
139
136
configuration.ddspipe_configuration ,
0 commit comments