(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.28 and 1.39

version 1.28, 2002/06/07 00:56:01 version 1.39, 2003/10/22 14:26:03
Line 1 
Line 1 
 //%////-*-c++-*-////////////////////////////////////////////////////////////////  //%2003////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,  // Copyright (c) 2000, 2001, 2002  BMC Software, Hewlett-Packard Development
 // The Open Group, Tivoli Systems  // Company, L. P., IBM Corp., The Open Group, Tivoli Systems.
   // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.;
   // IBM Corp.; EMC Corporation, The Open Group.
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 32 
Line 34 
  
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #include <Pegasus/Common/Message.h> #include <Pegasus/Common/Message.h>
 #include <Pegasus/Common/Exception.h>  #include <Pegasus/Common/InternalException.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 111 
Line 114 
       }       }
  
       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(Boolean destroy_flag = false);
  
       Uint32 _mask;       Uint32 _mask;
       AtomicInt _die;       AtomicInt _die;
Line 162 
Line 167 
  
       AsyncDQueue<AsyncOpNode> _incoming;       AsyncDQueue<AsyncOpNode> _incoming;
       DQueue<AsyncOpNode> _callback;       DQueue<AsyncOpNode> _callback;
       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 172 
Line 178 
       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _callback_proc(void *);       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _callback_proc(void *);
  
       static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);       static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);
   
       AtomicInt _incoming_queue_shutdown;       AtomicInt _incoming_queue_shutdown;
       Semaphore _callback_ready;       Semaphore _callback_ready;
  
       Thread _req_thread;       Thread _req_thread;
       Thread _callback_thread;       Thread _callback_thread;
    protected:    protected:
       static ThreadPool _thread_pool;        static ThreadPool *_thread_pool;
    private:    private:
       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;
         friend class monitor_2;
   
 }; };
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

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