(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.48 and 1.54

version 1.48, 2005/05/27 02:34:02 version 1.54, 2006/08/09 21:12:42
Line 1 
Line 1 
 //%2005////////////////////////////////////////////////////////////////////////  //%2006////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
Line 8 
Line 8 
 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group. // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
 // EMC Corporation; VERITAS Software Corporation; The Open Group. // EMC Corporation; VERITAS Software Corporation; The Open Group.
   // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
   // EMC Corporation; Symantec 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 31 
Line 33 
 // //
 // Modified By: David Dillard, VERITAS Software Corp. // Modified By: David Dillard, VERITAS Software Corp.
 //                  (david.dillard@veritas.com) //                  (david.dillard@veritas.com)
   //              Jim Wunderlich (Jim_Wunderlich@prodigy.net)
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 40 
Line 43 
 #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/Mutex.h>
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 53 
Line 58 
  
 class message_module; class message_module;
  
 class PEGASUS_COMMON_LINKAGE MessageQueueService : public MessageQueue  
   class PEGASUS_COMMON_LINKAGE MessageQueueService :
       public Linkable, public MessageQueue
 { {
 public: public:
  
Line 102 
Line 109 
             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;
     AtomicInt _die;     AtomicInt _die;
         AtomicInt _threads;         AtomicInt _threads;
           Uint32 getIncomingCount() {return _incoming.count(); }
  
 protected: protected:
     virtual Boolean accept_async(AsyncOpNode *op);     virtual Boolean accept_async(AsyncOpNode *op);
Line 164 
Line 159 
     static Mutex _meta_dispatcher_mutex;     static Mutex _meta_dispatcher_mutex;
  
 private: private:
     AsyncDQueue<AsyncOpNode> _incoming;      AsyncQueue<AsyncOpNode> _incoming;
     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 AtomicInt _check_idle_flag;
  
     static DQueue<MessageQueueService> _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 183 
Line 182 
  
 private: private:
     struct timeval _default_op_timeout;     struct timeval _default_op_timeout;
     static AtomicInt _xid;  
     friend class cimom;     friend class cimom;
     friend class CIMServer;     friend class CIMServer;
 }; };

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