ACE/tests/Message_Queue_Test_Ex.h

   1 // -*- C++ -*-
   2
   3 //=============================================================================
   4 /**
   5  * @file Message_Queue_Test_Ex.h
   6  *
   7  * Define class needed for generating templates.
   8  *
   9  * @author Michael Vitlo <mvitalo@sprynet.com>
  10  * @author Irfan Pyarali <irfan@cs.wustl.edu>
  11  * @author David L. Levine <levine@cs.wustl.edu>
  12  * @author Guy Peleg <guy.peleg@amdocs.com>
  13  */
  14 //=============================================================================
  15
  16 #ifndef ACE_TESTS_MESSAGE_QUEUE_TEST_EX_H
  17 #define ACE_TESTS_MESSAGE_QUEUE_TEST_EX_H
  18
  19 #include "ace/OS_NS_string.h"
  20
  21 // User-defined class used for queue data.
  22 class User_Class
  23 {
  24 public:
  25   User_Class (const char inputMsg[])
  26   {
  27     ACE_NEW (this->message_, char[ACE_OS::strlen (inputMsg) + 1]);
  28     ACE_OS::strcpy (this->message_, inputMsg);
  29   }
  30
  31   ~User_Class () { delete [] this->message_; }
  32
  33   const char *message () const
  34   {
  35     return this->message_;
  36   }
  37
  38   // This is for checking the ACE_Message_Queue_Ex_N
  39   User_Class *next () const
  40   {
  41     return this->next_;
  42   }
  43
  44   void next (User_Class *uc)
  45   {
  46     this->next_ = uc;
  47   }
  48
  49 private:
  50   char *message_ {};
  51   User_Class *next_ {};
  52 };
  53
  54 // The main tests for the ACE_Message_Queue_Ex_N
  55 struct Receive_Messages;
  56
  57 class MQ_Ex_N_Tester
  58 {
  59 public:
  60   int single_thread_performance_test ();
  61
  62 #if defined (ACE_HAS_THREADS)
  63   int performance_test ();
  64
  65   /// Sender runs with an autonomous thread
  66   static ACE_THR_FUNC_RETURN sender (void *);
  67
  68   /// Receiver runs with an autonomous thread
  69   static ACE_THR_FUNC_RETURN receiver (void *);
  70
  71   /// Multi threaded tests use this queue
  72   ACE_Message_Queue_Ex_N<User_Class, ACE_MT_SYNCH>   mt_queue_;
  73 #endif /* ACE_HAS_THREADS */
  74
  75   /// Single threaded tests use this queue
  76   ACE_Message_Queue_Ex_N<User_Class, ACE_NULL_SYNCH> st_queue_;
  77
  78 private:
  79   /// Helper methods
  80   int test_enqueue_head ();
  81   int test_enqueue_tail ();
  82 };
  83
  84 #endif /* ACE_TESTS_MESSAGE_QUEUE_TEST_EX_H */