text: /**************************************************************************/
  /*                                                                        */
  /*       Copyright (c) Microsoft Corporation. All rights reserved.        */
  /*                                                                        */
  /*       This software is licensed under the Microsoft Software License   */
  /*       Terms for Microsoft Azure RTOS. Full text of the license can be  */
  /*       found in the LICENSE file at https://aka.ms/AzureRTOS_EULA       */
  /*       and in the root directory of this software.                      */
  /*                                                                        */
  /**************************************************************************/
  
  /**************************************************************************/
  /**************************************************************************/
  /**                                                                       */ 
  /** Thread-Metric Component                                               */
  /**                                                                       */
  /**   Message Processing Test                                             */
  /**                                                                       */
  /**************************************************************************/
  /**************************************************************************/
  
  
  /**************************************************************************/ 
  /*                                                                        */ 
  /*  FUCTION                                                RELEASE        */ 
  /*                                                                        */ 
  /*    tm_message_processing_test                          PORTABLE C      */ 
  /*                                                           6.1.7        */ 
  /*  AUTHOR                                                                */ 
  /*                                                                        */ 
  /*    William E. Lamie, Microsoft Corporation                             */ 
  /*                                                                        */ 
  /*  DESCRIPTION                                                           */ 
  /*                                                                        */ 
  /*    Basic test for message exchange processing.                         */
  /*                                                                        */ 
  /*  RELEASE HISTORY                                                       */ 
  /*                                                                        */ 
  /*    DATE              NAME                      DESCRIPTION             */ 
  /*                                                                        */ 
  /*  10-15-2021     William E. Lamie         Initial Version 6.1.7         */
  /*                                                                        */ 
  /**************************************************************************/ 
  #include "tm_api.h"
  
  
  /* Define the counters used in the demo application...  */
  
  unsigned long   tm_message_processing_counter;
  unsigned long   tm_message_sent[4];
  unsigned long   tm_message_received[4];
  
  
  /* Define the test thread prototypes.  */
  
  void            tm_message_processing_thread_0_entry(void);
  
  
  /* Define the reporting thread prototype.  */
  
  void            tm_message_processing_thread_report(void);
  
  
  /* Define the initialization prototype.  */
  
  void            tm_message_processing_initialize(void);
  
  
  /* Define main entry point.  */
  
  void tm_main()
  {
  
      /* Initialize the test.  */
      tm_initialize(tm_message_processing_initialize);
  }
  
  
  /* Define the message processing test initialization.  */
  
  void  tm_message_processing_initialize(void)
  {
  
      /* Create thread 0 at priority 10.  */
      tm_thread_create(0, 10, tm_message_processing_thread_0_entry);
  
      /* Resume thread 0.  */
      tm_thread_resume(0);
  
      /* Create a queue for the message passing.  */
      tm_queue_create(0);
  
      /* Create the reporting thread. It will preempt the other 
         threads and print out the test results.  */
      tm_thread_create(5, 2, tm_message_processing_thread_report);
      tm_thread_resume(5);
  }
  
  
  /* Define the message processing thread.  */
  void  tm_message_processing_thread_0_entry(void)
  {
  
      /* Initialize the source message.   */
      tm_message_sent[0] =  0x11112222;
      tm_message_sent[1] =  0x33334444;
      tm_message_sent[2] =  0x55556666;
      tm_message_sent[3] =  0x77778888;
  
      while(1)
      {   	
          /* Send a message to the queue.  */
          tm_queue_send(0, tm_message_sent);
  
          /* Receive a message from the queue.  */
          tm_queue_receive(0, tm_message_received);
  
          /* Check for invalid message.  */
          if (tm_message_received[3] != tm_message_sent[3])
              break;
  
          /* Increment the last word of the 16-byte message.  */
          tm_message_sent[3]++;
  
          /* Increment the number of messages sent and received.  */
          tm_message_processing_counter++;
      }
  }
  
  
  /* Define the message test reporting thread.  */
  void  tm_message_processing_thread_report(void)
  {
  
  unsigned long   last_counter;
  unsigned long   relative_time;
  
  
      /* Initialize the last counter.  */
      last_counter =  0;
  
      /* Initialize the relative time.  */
      relative_time =  0;
  
      while(1)
      {
  
          /* Sleep to allow the test to run.  */
          tm_thread_sleep(TM_TEST_DURATION);
  
          /* Increment the relative time.  */
          relative_time =  relative_time + TM_TEST_DURATION;
  
          /* Print results to the stdio window.  */
          printf("**** Thread-Metric Message Processing Test **** Relative Time: %lu\n", relative_time);
  
          /* See if there are any errors.  */
          if (tm_message_processing_counter == last_counter)
          {
  
              printf("ERROR: Invalid counter value(s). Error sending/receiving messages!\n");
          }
  
          /* Show the time period total.  */
          printf("Time Period Total:  %lu\n\n", tm_message_processing_counter - last_counter);
  
          /* Save the last counter.  */
          last_counter =  tm_message_processing_counter;
      }
  }
  