00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013 #ifndef ACE_BASE_THREAD_ADAPTER_H
00014 #define ACE_BASE_THREAD_ADAPTER_H
00015 #include "ace/pre.h"
00016
00017 #include "ace/OS_Log_Msg_Attributes.h"
00018
00019 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00020 # pragma once
00021 #endif
00022
00023 #include "ace/ACE_export.h"
00024 #include "ace/OS_Log_Msg_Attributes.h"
00025
00026 #ifdef ACE_USES_GPROF
00027 #include "os_include/sys/os_time.h"
00028 #endif // ACE_USES_GPROF
00029
00030 #if (defined (ACE_HAS_VERSIONED_NAMESPACE) && ACE_HAS_VERSIONED_NAMESPACE == 1)
00031 # define ACE_THREAD_ADAPTER_NAME ACE_PREPROC_CONCATENATE(ACE_VERSIONED_NAMESPACE_NAME, _ace_thread_adapter)
00032 #else
00033 # define ACE_THREAD_ADAPTER_NAME ace_thread_adapter
00034 #endif
00035
00036
00037
00038
00039 extern "C" ACE_Export ACE_THR_FUNC_RETURN ACE_THREAD_ADAPTER_NAME (void *args);
00040
00041 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
00042
00043
00044
00045
00046
00047
00048
00049
00050
00051 class ACE_Export ACE_OS_Thread_Descriptor
00052 {
00053 public:
00054
00055 long flags (void) const;
00056
00057 protected:
00058
00059 ACE_OS_Thread_Descriptor (long flags = 0);
00060
00061
00062
00063
00064
00065
00066
00067 long flags_;
00068 };
00069
00070
00071
00072
00073
00074
00075
00076
00077
00078
00079
00080
00081
00082
00083
00084
00085
00086 class ACE_Export ACE_Base_Thread_Adapter
00087 {
00088 public:
00089
00090 virtual ~ACE_Base_Thread_Adapter (void);
00091
00092
00093 virtual ACE_THR_FUNC_RETURN invoke (void) = 0;
00094
00095
00096
00097 ACE_THR_C_FUNC entry_point (void);
00098
00099 #ifdef ACE_USES_GPROF
00100
00101
00102 struct itimerval* timerval (void);
00103 #endif // ACE_USES_PROF
00104
00105
00106 static void close_log_msg (void);
00107
00108
00109 static void sync_log_msg (const ACE_TCHAR *prog_name);
00110
00111
00112 static ACE_OS_Thread_Descriptor *thr_desc_log_msg (void);
00113
00114 protected:
00115
00116 ACE_Base_Thread_Adapter (ACE_THR_FUNC user_func,
00117 void *arg,
00118 ACE_THR_C_FUNC entry_point = (ACE_THR_C_FUNC) ACE_THREAD_ADAPTER_NAME,
00119 ACE_OS_Thread_Descriptor *td = 0
00120 # if defined (ACE_HAS_WIN32_STRUCTURAL_EXCEPTIONS)
00121 , ACE_SEH_EXCEPT_HANDLER selector = 0
00122 , ACE_SEH_EXCEPT_HANDLER handler = 0
00123 # endif
00124 );
00125
00126
00127 void inherit_log_msg (void);
00128
00129 private:
00130
00131 static ACE_INIT_LOG_MSG_HOOK init_log_msg_hook_;
00132 static ACE_INHERIT_LOG_MSG_HOOK inherit_log_msg_hook_;
00133 static ACE_CLOSE_LOG_MSG_HOOK close_log_msg_hook_;
00134 static ACE_SYNC_LOG_MSG_HOOK sync_log_msg_hook_;
00135 static ACE_THR_DESC_LOG_MSG_HOOK thr_desc_log_msg_hook_;
00136
00137
00138 static void set_log_msg_hooks (ACE_INIT_LOG_MSG_HOOK init_hook,
00139 ACE_INHERIT_LOG_MSG_HOOK inherit_hook,
00140 ACE_CLOSE_LOG_MSG_HOOK close_hook,
00141 ACE_SYNC_LOG_MSG_HOOK sync_hook,
00142 ACE_THR_DESC_LOG_MSG_HOOK thr_desc);
00143
00144
00145 friend class ACE_Log_Msg;
00146
00147 protected:
00148
00149 ACE_THR_FUNC user_func_;
00150
00151
00152 void *arg_;
00153
00154
00155
00156 ACE_THR_C_FUNC entry_point_;
00157
00158
00159
00160
00161
00162
00163
00164 ACE_OS_Thread_Descriptor *thr_desc_;
00165
00166
00167 ACE_OS_Log_Msg_Attributes log_msg_attributes_;
00168
00169 #ifdef ACE_USES_GPROF
00170 struct itimerval itimer_;
00171 #endif // ACE_USES_GPROF
00172
00173 };
00174
00175 ACE_END_VERSIONED_NAMESPACE_DECL
00176
00177 # if defined (ACE_HAS_INLINED_OSCALLS)
00178 # if defined (ACE_INLINE)
00179 # undef ACE_INLINE
00180 # endif
00181 # define ACE_INLINE inline
00182 # include "ace/Base_Thread_Adapter.inl"
00183 # endif
00184
00185 #include "ace/post.h"
00186 #endif