@@ -83,7 +83,8 @@ DdsRouterConfiguration dds_test_simple_configuration(
8383 topic_keyed.type_name = " HelloWorldKeyed" ;
8484 topic_keyed.topic_qos .keyed = true ;
8585
86- conf.ddspipe_configuration .builtin_topics .insert (utils::Heritable<core::types::DdsTopic>::make_heritable (topic));
86+ conf.ddspipe_configuration .builtin_topics .insert (utils::Heritable<core::types::DdsTopic>::make_heritable (
87+ topic));
8788 conf.ddspipe_configuration .builtin_topics .insert (utils::Heritable<core::types::DdsTopic>::make_heritable (
8889 topic_keyed));
8990 }
@@ -239,7 +240,9 @@ void test_original_writer_forwarding(
239240 sent_msg.index (samples_sent);
240241 ASSERT_EQ (publisher.publish (sent_msg), eprosima::fastdds::dds::RETCODE_OK );
241242 // Watiting for the message to be received
242- while (samples_received.load () < 1 ){};
243+ while (samples_received.load () < 1 )
244+ {
245+ }
243246 ASSERT_EQ (subscriber.original_writer_guid (), publisher.original_writer_guid ());
244247
245248 // CASE 2: Send message with original_writer_param set to unknown, should be set to other value
@@ -248,7 +251,9 @@ void test_original_writer_forwarding(
248251 params.original_writer_guid (eprosima::fastdds::rtps::GUID_t::unknown ());
249252 ASSERT_EQ (publisher.publish_with_params (sent_msg, params), eprosima::fastdds::dds::RETCODE_OK );
250253 // Watiting for the message to be received
251- while (samples_received.load () < 2 ){};
254+ while (samples_received.load () < 2 )
255+ {
256+ }
252257 ASSERT_EQ (subscriber.original_writer_guid (), publisher.original_writer_guid ());
253258
254259 // CASE 3: Send message with original_writer_param set to some value, value must be kept
@@ -258,13 +263,14 @@ void test_original_writer_forwarding(
258263 params_with_og_writer.original_writer_guid (guid);
259264 ASSERT_EQ (publisher.publish_with_params (sent_msg, params_with_og_writer), eprosima::fastdds::dds::RETCODE_OK );
260265 // Watiting for the message to be received
261- while (samples_received.load () < 2 ){};
266+ while (samples_received.load () < 2 )
267+ {
268+ }
262269 ASSERT_EQ (subscriber.original_writer_guid (), guid);
263270
264271 router.stop ();
265272}
266273
267-
268274} /* namespace test */
269275
270276/* *
0 commit comments