pegasus/src/Pegasus/Common/MessageQueueService.h - diff

Return to MessageQueueService.h CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

version 1.9, 2002/02/07 00:28:48

version 1.10, 2002/02/11 01:17:41

Line 40

PEGASUS_NAMESPACE_BEGIN

extern const Uint32 CIMOM_Q_ID;

class message_module;

Line 49

Line 50

typedef MessageQueue Base;

MessageQueueService(const char *name, Uint32 queueID, Uint32 capabilities, Uint32 mask) ;

MessageQueueService(const char *name, Uint32 queueID,

Uint32 capabilities = 0,

Uint32 mask = message_mask::type_cimom |

message_mask::type_service |

message_mask::ha_request |

message_mask::ha_reply |

message_mask::ha_async ) ;

virtual ~MessageQueueService(void);

Line 67

Line 74

virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req);

virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep);

virtual Boolean isAsync(void) { return true; }

virtual Boolean accept_async(AsyncOpNode *op);

virtual Boolean messageOK(const Message *msg) ;

Line 96

Line 105

virtual void _handle_incoming_operation(AsyncOpNode *operation, Thread *thread, MessageQueue *queue);

virtual void _handle_async_request(AsyncRequest *req);

virtual void _make_response(AsyncRequest *req, Uint32 code);

cimom *_meta_dispatcher;

static cimom *_meta_dispatcher;

static AtomicInt _service_count;

static Mutex _meta_dispatcher_mutex;

private:

void handleEnqueue();

Legend: