diff options
Diffstat (limited to 'src/components/utils/test/message_queue_test.cc')
-rw-r--r-- | src/components/utils/test/message_queue_test.cc | 55 |
1 files changed, 31 insertions, 24 deletions
diff --git a/src/components/utils/test/message_queue_test.cc b/src/components/utils/test/message_queue_test.cc index 8ce7196b07..d80016c6a8 100644 --- a/src/components/utils/test/message_queue_test.cc +++ b/src/components/utils/test/message_queue_test.cc @@ -43,21 +43,20 @@ using ::utils::MessageQueue; class MessageQueueTest : public testing::Test { public: MessageQueueTest() - : test_val_1("Hello,"), - test_val_2("Beautiful "), - test_val_3("World!"), - test_line(""), - check_value(false) { - } + : test_val_1("Hello,") + , test_val_2("Beautiful ") + , test_val_3("World!") + , test_line("") + , check_value(false) {} void add_one_element_to_queue(); void extract_from_queue(); void add_three_elements_to_queue(); void ShutDownQueue(); - static void* add_one_element_to_queue_helper(void *context); - static void* extract_from_queue_helper(void *context); - static void* add_three_elements_to_queue_helper(void *context); - static void* ShutDownQueue_helper(void *context); + static void* add_one_element_to_queue_helper(void* context); + static void* extract_from_queue_helper(void* context); + static void* add_three_elements_to_queue_helper(void* context); + static void* ShutDownQueue_helper(void* context); protected: MessageQueue<std::string> test_queue; @@ -96,20 +95,20 @@ void MessageQueueTest::ShutDownQueue() { pthread_exit(NULL); } -void* MessageQueueTest::add_one_element_to_queue_helper(void *context) { - (reinterpret_cast<MessageQueueTest *>(context))->add_one_element_to_queue(); +void* MessageQueueTest::add_one_element_to_queue_helper(void* context) { + (reinterpret_cast<MessageQueueTest*>(context))->add_one_element_to_queue(); return NULL; } -void* MessageQueueTest::extract_from_queue_helper(void *context) { - (reinterpret_cast<MessageQueueTest *>(context))->extract_from_queue(); +void* MessageQueueTest::extract_from_queue_helper(void* context) { + (reinterpret_cast<MessageQueueTest*>(context))->extract_from_queue(); return NULL; } -void* MessageQueueTest::add_three_elements_to_queue_helper(void *context) { - (reinterpret_cast<MessageQueueTest *>(context))->add_three_elements_to_queue(); +void* MessageQueueTest::add_three_elements_to_queue_helper(void* context) { + (reinterpret_cast<MessageQueueTest*>(context))->add_three_elements_to_queue(); return NULL; } -void* MessageQueueTest::ShutDownQueue_helper(void *context) { - (reinterpret_cast<MessageQueueTest *>(context))->ShutDownQueue(); +void* MessageQueueTest::ShutDownQueue_helper(void* context) { + (reinterpret_cast<MessageQueueTest*>(context))->ShutDownQueue(); return NULL; } @@ -119,9 +118,13 @@ TEST_F(MessageQueueTest, DefaultCtorTest_ExpectEmptyQueueCreated) { ASSERT_EQ(test_value, test_queue.empty()); } -TEST_F(MessageQueueTest, MessageQueuePushThreeElementsTest_ExpectThreeElementsAdded) { +TEST_F(MessageQueueTest, + MessageQueuePushThreeElementsTest_ExpectThreeElementsAdded) { pthread_t thread1; - pthread_create(&thread1, NULL, &MessageQueueTest::add_three_elements_to_queue_helper, this); + pthread_create(&thread1, + NULL, + &MessageQueueTest::add_three_elements_to_queue_helper, + this); pthread_join(thread1, NULL); // check if 3 elements were added successfully ASSERT_EQ(3u, test_queue.size()); @@ -140,12 +143,15 @@ TEST_F(MessageQueueTest, NotEmptyMessageQueueResetTest_ExpectEmptyQueue) { ASSERT_EQ(0u, test_queue.size()); } -TEST_F(MessageQueueTest, MessageQueuePopOneElementTest_ExpectOneElementRemovedFromQueue) { +TEST_F(MessageQueueTest, + MessageQueuePopOneElementTest_ExpectOneElementRemovedFromQueue) { pthread_t thread1; pthread_t thread2; // Creating threads with thread function mentioned above - pthread_create(&thread1, NULL, &MessageQueueTest::add_one_element_to_queue_helper, this); - pthread_create(&thread2, NULL, &MessageQueueTest::extract_from_queue_helper, this); + pthread_create( + &thread1, NULL, &MessageQueueTest::add_one_element_to_queue_helper, this); + pthread_create( + &thread2, NULL, &MessageQueueTest::extract_from_queue_helper, this); // Primary thread waits until thread 2 to be finished pthread_join(thread2, NULL); // Check if first element was removed successfully @@ -154,7 +160,8 @@ TEST_F(MessageQueueTest, MessageQueuePopOneElementTest_ExpectOneElementRemovedFr ASSERT_EQ(0u, test_queue.size()); } -TEST_F(MessageQueueTest, MessageQueueShutdownTest_ExpectMessageQueueWillBeShutDown) { +TEST_F(MessageQueueTest, + MessageQueueShutdownTest_ExpectMessageQueueWillBeShutDown) { pthread_t thread1; // Creating thread with thread function mentioned above pthread_create(&thread1, NULL, &MessageQueueTest::ShutDownQueue_helper, this); |