diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1996-11-17 19:55:21 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1996-11-17 19:55:21 +0000 |
commit | 8a0c00861bffa7450a5f0e85c0610c3278f66945 (patch) | |
tree | f06de49d2d57a8cea0bb20129c6079f8ce1eb7a5 /tests/Priority_Buffer_Test.cpp | |
parent | cdaa50473d4305fca20da3227099dcb1de31c1b8 (diff) | |
download | ATCD-8a0c00861bffa7450a5f0e85c0610c3278f66945.tar.gz |
Jammer!
Diffstat (limited to 'tests/Priority_Buffer_Test.cpp')
-rw-r--r-- | tests/Priority_Buffer_Test.cpp | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/tests/Priority_Buffer_Test.cpp b/tests/Priority_Buffer_Test.cpp index 1b436414603..cf0804d8713 100644 --- a/tests/Priority_Buffer_Test.cpp +++ b/tests/Priority_Buffer_Test.cpp @@ -21,14 +21,12 @@ #include "ace/Log_Msg.h" #include "ace/Message_Queue.h" -#include "ace/Thread_Manager.h" #include "ace/Service_Config.h" #include "test_config.h" #if defined (ACE_HAS_THREADS) // Global thread manager. -static ACE_Thread_Manager thr_mgr; static int count = 0; // Make the queue be capable of being *very* large. @@ -87,7 +85,7 @@ static void * producer (ACE_Message_Queue<ACE_MT_SYNCH> *msg_queue) { // Insert thread into thr_mgr. - ACE_Thread_Control thread_control (&thr_mgr); + ACE_Thread_Control thread_control (ACE_Service_Config::thr_mgr ()); ACE_NEW_THREAD; ACE_Message_Block *mb = 0; @@ -133,17 +131,18 @@ producer (ACE_Message_Queue<ACE_MT_SYNCH> *msg_queue) int main (int argc, char *argv[]) { - ACE_START_TEST; + ACE_START_TEST ("Priority_Buffer_Test.cpp"); // Message queue. ACE_Message_Queue<ACE_MT_SYNCH> msg_queue (max_queue); - if (thr_mgr.spawn (ACE_THR_FUNC (producer), (void *) &msg_queue, - THR_NEW_LWP | THR_DETACHED) == -1) + if (ACE_Service_Config::thr_mgr ()->spawn (ACE_THR_FUNC (producer), + (void *) &msg_queue, + THR_NEW_LWP | THR_DETACHED) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "spawn"), 1); // Wait for producer and consumer threads to exit. - thr_mgr.wait (); + ACE_Service_Config::thr_mgr ()->wait (); ACE_END_TEST; return 0; |