|
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 |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common