Skip to content

Commit

Permalink
add more debug prints
Browse files Browse the repository at this point in the history
  • Loading branch information
alfred2g committed Dec 20, 2023
1 parent 1ba04ec commit 1d009c9
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions tests/Mqtt5ClientTest.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2114,6 +2114,7 @@ static int s_TestMqtt5SharedSubscriptionTest(Aws::Crt::Allocator *allocator, voi
fprintf(stderr, "all packets sent =========\n");
client1_received.get_future().wait();
client2_received.get_future().wait();
fprintf(stderr, "all packets received =========\n");

/* makes sure messages are distrubuted evenly between the two clients*/
ASSERT_INT_EQUALS(5, client1_messages);
Expand All @@ -2124,6 +2125,7 @@ static int s_TestMqtt5SharedSubscriptionTest(Aws::Crt::Allocator *allocator, voi
{
ASSERT_TRUE(receivedMessages[i] > 0);
}
fprintf(stderr, "all packets checked =========\n");

/* Stop all clients */
ASSERT_TRUE(mqtt5Client->Stop());
Expand All @@ -2134,6 +2136,7 @@ static int s_TestMqtt5SharedSubscriptionTest(Aws::Crt::Allocator *allocator, voi
stoppedPromise.get_future().get();
stoppedPromise2.get_future().get();
stoppedPromise3.get_future().get();
fprintf(stderr, "all connections stopped =========\n");

delete subscribe_builder;
delete subscribe_builder2;
Expand Down

0 comments on commit 1d009c9

Please sign in to comment.