version 1.56, 2006/08/30 19:10:02
|
version 1.57, 2006/09/13 21:05:37
|
|
|
static AsyncOpNode *get_op(); | static AsyncOpNode *get_op(); |
void return_op(AsyncOpNode *op); | void return_op(AsyncOpNode *op); |
| |
static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *); |
|
static ThreadReturnType PEGASUS_THREAD_CDECL kill_idle_threads(void *); |
|
static ThreadPool *get_thread_pool(); | static ThreadPool *get_thread_pool(); |
|
static void cleanupThreadPool(); |
| |
Uint32 _mask; | Uint32 _mask; |
AtomicInt _die; | AtomicInt _die; |
|
|
static cimom *_meta_dispatcher; | static cimom *_meta_dispatcher; |
static AtomicInt _service_count; | static AtomicInt _service_count; |
static Mutex _meta_dispatcher_mutex; | static Mutex _meta_dispatcher_mutex; |
|
static ThreadPool *_thread_pool; |
| |
private: | private: |
|
static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *); |
|
static ThreadReturnType PEGASUS_THREAD_CDECL kill_idle_threads(void *); |
|
|
AsyncQueue<AsyncOpNode> _incoming; | AsyncQueue<AsyncOpNode> _incoming; |
static Thread* _polling_thread; | static Thread* _polling_thread; |
static Semaphore _polling_sem; | static Semaphore _polling_sem; |
|
|
| |
AtomicInt _incoming_queue_shutdown; | AtomicInt _incoming_queue_shutdown; |
| |
protected: |
|
static ThreadPool *_thread_pool; |
|
|
|
private: |
|
struct timeval _default_op_timeout; | struct timeval _default_op_timeout; |
|
|
friend class cimom; | friend class cimom; |
friend class CIMServer; |
|
}; | }; |
| |
PEGASUS_NAMESPACE_END | PEGASUS_NAMESPACE_END |