(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.50.12.3 and 1.55

version 1.50.12.3, 2006/06/30 02:52:02 version 1.55, 2006/08/29 17:32:05
Line 29 
Line 29 
 // //
 //============================================================================== //==============================================================================
 // //
 // Author: Mike Day (mdday@us.ibm.com)  
 //  
 // Modified By: David Dillard, VERITAS Software Corp.  
 //                  (david.dillard@veritas.com)  
 //              Jim Wunderlich (Jim_Wunderlich@prodigy.net)  
 //  
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #ifndef Pegasus_MessageQueue_Service_h #ifndef Pegasus_MessageQueue_Service_h
Line 43 
Line 37 
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #include <Pegasus/Common/Message.h> #include <Pegasus/Common/Message.h>
 #include <Pegasus/Common/InternalException.h> #include <Pegasus/Common/InternalException.h>
 #include <Pegasus/Common/IPC.h>  
 #include <Pegasus/Common/Thread.h> #include <Pegasus/Common/Thread.h>
   #include <Pegasus/Common/ThreadPool.h>
 #include <Pegasus/Common/AsyncOpNode.h> #include <Pegasus/Common/AsyncOpNode.h>
 #include <Pegasus/Common/Cimom.h> #include <Pegasus/Common/Cimom.h>
   #include <Pegasus/Common/Mutex.h>
 #include <Pegasus/Common/CimomMessage.h> #include <Pegasus/Common/CimomMessage.h>
 #include <Pegasus/Common/Linkage.h> #include <Pegasus/Common/Linkage.h>
 #include <Pegasus/Common/RecursiveMutex.h>  #include <Pegasus/Common/Mutex.h>
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 57 
Line 52 
  
 class message_module; class message_module;
  
   
 class PEGASUS_COMMON_LINKAGE MessageQueueService : class PEGASUS_COMMON_LINKAGE MessageQueueService :
     public Linkable, public MessageQueue     public Linkable, public MessageQueue
 { {
Line 64 
Line 60 
  
     typedef MessageQueue Base;     typedef MessageQueue Base;
  
     MessageQueueService(const char *name,      MessageQueueService(
           const char *name,
             Uint32 queueID = MessageQueue::getNextQueueId(),             Uint32 queueID = MessageQueue::getNextQueueId(),
             Uint32 capabilities = 0,             Uint32 capabilities = 0,
             Uint32 mask = message_mask::type_cimom |          Uint32 mask = MessageMask::type_cimom |
             message_mask::type_service |              MessageMask::type_service |
             message_mask::ha_request |              MessageMask::ha_request |
             message_mask::ha_reply |              MessageMask::ha_reply |
             message_mask::ha_async );              MessageMask::ha_async);
  
     virtual ~MessageQueueService();     virtual ~MessageQueueService();
  
Line 107 
Line 104 
             Uint32 mask,             Uint32 mask,
             Array<Uint32> *results);             Array<Uint32> *results);
     void enumerate_service(Uint32 queue, message_module *result);     void enumerate_service(Uint32 queue, message_module *result);
     Uint32 get_next_xid();  
     static AsyncOpNode *get_op();     static AsyncOpNode *get_op();
     void return_op(AsyncOpNode *op);     void return_op(AsyncOpNode *op);
  
     Boolean operator ==(const MessageQueueService & svce) const      static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *);
     {      static ThreadReturnType PEGASUS_THREAD_CDECL kill_idle_threads(void *);
         return operator==((const void *)&svce);  
     }  
   
     Boolean operator ==(const void *svce) const  
     {  
         if((const void *)this == svce)  
             return true;  
         return false;  
     }  
   
     static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *);  
     static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL kill_idle_threads(void *);  
     static ThreadPool *get_thread_pool();     static ThreadPool *get_thread_pool();
  
     Uint32 _mask;     Uint32 _mask;
Line 176 
Line 160 
     static AtomicInt _stop_polling;     static AtomicInt _stop_polling;
     static AtomicInt _check_idle_flag;     static AtomicInt _check_idle_flag;
  
     static List<MessageQueueService, RecursiveMutex> _polling_list;      typedef List<MessageQueueService, Mutex> PollingList;
       static PollingList* _polling_list;
       static Mutex _polling_list_mutex;
   
       PollingList* _get_polling_list();
  
     static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);      static ThreadReturnType PEGASUS_THREAD_CDECL _req_proc(void *);
  
     static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);     static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);
  
Line 189 
Line 177 
  
 private: private:
     struct timeval _default_op_timeout;     struct timeval _default_op_timeout;
     static Mutex _xidMutex;  
     static Uint32 _xid;  
     friend class cimom;     friend class cimom;
     friend class CIMServer;     friend class CIMServer;
 }; };

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