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

Diff for /pegasus/src/Pegasus/Common/ThreadPool.cpp between version 1.5 and 1.14.12.2

version 1.5, 2007/01/11 16:21:54 version 1.14.12.2, 2008/06/10 15:33:33
Line 95 
Line 95 
         // Set the dying flag so all thread know the destructor has been         // Set the dying flag so all thread know the destructor has been
         // entered         // entered
         _dying++;         _dying++;
         Tracer::trace(TRC_THREAD, Tracer::LEVEL2,          PEG_TRACE((TRC_THREAD, Tracer::LEVEL2,
             "Cleaning up %d idle threads.", _currentThreads.get());              "Cleaning up %d idle threads.", _currentThreads.get()));
  
         while (_currentThreads.get() > 0)         while (_currentThreads.get() > 0)
         {         {
Line 150 
Line 150 
         }         }
         catch (...)         catch (...)
         {         {
             Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,              PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                 "ThreadPool::_loop: Failure getting sleep_sem or "                 "ThreadPool::_loop: Failure getting sleep_sem or "
                     "lastActivityTime.");                     "lastActivityTime.");
             PEGASUS_ASSERT(false);             PEGASUS_ASSERT(false);
Line 168 
Line 168 
             }             }
             catch (...)             catch (...)
             {             {
                 Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,                  PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                     "ThreadPool::_loop: failure on sleep_sem->wait().");                     "ThreadPool::_loop: failure on sleep_sem->wait().");
                 PEGASUS_ASSERT(false);                 PEGASUS_ASSERT(false);
                 pool->_idleThreads.remove(myself);                 pool->_idleThreads.remove(myself);
Line 197 
Line 197 
             }             }
             catch (...)             catch (...)
             {             {
                 Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,                  PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                     "ThreadPool::_loop: Failure accessing work func, work "                     "ThreadPool::_loop: Failure accessing work func, work "
                         "parm, or blocking sem.");                         "parm, or blocking sem.");
                 PEGASUS_ASSERT(false);                 PEGASUS_ASSERT(false);
Line 209 
Line 209 
  
             if (work == 0)             if (work == 0)
             {             {
                 Tracer::trace(TRC_THREAD, Tracer::LEVEL4,                  PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,
                     "ThreadPool::_loop: work func is 0, meaning we should "                     "ThreadPool::_loop: work func is 0, meaning we should "
                         "exit.");                         "exit.");
                 break;                 break;
Line 219 
Line 219 
  
             try             try
             {             {
                 PEG_TRACE_STRING(TRC_THREAD, Tracer::LEVEL4,                  PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,
                                  "Work starting.");                                  "Work starting.");
                 work(parm);                 work(parm);
                 PEG_TRACE_STRING(TRC_THREAD, Tracer::LEVEL4,                  PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,
                                  "Work finished.");                                  "Work finished.");
             }             }
             catch (Exception& e)             catch (Exception& e)
Line 231 
Line 231 
                     String("Exception from work in ThreadPool::_loop: ") +                     String("Exception from work in ThreadPool::_loop: ") +
                         e.getMessage());                         e.getMessage());
             }             }
 #if !defined(PEGASUS_OS_LSB)  
             catch (const exception& e)             catch (const exception& e)
             {             {
                 PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,                 PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                     String("Exception from work in ThreadPool::_loop: ") +                     String("Exception from work in ThreadPool::_loop: ") +
                         e.what());                         e.what());
             }             }
 #endif  
             catch (...)             catch (...)
             {             {
                 PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,                  PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                     "Unknown exception from work in ThreadPool::_loop.");                     "Unknown exception from work in ThreadPool::_loop.");
             }             }
  
Line 259 
Line 257 
             }             }
             catch (...)             catch (...)
             {             {
                 Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,                  PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                     "ThreadPool::_loop: Adding thread to idle pool failed.");                     "ThreadPool::_loop: Adding thread to idle pool failed.");
                 PEGASUS_ASSERT(false);                 PEGASUS_ASSERT(false);
                 pool->_currentThreads--;                 pool->_currentThreads--;
Line 275 
Line 273 
     }     }
     catch (...)     catch (...)
     {     {
         PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,          PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
             "Caught unrecognized exception.  Exiting _loop.");             "Caught unrecognized exception.  Exiting _loop.");
     }     }
  
Line 298 
Line 296 
     {     {
         if (_dying.get())         if (_dying.get())
         {         {
             Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,              PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                 "ThreadPool::allocate_and_awaken: ThreadPool is dying(1).");                 "ThreadPool::allocate_and_awaken: ThreadPool is dying(1).");
             return PEGASUS_THREAD_UNAVAILABLE;             return PEGASUS_THREAD_UNAVAILABLE;
         }         }
Line 319 
Line 317 
  
         if (th == 0)         if (th == 0)
         {         {
             Tracer::trace(TRC_THREAD, Tracer::LEVEL2,              PEG_TRACE((TRC_THREAD, Tracer::LEVEL2,
                 "ThreadPool::allocate_and_awaken: Insufficient resources: "                 "ThreadPool::allocate_and_awaken: Insufficient resources: "
                     " pool = %s, running threads = %d, idle threads = %d",                     " pool = %s, running threads = %d, idle threads = %d",
                 _key, _runningThreads.size(), _idleThreads.size());                  _key, _runningThreads.size(), _idleThreads.size()));
             return PEGASUS_THREAD_INSUFFICIENT_RESOURCES;             return PEGASUS_THREAD_INSUFFICIENT_RESOURCES;
         }         }
  
         // initialize the thread data with the work function and parameters         // initialize the thread data with the work function and parameters
         Tracer::trace(TRC_THREAD, Tracer::LEVEL4,          PEG_TRACE((TRC_THREAD, Tracer::LEVEL4,
             "Initializing thread with work function and parameters: parm = %p",              "Initializing thread(%s)"
             parm);                  " with work function and parameters: parm = %p",
               Threads::id(th->getThreadHandle().thid).buffer,
               parm));
  
         th->delete_tsd("work func");         th->delete_tsd("work func");
         th->put_tsd("work func", NULL,         th->put_tsd("work func", NULL,
Line 348 
Line 348 
         Semaphore *sleep_sem = (Semaphore *) th->reference_tsd("sleep sem");         Semaphore *sleep_sem = (Semaphore *) th->reference_tsd("sleep sem");
         PEGASUS_ASSERT(sleep_sem != 0);         PEGASUS_ASSERT(sleep_sem != 0);
  
         Tracer::trace(TRC_THREAD, Tracer::LEVEL4, "Signal thread to awaken");          PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,
               "Signal thread to awaken");
         sleep_sem->signal();         sleep_sem->signal();
         th->dereference_tsd();         th->dereference_tsd();
     }     }
     catch (...)     catch (...)
     {     {
         Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,          PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                       "ThreadPool::allocate_and_awaken: Operation Failed.");                       "ThreadPool::allocate_and_awaken: Operation Failed.");
         PEG_METHOD_EXIT();         PEG_METHOD_EXIT();
         // ATTN: Error result has not yet been defined         // ATTN: Error result has not yet been defined
Line 373 
Line 374 
  
     Uint32 numThreadsCleanedUp = 0;     Uint32 numThreadsCleanedUp = 0;
  
     size_t numIdleThreads = _idleThreads.size();      Uint32 numIdleThreads = _idleThreads.size();
     for (size_t i = 0; i < numIdleThreads; i++)      for (Uint32 i = 0; i < numIdleThreads; i++)
     {     {
         // Do not dip below the minimum thread count         // Do not dip below the minimum thread count
         if (_currentThreads.get() <= (Uint32) _minThreads)         if (_currentThreads.get() <= (Uint32) _minThreads)
Line 454 
Line 455 
     struct timeval* start,     struct timeval* start,
     struct timeval* interval)     struct timeval* interval)
 { {
       PEGASUS_ASSERT(interval != 0);
   
     // never time out if the interval is zero     // never time out if the interval is zero
     if (interval && (interval->tv_sec == 0) && (interval->tv_usec == 0))      if ((interval->tv_sec == 0) && (interval->tv_usec == 0))
     {     {
         return false;         return false;
     }     }
Line 463 
Line 466 
     struct timeval now, finish, remaining;     struct timeval now, finish, remaining;
     Uint32 usec;     Uint32 usec;
     Time::gettimeofday(&now);     Time::gettimeofday(&now);
   
   #if defined(PEGASUS_PLATFORM_SOLARIS_IX86_CC) || \
       defined(PEGASUS_PLATFORM_SOLARIS_X86_64_CC)
       memset(&remaining, 0, sizeof(remaining));
   #else
     Time::gettimeofday(&remaining);     // Avoid valgrind error     Time::gettimeofday(&remaining);     // Avoid valgrind error
   #endif
  
     finish.tv_sec = start->tv_sec + interval->tv_sec;     finish.tv_sec = start->tv_sec + interval->tv_sec;
     usec = start->tv_usec + interval->tv_usec;     usec = start->tv_usec + interval->tv_usec;
Line 505 
Line 514 
  
     if (th->run() != PEGASUS_THREAD_OK)     if (th->run() != PEGASUS_THREAD_OK)
     {     {
         Tracer::trace(TRC_THREAD, Tracer::LEVEL2,          PEG_TRACE((TRC_THREAD, Tracer::LEVEL2,
             "Could not create thread. Error code is %d.", errno);              "Could not create thread. Error code is %d.", errno));
         delete th;         delete th;
         return 0;         return 0;
     }     }
     _currentThreads++;     _currentThreads++;
     Threads::yield();  
  
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
     return th;     return th;
Line 521 
Line 529 
 { {
     if (th == 0)     if (th == 0)
     {     {
         Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,          PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
             "ThreadPool::_addToIdleThreadsQueue: Thread pointer is null.");             "ThreadPool::_addToIdleThreadsQueue: Thread pointer is null.");
         throw NullPointer();         throw NullPointer();
     }     }
Line 532 
Line 540 
     }     }
     catch (...)     catch (...)
     {     {
         Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,          PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2,
             "ThreadPool::_addToIdleThreadsQueue: _idleThreads.insert_front "             "ThreadPool::_addToIdleThreadsQueue: _idleThreads.insert_front "
                 "failed.");                 "failed.");
     }     }

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