//%2006//////////////////////////////////////////////////////////////////////// // // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.; // 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. // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; // EMC Corporation; VERITAS Software Corporation; The Open Group. // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.; // EMC Corporation; Symantec Corporation; The Open Group. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to // deal in the Software without restriction, including without limitation the // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or // sell copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // //============================================================================== // //%///////////////////////////////////////////////////////////////////////////// #include "CMPI_Version.h" #include "CMPIProviderManager.h" #include "CMPI_Object.h" #include "CMPI_Instance.h" #include "CMPI_ObjectPath.h" #include "CMPI_Result.h" #include "CMPI_SelectExp.h" #include #include #include #include #include #include #include #include //l10n #include #include #include #include #include #include #include #include #include PEGASUS_USING_STD; PEGASUS_NAMESPACE_BEGIN ReadWriteSem CMPIProviderManager::rwSemProvTab; ReadWriteSem CMPIProviderManager::rwSemSelxTab; CMPIProviderManager::IndProvTab CMPIProviderManager::provTab; CMPIProviderManager::IndSelectTab CMPIProviderManager::selxTab; class CMPIPropertyList { char **props; int pCount; public: CMPIPropertyList(CIMPropertyList &propertyList) : props(0), pCount(0) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIPropertyList::CMPIPropertyList()"); if (!propertyList.isNull()) { Array p=propertyList.getPropertyNameArray(); pCount=p.size(); props = new char*[1+pCount]; for (int i=0; ihandler) delete prec->handler; delete prec; //Remove is not neccessary, since the hashtable destructor takes //care of this already. But instead removing entries while //iterating the hashtable sometimes causes a segmentation fault!!! //provTab.remove(i.key()); prec=NULL; } } indSelectRecord *selx=NULL; { WriteLock writeLock(rwSemSelxTab); for (IndSelectTab::Iterator i = selxTab.start(); i; i++) { selxTab.lookup(i.key(), selx); if (selx->eSelx) delete selx->eSelx; if (selx->qContext) delete selx->qContext; delete selx; //Same as above! //selxTab.remove(i.key()); selx=NULL; } } PEG_METHOD_EXIT(); } Message * CMPIProviderManager::processMessage(Message * request) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::processMessage()"); Message * response = 0; // pass the request message to a handler method based on message type switch (request->getType()) { case CIM_GET_INSTANCE_REQUEST_MESSAGE: response = handleGetInstanceRequest(request); break; case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE: response = handleEnumerateInstancesRequest(request); break; case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE: response = handleEnumerateInstanceNamesRequest(request); break; case CIM_CREATE_INSTANCE_REQUEST_MESSAGE: response = handleCreateInstanceRequest(request); break; case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE: response = handleModifyInstanceRequest(request); break; case CIM_DELETE_INSTANCE_REQUEST_MESSAGE: response = handleDeleteInstanceRequest(request); break; case CIM_EXEC_QUERY_REQUEST_MESSAGE: response = handleExecQueryRequest(request); break; case CIM_ASSOCIATORS_REQUEST_MESSAGE: response = handleAssociatorsRequest(request); break; case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE: response = handleAssociatorNamesRequest(request); break; case CIM_REFERENCES_REQUEST_MESSAGE: response = handleReferencesRequest(request); break; case CIM_REFERENCE_NAMES_REQUEST_MESSAGE: response = handleReferenceNamesRequest(request); break; case CIM_INVOKE_METHOD_REQUEST_MESSAGE: response = handleInvokeMethodRequest(request); break; case CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE: response = handleCreateSubscriptionRequest(request); break; /* case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE: response = handleModifySubscriptionRequest(request); break; */ case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE: response = handleDeleteSubscriptionRequest(request); break; /* case CIM_EXPORT_INDICATION_REQUEST_MESSAGE: response = handleExportIndicationRequest(request); break; */ case CIM_DISABLE_MODULE_REQUEST_MESSAGE: response = handleDisableModuleRequest(request); break; case CIM_ENABLE_MODULE_REQUEST_MESSAGE: response = handleEnableModuleRequest(request); break; case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE: response = handleStopAllProvidersRequest(request); break; case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE: response = handleSubscriptionInitCompleteRequest (request); break; case CIM_GET_PROPERTY_REQUEST_MESSAGE: response = handleGetPropertyRequest(request); break; case CIM_SET_PROPERTY_REQUEST_MESSAGE: response = handleSetPropertyRequest(request); break; default: response = handleUnsupportedRequest(request); break; } PEG_METHOD_EXIT(); return(response); } Boolean CMPIProviderManager::hasActiveProviders() { return providerManager.hasActiveProviders(); } void CMPIProviderManager::unloadIdleProviders() { providerManager.unloadIdleProviders(); } #define CHARS(cstring) (char*)(strlen(cstring)?(const char*)cstring:NULL) #define HandlerIntroBase(type,type1,message,request,response,handler) \ CIM##type##RequestMessage * request = \ dynamic_cast(const_cast \ (message)); \ PEGASUS_ASSERT(request != 0); \ CIM##type##ResponseMessage * response = \ dynamic_cast(request->buildResponse()); \ PEGASUS_ASSERT(response != 0); \ type1##ResponseHandler handler(request, response, _responseChunkCallback); #define HandlerIntroInd(type,message,request,response,handler) \ HandlerIntroBase(type,Operation,message,request,response,handler) #define HandlerIntroInit(type,message,request,response,handler) \ HandlerIntroBase(type,Operation,message,request,response,handler) #define HandlerIntro(type,message,request,response,handler) \ HandlerIntroBase(type,type,message,request,response,handler) #define HandlerCatch(handler) \ catch(const CIMException & e) \ { PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1, \ "Exception: " + e.getMessage()); \ handler.setCIMException(e); \ } \ catch(const Exception & e) \ { PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1, \ "Exception: " + e.getMessage()); \ handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), \ e.getMessage()); \ } \ catch(...) \ { PEG_TRACE_CSTRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1, \ "Exception: Unknown"); \ handler.setStatus(CIM_ERR_FAILED, "Unknown error."); \ } void CMPIProviderManager::_setupCMPIContexts( CMPI_ContextOnStack * eCtx, OperationContext * context, ProviderIdContainer * pidc, const String &nameSpace, Boolean remote, Boolean includeQualifiers, Boolean includeClassOrigin, Boolean setFlags) { if (setFlags) { // set CMPI invocation flags CMPIValue value; value.uint32 = 0; if (includeQualifiers) value.uint32 |= CMPI_FLAG_IncludeQualifiers; if (includeClassOrigin) value.uint32 |= CMPI_FLAG_IncludeClassOrigin; eCtx->ft->addEntry( eCtx, CMPIInvocationFlags, &value, CMPI_uint32); } // add identity context const IdentityContainer container = context->get(IdentityContainer::NAME); eCtx->ft->addEntry( eCtx, CMPIPrincipal, (CMPIValue*)(const char*)container.getUserName().getCString(), CMPI_chars); // add AcceptLanguages to CMPI context const AcceptLanguageListContainer accept_language= context->get(AcceptLanguageListContainer::NAME); const AcceptLanguageList acceptLangs = accept_language.getLanguages(); eCtx->ft->addEntry( eCtx, CMPIAcceptLanguage, (CMPIValue*)(const char*) LanguageParser::buildAcceptLanguageHeader(acceptLangs).getCString(), CMPI_chars); // add initial namespace to context eCtx->ft->addEntry( eCtx, CMPIInitNameSpace, (CMPIValue*)(const char*)nameSpace.getCString(), CMPI_chars); // add remote info to context if (remote) { CString info=pidc->getRemoteInfo().getCString(); eCtx->ft->addEntry( eCtx, "CMPIRRemoteInfo",(CMPIValue*)(const char*)info, CMPI_chars); } } Message * CMPIProviderManager::handleGetInstanceRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleGetInstanceRequest()"); HandlerIntro(GetInstance,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleGetInstanceRequest - Host name:" " %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->instanceName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->instanceName.getClassName(), request->instanceName.getKeyBindings()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT AutoPtr tmpNormalizerContext( new CIMOMHandleContext(*pr.getCIMOMHandle())); request->operationContext.insert( NormalizerContextContainer(tmpNormalizerContext)); #endif PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.getInstance: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); CMPIPropertyList props(request->propertyList); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, request->includeQualifiers, request->includeClassOrigin, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->getInstance( pr.getInstMI(), &eCtx, &eRes, &eRef, (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleEnumerateInstancesRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleEnumerateInstanceRequest()"); HandlerIntro(EnumerateInstances,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleEnumerateInstancesRequest - Host name:" " %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->className.getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->className); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); CIMPropertyList propertyList(request->propertyList); // forward request CMPIProvider & pr=ph.GetProvider(); #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT AutoPtr tmpNormalizerContext( new CIMOMHandleContext(*pr.getCIMOMHandle())); request->operationContext.insert( NormalizerContextContainer(tmpNormalizerContext)); #endif PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.enumerateInstances: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); CMPIPropertyList props(propertyList); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, request->includeQualifiers, request->includeClassOrigin, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->enumerateInstances( pr.getInstMI(), &eCtx, &eRes, &eRef, (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry(&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleEnumerateInstanceNamesRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleEnumerateInstanceNamesRequest()"); HandlerIntro(EnumerateInstanceNames,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleEnumerateInstanceNamesRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->className.getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->className); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.enumerateInstanceNames: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->enumerateInstanceNames( pr.getInstMI(), &eCtx, &eRes, &eRef); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleCreateInstanceRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleCreateInstanceRequest()"); HandlerIntro(CreateInstance,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleCreateInstanceRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->newInstance.getPath().getClassName().getString().getCString() )); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->newInstance.getPath().getClassName(), request->newInstance.getPath().getKeyBindings()); request->newInstance.setPath(objectPath); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.createInstance: " + ph.GetProvider().getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_InstanceOnStack eInst(request->newInstance); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->createInstance( pr.getInstMI(), &eCtx, &eRes, &eRef, &eInst); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleModifyInstanceRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleModifyInstanceRequest()"); HandlerIntro(ModifyInstance,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleModifyInstanceRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->modifiedInstance.\ getPath().getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->modifiedInstance.getPath ().getClassName(), request->modifiedInstance.getPath ().getKeyBindings()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.modifyInstance: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_InstanceOnStack eInst(request->modifiedInstance); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); CMPIPropertyList props(request->propertyList); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, request->includeQualifiers, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->modifyInstance( pr.getInstMI(), &eCtx, &eRes, &eRef, &eInst, (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleDeleteInstanceRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleDeleteInstanceRequest()"); HandlerIntro(DeleteInstance,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleDeleteInstanceRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->instanceName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->instanceName.getClassName(), request->instanceName.getKeyBindings()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.deleteInstance: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->deleteInstance( pr.getInstMI(), &eCtx, &eRes, &eRef); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleExecQueryRequest(const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleExecQueryRequest()"); HandlerIntro(ExecQuery,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::ExecQueryRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->className.getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->className); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.execQuery: " + pr.getName()); const char **props=NULL; CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); const CString queryLan=request->queryLanguage.getCString(); const CString query=request->query.getCString(); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->execQuery( pr.getInstMI(), &eCtx, &eRes, &eRef, CHARS(queryLan), CHARS(query)); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleAssociatorsRequest(const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleAssociatorsRequest()"); HandlerIntro(Associators,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleAssociatorsRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->objectName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->objectName.getClassName()); objectPath.setKeyBindings(request->objectName.getKeyBindings()); CIMObjectPath assocPath( System::getHostName(), request->nameSpace, request->assocClass.getString()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT AutoPtr tmpNormalizerContext( new CIMOMHandleContext(*pr.getCIMOMHandle())); request->operationContext.insert( NormalizerContextContainer(tmpNormalizerContext)); #endif PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.associators: " + pr.getName()); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, String("--- CMPIProviderManager::associators < role: >" ) + request->role + request->assocClass.getString()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); const CString aClass=request->assocClass.getString().getCString(); const CString rClass=request->resultClass.getString().getCString(); const CString rRole=request->role.getCString(); const CString resRole=request->resultRole.getCString(); CMPIPropertyList props(request->propertyList); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, request->includeQualifiers, request->includeClassOrigin, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getAssocMI()->ft->associators( pr.getAssocMI(), &eCtx, &eRes, &eRef, CHARS(aClass), CHARS(rClass), CHARS(rRole), CHARS(resRole), (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry ( &eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleAssociatorNamesRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleAssociatorNamesRequest()"); HandlerIntro(AssociatorNames,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleAssociatorNamesRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->objectName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->objectName.getClassName()); objectPath.setKeyBindings(request->objectName.getKeyBindings()); CIMObjectPath assocPath( System::getHostName(), request->nameSpace, request->assocClass.getString()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.associatorNames: " + pr.getName()); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, String("--- CMPIProviderManager::associatorNames -- role: ") + request->role + "< aCls " + request->assocClass.getString()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); const CString aClass=request->assocClass.getString().getCString(); const CString rClass=request->resultClass.getString().getCString(); const CString rRole=request->role.getCString(); const CString resRole=request->resultRole.getCString(); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getAssocMI()->ft->associatorNames( pr.getAssocMI(), &eCtx, &eRes, &eRef, CHARS(aClass), CHARS(rClass), CHARS(rRole), CHARS(resRole)); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleReferencesRequest(const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleReferencesRequest()"); HandlerIntro(References,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleReferencesRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->objectName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->objectName.getClassName()); objectPath.setKeyBindings(request->objectName.getKeyBindings()); CIMObjectPath resultPath( System::getHostName(), request->nameSpace, request->resultClass.getString()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT AutoPtr tmpNormalizerContext( new CIMOMHandleContext(*pr.getCIMOMHandle())); request->operationContext.insert( NormalizerContextContainer(tmpNormalizerContext)); #endif PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.references: " + pr.getName()); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, String("--- CMPIProviderManager::references -- role:") + request->role + "< aCls " + request->resultClass.getString()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); const CString rClass=request->resultClass.getString().getCString(); const CString rRole=request->role.getCString(); CMPIPropertyList props(request->propertyList); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, request->includeQualifiers, request->includeClassOrigin, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getAssocMI()->ft->references( pr.getAssocMI(), &eCtx, &eRes, &eRef, CHARS(rClass), CHARS(rRole), (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleReferenceNamesRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleReferenceNamesRequest()"); HandlerIntro(ReferenceNames,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleReferenceNamesRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->objectName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->objectName.getClassName()); objectPath.setKeyBindings(request->objectName.getKeyBindings()); CIMObjectPath resultPath( System::getHostName(), request->nameSpace, request->resultClass.getString()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.referenceNames: " + pr.getName()); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, String("--- CMPIProviderManager::referenceNames -- role: ") + request->role + "< aCls " + request->resultClass.getString()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); const CString rClass=request->resultClass.getString().getCString(); const CString rRole=request->role.getCString(); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getAssocMI()->ft->referenceNames( pr.getAssocMI(), &eCtx, &eRes, &eRef, CHARS(rClass), CHARS(rRole)); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleInvokeMethodRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleInvokeMethodRequest()"); HandlerIntro(InvokeMethod,message,request,response,handler); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleInvokeMethodRequest" " - Host name: %s Name space: %s Class name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->instanceName.getClassName().getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->instanceName.getClassName(), request->instanceName.getKeyBindings()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); CIMObjectPath instanceReference(request->instanceName); // ATTN: propagate namespace instanceReference.setNameSpace(request->nameSpace); // forward request CMPIProvider & pr=ph.GetProvider(); #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT AutoPtr tmpNormalizerContext( new CIMOMHandleContext(*pr.getCIMOMHandle())); request->operationContext.insert( NormalizerContextContainer(tmpNormalizerContext)); #endif PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.invokeMethod: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); CMPI_ArgsOnStack eArgsIn(request->inParameters); Array outArgs; CMPI_ArgsOnStack eArgsOut(outArgs); CString mName=request->methodName.getString().getCString(); _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getMethMI()->ft->invokeMethod( pr.getMethMI(), &eCtx, &eRes, &eRef, CHARS(mName), &eArgsIn, &eArgsOut); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT // Even if external normalization is enabled we don't normalize the // Embedded instances present in output args. Normalize them here. { // There is no try catch here because if there is no external // normalization, then these containers were added by this method. const CachedClassDefinitionContainer * classCont = dynamic_cast( &request->operationContext.get( CachedClassDefinitionContainer::NAME)); PEGASUS_ASSERT(classCont != 0); const NormalizerContextContainer * contextCont = dynamic_cast( &request->operationContext.get( NormalizerContextContainer::NAME)); PEGASUS_ASSERT(contextCont != 0); CIMClass classDef(classCont->getClass()); Uint32 methodIndex = classDef.findMethod(request->methodName); PEGASUS_ASSERT(methodIndex != PEG_NOT_FOUND); CIMMethod methodDef(classDef.getMethod(methodIndex)); for (unsigned int i = 0, n = outArgs.size(); i < n; ++i) { CIMParamValue currentParam(outArgs[i]); CIMValue paramValue(currentParam.getValue()); // If the parameter value is an EmbeddedObject type, we have // to check against the type of the parameter definition. // CMPI does not distinguish between EmbeddedObjects and // EmbeddedInstances, so if the parameter definition has a type // of EmbeddedInstance, the type of the output parameter must // be changed. if (paramValue.getType() == CIMTYPE_OBJECT) { String currentParamName(currentParam.getParameterName()); Uint32 paramIndex = methodDef.findParameter( CIMName(currentParamName)); if (paramIndex == PEG_NOT_FOUND) { MessageLoaderParms msg("ProviderManager.CMPI." "CMPIProviderManager.PARAMETER_NOT_FOUND", "Parameter $0 not found in definition for " "method $1.", currentParamName, request->methodName.getString()); PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1, MessageLoader::getMessage(msg)); handler.setStatus(CIM_ERR_FAILED, MessageLoader::getMessage(msg)); } else { CIMConstParameter paramDef( methodDef.getParameter(paramIndex)); if (paramDef.findQualifier(CIMName("EmbeddedInstance")) != PEG_NOT_FOUND) { if (paramValue.isArray()) { Array paramInstArr; Array paramObjectArr; paramValue.get(paramObjectArr); for (Uint32 i = 0 ; i < paramObjectArr.size() ; ++i) { paramInstArr.append( CIMInstance(paramObjectArr[i])); // resolve each embedded instance. resolveEmbeddedInstanceTypes( &handler, paramInstArr[i]); } currentParam = CIMParamValue(currentParamName, CIMValue(paramInstArr)); } else { CIMObject paramObject; paramValue.get(paramObject); CIMInstance paramInst(paramObject); resolveEmbeddedInstanceTypes(&handler, paramInst); currentParam = CIMParamValue(currentParamName, CIMValue(paramInst)); } } else { currentParam = CIMParamValue(currentParamName, paramValue); } handler.deliverParamValue(currentParam); } } else { handler.deliverParamValue(currentParam); } } } #else for (int i=0,s=outArgs.size(); ioperationContext.get( ProviderIdContainer::NAME); req_provider = pidc.getProvider(); req_providerModule = pidc.getModule(); String providerName,providerLocation; LocateIndicationProviderNames(req_provider, req_providerModule, providerName,providerLocation); PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleCreateSubscriptionRequest" " - Host name: %s Name space: %s Provider name(s): %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) providerName.getCString())); Boolean remote=false; OpProviderHolder ph; if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( providerLocation, providerName); } else { // get cached or load new provider module ph = providerManager.getProvider( providerLocation, providerName); } indProvRecord *prec=NULL; { WriteLock writeLock(rwSemProvTab); provTab.lookup(ph.GetProvider().getName(),prec); if (prec) prec->count++; else { prec=new indProvRecord(); #ifdef PEGASUS_ENABLE_REMOTE_CMPI if (remote) { prec->remoteInfo = pidc.getRemoteInfo(); } #endif provTab.insert(ph.GetProvider().getName(),prec); } } // // Save the provider instance from the request // ph.GetProvider ().setProviderInstance (req_provider); const CIMObjectPath &sPath=request->subscriptionInstance.getPath(); indSelectRecord *srec=NULL; { WriteLock writeLock(rwSemSelxTab); selxTab.lookup(sPath,srec); if (srec) srec->count++; else { srec=new indSelectRecord(); selxTab.insert(sPath,srec); } } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); context.insert( request->operationContext.get(SubscriptionInstanceContainer::NAME)); context.insert( request->operationContext.get( SubscriptionFilterConditionContainer::NAME)); CIMObjectPath subscriptionName = request->subscriptionInstance.getPath(); CMPIProvider & pr=ph.GetProvider(); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); SubscriptionFilterConditionContainer sub_cntr = request->operationContext.get( SubscriptionFilterConditionContainer::NAME); CIMOMHandleQueryContext *_context= new CIMOMHandleQueryContext( CIMNamespaceName( request->nameSpace.getString()), *pr.getCIMOMHandle()); CMPI_SelectExp *eSelx=new CMPI_SelectExp( context, _context, request->query, sub_cntr.getQueryLanguage()); srec->eSelx=eSelx; srec->qContext=_context; CMPI_ThreadContext thr(pr.getBroker(),&eCtx); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.createSubscriptionRequest: " + pr.getName()); for (Uint32 i = 0, n = request->classNames.size(); i < n; i++) { CIMObjectPath className( System::getHostName(), request->nameSpace, request->classNames[i]); eSelx->classNames.append(className); } CMPI_ObjectPathOnStack eRef(eSelx->classNames[0]); CIMPropertyList propertyList = request->propertyList; if (!propertyList.isNull()) { Array p=propertyList.getPropertyNameArray(); int pCount=p.size(); eSelx->props = new const char*[1+pCount]; for (int i=0; iprops[i]=strdup(p[i].getString().getCString()); } eSelx->props[pCount]=NULL; } Uint16 repeatNotificationPolicy = request->repeatNotificationPolicy; // includeQualifiers and includeClassOrigin not of interest for // this type of request _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); if (pr.getIndMI()->ft->ftVersion >= 100) { rc = pr.getIndMI()->ft->activateFilter( pr.getIndMI(), &eCtx,eSelx, CHARS(eSelx->classNames[0].getClassName().getString(). getCString()), &eRef, false); } else { // Older version of (pre 1.00) also pass in a CMPIResult rc = ((CMPIStatus (*)(CMPIIndicationMI*, CMPIContext*, CMPIResult*, CMPISelectExp*, const char *, CMPIObjectPath*, CMPIBoolean)) pr.getIndMI()->ft->activateFilter) (pr.getIndMI(),&eCtx,NULL,eSelx, CHARS(eSelx->classNames[0].getClassName().getString(). getCString()),&eRef,false); } } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); } if (rc.rc!=CMPI_RC_OK) { // Removed the select expression from the cache WriteLock lock(rwSemSelxTab); if (--srec->count<=0) { selxTab.remove(sPath); delete _context; delete eSelx; delete srec; } throw CIMException((CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); } else { // // Increment count of current subscriptions for this provider // if (ph.GetProvider ().testIfZeroAndIncrementSubscriptions ()) { // // If there were no current subscriptions before the increment, // the first subscription has been created // Call the provider's enableIndications method // if (_subscriptionInitComplete) { _callEnableIndications (req_provider, _indicationCallback, ph, (const char*)pidc.getRemoteInfo().getCString()); } } } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleDeleteSubscriptionRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleDeleteSubscriptionRequest()"); HandlerIntroInd(DeleteSubscription,message,request,response, handler); try { String providerName,providerLocation; CIMInstance req_provider, req_providerModule; ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get( ProviderIdContainer::NAME); req_provider = pidc.getProvider(); req_providerModule = pidc.getModule(); LocateIndicationProviderNames(req_provider, req_providerModule, providerName,providerLocation); PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleDeleteSubscriptionRequest" " - Host name: %s Name space: %s Provider name(s): %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) providerName.getCString())); Boolean remote=false; OpProviderHolder ph; if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( providerLocation, providerName); } else { // get cached or load new provider module ph = providerManager.getProvider( providerLocation, providerName); } indProvRecord *prec=NULL; { WriteLock writeLock(rwSemProvTab); provTab.lookup(ph.GetProvider().getName(),prec); if (--prec->count<=0) { if (prec->handler) delete prec->handler; delete prec; provTab.remove(ph.GetProvider().getName()); prec=NULL; } } indSelectRecord *srec=NULL; const CIMObjectPath &sPath=request->subscriptionInstance.getPath(); WriteLock writeLock(rwSemSelxTab); if (!selxTab.lookup(sPath,srec)) { MessageLoaderParms parms( "ProviderManager.CMPI.CMPIProviderManager." "FAILED_LOCATE_SUBSCRIPTION_FILTER", "Failed to locate the subscription filter."); // failed to get select expression from hash table throw CIMException(CIM_ERR_FAILED, parms); }; CMPI_SelectExp *eSelx=srec->eSelx; CIMOMHandleQueryContext *qContext=srec->qContext; CMPI_ObjectPathOnStack eRef(eSelx->classNames[0]); if (--srec->count<=0) { selxTab.remove(sPath); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); context.insert( request->operationContext.get(SubscriptionInstanceContainer::NAME)); CIMObjectPath subscriptionName = request->subscriptionInstance.getPath(); CMPIProvider & pr=ph.GetProvider(); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.deleteSubscriptionRequest: " + pr.getName()); // includeQualifiers and includeClassOrigin not of interest for // this type of request _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); if (pr.getIndMI()->ft->ftVersion >= 100) { rc = pr.getIndMI()->ft->deActivateFilter( pr.getIndMI(), &eCtx, eSelx, CHARS(eSelx->classNames[0].getClassName().getString(). getCString()), &eRef, prec==NULL); } else { // Older version of (pre 1.00) also pass in a CMPIResult rc = ((CMPIStatus (*)(CMPIIndicationMI*, CMPIContext*, CMPIResult*, CMPISelectExp*, const char *, CMPIObjectPath*, CMPIBoolean)) pr.getIndMI()->ft->deActivateFilter) (pr.getIndMI(),&eCtx,NULL,eSelx, CHARS(eSelx->classNames[0].getClassName().getString(). getCString()),&eRef,prec==NULL); } } if (srec->count<=0) { delete qContext; delete eSelx; delete srec; } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); } if (rc.rc!=CMPI_RC_OK) { throw CIMException((CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); } else { // // Decrement count of current subscriptions for this provider // if (ph.GetProvider ().decrementSubscriptionsAndTestIfZero ()) { // // If there are no current subscriptions after the decrement, // the last subscription has been deleted // Call the provider's disableIndications method // if (_subscriptionInitComplete) { _callDisableIndications( ph, (const char*)pidc.getRemoteInfo().getCString()); } } } } HandlerCatch(handler); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleDisableModuleRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleDisableModuleRequest()"); CIMDisableModuleRequestMessage * request = dynamic_cast( const_cast(message)); PEGASUS_ASSERT(request != 0); // get provider module name Boolean disableProviderOnly = request->disableProviderOnly; Array operationalStatus; // Assume success. operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_STOPPED); // // Unload providers // Array _pInstances = request->providers; Array _indicationProviders = request->indicationProviders; /* The CIMInstances on request->providers array is completly _different_ than the request->providerModule CIMInstance. Hence */ String physicalName=(request->providerModule.getProperty( request-> providerModule.findProperty("Location")).getValue().toString()); for (Uint32 i = 0, n = _pInstances.size(); i < n; i++) { String providerName; _pInstances [i].getProperty (_pInstances [i].findProperty (CIMName ("Name"))).getValue ().get (providerName); Uint32 pos = _pInstances[i].findProperty("Name"); if (!providerManager.isProviderActive(providerName)) { continue; } // // Reset the indication provider's count of current // subscriptions since it has been disabled // if (_indicationProviders [i]) { if (physicalName.size () > 0) { try { OpProviderHolder ph = providerManager.getProvider( physicalName, providerName); ph.GetProvider ().resetSubscriptions (); } catch (const Exception &e) { PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1, e.getMessage()); } } } providerManager.unloadProvider( physicalName, _pInstances[i].getProperty( _pInstances[i].findProperty("Name") ).getValue ().toString ()); } CIMDisableModuleResponseMessage* response = dynamic_cast( request->buildResponse()); PEGASUS_ASSERT(response != 0); response->operationalStatus = operationalStatus; PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleEnableModuleRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleEnableModuleRequest()"); CIMEnableModuleRequestMessage * request = dynamic_cast( const_cast(message)); PEGASUS_ASSERT(request != 0); Array operationalStatus; operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK); CIMEnableModuleResponseMessage* response = dynamic_cast( request->buildResponse()); PEGASUS_ASSERT(response != 0); response->operationalStatus = operationalStatus; PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleStopAllProvidersRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleStopAllProvidersRequest()"); CIMStopAllProvidersRequestMessage * request = dynamic_cast( const_cast(message)); PEGASUS_ASSERT(request != 0); CIMStopAllProvidersResponseMessage* response = dynamic_cast( request->buildResponse()); PEGASUS_ASSERT(response != 0); // tell the provider manager to shutdown all the providers providerManager.shutdownAllProviders(); PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleSubscriptionInitCompleteRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleSubscriptionInitCompleteRequest()"); CIMSubscriptionInitCompleteRequestMessage * request = dynamic_cast (const_cast (message)); PEGASUS_ASSERT (request != 0); CIMSubscriptionInitCompleteResponseMessage * response = dynamic_cast (request->buildResponse ()); PEGASUS_ASSERT (response != 0); // // Set indicator // _subscriptionInitComplete = true; // // For each provider that has at least one subscription, call // provider's enableIndications method // Array enableProviders; enableProviders = providerManager.getIndicationProvidersToEnable (); Uint32 numProviders = enableProviders.size (); for (Uint32 i = 0; i < numProviders; i++) { try { CIMInstance provider; provider = enableProviders [i]->getProviderInstance (); CString info; #ifdef PEGASUS_ENABLE_REMOTE_CMPI indProvRecord *provRec = 0; if (provTab.lookup (enableProviders [i]->getName(), provRec)) { if (provRec->remoteInfo != String::EMPTY) { info = provRec->remoteInfo.getCString(); } } #endif // // Get cached or load new provider module // OpProviderHolder ph; if ((const char*)info) { ph = providerManager.getRemoteProvider (enableProviders [i]->getModule ()->getFileName (), enableProviders [i]->getName ()); } else { ph = providerManager.getProvider (enableProviders [i]->getModule ()->getFileName (), enableProviders [i]->getName ()); } _callEnableIndications( provider, _indicationCallback, ph, (const char*)info); } catch (const CIMException & e) { PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL1, "CIMException: " + e.getMessage ()); } catch (const Exception & e) { PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL1, "Exception: " + e.getMessage ()); } catch (...) { PEG_TRACE_CSTRING( TRC_PROVIDERMANAGER, Tracer::LEVEL1, "Unknown error in handleSubscriptionInitCompleteRequest"); } } PEG_METHOD_EXIT (); return(response); } Message * CMPIProviderManager::handleGetPropertyRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleGetPropertyRequest()"); HandlerIntro(GetProperty,message,request,response,handler); // We're only going to be interested in the specific property from this // instance. Array localPropertyListArray; localPropertyListArray.append(request->propertyName); CIMPropertyList localPropertyList(localPropertyListArray); // NOTE: GetProperty will use the CIMInstanceProvider interface, so we // must manually define a request, response, and handler (emulate // HandlerIntro macro) CIMGetInstanceRequestMessage * GI_request = new CIMGetInstanceRequestMessage( request->messageId, request->nameSpace, request->instanceName, false, false, false, localPropertyList, request->queueIds, request->authType, request->userName ); PEGASUS_ASSERT(GI_request != 0); CIMGetInstanceResponseMessage * GI_response = dynamic_cast (GI_request->buildResponse()); PEGASUS_ASSERT(GI_response != 0); GetInstanceResponseHandler GI_handler( GI_request, GI_response, _responseChunkCallback); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleGetPropertyRequest" " - Host name: %s Name space: %s " "Class name: %s Property name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->instanceName.getClassName().getString().getCString(), (const char*) request->propertyName.getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->instanceName.getClassName(), request->instanceName.getKeyBindings()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT AutoPtr tmpNormalizerContext( new CIMOMHandleContext(*pr.getCIMOMHandle())); request->operationContext.insert( NormalizerContextContainer(tmpNormalizerContext)); #endif PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.getInstance via getProperty: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(GI_handler,pr.getBroker()); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); // For the getInstance provider call, use the property list that we // created containing the single property from the getProperty call. CMPIPropertyList props(localPropertyList); // Leave includeQualifiers and includeClassOrigin as false for this // call to getInstance _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->getInstance( pr.getInstMI(), &eCtx, &eRes, &eRef, (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } // Copy property value from instance to getProperty response if (!(GI_response->cimInstance.isUninitialized())) { Uint32 pos = GI_response->cimInstance.findProperty(request->propertyName); if (pos != PEG_NOT_FOUND) { response->value = GI_response->cimInstance.getProperty(pos).getValue(); } // Else property not found. Return CIM_ERR_NO_SUCH_PROPERTY. else { throw PEGASUS_CIM_EXCEPTION( CIM_ERR_NO_SUCH_PROPERTY, request->propertyName.getString() ); } } } HandlerCatch(handler); delete GI_request; delete GI_response; PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleSetPropertyRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleSetPropertyRequest()"); HandlerIntro(SetProperty,message,request,response,handler); // We're only going to be interested in the specific property from this // instance. Array localPropertyListArray; localPropertyListArray.append(request->propertyName); CIMPropertyList localPropertyList(localPropertyListArray); // Build a modified instance with just the specific property and its // new value. CIMInstance localModifiedInstance(request->instanceName.getClassName()); localModifiedInstance.setPath(request->instanceName); localModifiedInstance.addProperty( CIMProperty(request->propertyName, request->newValue)); // NOTE: SetProperty will use the CIMInstanceProvider interface, so we must // manually define a request, response, and handler. CIMModifyInstanceRequestMessage * MI_request = new CIMModifyInstanceRequestMessage( request->messageId, request->nameSpace, localModifiedInstance, false, localPropertyList, request->queueIds, request->authType, request->userName ); PEGASUS_ASSERT(MI_request != 0); CIMModifyInstanceResponseMessage * MI_response = dynamic_cast( MI_request->buildResponse()); PEGASUS_ASSERT(MI_response != 0); ModifyInstanceResponseHandler MI_handler( MI_request, MI_response, _responseChunkCallback); try { PEG_TRACE(( TRC_PROVIDERMANAGER, Tracer::LEVEL3, "CMPIProviderManager::handleSetPropertyRequest" " - Host name: %s Name space: %s " "Class name: %s Property name: %s", (const char*) System::getHostName().getCString(), (const char*) request->nameSpace.getString().getCString(), (const char*) request->instanceName.getClassName().getString().getCString(), (const char*) request->propertyName.getString().getCString())); // make target object path CIMObjectPath objectPath( System::getHostName(), request->nameSpace, request->instanceName.getClassName(), request->instanceName.getKeyBindings()); Boolean remote=false; OpProviderHolder ph; // resolve provider name ProviderIdContainer pidc = request->operationContext.get(ProviderIdContainer::NAME); ProviderName name = _resolveProviderName(pidc); if ((remote=pidc.isRemoteNameSpace())) { ph = providerManager.getRemoteProvider( name.getLocation(), name.getLogicalName()); } else { // get cached or load new provider module ph = providerManager.getProvider( name.getPhysicalName(), name.getLogicalName()); } // convert arguments OperationContext context; context.insert(request->operationContext.get(IdentityContainer::NAME)); context.insert( request->operationContext.get(AcceptLanguageListContainer::NAME)); context.insert( request->operationContext.get(ContentLanguageListContainer::NAME)); // forward request CMPIProvider & pr=ph.GetProvider(); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.modifyInstance via setProperty: " + pr.getName()); CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ObjectPathOnStack eRef(objectPath); CMPI_ResultOnStack eRes(MI_handler,pr.getBroker()); CMPI_InstanceOnStack eInst(localModifiedInstance); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); CMPIPropertyList props(localPropertyList); // Leave includeQualifiers as false for this call to modifyInstance _setupCMPIContexts( &eCtx, &context, &pidc, request->nameSpace.getString(), remote, false, false, true); CMPIProvider::pm_service_op_lock op_lock(&pr); AutoPThreadSecurity threadLevelSecurity(request->operationContext); { StatProviderTimeMeasurement providerTime(response); rc = pr.getInstMI()->ft->modifyInstance( pr.getInstMI(), &eCtx, &eRes, &eRef, &eInst, (const char **)props.getList()); } // Need to save ContentLanguage value into operation context of response // Do this before checking rc from provider to throw exception in case // rc.msg is also localized. CMPIStatus tmprc={CMPI_RC_OK,NULL}; CMPIData cldata = eCtx.ft->getEntry (&eCtx, CMPIContentLanguage, &tmprc); if (tmprc.rc == CMPI_RC_OK) { response->operationContext.set( ContentLanguageListContainer( ContentLanguageList( LanguageParser::parseContentLanguageHeader( CMGetCharPtr(cldata.value.string))))); handler.setContext(response->operationContext); } if (rc.rc!=CMPI_RC_OK) { CIMException cimException( (CIMStatusCode)rc.rc, rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY); if (eRes.resError) { for (CMPI_Error* currErr=eRes.resError; currErr!=NULL; currErr=currErr->nextError) { cimException.addError( ((CIMError*)currErr->hdl)->getInstance()); } } throw cimException; } } HandlerCatch(handler); delete MI_request; delete MI_response; PEG_METHOD_EXIT(); return(response); } Message * CMPIProviderManager::handleUnsupportedRequest( const Message * message) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::handleUnsupportedRequest()"); CIMRequestMessage* request = dynamic_cast(const_cast(message)); PEGASUS_ASSERT(request != 0 ); CIMResponseMessage* response = request->buildResponse(); response->cimException = PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED, String::EMPTY); PEG_METHOD_EXIT(); return response; } ProviderName CMPIProviderManager::_resolveProviderName( const ProviderIdContainer & providerId) { String providerName; String fileName; String location; String moduleName; CIMValue genericValue; PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::_resolveProviderName()"); genericValue = providerId.getModule().getProperty( providerId.getModule().findProperty("Name")).getValue(); genericValue.get(moduleName); genericValue = providerId.getProvider().getProperty( providerId.getProvider().findProperty("Name")).getValue(); genericValue.get(providerName); genericValue = providerId.getModule().getProperty( providerId.getModule().findProperty("Location")).getValue(); genericValue.get(location); fileName = _resolvePhysicalName(location); // An empty file name is only for interest if we are in the // local name space. So the message is only issued if not // in the remote Name Space. if (fileName == String::EMPTY && (!providerId.isRemoteNameSpace())) { genericValue.get(location); String fullName = FileSystem::buildLibraryFileName(location); Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::SEVERE, "ProviderManager.CMPI.CMPIProviderManager.CANNOT_FIND_LIBRARY", "For provider $0 library $1 was not found.", providerName, fullName); } ProviderName name(moduleName, providerName, fileName); name.setLocation(location); PEG_METHOD_EXIT(); return name; } void CMPIProviderManager::_callEnableIndications (CIMInstance & req_provider, PEGASUS_INDICATION_CALLBACK_T _indicationCallback, OpProviderHolder & ph, const char* remoteInfo) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::_callEnableIndications()"); try { indProvRecord *provRec =0; { WriteLock lock(rwSemProvTab); if (provTab.lookup (ph.GetProvider ().getName (), provRec)) { provRec->enabled = true; CIMRequestMessage * request = 0; CIMResponseMessage * response = 0; provRec->handler=new EnableIndicationsResponseHandler( request, response, req_provider, _indicationCallback, _responseChunkCallback); } } CMPIProvider & pr=ph.GetProvider(); // // Versions prior to 86 did not include enableIndications routine // if (pr.getIndMI()->ft->ftVersion >= 86) { OperationContext context; #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY // For the z/OS security model we always need an Identity container // in the operation context. Since we don't have a client request // ID here we have to use the cim servers identity for the time // being. IdentityContainer idContainer(System::getEffectiveUserName()); context.insert(idContainer); #endif CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); CMPI_ThreadContext thr(pr.getBroker(),&eCtx); // Add RemoteInformation -V 5245 if (remoteInfo) { eCtx.ft->addEntry(&eCtx,"CMPIRRemoteInfo", (CMPIValue*)(const char*)remoteInfo,CMPI_chars); } PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.enableIndications: " + pr.getName()); pr.protect(); // enableIndications() is defined by the CMPI standard as // returning a CMPIStatus return value. Unfortunately, Pegasus // originally implemented enableIndications() with a void // return type, and this incompatibility was not detected for // some time. Since exceptions thrown from enableIndications() // are not reported (other than via logging), it was decided to // discard the returned CMPIStatus here. This will prevent us from // breaking existing CMPI Indication providers. This is ok since // there really isn't a user to which the problem should be // reported. pr.getIndMI()->ft->enableIndications(pr.getIndMI(),&eCtx); } else { PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Not calling provider.enableIndications: " + pr.getName() + " routine as it is an earlier version that does not support " \ "this function"); } } catch (const Exception & e) { Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING, "ProviderManager.CMPI.CMPIProviderManager." "ENABLE_INDICATIONS_FAILED", "Failed to enable indications for provider $0: $1.", ph.GetProvider ().getName (), e.getMessage ()); } catch (...) { Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING, "ProviderManager.CMPI.CMPIProviderManager." "ENABLE_INDICATIONS_FAILED_UNKNOWN", "Failed to enable indications for provider $0.", ph.GetProvider ().getName ()); } PEG_METHOD_EXIT (); } void CMPIProviderManager::_callDisableIndications (OpProviderHolder & ph, const char *remoteInfo) { PEG_METHOD_ENTER( TRC_PROVIDERMANAGER, "CMPIProviderManager::_callDisableIndications()"); try { indProvRecord * provRec = 0; { WriteLock writeLock(rwSemProvTab); if (provTab.lookup (ph.GetProvider ().getName (), provRec)) { provRec->enabled = false; if (provRec->handler) delete provRec->handler; provRec->handler = NULL; } } CMPIProvider & pr=ph.GetProvider(); // // Versions prior to 86 did not include disableIndications routine // if (pr.getIndMI()->ft->ftVersion >= 86) { OperationContext context; CMPIStatus rc={CMPI_RC_OK,NULL}; CMPI_ContextOnStack eCtx(context); if (remoteInfo) { eCtx.ft->addEntry(&eCtx,"CMPIRRemoteInfo", (CMPIValue*)(const char*)remoteInfo,CMPI_chars); } CMPI_ThreadContext thr(pr.getBroker(),&eCtx); PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.disableIndications: " + pr.getName()); // disableIndications() is defined by the CMPI standard as // returning a CMPIStatus return value. Unfortunately, Pegasus // originally implemented disableIndications() with a void // return type, and this incompatibility was not detected for // some time. For consistency with the enableIndications() // interface, it was decided to discard the returned CMPIStatus // here. This will prevent us from breaking existing CMPI // Indication providers. This is ok since there really isn't a // user to which the problem should be reported. pr.getIndMI()->ft->disableIndications( pr.getIndMI(), &eCtx); pr.unprotect(); } else { PEG_TRACE_STRING( TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Not calling provider.disableIndications: " + pr.getName() + " routine as it is an earlier version that does not support" \ " this function"); } } catch (const Exception & e) { Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING, "ProviderManager.CMPI.CMPIProviderManager." "DISABLE_INDICATIONS_FAILED", "Failed to disable indications for provider $0: $1.", ph.GetProvider ().getName (), e.getMessage ()); } catch (...) { Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING, "ProviderManager.CMPI.CMPIProviderManager." "DISABLE_INDICATIONS_FAILED_UNKNOWN", "Failed to disable indications for provider $0.", ph.GetProvider ().getName ()); } PEG_METHOD_EXIT (); } PEGASUS_NAMESPACE_END