summaryrefslogtreecommitdiff
path: root/ACE/tests/Message_Queue_Test_Ex.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/tests/Message_Queue_Test_Ex.cpp')
-rw-r--r--ACE/tests/Message_Queue_Test_Ex.cpp65
1 files changed, 30 insertions, 35 deletions
diff --git a/ACE/tests/Message_Queue_Test_Ex.cpp b/ACE/tests/Message_Queue_Test_Ex.cpp
index d13faea21a0..0dc5a19f6e7 100644
--- a/ACE/tests/Message_Queue_Test_Ex.cpp
+++ b/ACE/tests/Message_Queue_Test_Ex.cpp
@@ -1,28 +1,24 @@
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// tests
-//
-// = FILENAME
-// Message_Queue_Test_Ex.cpp
-//
-// = DESCRIPTION
-// This is:
-// 1. A simple test of the ACE_Message_Queue_Ex that executes
-// a performance measurement test for both single-threaded
-// (null synch) and thread-safe ACE_Message_Queue_Ex
-// instantiations.
-// 2. An example of using a user-defined class to parameterize
-// ACE_Message_Queue_Ex.
-//
-// = AUTHORS
-// Michael Vitlo <mvitalo@sprynet.com>, copied the code from:
-// Irfan Pyarali <irfan@cs.wustl.edu> and
-// David L. Levine <levine@cs.wustl.edu>
-//
-// ============================================================================
+
+//=============================================================================
+/**
+ * @file Message_Queue_Test_Ex.cpp
+ *
+ * $Id$
+ *
+ * This is:
+ * 1. A simple test of the ACE_Message_Queue_Ex that executes
+ * a performance measurement test for both single-threaded
+ * (null synch) and thread-safe ACE_Message_Queue_Ex
+ * instantiations.
+ * 2. An example of using a user-defined class to parameterize
+ * ACE_Message_Queue_Ex.
+ *
+ *
+ * @author Michael Vitlo <mvitalo@sprynet.com>
+ * @author copied the code from: Irfan Pyarali <irfan@cs.wustl.edu> and David L. Levine <levine@cs.wustl.edu>
+ */
+//=============================================================================
+
#include "test_config.h"
#include "ace/Thread_Manager.h"
@@ -70,26 +66,25 @@ print_message (const ACE_TCHAR *message)
#if defined (ACE_HAS_THREADS)
typedef ACE_Message_Queue_Ex<User_Class, ACE_MT_SYNCH> SYNCH_QUEUE;
+/**
+ * Container for data passed to sender and receiver in
+ * performance test.
+ *
+ * For use in multithreaded performance test.
+ */
struct Queue_Wrapper
{
- // = TITLE
- // Container for data passed to sender and receiver in
- // performance test.
- //
- // = DESCRIPTION
- // For use in multithreaded performance test.
-
+ /// The message queue.
SYNCH_QUEUE *q_;
- // The message queue.
+ /// Pointer to messages blocks for sender to send to reciever.
User_Class **send_block_;
- // Pointer to messages blocks for sender to send to reciever.
+ /// Default constructor.
Queue_Wrapper (void)
: q_ (0), send_block_ (0)
{
}
- // Default constructor.
};
struct MQ_Ex_N_Tester_Wrapper