Skip to content

feature/chained pubsub #1798

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Nov 20, 2024
Merged

feature/chained pubsub #1798

merged 4 commits into from
Nov 20, 2024

Conversation

rex-schilasky
Copy link
Contributor

Description

Added pubsub unit test to test publishing inside a subscriber callback.

…callback-sub1-pub2->sub2 chain (publishing inside a subscriber callback)
@rex-schilasky rex-schilasky added the cherry-pick-to-NONE Don't cherry-pick these changes label Nov 14, 2024
Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

clang-tidy made some suggestions

@@ -232,3 +232,69 @@ TEST(core_cpp_pubsub, TestPublisherIsSubscribedTiming)
// finalize eCAL API
eCAL::Finalize();
}

TEST(core_cpp_pubsub, TestChainedPublisherSubscriberCallback)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

warning: all parameters should be named in a function [readability-named-parameter]

Suggested change
TEST(core_cpp_pubsub, TestChainedPublisherSubscriberCallback)
TEST(core_cpp_pubsub /*unused*/, TestChainedPublisherSubscriberCallback /*unused*/)

comment out all logging (std::cout)
Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

clang-tidy made some suggestions

exit condition for TestChainedPublisherSubscriberCallback test added
clang-tidy const correctness
pub1_thread.join();
int max_message_loops(100);
while ((subscriber2_received_count < message_count) && (max_message_loops-- > 0))
{
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can you please explain the logic here?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

That loop will run approx. 1 second at maximum (or if all messages sent by by pub2 are received).

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Oh sorry, I see the problem. Fixed it.

@rex-schilasky rex-schilasky merged commit f30230b into master Nov 20, 2024
19 of 20 checks passed
@rex-schilasky rex-schilasky deleted the feature/chained-pubsub branch November 20, 2024 10:58
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
cherry-pick-to-NONE Don't cherry-pick these changes
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants