(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.47 and 1.50.12.5

version 1.47, 2005/05/18 15:56:51 version 1.50.12.5, 2006/06/30 22:37:52
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 44 
Line 47 
 #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/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/IDFactory.h>
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 53 
Line 59 
  
 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 124 
Line 132 
  
     Uint32 _mask;     Uint32 _mask;
     AtomicInt _die;     AtomicInt _die;
           AtomicInt _threads;
           Uint32 getIncomingCount() {return _incoming.count(); }
  
 protected: protected:
     virtual Boolean accept_async(AsyncOpNode *op);     virtual Boolean accept_async(AsyncOpNode *op);
Line 163 
Line 173 
     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, RecursiveMutex> 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 PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);
  
Line 182 
Line 196 
  
 private: private:
     struct timeval _default_op_timeout;     struct timeval _default_op_timeout;
     static AtomicInt _xid;      static IDFactory _xidFactory;
     friend class cimom;     friend class cimom;
     friend class CIMServer;     friend class CIMServer;
 }; };

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