(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.34 and 1.34.4.1

version 1.34, 2002/08/17 00:59:36 version 1.34.4.1, 2002/10/28 22:41:43
Line 32 
Line 32 
  
 #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/Exception.h>
 #include <Pegasus/Common/IPC.h> #include <Pegasus/Common/IPC.h>
 #include <Pegasus/Common/Thread.h> #include <Pegasus/Common/Thread.h>
 #include <Pegasus/Common/AsyncOpNode.h> #include <Pegasus/Common/AsyncOpNode.h>
 #include <Pegasus/Common/Cimom.h> #include <Pegasus/Common/Cimom.h>
 #include <Pegasus/Common/CimomMessage.h> #include <Pegasus/Common/CimomMessage.h>
 #include <Pegasus/Common/Linkage.h>  
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 112 
Line 111 
       }       }
  
       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *);       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *);
       static int kill_idle_threads(void);        static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL kill_idle_threads(void *);
       static int pooled_threads(void)       static int pooled_threads(void)
       {       {
          return _thread_pool->running_count() + _thread_pool->dead_count() + _thread_pool->pool_count();          return _thread_pool->running_count() + _thread_pool->dead_count() + _thread_pool->pool_count();
       }       }
         static ThreadPool *get_thread_pool(void);
         static void force_shutdown(void);
  
       Uint32 _mask;       Uint32 _mask;
       AtomicInt _die;       AtomicInt _die;
Line 166 
Line 167 
       static Thread* _polling_thread;       static Thread* _polling_thread;
       static Semaphore _polling_sem;       static Semaphore _polling_sem;
       static AtomicInt _stop_polling;       static AtomicInt _stop_polling;
         static AtomicInt _check_idle_flag;
  
       static DQueue<MessageQueueService> _polling_list;       static DQueue<MessageQueueService> _polling_list;
  
Line 185 
Line 187 
       struct timeval _default_op_timeout;       struct timeval _default_op_timeout;
       static AtomicInt _xid;       static AtomicInt _xid;
       friend class cimom;       friend class cimom;
         friend class CIMServer;
 }; };
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END


Legend:
Removed from v.1.34  
changed lines
  Added in v.1.34.4.1

No CVS admin address has been configured
Powered by
ViewCVS 0.9.2