|
version 1.78, 2009/04/09 05:23:26
|
version 1.79, 2009/05/19 09:21:52
|
|
|
|
| | |
| virtual void enqueue(Message *); | virtual void enqueue(Message *); |
| | |
| AsyncReply* SendWait(AsyncRequest* request); |
static AsyncReply* SendWait(AsyncRequest* request); |
| Boolean SendAsync(AsyncOpNode* op, | Boolean SendAsync(AsyncOpNode* op, |
| Uint32 destination, | Uint32 destination, |
| void (*callback)(AsyncOpNode*, MessageQueue*, void*), | void (*callback)(AsyncOpNode*, MessageQueue*, void*), |
| MessageQueue* callback_q, | MessageQueue* callback_q, |
| void* callback_ptr); | void* callback_ptr); |
| | |
| Boolean SendForget(Message* msg); |
static Boolean SendForget(Message* msg); |
| | |
| Boolean update_service(Uint32 capabilities, Uint32 mask); | Boolean update_service(Uint32 capabilities, Uint32 mask); |
| Boolean deregister_service(); | Boolean deregister_service(); |
| | |
| Uint32 find_service_qid(const char* name); | Uint32 find_service_qid(const char* name); |
| static AsyncOpNode* get_op(); | static AsyncOpNode* get_op(); |
| void return_op(AsyncOpNode* op); |
static void return_op(AsyncOpNode* op); |
| | |
| static ThreadPool* get_thread_pool(); | static ThreadPool* get_thread_pool(); |
| | |
|
|
|
| static ThreadPool* _thread_pool; | static ThreadPool* _thread_pool; |
| Boolean _isRunning; | Boolean _isRunning; |
| private: | private: |
| Boolean _sendAsync(AsyncOpNode* op, |
static Boolean _sendAsync(AsyncOpNode* op, |
| Uint32 destination, | Uint32 destination, |
| void (*callback)(AsyncOpNode*, MessageQueue*, void*), | void (*callback)(AsyncOpNode*, MessageQueue*, void*), |
| MessageQueue* callback_q, | MessageQueue* callback_q, |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common