(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.77 and 1.80

version 1.77, 2008/12/19 12:00:36 version 1.80, 2013/06/11 11:18:29
Line 46 
Line 46 
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
 extern const Uint32 CIMOM_Q_ID;  
   
 class message_module; class message_module;
 class cimom; class cimom;
  
Line 60 
Line 58 
     typedef MessageQueue Base;     typedef MessageQueue Base;
  
     MessageQueueService(     MessageQueueService(
         const char* name,          const char* name);
         Uint32 queueID = MessageQueue::getNextQueueId());  
  
     virtual ~MessageQueueService();     virtual ~MessageQueueService();
  
Line 69 
Line 66 
  
     virtual void enqueue(Message *);     virtual void enqueue(Message *);
  
     AsyncReply* SendWait(AsyncRequest* request);      static AsyncReply* SendWait(AsyncRequest* request);
     Boolean SendAsync(AsyncOpNode* op,     Boolean SendAsync(AsyncOpNode* op,
         Uint32 destination,         Uint32 destination,
         void (*callback)(AsyncOpNode*, MessageQueue*, void*),         void (*callback)(AsyncOpNode*, MessageQueue*, void*),
         MessageQueue* callback_q,         MessageQueue* callback_q,
         void* callback_ptr);         void* callback_ptr);
  
     Boolean SendForget(Message* msg);      static Boolean SendForget(Message* msg);
  
     Boolean update_service(Uint32 capabilities, Uint32 mask);     Boolean update_service(Uint32 capabilities, Uint32 mask);
     Boolean deregister_service();     Boolean deregister_service();
  
     Uint32 find_service_qid(const char* name);      static Uint32 find_service_qid(const char* name);
     static AsyncOpNode* get_op();     static AsyncOpNode* get_op();
     void return_op(AsyncOpNode* op);      static void return_op(AsyncOpNode* op);
  
     static ThreadPool* get_thread_pool();     static ThreadPool* get_thread_pool();
  
Line 117 
Line 114 
     static ThreadPool* _thread_pool;     static ThreadPool* _thread_pool;
     Boolean _isRunning;     Boolean _isRunning;
 private: private:
     Boolean _sendAsync(AsyncOpNode* op,      static Boolean _sendAsync(AsyncOpNode* op,
         Uint32 destination,         Uint32 destination,
         void (*callback)(AsyncOpNode*, MessageQueue*, void*),         void (*callback)(AsyncOpNode*, MessageQueue*, void*),
         MessageQueue* callback_q,         MessageQueue* callback_q,

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