Skip to content

Commit ec901b6

Browse files
committed
Fix infinite loop on original_writer test
Signed-off-by: Emilio Cuesta <[email protected]>
1 parent 4013cad commit ec901b6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ddsrouter_core/test/blackbox/ddsrouter_core/dds/local/DDSTestLocal.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ void test_original_writer_forwarding(
249249
params_with_og_writer.original_writer_info().original_writer_guid(guid);
250250
ASSERT_EQ(publisher.publish_with_params(sent_msg, params_with_og_writer), eprosima::fastdds::dds::RETCODE_OK);
251251
// Waiting for the message to be received
252-
while (samples_received.load() < 3)
252+
while (samples_received.load() < 2)
253253
{
254254
}
255255
ASSERT_EQ(subscriber.original_writer_guid(), guid);
@@ -260,7 +260,7 @@ void test_original_writer_forwarding(
260260
params.original_writer_info(eprosima::fastdds::rtps::OriginalWriterInfo::unknown());
261261
ASSERT_EQ(publisher.publish_with_params(sent_msg, params), eprosima::fastdds::dds::RETCODE_OK);
262262
// Waiting for the message to be received
263-
while (samples_received.load() < 2)
263+
while (samples_received.load() < 3)
264264
{
265265
}
266266
ASSERT_EQ(subscriber.original_writer_guid(), publisher.original_writer_guid());

0 commit comments

Comments
 (0)