(file) Return to ThreadPool.h CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/ThreadPool.h between version 1.2 and 1.7

version 1.2, 2006/08/09 21:12:42 version 1.7, 2008/12/02 09:00:53
Line 1 
Line 1 
 //%2006////////////////////////////////////////////////////////////////////////  //%LICENSE////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development  // Licensed to The Open Group (TOG) under one or more contributor license
 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.  // agreements.  Refer to the OpenPegasusNOTICE.txt file distributed with
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;  // this work for additional information regarding copyright ownership.
 // IBM Corp.; EMC Corporation, The Open Group.  // Each contributor licenses this file to you under the OpenPegasus Open
 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;  // Source License; you may not use this file except in compliance with the
 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.  // License.
 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;  //
 // EMC Corporation; VERITAS Software Corporation; The Open Group.  // Permission is hereby granted, free of charge, to any person obtaining a
 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;  // copy of this software and associated documentation files (the "Software"),
 // EMC Corporation; Symantec Corporation; The Open Group.  // to deal in the Software without restriction, including without limitation
 //  // the rights to use, copy, modify, merge, publish, distribute, sublicense,
 // Permission is hereby granted, free of charge, to any person obtaining a copy  // and/or sell copies of the Software, and to permit persons to whom the
 // of this software and associated documentation files (the "Software"), to  // Software is furnished to do so, subject to the following conditions:
 // deal in the Software without restriction, including without limitation the  //
 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or  // The above copyright notice and this permission notice shall be included
 // sell copies of the Software, and to permit persons to whom the Software is  // in all copies or substantial portions of the Software.
 // furnished to do so, subject to the following conditions:  //
 //  // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN  // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED  // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT  // IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR  // CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT  // TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN  // SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION  
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.  
 //  
 //==============================================================================  
 //  
 // Author: Mike Day (mdday@us.ibm.com)  
 //  
 // Modified By: Markus Mueller  
 //              Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)  
 //              Amit K Arora, IBM (amita@in.ibm.com) for PEP#101  
 //              David Dillard, VERITAS Software Corp.  
 //                  (david.dillard@veritas.com)  
 //              Sean Keenan, Hewlett-Packard Company (sean.keenan@hp.com)  
 //              Josephine Eskaline Joyce, IBM (jojustin@in.ibm.com) for Bug#2393  
 // //
 //%/////////////////////////////////////////////////////////////////////////////  //////////////////////////////////////////////////////////////////////////
   //
   //%////////////////////////////////////////////////////////////////////////////
  
 #ifndef Pegasus_ThreadPool_h #ifndef Pegasus_ThreadPool_h
 #define Pegasus_ThreadPool_h #define Pegasus_ThreadPool_h
Line 68 
Line 56 
         @param deallocateWait The minimum time that a thread should be idle         @param deallocateWait The minimum time that a thread should be idle
             before it is removed from the pool and cleaned up.             before it is removed from the pool and cleaned up.
      */      */
     ThreadPool(Sint16 initialSize,      ThreadPool(
           Sint16 initialSize,
                const char *key,                const char *key,
                Sint16 minThreads,                Sint16 minThreads,
                Sint16 maxThreads, struct timeval &deallocateWait);          Sint16 maxThreads,
           struct timeval& deallocateWait);
  
     /**     /**
         Destructs the ThreadPool object.         Destructs the ThreadPool object.
Line 93 
Line 83 
                 could not be setup properly. PEGASUS_THREAD_UNAVAILABLE                 could not be setup properly. PEGASUS_THREAD_UNAVAILABLE
                 if this service is shutting down and no more threads can                 if this service is shutting down and no more threads can
                 be allocated.                 be allocated.
         @exception IPCException  
      */      */
     ThreadStatus allocate_and_awaken(void *parm,      ThreadStatus allocate_and_awaken(
                                      ThreadReturnType(PEGASUS_THREAD_CDECL *          void* parm,
                                                       work) (void *),          ThreadReturnType(PEGASUS_THREAD_CDECL* work) (void*),
                                      Semaphore * blocking = 0);                                      Semaphore * blocking = 0);
  
     /**     /**
Line 105 
Line 94 
         deallocate_wait configuration and more than the configured         deallocate_wait configuration and more than the configured
         minimum number of threads is running.         minimum number of threads is running.
         @return The number of threads that were cleaned up.         @return The number of threads that were cleaned up.
         @exception IPCException  
      */      */
     Uint32 cleanupIdleThreads();     Uint32 cleanupIdleThreads();
  
Line 133 
Line 121 
  
     inline Uint32 runningCount()     inline Uint32 runningCount()
     {     {
         return _runningThreads.size();          return (Uint32) _runningThreads.size();
     }     }
  
     inline Uint32 idleCount()     inline Uint32 idleCount()
     {     {
         return _idleThreads.size();          return (Uint32) _idleThreads.size();
     }     }
  
 private: private:
Line 149 
Line 137 
  
     static ThreadReturnType PEGASUS_THREAD_CDECL _loop(void *);     static ThreadReturnType PEGASUS_THREAD_CDECL _loop(void *);
  
     static Boolean _timeIntervalExpired(struct timeval *start,      static Boolean _timeIntervalExpired(
           struct timeval* start,
                                         struct timeval *interval);                                         struct timeval *interval);
  
     static void _deleteSemaphore(void *p);     static void _deleteSemaphore(void *p);

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