|
version 1.3, 2004/07/30 02:51:46
|
version 1.5.2.1, 2005/08/12 22:52:44
|
|
|
|
| //%2003//////////////////////////////////////////////////////////////////////// |
//%2004//////////////////////////////////////////////////////////////////////// |
| // | // |
| // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Development |
// Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development |
| // Company, L. P., IBM Corp., The Open Group, Tivoli Systems. |
// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. |
| // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.; | // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.; |
| // IBM Corp.; EMC Corporation, The Open Group. | // IBM Corp.; EMC Corporation, The Open Group. |
| |
// Copyright (c) 2004 BMC Software; 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 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 |
|
|
|
| _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 (...) |
| { | { |
|
|
|
| void ProviderAgentContainer::unloadIdleProviders() | void ProviderAgentContainer::unloadIdleProviders() |
| { | { |
| PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, |
| "ProviderAgentContainer::processMessage"); |
"ProviderAgentContainer::unloadIdleProviders"); |
| | |
| AutoMutex lock(_agentMutex); | AutoMutex lock(_agentMutex); |
| if (_isInitialized) | if (_isInitialized) |
Return to
OOPProviderManagerRouter.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic