(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.25 and 1.28

version 1.25, 2002/04/25 17:46:03 version 1.28, 2002/06/07 00:56:01
Line 1 
Line 1 
 //%////-*-c++-*-//////////////////////////////////////////////////////////////// //%////-*-c++-*-////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001 The Open group, BMC Software, Tivoli Systems, IBM  // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,
   // The Open Group, Tivoli Systems
 // //
 // 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 95 
Line 96 
                          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(void);       Uint32 get_next_xid(void);
       AsyncOpNode *get_op(void);        static AsyncOpNode *get_op(void);
       void return_op(AsyncOpNode *op);       void return_op(AsyncOpNode *op);
  
         Boolean operator ==(const MessageQueueService & svce)
         {
            return operator==((const void *)&svce);
         }
         Boolean operator ==(const void *svce)
         {
            if((void *)this == svce)
               return true;
            return false;
         }
   
         static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *);
         static int kill_idle_threads(void);
         static int pooled_threads(void)
         {
            return _thread_pool.running_count() + _thread_pool.dead_count() + _thread_pool.pool_count();
         }
   
       Uint32 _mask;       Uint32 _mask;
       AtomicInt _die;       AtomicInt _die;
    protected:    protected:
Line 143 
Line 162 
  
       AsyncDQueue<AsyncOpNode> _incoming;       AsyncDQueue<AsyncOpNode> _incoming;
       DQueue<AsyncOpNode> _callback;       DQueue<AsyncOpNode> _callback;
         static Thread _polling_thread;
         static Semaphore _polling_sem;
         static AtomicInt _stop_polling;
   
         static DQueue<MessageQueueService> _polling_list;
  
       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);
       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _callback_proc(void *);       static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _callback_proc(void *);
Line 153 
Line 177 
  
       Thread _req_thread;       Thread _req_thread;
       Thread _callback_thread;       Thread _callback_thread;
      protected:
         static ThreadPool _thread_pool;
      private:
       struct timeval _default_op_timeout;       struct timeval _default_op_timeout;
       static AtomicInt _xid;       static AtomicInt _xid;
       friend class cimom;       friend class cimom;

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