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);