ACE/ace/Base_Thread_Adapter.cpp

   1 #include "ace/Base_Thread_Adapter.h"
   2
   3 #if !defined (ACE_HAS_INLINED_OSCALLS)
   4 # include "ace/Base_Thread_Adapter.inl"
   5 #endif /* ACE_HAS_INLINED_OSCALLS */
   6
   7 #if defined (ACE_HAS_TSS_EMULATION)
   8 #  include "ace/OS_NS_Thread.h"
   9 #endif /* ACE_HAS_TSS_EMULATION */
  10
  11 #include "ace/Service_Config.h"
  12
  13 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  14
  15 ACE_INIT_LOG_MSG_HOOK     ACE_Base_Thread_Adapter::init_log_msg_hook_ = 0;
  16 ACE_INHERIT_LOG_MSG_HOOK  ACE_Base_Thread_Adapter::inherit_log_msg_hook_ = 0;
  17 ACE_CLOSE_LOG_MSG_HOOK    ACE_Base_Thread_Adapter::close_log_msg_hook_ = 0;
  18 ACE_SYNC_LOG_MSG_HOOK     ACE_Base_Thread_Adapter::sync_log_msg_hook_ = 0;
  19 ACE_THR_DESC_LOG_MSG_HOOK ACE_Base_Thread_Adapter::thr_desc_log_msg_hook_ = 0;
  20
  21 ACE_Base_Thread_Adapter::ACE_Base_Thread_Adapter (
  22      ACE_THR_FUNC user_func,
  23      void *arg,
  24      ACE_THR_C_FUNC entry_point,
  25      ACE_OS_Thread_Descriptor *td
  26 #if defined (ACE_HAS_WIN32_STRUCTURAL_EXCEPTIONS)
  27      , ACE_SEH_EXCEPT_HANDLER selector
  28      , ACE_SEH_EXCEPT_HANDLER handler
  29 #endif /* ACE_HAS_WIN32_STRUCTURAL_EXCEPTIONS */
  30      , long cancel_flags
  31    )
  32   : user_func_ (user_func)
  33   , arg_ (arg)
  34   , entry_point_ (entry_point)
  35   , thr_desc_ (td)
  36   , ctx_ (ACE_Service_Config::current())
  37   , flags_ (cancel_flags)
  38 {
  39   ACE_OS_TRACE ("ACE_Base_Thread_Adapter::ACE_Base_Thread_Adapter");
  40
  41   if (ACE_Base_Thread_Adapter::init_log_msg_hook_ != 0)
  42     (*ACE_Base_Thread_Adapter::init_log_msg_hook_) (
  43           this->log_msg_attributes_
  44 # if defined (ACE_HAS_WIN32_STRUCTURAL_EXCEPTIONS)
  45           , selector
  46           , handler
  47 # endif /* ACE_HAS_WIN32_STRUCTURAL_EXCEPTIONS */
  48           );
  49 #ifdef ACE_USES_GPROF
  50   getitimer (ITIMER_PROF, &itimer_);
  51 #endif // ACE_USES_GPROF
  52 }
  53
  54 ACE_Base_Thread_Adapter::~ACE_Base_Thread_Adapter (void)
  55 {
  56 }
  57
  58 void
  59 ACE_Base_Thread_Adapter::inherit_log_msg (void)
  60 {
  61   if (ACE_Base_Thread_Adapter::inherit_log_msg_hook_ != 0)
  62     (*ACE_Base_Thread_Adapter::inherit_log_msg_hook_)(
  63            this->thr_desc_,
  64            this->log_msg_attributes_);
  65
  66   // Initialize the proper configuration context for the new thread
  67   // Placed here since inherit_log_msg() gets called from any of our
  68   // descendants (before self-destructing)
  69   ACE_Service_Config::current (this->ctx_);
  70 }
  71
  72 void
  73 ACE_Base_Thread_Adapter::close_log_msg (void)
  74 {
  75   if (ACE_Base_Thread_Adapter::close_log_msg_hook_ != 0)
  76     (*ACE_Base_Thread_Adapter::close_log_msg_hook_) ();
  77 }
  78
  79 void
  80 ACE_Base_Thread_Adapter::sync_log_msg (const ACE_TCHAR *prg)
  81 {
  82   if (ACE_Base_Thread_Adapter::sync_log_msg_hook_ != 0)
  83     (*ACE_Base_Thread_Adapter::sync_log_msg_hook_) (prg);
  84 }
  85
  86 ACE_OS_Thread_Descriptor::~ACE_OS_Thread_Descriptor (void)
  87 {
  88 }
  89
  90 ACE_OS_Thread_Descriptor *
  91 ACE_Base_Thread_Adapter::thr_desc_log_msg (void)
  92 {
  93   if (ACE_Base_Thread_Adapter::thr_desc_log_msg_hook_ != 0)
  94     return (*ACE_Base_Thread_Adapter::thr_desc_log_msg_hook_) ();
  95   return 0;
  96 }
  97
  98 ACE_END_VERSIONED_NAMESPACE_DECL
  99
 100 // Run the thread entry point for the <ACE_Thread_Adapter>.  This must
 101 // be an extern "C" to make certain compilers happy...
 102
 103 extern "C" ACE_THR_FUNC_RETURN
 104 ACE_THREAD_ADAPTER_NAME (void *args)
 105 {
 106   ACE_OS_TRACE ("ACE_THREAD_ADAPTER_NAME");
 107
 108 #if defined (ACE_HAS_TSS_EMULATION)
 109   // As early as we can in the execution of the new thread, allocate
 110   // its local TS storage.  Allocate it on the stack, to save dynamic
 111   // allocation/dealloction.
 112   void *ts_storage[ACE_TSS_Emulation::ACE_TSS_THREAD_KEYS_MAX];
 113   ACE_TSS_Emulation::tss_open (ts_storage);
 114 #endif /* ACE_HAS_TSS_EMULATION */
 115
 116   ACE_Base_Thread_Adapter * const thread_args =
 117     static_cast<ACE_Base_Thread_Adapter *> (args);
 118
 119 #ifdef ACE_USES_GPROF
 120   setitimer (ITIMER_PROF, thread_args->timerval (), 0);
 121 #endif // ACE_USES_GPROF
 122
 123   // Invoke the user-supplied function with the args.
 124   ACE_THR_FUNC_RETURN status = thread_args->invoke ();
 125
 126   return status;
 127 }
 128