|
version 1.19, 2002/03/08 21:08:18
|
version 1.20, 2002/03/11 02:36:18
|
|
|
|
| | |
| virtual ~MessageQueueService(void); | virtual ~MessageQueueService(void); |
| | |
| |
|
| |
|
| virtual Boolean isAsync(void) { return true; } | virtual Boolean isAsync(void) { return true; } |
| | |
| |
|
| |
|
| |
|
| virtual void enqueue(Message *) throw(IPCException); | virtual void enqueue(Message *) throw(IPCException); |
| | |
| AsyncReply *SendWait(AsyncRequest *request); | AsyncReply *SendWait(AsyncRequest *request); |
|
|
|
| Boolean update_service(Uint32 capabilities, Uint32 mask); | Boolean update_service(Uint32 capabilities, Uint32 mask); |
| Boolean deregister_service(void); | Boolean deregister_service(void); |
| virtual void _shutdown_incoming_queue(void); | virtual void _shutdown_incoming_queue(void); |
| |
|
| void find_services(String name, | void find_services(String name, |
| Uint32 capabilities, | Uint32 capabilities, |
| Uint32 mask, | Uint32 mask, |
|
|
|
| AsyncReply *reply, | AsyncReply *reply, |
| Uint32 state, | Uint32 state, |
| Uint32 flag); | Uint32 flag); |
| |
void _complete_op_node(AsyncOpNode *, Uint32, Uint32, Uint32); |
| |
|
| | |
| static cimom *_meta_dispatcher; | static cimom *_meta_dispatcher; |
| static AtomicInt _service_count; | static AtomicInt _service_count; |
|
|
|
| | |
| DQueue<AsyncOpNode> _pending; | DQueue<AsyncOpNode> _pending; |
| AsyncDQueue<AsyncOpNode> _incoming; | AsyncDQueue<AsyncOpNode> _incoming; |
| |
AsyncDQueue<AsyncOpNode> _callback; |
| | |
| static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *); | static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *); |
| AtomicInt _incoming_queue_shutdown; | AtomicInt _incoming_queue_shutdown; |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common