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

Return to MessageQueueService.h CVS log

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

Diff for /pegasus/src/Pegasus/Common/MessageQueueService.h between version 1.3 and 1.10

version 1.3, 2002/01/21 02:01:22

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);

// don't allow derived classes to override

void handleEnqueue();

virtual void handle_heartbeat_request(AsyncRequest *req);

virtual void handle_heartbeat_reply(AsyncReply *rep);

Line 65

Line 70

virtual void handle_CimServiceResume(CimServiceResume *req);

virtual void handle_AsyncOperationStart(AsyncOperationStart *req);

virtual void handle_AsyncOperationResult(AsyncOperationResult *req);

virtual void handle_AsyncOperationResult(AsyncOperationResult *rep);

virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req);

virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep);

virtual Boolean accept_async(AsyncOpNode *op) throw(IPCException);

virtual Boolean isAsync(void) { return true; }

virtual Boolean messageOK(const Message *msg) ;

// virtual Message *openEnvelope(Message *msg);

virtual Boolean accept_async(AsyncOpNode *op);

virtual Boolean messageOK(const Message *msg) ;

// Boolean SendAsync(AsyncMessage *msg);

AsyncReply *SendWait(AsyncRequest *request);

void _completeAsyncResponse(AsyncRequest *request,

Line 82

Line 88

Boolean register_service(String name, Uint32 capabilities, Uint32 mask);

Boolean update_service(Uint32 capabilities, Uint32 mask);

Boolean deregister_service(void);

virtual void _shutdown_incoming_queue(void);

void find_services(String name,

Uint32 capabilities,

Uint32 mask,

Line 96

Line 102

AtomicInt _die;

protected:

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

virtual void _handle_async_request(AsyncRequest *req);

virtual void _handle_async_reply(AsyncReply *rep);

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:

AsyncDQueue<AsyncOpNode> _pending;

private:

void handleEnqueue();

DQueue<AsyncOpNode> _pending;

AsyncDQueue<AsyncOpNode> _incoming;

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _rpl_proc(void *);

AtomicInt _incoming_queue_shutdown;

Thread _req_thread;

Thread _rpl_thread;

struct timeval _default_op_timeout;

static AtomicInt _xid;

void _handle_incoming_operation(AsyncOpNode *operation);

};

Legend:

Removed from v.1.3
changed lines
	Added in v.1.10

No CVS admin address has been configured