(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.73 and 1.77

version 1.73, 2008/12/05 09:00:57 version 1.77, 2008/12/19 12:00:36
Line 51 
Line 51 
 class message_module; class message_module;
 class cimom; class cimom;
  
 struct PollingListEntry;  
  
 class PEGASUS_COMMON_LINKAGE MessageQueueService : class PEGASUS_COMMON_LINKAGE MessageQueueService :
     public MessageQueue      public Linkable, public MessageQueue
 { {
 public: public:
  
Line 82 
Line 81 
     Boolean update_service(Uint32 capabilities, Uint32 mask);     Boolean update_service(Uint32 capabilities, Uint32 mask);
     Boolean deregister_service();     Boolean deregister_service();
  
     Uint32 find_service_qid(const String &name);      Uint32 find_service_qid(const char* name);
     static AsyncOpNode* get_op();     static AsyncOpNode* get_op();
     void return_op(AsyncOpNode* op);     void return_op(AsyncOpNode* op);
     Boolean isRunning() const { return _isRunning; }  
  
     static ThreadPool* get_thread_pool();     static ThreadPool* get_thread_pool();
  
     PollingListEntry *pollingListEntry;      AtomicInt _die;
     AtomicInt _threads;     AtomicInt _threads;
     Uint32 getIncomingCount() {return _incoming.count(); }     Uint32 getIncomingCount() {return _incoming.count(); }
  
Line 114 
Line 112 
     void _complete_op_node(AsyncOpNode *);     void _complete_op_node(AsyncOpNode *);
  
     static cimom* _meta_dispatcher;     static cimom* _meta_dispatcher;
     static Mutex _meta_dispatcher_mutex;  
     static AtomicInt _service_count;     static AtomicInt _service_count;
       static Mutex _meta_dispatcher_mutex;
     static ThreadPool* _thread_pool;     static ThreadPool* _thread_pool;
     Boolean _isRunning;     Boolean _isRunning;
 private: private:
Line 126 
Line 124 
         void* callback_ptr,         void* callback_ptr,
         Uint32 flags);         Uint32 flags);
  
       void _removeFromPollingList(MessageQueueService *service);
   
     static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *);     static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *);
  
     AsyncQueue<AsyncOpNode> _incoming;     AsyncQueue<AsyncOpNode> _incoming;
Line 133 
Line 133 
     static Semaphore _polling_sem;     static Semaphore _polling_sem;
     static AtomicInt _stop_polling;     static AtomicInt _stop_polling;
  
     typedef List<PollingListEntry, NullLock> PollingList;      typedef List<MessageQueueService, NullLock> PollingList;
     static PollingList* _polling_list;     static PollingList* _polling_list;
       static Mutex _polling_list_mutex;
  
     static ThreadReturnType PEGASUS_THREAD_CDECL _req_proc(void *);     static ThreadReturnType PEGASUS_THREAD_CDECL _req_proc(void *);
  
     static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);  
   
     AtomicInt _incoming_queue_shutdown;     AtomicInt _incoming_queue_shutdown;
  
     friend class cimom;     friend class cimom;

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