|
version 1.5, 2004/10/17 20:40:00
|
version 1.5.2.1, 2005/08/12 22:52:44
|
|
|
|
| _isInitialized = true; | _isInitialized = true; |
| | |
| // Start a thread to read and process responses from the Provider Agent | // Start a thread to read and process responses from the Provider Agent |
| while (!MessageQueueService::get_thread_pool()->allocate_and_awaken( |
ThreadStatus rtn = PEGASUS_THREAD_OK; |
| this, _responseProcessor)) |
while ((rtn = MessageQueueService::get_thread_pool()-> |
| |
allocate_and_awaken(this, _responseProcessor)) != |
| |
PEGASUS_THREAD_OK) |
| |
{ |
| |
if (rtn == PEGASUS_THREAD_INSUFFICIENT_RESOURCES) |
| { | { |
| pegasus_yield(); | pegasus_yield(); |
| } | } |
| |
else |
| |
{ |
| |
Logger::put( |
| |
Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE, |
| |
"Not enough threads to process responses from the " |
| |
"provider agent."); |
| |
|
| |
Tracer::trace(TRC_PROVIDERMANAGER, Tracer::LEVEL2, |
| |
"Could not allocate thread to process responses from the " |
| |
"provider agent."); |
| |
|
| |
throw Exception(MessageLoaderParms( |
| |
"ProviderManager.OOPProviderManagerRouter." |
| |
"CIMPROVAGT_THREAD_ALLOCATION_FAILED", |
| |
"Failed to allocate thread for cimprovagt \"$0\".", |
| |
_moduleName)); |
| |
} |
| |
} |
| } | } |
| catch (...) | catch (...) |
| { | { |
Return to
OOPProviderManagerRouter.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic