diff options
Diffstat (limited to 'tests/Thread_Manager_Test.cpp')
| -rw-r--r-- | tests/Thread_Manager_Test.cpp | 265 |
1 files changed, 0 insertions, 265 deletions
diff --git a/tests/Thread_Manager_Test.cpp b/tests/Thread_Manager_Test.cpp deleted file mode 100644 index 63619537650..00000000000 --- a/tests/Thread_Manager_Test.cpp +++ /dev/null @@ -1,265 +0,0 @@ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// tests -// -// = FILENAME -// Thread_Manager_Test.cpp -// -// = DESCRIPTION -// This program tests the group management mechanisms provided by -// the <ACE_Thread_Manager>, including the group signal handling, -// group suspension and resumption, and cooperative thread -// cancellation mechanisms. -// -// = AUTHOR -// Prashant Jain and Douglas C. Schmidt -// -// ============================================================================ - -#include "test_config.h" -#include "ace/Thread_Manager.h" -#include "ace/Signal.h" - -ACE_RCSID(tests, Thread_Manager_Test, "$Id$") - -#if defined(__BORLANDC__) && __BORLANDC__ >= 0x0530 -USELIB("..\ace\aced.lib"); -//--------------------------------------------------------------------------- -#endif /* defined(__BORLANDC__) && __BORLANDC__ >= 0x0530 */ - -#if defined (ACE_HAS_THREADS) - -#include "Thread_Manager_Test.h" - -// Each thread keeps track of whether it has been signaled within a -// separate TSS entry. See comment below about why it's allocated -// dynamically. -static ACE_TSS<Signal_Catcher> *signal_catcher = 0; - -// Synchronize starts of threads, so that they all start before the -// main thread cancels them. To avoid creating a static object, it -// is dynamically allocated, before spawning any threads. -static ACE_Barrier *thread_start; - -extern "C" void -handler (int signum) -{ - if (signal_catcher) - { - ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) received signal %d, signaled = %d\n"), - signum, - (*signal_catcher)->signaled ())); - (*signal_catcher)->signaled (1); - } -} - -static void * -worker (int iterations) -{ -#if defined (VXWORKS) - ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("(%P|%t) %s: stack size is %u\n"), - ACE_OS::thr_self (), ACE_OS::thr_min_stack ())); -#endif /* VXWORKS */ - -#if !defined (ACE_LACKS_UNIX_SIGNALS) - // Cache a pointer to this thread's Signal_Catcher. That way, we - // try to avoid dereferencing signal_catcher below in a thread that - // hasn't terminated when main exits. That shouldn't happen, but it - // seems to on Linux and LynxOS. - if (!signal_catcher) - { - ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) (worker): signal catcher is 0!!!!\n"))); - return (void *) -1; - } - - Signal_Catcher *my_signal_catcher = *signal_catcher; - - if (my_signal_catcher == 0) - { - ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) (worker): *signal catcher is 0!!!!\n"))); - return (void *) -1; - } - - ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance (); -#endif /* ! ACE_LACKS_UNIX_SIGNAL */ - - // After setting up the signal catcher, block on the start barrier. - thread_start->wait (); - - ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) worker starting loop\n"))); - - for (int i = 0; i < iterations; i++) - { - if ((i % 1000) == 0) - { -#if !defined (ACE_LACKS_UNIX_SIGNALS) - if (my_signal_catcher->signaled () > 0 && - // Only test for cancellation after we've been signaled, - // to avoid race conditions for suspend() and resume(). - thr_mgr->testcancel (ACE_Thread::self ()) != 0) - { - ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) has been cancelled before iteration %d!\n"), - i)); - break; - } -#endif /* ! ACE_LACKS_UNIX_SIGNAL */ - ACE_OS::sleep (1); - } - } - - // Destructor removes thread from Thread_Manager. - return 0; -} - -static const int DEFAULT_THREADS = ACE_MAX_THREADS; -static const int DEFAULT_ITERATIONS = 10000; - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_TSS<Signal_Catcher>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_TSS<Signal_Catcher> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ - -#endif /* ACE_HAS_THREADS */ - -int -main (int, ASYS_TCHAR *[]) -{ - ACE_START_TEST (ASYS_TEXT ("Thread_Manager_Test")); - -#if defined (ACE_HAS_THREADS) - int n_threads = DEFAULT_THREADS; - int n_iterations = DEFAULT_ITERATIONS; - - // Dynamically allocate signal_catcher so that we can control when - // it gets deleted. Specifically, we need to delete it before the - // main thread's TSS is cleaned up. - ACE_NEW_RETURN (signal_catcher, ACE_TSS<Signal_Catcher>, 1); - - // And similarly, dynamically allocate the thread_start barrier. - ACE_NEW_RETURN (thread_start, ACE_Barrier (n_threads + 1), -1); - - // Register a signal handler. - ACE_Sig_Action sa ((ACE_SignalHandler) handler, SIGINT); - ACE_UNUSED_ARG (sa); - - ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance (); - -#if defined (VXWORKS) - // Assign thread (VxWorks task) names to test that feature. - ACE_thread_t *thread_name; - ACE_NEW_RETURN (thread_name, ACE_thread_t[n_threads], -1); - - // And test the ability to specify stack size. - size_t *stack_size; - ACE_NEW_RETURN (stack_size, size_t[n_threads], -1); - - int i; - - for (i = 0; i < n_threads; ++i) - { - if (i < n_threads - 1) - { - ACE_NEW_RETURN (thread_name[i], char[32], -1); - ACE_OS::sprintf (thread_name[i], ASYS_TEXT ("thread%u"), i); - } - else - // Pass an ACE_thread_t pointer of 0 for the last thread name. - thread_name[n_threads - 1] = 0; - - stack_size[i] = 40000; - } -#endif /* VXWORKS */ - - int grp_id = thr_mgr->spawn_n - ( -#if defined (VXWORKS) - thread_name, -#endif /* VXWORKS */ - n_threads, - (ACE_THR_FUNC) worker, - (void *) n_iterations, - THR_BOUND | THR_DETACHED -#if defined (VXWORKS) - , ACE_DEFAULT_THREAD_PRIORITY - , -1 - , 0 - , stack_size -#endif /* VXWORKS */ - ); - - ACE_ASSERT (grp_id != -1); - thread_start->wait (); - - // Pthreads doesn't do suspend/resume. -#if !defined (ACE_HAS_PTHREADS) - // Wait for 1 second and then suspend every thread in the group. - ACE_OS::sleep (1); - ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("(%t) suspending group\n"))); - - ACE_ASSERT (thr_mgr->suspend_grp (grp_id) != -1); - - // Wait for 1 more second and then resume every thread in the - // group. - ACE_OS::sleep (ACE_Time_Value (1)); - - ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("(%t) resuming group\n"))); - - ACE_ASSERT (thr_mgr->resume_grp (grp_id) != -1); -#endif /* ! ACE_HAS_PTHREADS */ - - // Wait for 1 more second and then send a SIGINT to every thread in - // the group. - ACE_OS::sleep (ACE_Time_Value (1)); - - ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("(%t) signaling group\n"))); - -#if defined (ACE_HAS_WTHREADS) - thr_mgr->kill_grp (grp_id, SIGINT); -#elif !defined (ACE_HAS_PTHREADS_DRAFT4) - ACE_ASSERT (thr_mgr->kill_grp (grp_id, SIGINT) != -1); -#endif /* ACE_HAS_WTHREADS */ - - // Wait for 1 more second and then cancel all the threads. - ACE_OS::sleep (ACE_Time_Value (1)); - - ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("(%t) cancelling group\n"))); - - ACE_ASSERT (thr_mgr->cancel_grp (grp_id) != -1); - - // Perform a barrier wait until all the threads have shut down. - ACE_ASSERT (thr_mgr->wait () != -1); - - ACE_DEBUG ((LM_DEBUG, ASYS_TEXT ("(%t) main thread finished\n"))); - -#if defined (VXWORKS) - for (i = 0; i < n_threads - 1; ++i) - { - delete [] thread_name[i]; - // Don't delete the last thread_name, because it points - // to the name in the TCB. It was initially 0. - } - delete [] thread_name; - delete [] stack_size; -#endif /* VXWORKS */ - - delete thread_start; - thread_start = 0; - delete signal_catcher; - signal_catcher = 0; - -#else - ACE_ERROR ((LM_ERROR, ASYS_TEXT ("threads not supported on this platform\n"))); -#endif /* ACE_HAS_THREADS */ - - ACE_END_TEST; - return 0; -} |