Skip to content

Commit

Permalink
iox-#910 Set callback function in waitset tests
Browse files Browse the repository at this point in the history
  • Loading branch information
dkroenke committed Sep 23, 2021
1 parent 6c1a632 commit 2886e45
Show file tree
Hide file tree
Showing 4 changed files with 59 additions and 50 deletions.
14 changes: 10 additions & 4 deletions iceoryx_binding_c/test/moduletests/test_notification_info.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -91,6 +91,10 @@ class iox_notification_info_test : public Test
return m_memoryManager.getChunk(chunkSettings);
}

static void triggerCallback(iox_sub_t sub)
{
(void)sub;
}

static UserTrigger* m_lastNotificationCallbackArgument;
ConditionVariableData m_condVar{"myApp"};
Expand Down Expand Up @@ -142,7 +146,7 @@ TEST_F(iox_notification_info_test, notificationOriginIsUserTriggerPointerWhenIts

TEST_F(iox_notification_info_test, notificationOriginIsSubscriberPointerWhenItsOriginatingFromThemStateBased)
{
iox_ws_attach_subscriber_state(&m_waitSet, m_subscriberHandle, SubscriberState_HAS_DATA, 587U, NULL);
iox_ws_attach_subscriber_state(&m_waitSet, m_subscriberHandle, SubscriberState_HAS_DATA, 587U, triggerCallback);
this->Subscribe(&m_portPtr);
m_chunkPusher.push(getChunkFromMemoryManager());

Expand All @@ -154,7 +158,8 @@ TEST_F(iox_notification_info_test, notificationOriginIsSubscriberPointerWhenItsO

TEST_F(iox_notification_info_test, notificationOriginIsSubscriberPointerWhenItsOriginatingFromThemEventBased)
{
iox_ws_attach_subscriber_event(&m_waitSet, m_subscriberHandle, SubscriberEvent_DATA_RECEIVED, 587U, NULL);
iox_ws_attach_subscriber_event(
&m_waitSet, m_subscriberHandle, SubscriberEvent_DATA_RECEIVED, 587U, triggerCallback);
this->Subscribe(&m_portPtr);
m_chunkPusher.push(getChunkFromMemoryManager());

Expand All @@ -178,7 +183,7 @@ TEST_F(iox_notification_info_test, getOriginReturnsPointerToUserTriggerWhenOrigi

TEST_F(iox_notification_info_test, getOriginReturnsPointerToSubscriberWhenOriginatingFromThemStateBased)
{
iox_ws_attach_subscriber_state(&m_waitSet, m_subscriberHandle, SubscriberState_HAS_DATA, 587U, NULL);
iox_ws_attach_subscriber_state(&m_waitSet, m_subscriberHandle, SubscriberState_HAS_DATA, 587U, triggerCallback);
this->Subscribe(&m_portPtr);
m_chunkPusher.push(getChunkFromMemoryManager());

Expand All @@ -190,7 +195,8 @@ TEST_F(iox_notification_info_test, getOriginReturnsPointerToSubscriberWhenOrigin

TEST_F(iox_notification_info_test, getOriginReturnsPointerToSubscriberWhenOriginatingFromThemEventBased)
{
iox_ws_attach_subscriber_event(&m_waitSet, m_subscriberHandle, SubscriberEvent_DATA_RECEIVED, 587U, NULL);
iox_ws_attach_subscriber_event(
&m_waitSet, m_subscriberHandle, SubscriberEvent_DATA_RECEIVED, 587U, triggerCallback);
this->Subscribe(&m_portPtr);
m_chunkPusher.push(getChunkFromMemoryManager());

Expand Down
10 changes: 5 additions & 5 deletions iceoryx_binding_c/test/moduletests/test_subscriber.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -327,32 +327,32 @@ TEST_F(iox_sub_test, sendingTooMuchLeadsToOverflow)

TEST_F(iox_sub_test, attachingToWaitSetWorks)
{
EXPECT_EQ(iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 0U, NULL),
EXPECT_EQ(iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 0U, triggerCallback),
WaitSetResult_SUCCESS);
EXPECT_EQ(m_waitSet->size(), 1U);
}

TEST_F(iox_sub_test, attachingToAnotherWaitsetCleansupAtOriginalWaitset)
{
WaitSetMock m_waitSet2{m_condVar};
iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 0U, NULL);
iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 0U, triggerCallback);

EXPECT_EQ(iox_ws_attach_subscriber_state(&m_waitSet2, m_sut, SubscriberState_HAS_DATA, 0U, NULL),
EXPECT_EQ(iox_ws_attach_subscriber_state(&m_waitSet2, m_sut, SubscriberState_HAS_DATA, 0U, triggerCallback),
WaitSetResult_SUCCESS);
EXPECT_EQ(m_waitSet->size(), 0U);
EXPECT_EQ(m_waitSet2.size(), 1U);
}

TEST_F(iox_sub_test, detachingFromWaitSetWorks)
{
iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 0U, NULL);
iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 0U, triggerCallback);
iox_ws_detach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA);
EXPECT_EQ(m_waitSet->size(), 0U);
}

TEST_F(iox_sub_test, hasDataTriggersWaitSetWithCorrectNotificationId)
{
iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 587U, NULL);
iox_ws_attach_subscriber_state(m_waitSet.get(), m_sut, SubscriberState_HAS_DATA, 587U, triggerCallback);
this->Subscribe(&m_portPtr);
m_chunkPusher.push(getChunkFromMemoryManager());

Expand Down
10 changes: 5 additions & 5 deletions iceoryx_binding_c/test/moduletests/test_user_trigger.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -79,14 +79,14 @@ TEST_F(iox_user_trigger_test, cannotBeTriggeredWhenNotAttached)

TEST_F(iox_user_trigger_test, canBeTriggeredWhenAttached)
{
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 0U, NULL);
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 0U, triggerCallback);
iox_user_trigger_trigger(m_sut);
EXPECT_TRUE(iox_user_trigger_has_triggered(m_sut));
}

TEST_F(iox_user_trigger_test, triggeringWaitSetResultsInCorrectNotificationId)
{
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 88191U, NULL);
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 88191U, triggerCallback);
iox_user_trigger_trigger(m_sut);

auto eventVector = m_waitSet.wait();
Expand All @@ -111,9 +111,9 @@ TEST_F(iox_user_trigger_test, triggeringWaitSetResultsInCorrectCallback)
TEST_F(iox_user_trigger_test, attachingToAnotherWaitSetCleansupFirstWaitset)
{
WaitSetMock m_waitSet2{m_condVar};
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 0U, NULL);
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 0U, triggerCallback);

iox_ws_attach_user_trigger_event(&m_waitSet2, m_sut, 0U, NULL);
iox_ws_attach_user_trigger_event(&m_waitSet2, m_sut, 0U, triggerCallback);

EXPECT_EQ(m_waitSet.size(), 0U);
EXPECT_EQ(m_waitSet2.size(), 1U);
Expand All @@ -122,7 +122,7 @@ TEST_F(iox_user_trigger_test, attachingToAnotherWaitSetCleansupFirstWaitset)
TEST_F(iox_user_trigger_test, disable_trigger_eventingItFromWaitsetCleansup)
{
WaitSetMock m_waitSet2{m_condVar};
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 0U, NULL);
iox_ws_attach_user_trigger_event(&m_waitSet, m_sut, 0U, triggerCallback);

iox_ws_detach_user_trigger_event(&m_waitSet, m_sut);

Expand Down
Loading

0 comments on commit 2886e45

Please sign in to comment.