version 1.11.4.3, 2004/03/10 14:19:29
|
version 1.19, 2004/02/27 19:10:17
|
|
|
#include <Pegasus/Common/Logger.h> | #include <Pegasus/Common/Logger.h> |
#include <Pegasus/Common/MessageLoader.h> //l10n | #include <Pegasus/Common/MessageLoader.h> //l10n |
| |
//#include <Pegasus/Common/QueryExpression.h> |
#include <Pegasus/Common/QueryExpression.h> |
//#include <Pegasus/ProviderManager2/QueryExpressionFactory.h> |
#include <Pegasus/ProviderManager2/QueryExpressionFactory.h> |
| |
#include <Pegasus/Config/ConfigManager.h> | #include <Pegasus/Config/ConfigManager.h> |
| |
#include <Pegasus/ProviderManager2/Default/Provider.h> | #include <Pegasus/ProviderManager2/Default/Provider.h> |
#include <Pegasus/ProviderManager2/OperationResponseHandler.h> |
#include <Pegasus/ProviderManager2/Default/OperationResponseHandler.h> |
| |
#include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h> | #include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h> |
#include <Pegasus/ProviderManager2/ProviderManagerService.h> | #include <Pegasus/ProviderManager2/ProviderManagerService.h> |
|
|
{ | { |
} | } |
| |
Message * DefaultProviderManager::processMessage(Message * request) |
Message * DefaultProviderManager::processMessage(Message * request) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, |
"DefaultProviderManager::processMessage()"); | "DefaultProviderManager::processMessage()"); |
|
|
response = handleDeleteInstanceRequest(request); | response = handleDeleteInstanceRequest(request); |
| |
break; | break; |
// case CIM_EXEC_QUERY_REQUEST_MESSAGE: |
case CIM_EXEC_QUERY_REQUEST_MESSAGE: |
// response = handleExecQueryRequest(request); |
response = handleExecQueryRequest(request); |
| |
// break; |
break; |
case CIM_ASSOCIATORS_REQUEST_MESSAGE: | case CIM_ASSOCIATORS_REQUEST_MESSAGE: |
response = handleAssociatorsRequest(request); | response = handleAssociatorsRequest(request); |
| |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleUnsupportedRequest(const Message * message) |
Message * DefaultProviderManager::handleUnsupportedRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleUnsupportedRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleUnsupportedRequest"); |
| |
|
|
return(0); | return(0); |
} | } |
| |
Message * DefaultProviderManager::handleGetInstanceRequest(const Message * message) |
Message * DefaultProviderManager::handleGetInstanceRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetInstanceRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetInstanceRequest"); |
| |
|
|
request->instanceName.getKeyBindings()); | request->instanceName.getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::INSTANCE); | ProviderType::INSTANCE); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleEnumerateInstancesRequest(const Message * message) |
Message * DefaultProviderManager::handleEnumerateInstancesRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnumerateInstanceRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnumerateInstanceRequest"); |
| |
|
|
request->className); | request->className); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::INSTANCE); | ProviderType::INSTANCE); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleEnumerateInstanceNamesRequest(const Message * message) |
Message * DefaultProviderManager::handleEnumerateInstanceNamesRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnumerateInstanceNamesRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnumerateInstanceNamesRequest"); |
| |
|
|
| |
// build an internal provider name from the request arguments | // build an internal provider name from the request arguments |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::INSTANCE); | ProviderType::INSTANCE); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleCreateInstanceRequest(const Message * message) |
Message * DefaultProviderManager::handleCreateInstanceRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateInstanceRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateInstanceRequest"); |
| |
|
|
request->newInstance.getPath().getKeyBindings()); | request->newInstance.getPath().getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::INSTANCE); | ProviderType::INSTANCE); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleModifyInstanceRequest(const Message * message) |
Message * DefaultProviderManager::handleModifyInstanceRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleModifyInstanceRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleModifyInstanceRequest"); |
| |
|
|
request->modifiedInstance.getPath ().getKeyBindings()); | request->modifiedInstance.getPath ().getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::INSTANCE); | ProviderType::INSTANCE); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleDeleteInstanceRequest(const Message * message) |
Message * DefaultProviderManager::handleDeleteInstanceRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDeleteInstanceRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDeleteInstanceRequest"); |
| |
|
|
request->instanceName.getKeyBindings()); | request->instanceName.getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::INSTANCE); | ProviderType::INSTANCE); |
| |
// resolve provider name | // resolve provider name |
|
|
| |
return(response); | return(response); |
} | } |
/* |
|
Message * DefaultProviderManager::handleExecQueryRequest(const Message * message) |
Message * DefaultProviderManager::handleExecQueryRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleExecQueryRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleExecQueryRequest"); |
| |
|
|
request->className); | request->className); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::QUERY); | ProviderType::QUERY); |
| |
// resolve provider name | // resolve provider name |
|
|
| |
return(response); | return(response); |
} | } |
*/ |
|
Message * DefaultProviderManager::handleAssociatorsRequest(const Message * message) |
Message * DefaultProviderManager::handleAssociatorsRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorsRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorsRequest"); |
| |
|
|
request->assocClass.getString()); | request->assocClass.getString()); |
| |
ProviderName name( | ProviderName name( |
assocPath, |
assocPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::ASSOCIATION); | ProviderType::ASSOCIATION); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleAssociatorNamesRequest(const Message * message) |
Message * DefaultProviderManager::handleAssociatorNamesRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorNamesRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorNamesRequest"); |
| |
|
|
request->assocClass.getString()); | request->assocClass.getString()); |
| |
ProviderName name( | ProviderName name( |
assocPath, |
assocPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::ASSOCIATION); | ProviderType::ASSOCIATION); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleReferencesRequest(const Message * message) |
Message * DefaultProviderManager::handleReferencesRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleReferencesRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleReferencesRequest"); |
| |
|
|
request->resultClass.getString()); | request->resultClass.getString()); |
| |
ProviderName name( | ProviderName name( |
resultPath, |
resultPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::ASSOCIATION); | ProviderType::ASSOCIATION); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleReferenceNamesRequest(const Message * message) |
Message * DefaultProviderManager::handleReferenceNamesRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleReferenceNamesRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleReferenceNamesRequest"); |
| |
|
|
request->resultClass.getString()); | request->resultClass.getString()); |
| |
ProviderName name( | ProviderName name( |
resultPath, |
resultPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::ASSOCIATION); | ProviderType::ASSOCIATION); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleGetPropertyRequest(const Message * message) |
Message * DefaultProviderManager::handleGetPropertyRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetPropertyRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetPropertyRequest"); |
| |
|
|
request->instanceName.getKeyBindings()); | request->instanceName.getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
0); | 0); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleSetPropertyRequest(const Message * message) |
Message * DefaultProviderManager::handleSetPropertyRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleSetPropertyRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleSetPropertyRequest"); |
| |
|
|
request->instanceName.getKeyBindings()); | request->instanceName.getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
0); | 0); |
| |
// resolve provider name | // resolve provider name |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleInvokeMethodRequest(const Message * message) |
Message * DefaultProviderManager::handleInvokeMethodRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleInvokeMethodRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleInvokeMethodRequest"); |
| |
|
|
request->instanceName.getKeyBindings()); | request->instanceName.getKeyBindings()); |
| |
ProviderName name( | ProviderName name( |
objectPath, |
objectPath.toString(), |
|
String::EMPTY, |
|
String::EMPTY, |
|
String::EMPTY, |
ProviderType::METHOD, | ProviderType::METHOD, |
request->methodName); | request->methodName); |
| |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleCreateSubscriptionRequest(const Message * message) |
Message * DefaultProviderManager::handleCreateSubscriptionRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateSubscriptionRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateSubscriptionRequest"); |
| |
|
|
request->providerModule.getProperty( | request->providerModule.getProperty( |
request->providerModule.findProperty("Location")).getValue().toString()); | request->providerModule.findProperty("Location")).getValue().toString()); |
| |
ProviderName name( |
ProviderName name(String::EMPTY, |
request->provider.getProperty(request->provider.findProperty | request->provider.getProperty(request->provider.findProperty |
("Name")).getValue ().toString (), | ("Name")).getValue ().toString (), |
physicalName, | physicalName, |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleModifySubscriptionRequest( const Message * message) |
Message * DefaultProviderManager::handleModifySubscriptionRequest( const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleModifySubscriptionRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleModifySubscriptionRequest"); |
| |
|
|
request->providerModule.getProperty( | request->providerModule.getProperty( |
request->providerModule.findProperty("Location")).getValue().toString()); | request->providerModule.findProperty("Location")).getValue().toString()); |
| |
ProviderName name( |
ProviderName name(String::EMPTY, |
request->provider.getProperty(request->provider.findProperty | request->provider.getProperty(request->provider.findProperty |
("Name")).getValue ().toString (), | ("Name")).getValue ().toString (), |
physicalName, | physicalName, |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleDeleteSubscriptionRequest(const Message * message) |
Message * DefaultProviderManager::handleDeleteSubscriptionRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDeleteSubscriptionRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDeleteSubscriptionRequest"); |
| |
|
|
request->providerModule.getProperty( | request->providerModule.getProperty( |
request->providerModule.findProperty("Location")).getValue().toString()); | request->providerModule.findProperty("Location")).getValue().toString()); |
| |
ProviderName name( |
ProviderName name(String::EMPTY, |
request->provider.getProperty(request->provider.findProperty | request->provider.getProperty(request->provider.findProperty |
("Name")).getValue ().toString (), | ("Name")).getValue ().toString (), |
physicalName, | physicalName, |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleEnableIndicationsRequest(const Message * message) |
Message * DefaultProviderManager::handleEnableIndicationsRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager:: handleEnableIndicationsRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager:: handleEnableIndicationsRequest"); |
| |
|
|
request->providerModule.getProperty( | request->providerModule.getProperty( |
request->providerModule.findProperty("Location")).getValue().toString()); | request->providerModule.findProperty("Location")).getValue().toString()); |
| |
ProviderName name( |
ProviderName name(String::EMPTY, |
request->provider.getProperty(request->provider.findProperty | request->provider.getProperty(request->provider.findProperty |
("Name")).getValue ().toString (), | ("Name")).getValue ().toString (), |
physicalName, | physicalName, |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleDisableIndicationsRequest(const Message * message) |
Message * DefaultProviderManager::handleDisableIndicationsRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableIndicationsRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableIndicationsRequest"); |
| |
|
|
request->providerModule.getProperty( | request->providerModule.getProperty( |
request->providerModule.findProperty("Location")).getValue().toString()); | request->providerModule.findProperty("Location")).getValue().toString()); |
| |
ProviderName name( |
ProviderName name(String::EMPTY, |
request->provider.getProperty(request->provider.findProperty | request->provider.getProperty(request->provider.findProperty |
("Name")).getValue ().toString (), | ("Name")).getValue ().toString (), |
physicalName, | physicalName, |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleConsumeIndicationRequest(const Message *message) |
Message * DefaultProviderManager::handleConsumeIndicationRequest(const Message *message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handlConsumeIndicationRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handlConsumeIndicationRequest"); |
| |
|
|
String::EMPTY, | String::EMPTY, |
String::EMPTY, | String::EMPTY, |
String::EMPTY, | String::EMPTY, |
|
String::EMPTY, |
0); | 0); |
| |
/* | /* |
|
|
} | } |
| |
| |
Message *DefaultProviderManager::handleExportIndicationRequest(const Message *message) |
Message *DefaultProviderManager::handleExportIndicationRequest(const Message *message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManagerService::handlExportIndicationRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManagerService::handlExportIndicationRequest"); |
| |
|
|
String::EMPTY, | String::EMPTY, |
String::EMPTY, | String::EMPTY, |
String::EMPTY, | String::EMPTY, |
|
String::EMPTY, |
0); | 0); |
| |
// resolve provider name | // resolve provider name |
|
|
// | // |
// ATTN-YZ-P2-20030519: Provider needs to be blocked when disable a provider. | // ATTN-YZ-P2-20030519: Provider needs to be blocked when disable a provider. |
// | // |
Message * DefaultProviderManager::handleDisableModuleRequest(const Message * message) |
Message * DefaultProviderManager::handleDisableModuleRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableModuleRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableModuleRequest"); |
| |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleEnableModuleRequest(const Message * message) |
Message * DefaultProviderManager::handleEnableModuleRequest(const Message * message) throw() |
{ | { |
// HACK | // HACK |
ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager(); | ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager(); |
|
|
return(response); | return(response); |
} | } |
| |
Message * DefaultProviderManager::handleStopAllProvidersRequest(const Message * message) |
Message * DefaultProviderManager::handleStopAllProvidersRequest(const Message * message) throw() |
{ | { |
PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleStopAllProvidersRequest"); | PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleStopAllProvidersRequest"); |
| |