niklas/cyclonedds
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix writer-reader sync in secure_communication tests

Browse source 
Signed-off-by: Dennis Potman <dennis.potman@adlinktech.com>
This commit is contained in:
Dennis Potman 2020-03-02 14:58:31 +01:00 • committed by eboasson
parent 28aa06915e
commit 8f464e0c99
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/security/core/tests/secure_communication.c
View file

@ -252,11 +252,11 @@ static void test_fini(size_t n_sub_domain, size_t n_pub_domain)
static void sync_writer_to_readers(dds_entity_t pub_participant, dds_entity_t writer, size_t n_exp_rd) static void sync_writer_to_readers(dds_entity_t pub_participant, dds_entity_t writer, size_t n_exp_rd)
{ {
size_t found = 0;
dds_attach_t triggered; dds_attach_t triggered;
dds_return_t ret; dds_return_t ret;
dds_entity_t waitset_wr = dds_create_waitset (pub_participant); dds_entity_t waitset_wr = dds_create_waitset (pub_participant);
CU_ASSERT_FATAL (waitset_wr > 0); CU_ASSERT_FATAL (waitset_wr > 0);
dds_publication_matched_status_t pub_matched;
/* Sync writer to reader. */ /* Sync writer to reader. */
ret = dds_waitset_attach (waitset_wr, writer, writer); ret = dds_waitset_attach (waitset_wr, writer, writer);
@ -266,7 +266,9 @@ static void sync_writer_to_readers(dds_entity_t pub_participant, dds_entity_t wr
ret = dds_waitset_wait (waitset_wr, &triggered, 1, DDS_SECS(5)); ret = dds_waitset_wait (waitset_wr, &triggered, 1, DDS_SECS(5));
CU_ASSERT_FATAL (ret >= 1); CU_ASSERT_FATAL (ret >= 1);
CU_ASSERT_EQUAL_FATAL (writer, (dds_entity_t)(intptr_t) triggered); CU_ASSERT_EQUAL_FATAL (writer, (dds_entity_t)(intptr_t) triggered);
if ((found += (size_t)ret) >= n_exp_rd) ret = dds_get_publication_matched_status(writer, &pub_matched);
CU_ASSERT_EQUAL_FATAL (ret, DDS_RETCODE_OK);
if (pub_matched.total_count >= n_exp_rd)
break; break;
}; };
dds_delete (waitset_wr); dds_delete (waitset_wr);