|
version 1.29, 2005/03/10 00:38:21
|
version 1.30, 2005/04/01 17:26:54
|
|
|
|
| { | { |
| //MessageQueueService::_check_idle_flag = 1; | //MessageQueueService::_check_idle_flag = 1; |
| //MessageQueueService::_polling_sem.signal(); | //MessageQueueService::_polling_sem.signal(); |
| MessageQueueService::get_thread_pool()->kill_idle_threads(); |
MessageQueueService::get_thread_pool()->cleanupIdleThreads(); |
| } | } |
| catch(...) | catch(...) |
| { | { |
|
|
|
| | |
| return 0; | return 0; |
| } | } |
| static struct timeval create_time = {0, 1}; |
|
| static struct timeval destroy_time = {15, 0}; |
|
| | |
| ///////////////////////////////////////////////////////////////////////////// | ///////////////////////////////////////////////////////////////////////////// |
| // CIMListenerRep | // CIMListenerRep |
|
|
|
| throw; | throw; |
| } | } |
| | |
| _thread_pool = new ThreadPool(0, "Listener", 0, 1, |
struct timeval deallocateWait = {15, 0}; |
| create_time, destroy_time); |
_thread_pool = new ThreadPool(0, "Listener", 0, 1, deallocateWait); |
| | |
| _listener_sem = new Semaphore(0); | _listener_sem = new Semaphore(0); |
| _thread_pool->allocate_and_awaken(svc, | _thread_pool->allocate_and_awaken(svc, |
Return to
CIMListener.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Listener