(file) Return to CMPIProviderManager.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI

Diff for /pegasus/src/Pegasus/ProviderManager2/CMPI/CMPIProviderManager.cpp between version 1.28 and 1.29

version 1.28, 2004/04/13 17:55:15 version 1.29, 2004/04/15 22:45:07
Line 125 
Line 125 
 } }
  
  
 Message * CMPIProviderManager::processMessage(Message * request, ProviderName providerName)  Message * CMPIProviderManager::processMessage(Message * request)
 { {
       PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,       PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
         "CMPIProviderManager::processMessage()");         "CMPIProviderManager::processMessage()");
Line 136 
Line 136 
     switch(request->getType())     switch(request->getType())
     {     {
     case CIM_GET_INSTANCE_REQUEST_MESSAGE:     case CIM_GET_INSTANCE_REQUEST_MESSAGE:
         response = handleGetInstanceRequest(request,providerName);          response = handleGetInstanceRequest(request);
  
         break;         break;
     case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:     case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:
         response = handleEnumerateInstancesRequest(request,providerName);          response = handleEnumerateInstancesRequest(request);
  
         break;         break;
     case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:     case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:
         response = handleEnumerateInstanceNamesRequest(request,providerName);          response = handleEnumerateInstanceNamesRequest(request);
  
         break;         break;
     case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:     case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:
         response = handleCreateInstanceRequest(request,providerName);          response = handleCreateInstanceRequest(request);
  
         break;         break;
     case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:     case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:
         response = handleModifyInstanceRequest(request,providerName);          response = handleModifyInstanceRequest(request);
  
         break;         break;
     case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:     case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:
         response = handleDeleteInstanceRequest(request,providerName);          response = handleDeleteInstanceRequest(request);
  
         break;         break;
     case CIM_EXEC_QUERY_REQUEST_MESSAGE:     case CIM_EXEC_QUERY_REQUEST_MESSAGE:
         response = handleExecQueryRequest(request,providerName);          response = handleExecQueryRequest(request);
  
         break;         break;
     case CIM_ASSOCIATORS_REQUEST_MESSAGE:     case CIM_ASSOCIATORS_REQUEST_MESSAGE:
         response = handleAssociatorsRequest(request,providerName);          response = handleAssociatorsRequest(request);
  
         break;         break;
     case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:     case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:
         response = handleAssociatorNamesRequest(request,providerName);          response = handleAssociatorNamesRequest(request);
  
         break;         break;
     case CIM_REFERENCES_REQUEST_MESSAGE:     case CIM_REFERENCES_REQUEST_MESSAGE:
         response = handleReferencesRequest(request,providerName);          response = handleReferencesRequest(request);
  
         break;         break;
     case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:     case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:
         response = handleReferenceNamesRequest(request,providerName);          response = handleReferenceNamesRequest(request);
  
         break;         break;
     case CIM_INVOKE_METHOD_REQUEST_MESSAGE:     case CIM_INVOKE_METHOD_REQUEST_MESSAGE:
         response = handleInvokeMethodRequest(request,providerName);          response = handleInvokeMethodRequest(request);
  
         break;         break;
     case CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE:     case CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE:
         response = handleCreateSubscriptionRequest(request,providerName);          response = handleCreateSubscriptionRequest(request);
  
         break;         break;
 /*    case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE: /*    case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE:
         response = handleModifySubscriptionRequest(request,providerName);          response = handleModifySubscriptionRequest(request);
  
         break;         break;
 */  case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE: */  case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE:
         response = handleDeleteSubscriptionRequest(request,providerName);          response = handleDeleteSubscriptionRequest(request);
  
         break;         break;
     case CIM_ENABLE_INDICATIONS_REQUEST_MESSAGE:     case CIM_ENABLE_INDICATIONS_REQUEST_MESSAGE:
         response = handleEnableIndicationsRequest(request,providerName);          response = handleEnableIndicationsRequest(request);
  
         break;         break;
     case CIM_DISABLE_INDICATIONS_REQUEST_MESSAGE:     case CIM_DISABLE_INDICATIONS_REQUEST_MESSAGE:
         response = handleDisableIndicationsRequest(request,providerName);          response = handleDisableIndicationsRequest(request);
  
         break;         break;
 /*    case CIM_CONSUME_INDICATION_REQUEST_MESSAGE: /*    case CIM_CONSUME_INDICATION_REQUEST_MESSAGE:
         response = handleConsumeIndicationRequest(request,providerName);          response = handleConsumeIndicationRequest(request);
         break;         break;
 */ */
     case CIM_DISABLE_MODULE_REQUEST_MESSAGE:     case CIM_DISABLE_MODULE_REQUEST_MESSAGE:
         response = handleDisableModuleRequest(request,providerName);          response = handleDisableModuleRequest(request);
  
         break;         break;
     case CIM_ENABLE_MODULE_REQUEST_MESSAGE:     case CIM_ENABLE_MODULE_REQUEST_MESSAGE:
         response = handleEnableModuleRequest(request,providerName);          response = handleEnableModuleRequest(request);
  
         break;         break;
     case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE:     case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE:
         response = handleStopAllProvidersRequest(request,providerName);          response = handleStopAllProvidersRequest(request);
  
         break;         break;
     default:     default:
         response = handleUnsupportedRequest(request,providerName);          response = handleUnsupportedRequest(request);
  
         break;         break;
     }     }
Line 290 
Line 290 
  
  
  
 Message * CMPIProviderManager::handleGetInstanceRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleGetInstanceRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
         "CMPIProviderManager::handleGetInstanceRequest");         "CMPIProviderManager::handleGetInstanceRequest");
Line 316 
Line 316 
             ProviderType::INSTANCE);             ProviderType::INSTANCE);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph = providerManager.getProvider(name.getPhysicalName(),         CMPIProvider::OpProviderHolder ph = providerManager.getProvider(name.getPhysicalName(),
Line 383 
Line 383 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleEnumerateInstancesRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleEnumerateInstancesRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
         "CMPIProviderManager::handleEnumerateInstanceRequest");         "CMPIProviderManager::handleEnumerateInstanceRequest");
Line 408 
Line 408 
             ProviderType::INSTANCE);             ProviderType::INSTANCE);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 481 
Line 481 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleEnumerateInstanceNamesRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleEnumerateInstanceNamesRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleEnumerateInstanceNamesRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleEnumerateInstanceNamesRequest");
  
Line 506 
Line 506 
             ProviderType::INSTANCE);             ProviderType::INSTANCE);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 568 
Line 568 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleCreateInstanceRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleCreateInstanceRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleCreateInstanceRequest");        "CMPIProviderManager::handleCreateInstanceRequest");
Line 594 
Line 594 
             ProviderType::INSTANCE);             ProviderType::INSTANCE);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 660 
Line 660 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleModifyInstanceRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleModifyInstanceRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleModifyInstanceRequest");        "CMPIProviderManager::handleModifyInstanceRequest");
Line 686 
Line 686 
             ProviderType::INSTANCE);             ProviderType::INSTANCE);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 754 
Line 754 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleDeleteInstanceRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleDeleteInstanceRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleDeleteInstanceRequest");        "CMPIProviderManager::handleDeleteInstanceRequest");
Line 780 
Line 780 
             ProviderType::INSTANCE);             ProviderType::INSTANCE);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 842 
Line 842 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleExecQueryRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleExecQueryRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleExecQueryRequest");        "CMPIProviderManager::handleExecQueryRequest");
Line 868 
Line 868 
             ProviderType::QUERY);             ProviderType::QUERY);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 939 
Line 939 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleAssociatorsRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleAssociatorsRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleAssociatorsRequest");        "CMPIProviderManager::handleAssociatorsRequest");
Line 971 
Line 971 
             ProviderType::ASSOCIATION);             ProviderType::ASSOCIATION);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 1045 
Line 1045 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleAssociatorNamesRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleAssociatorNamesRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleAssociatorNamesRequest");        "CMPIProviderManager::handleAssociatorNamesRequest");
Line 1077 
Line 1077 
             ProviderType::ASSOCIATION);             ProviderType::ASSOCIATION);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 1147 
Line 1147 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleReferencesRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleReferencesRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
        "CMPIProviderManager::handleReferencesRequest");        "CMPIProviderManager::handleReferencesRequest");
Line 1179 
Line 1179 
             ProviderType::ASSOCIATION);             ProviderType::ASSOCIATION);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 1251 
Line 1251 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleReferenceNamesRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleReferenceNamesRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
         "CMPIProviderManager::handleReferenceNamesRequest");         "CMPIProviderManager::handleReferenceNamesRequest");
Line 1283 
Line 1283 
             ProviderType::ASSOCIATION);             ProviderType::ASSOCIATION);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 1350 
Line 1350 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleInvokeMethodRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleInvokeMethodRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
         "CMPIProviderManager::handleInvokeMethodRequest");         "CMPIProviderManager::handleInvokeMethodRequest");
Line 1377 
Line 1377 
             request->methodName);             request->methodName);
  
         // resolve provider name         // resolve provider name
         name = _resolveProviderName(providerName);          name = _resolveProviderName(name);
  
         // get cached or load new provider module         // get cached or load new provider module
         CMPIProvider::OpProviderHolder ph =         CMPIProvider::OpProviderHolder ph =
Line 1490 
Line 1490 
    return String::EMPTY;    return String::EMPTY;
 } }
  
 Message * CMPIProviderManager::handleCreateSubscriptionRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleCreateSubscriptionRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleCreateSubscriptionRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleCreateSubscriptionRequest");
  
Line 1615 
Line 1615 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleDeleteSubscriptionRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleDeleteSubscriptionRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleDeleteSubscriptionRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleDeleteSubscriptionRequest");
  
Line 1716 
Line 1716 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleEnableIndicationsRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleEnableIndicationsRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager:: handleEnableIndicationsRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager:: handleEnableIndicationsRequest");
  
Line 1774 
Line 1774 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleDisableIndicationsRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleDisableIndicationsRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager:: handleDisableIndicationsRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager:: handleDisableIndicationsRequest");
  
Line 1839 
Line 1839 
 static const Uint16 _MODULE_STOPPING = 9; static const Uint16 _MODULE_STOPPING = 9;
 static const Uint16 _MODULE_STOPPED  = 10; static const Uint16 _MODULE_STOPPED  = 10;
  
 Message * CMPIProviderManager::handleDisableModuleRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleDisableModuleRequest(const Message * message)
 { {
     // HACK     // HACK
     ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager();     ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager();
Line 1963 
Line 1963 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleEnableModuleRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleEnableModuleRequest(const Message * message)
 { {
     // HACK     // HACK
     ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager();     ProviderRegistrationManager * _providerRegistrationManager = GetProviderRegistrationManager();
Line 2043 
Line 2043 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleStopAllProvidersRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleStopAllProvidersRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleStopAllProvidersRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleStopAllProvidersRequest");
  
Line 2074 
Line 2074 
     return(response);     return(response);
 } }
  
 Message * CMPIProviderManager::handleUnsupportedRequest(const Message * message, ProviderName providerName)  Message * CMPIProviderManager::handleUnsupportedRequest(const Message * message)
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleUnsupportedRequest");     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "CMPIProviderManager::handleUnsupportedRequest");
  
Line 2086 
Line 2086 
  
 ProviderName CMPIProviderManager::_resolveProviderName(const ProviderName & providerName) ProviderName CMPIProviderManager::_resolveProviderName(const ProviderName & providerName)
 { {
     //ProviderName temp = findProvider(providerName);      ProviderName temp = findProvider(providerName);
     ProviderName temp = providerName;  
  
     String physicalName=_resolvePhysicalName(temp.getPhysicalName());     String physicalName=_resolvePhysicalName(temp.getPhysicalName());
  

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