(file) Return to MessageQueueService.h CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/MessageQueueService.h between version 1.9 and 1.15

version 1.9, 2002/02/07 00:28:48 version 1.15, 2002/02/20 22:00:51
Line 40 
Line 40 
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
   extern const Uint32 CIMOM_Q_ID;
  
 class message_module; class message_module;
  
Line 49 
Line 50 
  
       typedef MessageQueue Base;       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);       virtual ~MessageQueueService(void);
  
Line 67 
Line 74 
       virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req);       virtual void handle_AsyncLegacyOperationStart(AsyncLegacyOperationStart *req);
       virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep);       virtual void handle_AsyncLegacyOperationResult(AsyncLegacyOperationResult *rep);
  
         virtual Boolean isAsync(void) {  return true;  }
   
       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 enqueue(Message *) throw(IPCException);
   
       AsyncReply *SendWait(AsyncRequest *request);       AsyncReply *SendWait(AsyncRequest *request);
         Boolean SendAsync(AsyncOpNode *op,
                           Uint32 destination,
                           void (*callback)(AsyncOpNode *, MessageQueue *, void *));
         Boolean  SendForget(Message *msg);
  
       void _completeAsyncResponse(AsyncRequest *request,       void _completeAsyncResponse(AsyncRequest *request,
                                  AsyncReply *reply,                                  AsyncReply *reply,
Line 88 
Line 103 
       Uint32 get_next_xid(void);       Uint32 get_next_xid(void);
       AsyncOpNode *get_op(void);       AsyncOpNode *get_op(void);
       void return_op(AsyncOpNode *op);       void return_op(AsyncOpNode *op);
       Uint32 _capabilities;  
       Uint32 _mask;       Uint32 _mask;
       AtomicInt _die;       AtomicInt _die;
    protected:    protected:
         virtual void handleEnqueue(void);
         virtual void handleEnqueue(Message *);
         virtual 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_async_request(AsyncRequest *req);       virtual void _handle_async_request(AsyncRequest *req);
       virtual void _make_response(AsyncRequest *req, Uint32 code);        virtual void _handle_async_callback(AsyncOpNode *operation);
       cimom *_meta_dispatcher;        virtual void _make_response(Message *req, Uint32 code);
   
         static cimom *_meta_dispatcher;
         static AtomicInt _service_count;
         static Mutex _meta_dispatcher_mutex;
   
  
    private:    private:
       void handleEnqueue();  
       DQueue<AsyncOpNode> _pending;       DQueue<AsyncOpNode> _pending;
       AsyncDQueue<AsyncOpNode> _incoming;       AsyncDQueue<AsyncOpNode> _incoming;
  

Legend:
Removed from v.1.9  
changed lines
  Added in v.1.15
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2