|
version 1.58, 2006/10/03 18:16:03
|
version 1.62, 2008/09/17 05:57:06
|
|
|
|
| const char *name, | const char *name, |
| Uint32 queueID = MessageQueue::getNextQueueId(), | Uint32 queueID = MessageQueue::getNextQueueId(), |
| Uint32 capabilities = 0, | Uint32 capabilities = 0, |
| Uint32 mask = MessageMask::type_cimom | |
Uint32 mask = MessageMask::ha_request | |
| MessageMask::type_service | |
|
| MessageMask::ha_request | |
|
| MessageMask::ha_reply | | MessageMask::ha_reply | |
| MessageMask::ha_async); | MessageMask::ha_async); |
| | |
|
|
|
| Boolean register_service(String name, Uint32 capabilities, Uint32 mask); | Boolean register_service(String name, Uint32 capabilities, Uint32 mask); |
| Boolean update_service(Uint32 capabilities, Uint32 mask); | Boolean update_service(Uint32 capabilities, Uint32 mask); |
| Boolean deregister_service(); | Boolean deregister_service(); |
| virtual void _shutdown_incoming_queue(); |
|
| | |
| void find_services(String name, |
void find_services( |
| |
String name, |
| Uint32 capabilities, | Uint32 capabilities, |
| Uint32 mask, | Uint32 mask, |
| Array<Uint32> *results); | Array<Uint32> *results); |
|
|
|
| Uint32 getIncomingCount() {return _incoming.count(); } | Uint32 getIncomingCount() {return _incoming.count(); } |
| | |
| protected: | protected: |
| |
virtual void _shutdown_incoming_queue(); |
| virtual Boolean accept_async(AsyncOpNode *op); | virtual Boolean accept_async(AsyncOpNode *op); |
| virtual Boolean messageOK(const Message *msg); | virtual Boolean messageOK(const Message *msg); |
| virtual void handleEnqueue() = 0; | virtual void handleEnqueue() = 0; |
| virtual void handleEnqueue(Message *) = 0; | virtual void handleEnqueue(Message *) = 0; |
| Boolean _enqueueResponse(Message *, Message *); | Boolean _enqueueResponse(Message *, Message *); |
| // virtual void _handle_incoming_operation(AsyncOpNode *operation, Thread *thread, MessageQueue *queue); |
// virtual void _handle_incoming_operation( |
| |
// AsyncOpNode* operation, |
| |
// Thread* thread, |
| |
// MessageQueue* queue); |
| virtual void _handle_incoming_operation(AsyncOpNode *); | virtual void _handle_incoming_operation(AsyncOpNode *); |
| | |
| virtual void _handle_async_request(AsyncRequest *req); | virtual void _handle_async_request(AsyncRequest *req); |
|
|
|
| | |
| virtual void handle_AsyncOperationStart(AsyncOperationStart *req); | virtual void handle_AsyncOperationStart(AsyncOperationStart *req); |
| virtual void handle_AsyncOperationResult(AsyncOperationResult *rep); | virtual void handle_AsyncOperationResult(AsyncOperationResult *rep); |
| virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req); |
|
| virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep); |
|
| | |
| void _completeAsyncResponse(AsyncRequest *request, |
void _completeAsyncResponse( |
| |
AsyncRequest* request, |
| AsyncReply *reply, | AsyncReply *reply, |
| Uint32 state, | Uint32 state, |
| Uint32 flag); | Uint32 flag); |
Return to
MessageQueueService.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common