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