From 1d009c911ab6ef22e9debf9f08ef59e5ce03fc99 Mon Sep 17 00:00:00 2001 From: Alfred Gedeon Date: Tue, 19 Dec 2023 23:37:06 -0800 Subject: [PATCH] add more debug prints --- tests/Mqtt5ClientTest.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/tests/Mqtt5ClientTest.cpp b/tests/Mqtt5ClientTest.cpp index f5d85b937..f3bbb91aa 100644 --- a/tests/Mqtt5ClientTest.cpp +++ b/tests/Mqtt5ClientTest.cpp @@ -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); @@ -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()); @@ -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;