summaryrefslogtreecommitdiff
path: root/tests/TSS_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/TSS_Test.cpp')
-rw-r--r--tests/TSS_Test.cpp302
1 files changed, 0 insertions, 302 deletions
diff --git a/tests/TSS_Test.cpp b/tests/TSS_Test.cpp
deleted file mode 100644
index 9b533796b5f..00000000000
--- a/tests/TSS_Test.cpp
+++ /dev/null
@@ -1,302 +0,0 @@
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// tests
-//
-// = FILENAME
-// TSS_Test.cpp
-//
-// = DESCRIPTION
-// This program tests thread specific storage of data. The ACE_TSS
-// wrapper transparently ensures that the objects of this class
-// will be placed in thread-specific storage. All calls on
-// ACE_TSS::operator->() are delegated to the appropriate method
-// in the Errno class.
-//
-// = AUTHOR
-// Prashant Jain <pjain@cs.wustl.edu> and Doug Schmidt <schmidt@cs.wustl.edu>
-//
-// ============================================================================
-
-#include "test_config.h"
-#include "ace/Synch.h"
-#include "ace/Thread_Manager.h"
-#include "ace/Signal.h"
-#include "TSS_Test_Errno.h"
-
-ACE_RCSID(tests, TSS_Test, "$Id$")
-
-static u_int errors = 0;
-
-#if defined (ACE_HAS_THREADS)
-
-#if defined (ACE_DEFAULT_THREAD_KEYS)
- // If ACE_DEFAULT_THREAD_KEYS is defined, it is probably
- // set to a small value. So that the test doesn't run out
- // of keys quickly in the first thread, set the number of
- // ITERATIONS to be small as well.
- static const int ITERATIONS =
- (ACE_DEFAULT_THREAD_KEYS - ACE_MAX_THREADS) / (2 * ACE_MAX_THREADS) < 2
- ? 1
- : (ACE_DEFAULT_THREAD_KEYS - ACE_MAX_THREADS) / (2 * ACE_MAX_THREADS);
-
-#elif defined (__Lynx__)
- // LynxOS only has 16 native TSS keys, and most of those don't seem
- // to be available.
- static const int ITERATIONS = 1;
-#else
- static const int ITERATIONS = 100;
-#endif /* ACE_DEFAULT_THREAD_KEYS */
-
-// Static variables.
-int Errno::flags_;
-ACE_Thread_Mutex *Errno::lock_ = 0;
-
-// This is our thread-specific error handler . . .
-// See comment below about why it's dynamically allocated.
-static ACE_TSS<Errno> *tss_error;
-
-// This is for testing/demonstrating ACE_TSS_Type_Adapter. It's
-// dynamically allocated to avoid static objects, also.
-static ACE_TSS<ACE_TSS_Type_Adapter<u_int> > *u;
-
-// Serializes output.
-static ACE_Thread_Mutex output_lock;
-
-extern "C" void
-cleanup (void *ptr)
-{
-#if defined (ACE_HAS_PTHREADS_DRAFT4)
- // The intended use of this function doesn't apply with
- // Draft 4 threads. With Draft 4 threads, this function
- // is called implicitly by pthread_setspecific whenever an
- // old value is replaced. This function is intended to be
- // used with Draft 6 and later threads, where it is called
- // on thread termination with the thread-specific value.
-
- // Anyways, for whatever reason, the ACE_DEBUG causes a
- // core dump on LynxOS 2.5.0.
- ACE_UNUSED_ARG (ptr);
-#else /* ! ACE_HAS_PTHREADS_DRAFT4 */
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) in cleanup, ptr = %x\n"), ptr));
-#endif /* ! ACE_HAS_PTHREADS_DRAFT4 */
-
- operator delete (ptr);
-}
-
-// This worker function is the entry point for each thread.
-
-static void *
-worker (void *c)
-{
- int count = *(ACE_static_cast (int*, c));
-
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) worker, iterations = %d\n"), count));
-
- ACE_thread_key_t key = ACE_OS::NULL_key;
- int *ip = 0;
-
- // Make one key that will be available when the thread exits so that
- // we'll have something to cleanup!
-
- if (ACE_Thread::keycreate (&key, cleanup) == -1)
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p (no keys available)\n"),
- ACE_TEXT ("ACE_Thread::keycreate")));
- return (void *) -1;
- }
-
- ACE_NEW_RETURN (ip, int, 0);
-
- if (ACE_Thread::setspecific (key, (void *) ip) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::setspecific")));
-
- for (int i = 0; i < count; i++)
- {
- if (ACE_Thread::keycreate (&key, cleanup) == -1)
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p (no more keys)\n"),
- ACE_TEXT ("ACE_Thread::keycreate")));
- break;
- }
-
- ACE_NEW_RETURN (ip, int, 0);
-
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) in worker at location 1, ")
- ACE_TEXT ("key = %d, ip = %x\n"),
- key, ip));
-
- if (ACE_Thread::setspecific (key, (void *) ip) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::setspecific")));
-
- if (ACE_Thread::getspecific (key, (void **) &ip) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::getspecific")));
-
- if (ACE_Thread::setspecific (key, (void *) 0) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::setspecific")));
-
-#if ! defined (ACE_HAS_PTHREADS_DRAFT4)
- // See comment in cleanup () above.
- delete ip;
-#endif /* ! ACE_HAS_PTHREADS_DRAFT4 */
-
- // We don't do keyfree for ACE_HAS_PTHREADS_DRAFT4 (or 6) since it
- // is not supported there, and will generate an error anyway. Unless
- // ACE_HAS_TSS_EMULATION is turned on, then it should work.
-#if !(defined (ACE_HAS_PTHREADS_DRAFT4) || defined (ACE_HAS_PTHREADS_DRAFT6)) \
- || defined (ACE_HAS_TSS_EMULATION)
- if (ACE_Thread::keyfree (key) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::keyfree")));
-#endif /* !(PTHREADS_DRAFT4 or 6) || defined (ACE_HAS_TSS_EMULATION) */
-
- // Cause an error.
- ACE_OS::read (ACE_INVALID_HANDLE, 0, 0);
-
- // The following two lines set the thread-specific state.
- (*tss_error)->error (errno);
- (*tss_error)->line (__LINE__);
-
- // This sets the static state (note how C++ makes it easy to do
- // both).
- (*tss_error)->flags (count);
-
- {
- // Use the guard to serialize access
- ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, output_lock, 0));
- ACE_ASSERT ((*tss_error)->flags () == ITERATIONS);
- }
-
- // Demonstrate use of ACE_TSS_Type_Adapter to wrap built-in
- // types when used with ACE_TSS. See DESCRIPTION of template
- // class ACE_TSS_Type_Adapter in ace/Synch_T.h for what this
- // should look like. Unfortunately, some compilers have trouble
- // with the implicit type conversions. Others have problems with
- // the *explicit* type conversions.
-#if !defined (ACE_HAS_BROKEN_EXPLICIT_TYPECAST_OPERATOR_INVOCATION)
- (*u)->operator u_int & () = 37;
- if ((*u)->operator u_int () != 37)
- {
- // Use the guard to serialize access to errors.
- ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, output_lock,
- 0));
- ACE_DEBUG ((LM_ERROR,
- ACE_TEXT ("use of ACE_TSS_Type_Adapter failed, value ")
- ACE_TEXT ("is %u, it should be 37!\n"),
- (*u)->operator u_int ()));
- ++errors;
- }
-#endif /* !defined (ACE_HAS_BROKEN_EXPLICIT_TYPECAST_OPERATOR_INVOCATION) */
-
-#if !defined (__Lynx__) || defined (ACE_HAS_TSS_EMULATION)
- key = ACE_OS::NULL_key;
-
- if (ACE_Thread::keycreate (&key, cleanup) == -1)
- {
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p (no more keys)\n"),
- ACE_TEXT ("ACE_Thread::keycreate")));
- break;
- }
-
- ACE_NEW_RETURN (ip, int, 0);
-
- ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) in worker at location 2, ")
- ACE_TEXT ("key = %d, ip = %x\n"),
- key, ip));
-
- if (ACE_Thread::setspecific (key, (void *) ip) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::setspecific")));
-
- if (ACE_Thread::getspecific (key, (void **) &ip) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::getspecific")));
-
- if (ACE_Thread::setspecific (key, (void *) 0) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::setspecific")));
-
-# if !defined (ACE_HAS_PTHREADS_DRAFT4)
- // See comment in cleanup () above.
- delete ip;
-# endif /* ! ACE_HAS_PTHREADS_DRAFT4 */
-
- // We don't do keyfree for ACE_HAS_PTHREADS_DRAFT4 (or 6) since it
- // is not supported there, and will generate an error anyway. Unless
- // ACE_HAS_TSS_EMULATION is turned on, then it should work.
-# if !(defined (ACE_HAS_PTHREADS_DRAFT4) || \
- defined (ACE_HAS_PTHREADS_DRAFT6) ) \
- || defined (ACE_HAS_TSS_EMULATION)
- if (ACE_Thread::keyfree (key) == -1)
- ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%t) %p\n"),
- ACE_TEXT ("ACE_Thread::keyfree")));
-# endif /* !(PTHREADS_DRAFT4 or 6) || defined (ACE_HAS_TSS_EMULATION) */
-#endif /* ! __Lynx__ || ACE_HAS_TSS_EMULATION */
- }
-
- return 0;
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class ACE_TSS<Errno>;
-template class ACE_TSS_Type_Adapter<u_int>;
-template class ACE_TSS<ACE_TSS_Type_Adapter<u_int> >;
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate ACE_TSS<Errno>
-#pragma instantiate ACE_TSS_Type_Adapter<u_int>
-#pragma instantiate ACE_TSS<ACE_TSS_Type_Adapter<u_int> >
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
-
-
-#endif /* ACE_HAS_THREADS */
-
-int
-ACE_TMAIN (int, ACE_TCHAR *[])
-{
- ACE_START_TEST (ACE_TEXT ("TSS_Test"));
-
-#if defined (ACE_HAS_THREADS)
- Errno::allocate_lock ();
-
- const u_int threads = ACE_MAX_THREADS;
-
- // Dynamically allocate TSS_Error so that we can control when it
- // gets deleted. Specifically, we need to delete it before the
- // ACE_Object_Manager destroys the ACE_Allocator. That's because
- // deletion of TSS_Error causes the internal structures of
- // ACE_TSS_Cleanup to be modified, and which in turn uses
- // ACE_Allocator.
- ACE_NEW_RETURN (tss_error, ACE_TSS<Errno>, 1);
-
- // Similarly, dynamically allocate u.
- ACE_NEW_RETURN (u, ACE_TSS<ACE_TSS_Type_Adapter<u_int> >, 1);
-
- int iterations = ITERATIONS;
- if (ACE_Thread_Manager::instance ()->spawn_n
- (threads,
- ACE_THR_FUNC (worker),
- &iterations,
- THR_BOUND) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("%p\n"), ACE_TEXT ("spawn_n")), 1);
-
- ACE_Thread_Manager::instance ()->wait ();
-
- delete u;
- delete tss_error;
-
- Errno::deallocate_lock ();
-#else
- ACE_ERROR ((LM_INFO,
- ACE_TEXT ("threads are not supported on this platform\n")));
-#endif /* ACE_HAS_THREADS */
-
- ACE_END_TEST;
- return errors ? -1 : 0;
-}