version 1.65, 2008/10/21 17:11:13
|
version 1.66, 2008/10/24 06:07:56
|
|
|
| |
MessageQueueService( | MessageQueueService( |
const char* name, | const char* name, |
Uint32 queueID = MessageQueue::getNextQueueId(), |
Uint32 queueID = MessageQueue::getNextQueueId()); |
Uint32 capabilities = 0, |
|
Uint32 mask = MessageMask::ha_request | |
|
MessageMask::ha_reply | |
|
MessageMask::ha_async); |
|
| |
virtual ~MessageQueueService(); | virtual ~MessageQueueService(); |
| |
|
|
Uint32 find_service_qid(const String &name); | Uint32 find_service_qid(const String &name); |
static AsyncOpNode* get_op(); | static AsyncOpNode* get_op(); |
void return_op(AsyncOpNode* op); | void return_op(AsyncOpNode* op); |
|
Boolean isRunning() const { return _isRunning; } |
| |
static ThreadPool* get_thread_pool(); | static ThreadPool* get_thread_pool(); |
| |
Uint32 _mask; |
|
AtomicInt _die; | AtomicInt _die; |
AtomicInt _threads; | AtomicInt _threads; |
Uint32 getIncomingCount() {return _incoming.count(); } | Uint32 getIncomingCount() {return _incoming.count(); } |
|
|
static AtomicInt _service_count; | static AtomicInt _service_count; |
static Mutex _meta_dispatcher_mutex; | static Mutex _meta_dispatcher_mutex; |
static ThreadPool* _thread_pool; | static ThreadPool* _thread_pool; |
|
Boolean _isRunning; |
private: | private: |
Boolean _sendAsync(AsyncOpNode* op, | Boolean _sendAsync(AsyncOpNode* op, |
Uint32 destination, | Uint32 destination, |