pegasus/src/Pegasus/ProviderManager2/JMPI/JMPIProviderManager.cpp - diff

Return to JMPIProviderManager.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / JMPI

Diff for /pegasus/src/Pegasus/ProviderManager2/JMPI/JMPIProviderManager.cpp between version 1.6 and 1.27

version 1.6, 2004/06/04 02:23:59

version 1.27, 2005/05/26 22:02:29

Line 1

//%2003////////////////////////////////////////////////////////////////////////

//%2005////////////////////////////////////////////////////////////////////////

// Company, L. P., IBM Corp., The Open Group, Tivoli Systems.

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

// IBM Corp.; EMC Corporation, The Open Group.

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; VERITAS Software 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

Line 25

Line 29

// Author: Adrian Schuur, schuur@de.ibm.com

// Modified By:

// Modified By: Seema Gupta (gseema@in.ibm.com) for PEP135

// Josephine Eskaline Joyce, IBM (jojustin@in.ibm.com) for PEP#101

//%/////////////////////////////////////////////////////////////////////////////

Line 35

Line 40

#include <Pegasus/Common/CIMMessage.h>

#include <Pegasus/Common/OperationContext.h>

#include <Pegasus/Common/Destroyer.h>

#include <Pegasus/Common/Tracer.h>

#include <Pegasus/Common/StatisticalData.h>

#include <Pegasus/Common/Logger.h>

#include <Pegasus/Common/MessageLoader.h> //l10n

#include <Pegasus/Common/Constants.h>

#include <Pegasus/Config/ConfigManager.h>

#include <Pegasus/ProviderManager2/ProviderName.h>

#include <Pegasus/ProviderManager2/JMPI/JMPIProvider.h>

#include <Pegasus/ProviderManager2/JMPI/JMPIProviderModule.h>

#include <Pegasus/ProviderManager2/ProviderManagerService.h>

#include <Pegasus/ProviderManager2/CMPI/CMPI_SelectExp.h>

PEGASUS_USING_STD;

PEGASUS_NAMESPACE_BEGIN

int _jmpi_trace=0;

int JMPIProviderManager::trace=0;

#ifdef PEGASUS_DEBUG

#define DDD(x) if (JMPIProviderManager::trace) x;

#else

#define DDD(x)

#endif

#include "Convert.h"

void JMPIProviderManager::debugPrintMethodPointers (JNIEnv *env, jclass jc)

{

// cd ${PEGAUSE_HOME}/src/Pegasus/ProviderManager2/JMPI/org/pegasus/jmpi/tests/JMPI_TestPropertyTypes

// javap -s -p JMPI_TestPropertyTypes

static const char *methodNames[][2] = {

// CIMProvider

// cimom-2003-11-24/org/snia/wbem/provider/CIMProvider.java

// src/Pegasus/ProviderManager2/JMPI/org/pegasus/jmpi/CIMProvider.java

{"initialize","(Lorg/pegasus/jmpi/CIMOMHandle;)V"},

{"cleanup","()V"},

// InstanceProvider

// cimom-2003-11-24/org/snia/wbem/provider/InstanceProvider.java

// src/Pegasus/ProviderManager2/JMPI/org/pegasus/jmpi/CIMInstanceProvider.java

{"enumInstances","(Lorg/pegasus/jmpi/CIMObjectPath;ZLorg/pegasus/jmpi/CIMClass;)Ljava/util/Vector;"},

{"enumInstances","(Lorg/pegasus/jmpi/CIMObjectPath;ZLorg/pegasus/jmpi/CIMClass;Z)Ljava/util/Vector;"},

{"getInstance","(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMClass;Z)Lorg/pegasus/jmpi/CIMInstance;"},

{"createInstance","(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMInstance;)Lorg/pegasus/jmpi/CIMObjectPath;"},

{"setInstance","(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMInstance;)V"},

{"deleteInstance","(Lorg/pegasus/jmpi/CIMObjectPath;)V"},

{"execQuery","(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;ILorg/pegasus/jmpi/CIMClass;)Ljava/util/Vector;"},

// MethodProvider

// cimom-2003-11-24/org/snia/wbem/provider/MethodProvider.java

// src/Pegasus/ProviderManager2/JMPI/org/pegasus/jmpi/CIMMethodProvider.java

{"invokeMethod","(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/util/Vector;Ljava/util/Vector;)Lorg/pegasus/jmpi/CIMValue;"},

// PropertyProvider

// cimom-2003-11-24/org/snia/wbem/provider/PropertyProvider.java

// AssociatorProvider

// cimom-2003-11-24/org/snia/wbem/provider20/AssociatorProvider.java

// src/Pegasus/ProviderManager2/JMPI/org/pegasus/jmpi/CIMAssociationProvider.java

// CIMProviderRouter

// cimom-2003-11-24/org/snia/wbem/provider20/CIMProviderRouter.java

// EventProvider

// cimom-2003-11-24/org/snia/wbem/provider20/EventProvider.java

// src/Pegasus/ProviderManager2/JMPI/org/pegasus/jmpi/EventProvider.java

{"authorizeFilter","(Lorg/pegasus/jmpi/SelectExp;Ljava/lang/String;Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;)V"},

{"mustPoll","(Lorg/pegasus/jmpi/SelectExp;Ljava/lang/String;Lorg/pegasus/jmpi/CIMObjectPath;)Z"},

{"activateFilter","(Lorg/pegasus/jmpi/SelectExp;Ljava/lang/String;Lorg/pegasus/jmpi/CIMObjectPath;Z)V"},

{"deActivateFilter","(Lorg/pegasus/jmpi/SelectExp;Ljava/lang/String;Lorg/pegasus/jmpi/CIMObjectPath;Z)V"},

// IndicationHandler

// cimom-2003-11-24/org/snia/wbem/provider20/IndicationHandler.java

// ProviderAdapter

// cimom-2003-11-24/org/snia/wbem/provider20/ProviderAdapter.java

// JMPI_TestPropertyTypes

{"findObjectPath","(Lorg/pegasus/jmpi/CIMObjectPath;)I"},

{"testPropertyTypesValue","(Lorg/pegasus/jmpi/CIMInstance;)V"}

};

if (!env)

{

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::debugPrintMethodPointers: env is NULL!"<<PEGASUS_STD(endl));

return;

}

if (!jc)

{

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::debugPrintMethodPointers: jc is NULL!"<<PEGASUS_STD(endl));

return;

}

#define DDD(x) if (_jmpi_trace) x;

for (int i = 0; i < (int)(sizeof (methodNames)/sizeof (methodNames[0])); i++)

{

jmethodID id = env->GetMethodID(jc,methodNames[i][0], methodNames[i][1]);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::debugPrintMethodPointers: "<<methodNames[i][0]<<", id = "<<PEGASUS_STD(hex)<<(int)id<<PEGASUS_STD(dec)<<PEGASUS_STD(endl));

env->ExceptionClear();

}

JMPIProviderManager::IndProvTab JMPIProviderManager::provTab;

JMPIProviderManager::IndSelectTab JMPIProviderManager::selxTab;

Line 62

Line 142

JMPIProviderManager::JMPIProviderManager(Mode m)

{

mode=m;

if (getenv("JMPI_TRACE")) _jmpi_trace=1;

_subscriptionInitComplete = false;

else _jmpi_trace=0;

#ifdef PEGASUS_DEBUG

if (getenv("PEGASUS_JMPI_TRACE"))

JMPIProviderManager::trace = 1;

else

JMPIProviderManager::trace = 0;

#else

JMPIProviderManager::trace = 0;

#endif

}

JMPIProviderManager::~JMPIProviderManager(void)

Line 74

Line 162

const String &ns, const String &cn)

{

String key(ns+String("::")+cn+String("::")+CIMValue(name.getCapabilitiesMask()).toString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::insertProvider: "<<key<<PEGASUS_STD(endl));

return provReg.insert(key,name);

}

Message * JMPIProviderManager::processMessage(Message * request) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager::processMessage()");

"JMPIProviderManager::processMessage()");

Message * response = 0;

Line 90

Line 179

{

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_EXEC_QUERY_REQUEST_MESSAGE:

response = handleExecuteQueryRequest(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_GET_PROPERTY_REQUEST_MESSAGE:

response = handleGetPropertyRequest(request);

break;

case CIM_SET_PROPERTY_REQUEST_MESSAGE:

response = handleSetPropertyRequest(request);

break;

/* case CIM_INVOKE_METHOD_REQUEST_MESSAGE:

response = handleInvokeMethodRequest(request);

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);

/* case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE:

response = handleModifySubscriptionRequest(request);

break;

case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE:

response = handleDeleteSubscriptionRequest(request);

break;

case CIM_ENABLE_INDICATIONS_REQUEST_MESSAGE:

response = handleEnableIndicationsRequest(request);

break;

case CIM_DISABLE_INDICATIONS_REQUEST_MESSAGE:

response = handleDisableIndicationsRequest(request);

/* case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:

response = handleExportIndicationRequest(request);

break;

case CIM_CONSUME_INDICATION_REQUEST_MESSAGE:

response = handleConsumeIndicationRequest(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;

break; */

case CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE:

response = handleInitializeProviderRequest(request);

break;

case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE:

response = handleSubscriptionInitCompleteRequest (request);

break;

default:

cout<<"*** Unsupported Request ??"<<request->getType()<<endl;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2,

asm("int $3");

"*** Unsupported Request "+request->getType());

response = handleUnsupportedRequest(request);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::processMessage: Unsupported request "<<request->getType ()<<PEGASUS_STD(endl));

response = handleUnsupportedRequest(request);

break;

}

Line 261

Line 355

handler.setStatus(CIM_ERR_FAILED, "Unknown error."); \

}

static jobjectArray getList(JvmVector *jv, JNIEnv *env, CIMPropertyList &list)

{

Uint32 s=list.size();

jobjectArray pl=NULL;

if (s) {

jstring initial=env->NewString(NULL,0);

pl=(jobjectArray)env->NewObjectArray(s,jv->StringClassRef,initial);

for (Uint32 i=0; i<s; i++) {

env->SetObjectArrayElement

(pl,i,env->NewStringUTF(list[i].getString().getCString()));

}

return pl;

}

Message * JMPIProviderManager::handleGetInstanceRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleGetInstanceRequest");

"JMPIProviderManager::handleGetInstanceRequest");

HandlerIntro(GetInstance,message,request,response,handler,CIMInstance());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleGetInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

Line 277

Line 391

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetInstanceRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->instanceName.getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

Line 296

Line 411

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.getInstance: " + pr.getName());

"Calling provider.getInstance: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetInstanceRequest: Calling provider getInstance: "<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract org.pegasus.jmpi.CIMInstance getInstance (org.pegasus.jmpi.CIMObjectPath cop,

// org.pegasus.jmpi.CIMClass cimClass,

// boolean localOnly)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"getInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMClass;Z)Lorg/pegasus/jmpi/CIMInstance;");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetInstanceRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public org.pegasus.jmpi.CIMInstance getInstance (org.pegasus.jmpi.CIMObjectPath op,

// boolean localOnly,

// boolean includeQualifiers,

// boolean includeClassOrigin,

// java.lang.String[] propertyList,

// org.pegasus.jmpi.CIMClass cc)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"getInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;ZZZ[Ljava/lang/String;Lorg/pegasus/jmpi/CIMClass;)Lorg/pegasus/jmpi/CIMInstance;");

DDD(cerr<<"--- JMPIProviderManager::getInstance"<<endl);

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetInstanceRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

JvmVector *jv;

JNIEnv *env=JMPIjvm::attachThread(&jv);

JMPIjvm::checkException(env);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

jv->CIMObjectPathNewI,(jint)&objectPath);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

CIMClass cls=pr._cimom_handle->getClass(context,request->nameSpace,

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->instanceName.getClassName(),

false,true,true,CIMPropertyList());

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jobject cc=env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,(jint)&cls);

jObj = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc = env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jObj);

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

STAT_GETSTARTTIME;

jobject inst = env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

request->localOnly,

request->includeQualifiers,

request->includeClassOrigin,

jPropertyList,

jCc);

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"getInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMClass;Z)Lorg/pegasus/jmpi/CIMInstance;");

JMPIjvm::checkException(env);

jobject inst=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,cc,true);

STAT_PMS_PROVIDEREND;

handler.processing();

if (inst) {

jint jCi = env->CallIntMethod(inst,JMPIjvm::jv.CIMInstanceCInst);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->instanceName.getClassName(),

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jObj = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc = env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jObj);

JMPIjvm::checkException(env);

jobject inst = env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

jCc,

true);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (inst) {

CIMInstance *ci=((CIMInstance*)env->CallIntMethod(inst,JMPIjvm::jv.CIMInstanceCInst));

jint jCi = env->CallIntMethod(inst,JMPIjvm::jv.CIMInstanceCInst);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetInstanceRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

Line 345

Line 580

Message * JMPIProviderManager::handleEnumerateInstancesRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleEnumerateInstanceRequest");

"JMPIProviderManager::handleEnumerateInstanceRequest");

HandlerIntro(EnumerateInstances,message,request,response,

HandlerIntro(EnumerateInstances,message,request,response,handler,Array<CIMInstance>());

handler,Array<CIMInstance>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleEnumerateInstancesRequest - Host name: $0 Name space: $1 Class name: $2",

Line 358

Line 599

request->nameSpace.getString(),

request->className.getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstancesRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->className.getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->className);

Line 376

Line 618

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMPropertyList propertyList(request->propertyList);

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.enumerateInstances: " + pr.getName());

"Calling provider.enumerateInstances: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::enumerateInstances"<<endl);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstancesRequest: Calling provider enumerateInstances: "<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv = 0;

JvmVector *jv;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

JMPIProvider::pm_service_op_lock op_lock(&pr);

jv->CIMObjectPathNewI,(jint)&objectPath);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract java.util.Vector enumInstances (org.pegasus.jmpi.CIMObjectPath cop,

// boolean deep,

// org.pegasus.jmpi.CIMClass cimClass,

// boolean localOnly)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"enumInstances",

"(Lorg/pegasus/jmpi/CIMObjectPath;ZLorg/pegasus/jmpi/CIMClass;Z)Ljava/util/Vector;");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstancesRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public org.pegasus.jmpi.CIMInstance[] enumerateInstances (org.pegasus.jmpi.CIMObjectPath op,

// boolean localOnly,

// boolean includeQualifiers,

// boolean includeClassOrigin,

// java.lang.String[] propertyList,

// org.pegasus.jmpi.CIMClass cc)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"enumerateInstances",

"(Lorg/pegasus/jmpi/CIMObjectPath;ZZZ[Ljava/lang/String;Lorg/pegasus/jmpi/CIMClass;)[Lorg/pegasus/jmpi/CIMInstance;");

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstancesRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

CIMClass cls=pr._cimom_handle->getClass(context,request->nameSpace,

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->className,

false,true,true,CIMPropertyList());

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jobject jCc=env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,(jint)&cls);

jObj = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc = env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jObj);

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

STAT_GETSTARTTIME;

jobjectArray jAr = (jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

request->localOnly,

request->includeQualifiers,

request->includeClassOrigin,

jPropertyList,

jCc);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jAr) {

for (int i=0,m=env->GetArrayLength(jAr); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jAr,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

JMPIjvm::checkException(env);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->className,

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jObj = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc = env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jObj);

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"enumInstances",

"(Lorg/pegasus/jmpi/CIMObjectPath;ZLorg/pegasus/jmpi/CIMClass;Z)Ljava/util/Vector;");

JMPIjvm::checkException(env);

jobject jVec=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,false,jCc,true);

jobject jVec = env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

false,

jCc,

true);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

Line 422

Line 778

if (jVec) {

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

JMPIjvm::checkException(env);

CIMInstance inst=*((CIMInstance*)env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst));

JMPIjvm::checkException(env);

// const CIMObjectPath& op=inst.getPath();

jint jCi = env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst);

// CIMObjectPath iop=inst.buildPath(cls);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

// iop.setNameSpace(op.getNameSpace());

// inst.setPath(iop);

JMPIjvm::checkException(env);

handler.deliver(inst);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstancesRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

Line 450

Line 814

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager::handleEnumerateInstanceNamesRequest");

HandlerIntro(EnumerateInstanceNames,message,request,response,

HandlerIntro(EnumerateInstanceNames,message,request,response, handler,Array<CIMObjectPath>());

handler,Array<CIMObjectPath>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleEnumerateInstanceNamesRequest - Host name: $0 Name space: $1 Class name: $2",

Line 460

Line 831

request->nameSpace.getString(),

request->className.getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstanceNamesRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->className.getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->className);

Line 477

Line 849

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.enumerateInstanceNames: " + pr.getName());

"Calling provider.enumerateInstanceNames: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::enumerateInstanceNames"<<endl);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstanceNamesRequest: Calling provider : enumerateInstanceNames"<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv = 0;

JvmVector *jv;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

JMPIProvider::pm_service_op_lock op_lock(&pr);

jv->CIMObjectPathNewI,(jint)&objectPath);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract java.util.Vector enumInstances (org.pegasus.jmpi.CIMObjectPath cop,

// boolean deep,

// org.pegasus.jmpi.CIMClass cimClass)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"enumInstances",

"(Lorg/pegasus/jmpi/CIMObjectPath;ZLorg/pegasus/jmpi/CIMClass;)Ljava/util/Vector;");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstanceNamesRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public org.pegasus.jmpi.CIMObjectPath[] enumerateInstanceNames (org.pegasus.jmpi.CIMObjectPath op,

// org.pegasus.jmpi.CIMClass cc)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"enumerateInstanceNames",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMClass;)[Lorg/pegasus/jmpi/CIMObjectPath;");

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstanceNamesRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

CIMClass cls=pr._cimom_handle->getClass(context,request->nameSpace,

switch (eMethodFound)

request->className,

{

false,true,true,CIMPropertyList());

case METHOD_PEGASUS_24:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

jobject jCc=env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,(jint)&cls);

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->className,

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

jObj = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

STAT_GETSTARTTIME;

jobject jCc = env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jObj);

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"enumInstances",

"(Lorg/pegasus/jmpi/CIMObjectPath;ZLorg/pegasus/jmpi/CIMClass;)Ljava/util/Vector;");

JMPIjvm::checkException(env);

jobject jVec=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,true,jCc);

jobjectArray jAr = (jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

jCc);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

if (jAr) {

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

for (int i=0,m=env->GetArrayLength(jAr); i<m; i++) {

JMPIjvm::checkException(env);

jobject jCop=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

jobject inst=env->GetObjectArrayElement(jAr,i);

JMPIjvm::checkException(env);

CIMObjectPath *cop=((CIMObjectPath*)env->CallIntMethod

(jCop,JMPIjvm::jv.CIMObjectPathCInst));

jint jCop = env->CallIntMethod(inst,JMPIjvm::jv.CIMObjectPathCInst);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

JMPIjvm::checkException(env);

handler.deliver(*cop);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->className,

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jObj = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc = env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jObj);

JMPIjvm::checkException(env);

jobject jVec = env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

true,

jCc);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

JMPIjvm::checkException(env);

jobject inst=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

JMPIjvm::checkException(env);

jint jCop = env->CallIntMethod(inst,JMPIjvm::jv.CIMObjectPathCInst);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

JMPIjvm::checkException(env);

handler.deliver(*cop);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleEnumerateInstanceNamesRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

Line 541

Line 1030

Message * JMPIProviderManager::handleCreateInstanceRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleCreateInstanceRequest");

"JMPIProviderManager::handleCreateInstanceRequest");

HandlerIntro(CreateInstance,message,request,response,

HandlerIntro(CreateInstance,message,request,response,handler,CIMObjectPath());

handler,CIMObjectPath());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleCreateInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

Line 554

Line 1048

request->nameSpace.getString(),

request->newInstance.getPath().getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateInstanceRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->newInstance.getPath().getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->newInstance.getPath().getClassName(),

request->newInstance.getPath().getKeyBindings());

Line 573

Line 1068

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.createInstance: " + ph.GetProvider().getName());

"Calling provider.createInstance: " +

ph.GetProvider().getName());

DDD(cerr<<"--- JMPIProviderManager::createInstances"<<endl);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateInstanceRequest: Calling provider createInstance: "<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv;

JvmVector *jv = 0;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

env = JMPIjvm::attachThread(&jv);

jv->CIMObjectPathNewI,(jint)&objectPath);

JMPIjvm::checkException(env);

jobject jInst=env->NewObject(jv->CIMInstanceClassRef,

jv->CIMInstanceNewI,(jint)&request->newInstance);

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"createInstance",

jmethodID id = NULL;

// public abstract org.pegasus.jmpi.CIMObjectPath createInstance (org.pegasus.jmpi.CIMObjectPath cop,

// org.pegasus.jmpi.CIMInstance cimInstance)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"createInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMInstance;)Lorg/pegasus/jmpi/CIMObjectPath;");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateInstanceRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

jobject jCop=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,jInst);

switch (eMethodFound)

{

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

CIMInstance *cInst = new CIMInstance (request->newInstance);

jObj = DEBUG_ConvertCToJava (CIMInstance*, jint, cInst);

jobject jInst = env->NewObject(jv->CIMInstanceClassRef,jv->CIMInstanceNewI,jObj);

JMPIjvm::checkException(env);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateInstanceRequest: id = "<<id<<", jRef = "<<jRef<<", jInst = "<<jInst<<PEGASUS_STD(endl));

jobject inst = env->CallObjectMethod((jobject)pr.jProvider,

id,

jRef,

jInst);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jCop) {

CIMObjectPath cop=*((CIMObjectPath*)env->CallIntMethod(jCop,JMPIjvm::jv.CIMObjectPathCInst));

if (inst) {

handler.deliver(cop);

jint jCop = env->CallIntMethod(inst,JMPIjvm::jv.CIMObjectPathCInst);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

handler.deliver(*cop);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateInstanceRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

Line 627

Line 1162

Message * JMPIProviderManager::handleModifyInstanceRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleModifyInstanceRequest");

"JMPIProviderManager::handleModifyInstanceRequest");

HandlerIntroVoid(ModifyInstance,message,request,response,handler);

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"DefaultProviderManager::handleModifyInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

"JMPIProviderManager::handleModifyInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->modifiedInstance.getPath().getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleModifyInstanceRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->modifiedInstance.getPath().getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->modifiedInstance.getPath ().getClassName(),

request->modifiedInstance.getPath ().getKeyBindings());

Line 650

Line 1193

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleModifyInstanceRequest: provider name physical = "<<name.getPhysicalName()<<", logical = "<<name.getLogicalName()<<PEGASUS_STD(endl));

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

Line 657

Line 1202

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

CIMPropertyList propertyList(request->propertyList);

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.modifyInstance: " + pr.getName());

"Calling provider.modifyInstance: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::modifyInstance"<<endl);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleModifyInstanceRequest: Calling provider "<<PEGASUS_STD(hex)<<(int)&pr<<PEGASUS_STD(dec)<<", name = "<<pr.getName ()<<", module = "<<pr.getModule()<<" modifyInstance: "<<pr.getName()<<PEGASUS_STD(endl));

////////DDD(debugPrintMethodPointers (env, (jclass)pr.jProviderClass));

JvmVector *jv;

JvmVector *jv = 0;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

env = JMPIjvm::attachThread(&jv);

jv->CIMObjectPathNewI,(jint)&objectPath);

JMPIjvm::checkException(env);

jobject jInst=env->NewObject(jv->CIMInstanceClassRef,

jv->CIMInstanceNewI,(jint)&request->modifiedInstance);

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"setInstance",

jmethodID id = NULL;

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMInstance;)V");

JMPIjvm::checkException(env);

env->CallVoidMethod((jobject)pr.jProvider,id,jRef,jInst);

STAT_PMS_PROVIDEREND;

// public abstract void setInstance (org.pegasus.jmpi.CIMObjectPath cop,

// org.pegasus.jmpi.CIMInstance cimInstance)

// org.pegasus.jmpi.throws CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"setInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMInstance;)V");

JMPIjvm::checkException(env);

if (id != NULL)

JMPIjvm::detachThread();

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleModifyInstanceRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

if (id == NULL)

{

env->ExceptionClear();

PEG_METHOD_EXIT();

// public void setInstance (org.pegasus.jmpi.CIMObjectPath op,

// org.pegasus.jmpi.CIMInstance ci,

// boolean includeQualifiers,

// java.lang.String[] propertyList)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"setInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;Z[Ljava/lang/String)V");

return(response);

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleModifyInstanceRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

Message * JMPIProviderManager::handleDeleteInstanceRequest(const Message * message) throw()

JMPIjvm::checkException(env);

switch (eMethodFound)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

case METHOD_PEGASUS_24:

"JMPIProviderManager::handleDeleteInstanceRequest");

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

HandlerIntroVoid(DeleteInstance,message,request,response,

JMPIjvm::checkException(env);

handler);

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"DefaultProviderManager::handleDeleteInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

// make target object path

CIMInstance *cInst = new CIMInstance (request->modifiedInstance);

CIMObjectPath objectPath(

System::getHostName(),

request->nameSpace,

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

// resolve provider name

jObj = DEBUG_ConvertCToJava (CIMInstance*, jint, cInst);

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

jobject jInst = env->NewObject(jv->CIMInstanceClassRef,jv->CIMInstanceNewI,jObj);

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

// convert arguments

JMPIjvm::checkException(env);

OperationContext context;

context.insert(IdentityContainer(request->userName));

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(ContentLanguageListContainer(request->contentLanguages));

// forward request

env->CallVoidMethod((jobject)pr.jProvider,

JMPIProvider & pr=ph.GetProvider();

id,

jRef,

jInst,

jPropertyList);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

JMPIjvm::checkException(env);

"Calling provider.deleteInstance: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::modifyInstance"<<endl);

STAT_PMS_PROVIDEREND;

break;

}

JvmVector *jv;

case METHOD_SNIA_PROVIDER20:

env=JMPIjvm::attachThread(&jv);

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

jv->CIMObjectPathNewI,(jint)&objectPath);

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

CIMInstance *cInst = new CIMInstance (request->modifiedInstance);

STAT_GETSTARTTIME;

jObj = DEBUG_ConvertCToJava (CIMInstance*, jint, cInst);

jobject jInst = env->NewObject(jv->CIMInstanceClassRef,jv->CIMInstanceNewI,jObj);

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"deleteInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;)V");

JMPIjvm::checkException(env);

env->CallVoidMethod((jobject)pr.jProvider,id,jRef);

env->CallVoidMethod((jobject)pr.jProvider,

id,

jRef,

jInst);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

break;

}

JMPIjvm::checkException(env);

case METHOD_UNKNOWN:

JMPIjvm::detachThread();

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleModifyInstanceRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleDeleteInstanceRequest(const Message * message) throw()

Message * JMPIProviderManager::handleAssociatorsRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleDeleteInstanceRequest");

"JMPIProviderManager::handleAssociatorsRequest");

HandlerIntro(Associators,message,request,response,

HandlerIntroVoid(DeleteInstance,message,request,response,handler);

handler,Array<CIMObject>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleAssociatorsRequest - Host name: $0 Name space: $1 Class name: $2",

"JMPIProviderManager::handleDeleteInstanceRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

request->instanceName.getClassName().getString());

// make target object path

CIMObjectPath objectPath(

System::getHostName(),

request->nameSpace,

request->objectName.getClassName());

objectPath.setKeyBindings(request->objectName.getKeyBindings());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteInstanceRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->instanceName.getClassName().getString()<<PEGASUS_STD(endl));

CIMObjectPath assocPath(

// make target object path

System::getHostName(),

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->assocClass.getString());

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

// resolve provider name

ProviderName name = _resolveProviderName(

Line 820

Line 1371

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.deleteInstance: " + pr.getName());

"Calling provider.associators: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::associators"<<

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteInstanceRequest: Calling provider deleteInstance: "<<pr.getName()<<PEGASUS_STD(endl));

" role: >"<<request->role<<"< aCls "<<

request->assocClass<<endl);

JvmVector *jv;

JvmVector *jv = 0;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

jv->CIMObjectPathNewI,(jint)&objectPath);

JMPIjvm::checkException(env);

jstring rClass=env->NewStringUTF(request->resultClass.getString().getCString());

env = JMPIjvm::attachThread(&jv);

jstring rRole=env->NewStringUTF(request->role.getCString());

jstring resRole=env->NewStringUTF(request->resultRole.getCString());

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"associators",

jmethodID id = NULL;

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;"

"Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;");

JMPIjvm::checkException(env);

// public abstract void deleteInstance (org.pegasus.jmpi.CIMObjectPath cop)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"deleteInstance",

"(Lorg/pegasus/jmpi/CIMObjectPath;)V");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteInstanceRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

jobject jVec=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,

rClass,rRole,resRole,false,false,NULL);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

switch (eMethodFound)

{

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

handler.processing();

if (jVec) {

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

JMPIjvm::checkException(env);

env->CallVoidMethod((jobject)pr.jProvider,id,jRef);

CIMInstance inst=*((CIMInstance*)env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst));

JMPIjvm::checkException(env);

CIMClass cls=pr._cimom_handle->getClass(context,request->nameSpace,

STAT_PMS_PROVIDEREND;

inst.getClassName(),false,true,true,CIMPropertyList());

break;

const CIMObjectPath& op=inst.getPath();

}

CIMObjectPath iop=inst.buildPath(cls);

iop.setNameSpace(op.getNameSpace());

inst.setPath(iop);

handler.deliver(inst);

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteInstanceRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

handler.complete();

}

HandlerCatch(handler);

Line 892

Line 1439

return(response);

}

Message * JMPIProviderManager::handleExecQueryRequest(const Message * message) throw()

Message * JMPIProviderManager::handleAssociatorNamesRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleExecQueryRequest");

"JMPIProviderManager::handleAssociatorNamesRequest");

HandlerIntro(AssociatorNames,message,request,response,

HandlerIntro(ExecQuery,message,request,response,handler,Array<CIMObject>());

handler,Array<CIMObjectPath>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleAssociatorNamesRequest - Host name: $0 Name space: $1 Class name: $2",

"JMPIProviderManager::handleExecQueryRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

request->className.getString());

// make target object path

CIMObjectPath objectPath(

System::getHostName(),

request->nameSpace,

request->objectName.getClassName());

objectPath.setKeyBindings(request->objectName.getKeyBindings());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleExecQueryRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->className.getString()<<PEGASUS_STD(endl));

CIMObjectPath assocPath(

// make target object path

System::getHostName(),

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->assocClass.getString());

request->className);

// resolve provider name

ProviderName name = _resolveProviderName(

Line 933

Line 1478

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.execQuery: " + pr.getName());

"Calling provider.associatorNames: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::associatorNames"<<

" role: >"<<request->role<<"< aCls "<<

request->assocClass<<endl);

JvmVector *jv;

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleExecQueryRequest: Calling provider execQuery: "<<pr.getName()<<", queryLanguage: "<<request->queryLanguage<<", query: "<<request->query<<PEGASUS_STD(endl));

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

JvmVector *jv = 0;

jv->CIMObjectPathNewI,(jint)&objectPath);

JMPIjvm::checkException(env);

jstring rClass=env->NewStringUTF(request->resultClass.getString().getCString());

env = JMPIjvm::attachThread(&jv);

jstring rRole=env->NewStringUTF(request->role.getCString());

jstring resRole=env->NewStringUTF(request->resultRole.getCString());

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"associatorNames",

jmethodID id = NULL;

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;"

"Ljava/lang/String;)Ljava/util/Vector;");

JMPIjvm::checkException(env);

// public abstract java.util.Vector execQuery (org.pegasus.jmpi.CIMObjectPath cop,

// java.lang.String queryStatement,

// int ql,

// org.pegasus.jmpi.CIMClass cimClass)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"execQuery",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;ILorg/pegasus/jmpi/CIMClass;)Ljava/util/Vector;");

jobject jVec=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,

if (id != NULL)

rClass,rRole,resRole);

{

JMPIjvm::checkException(env);

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleExecQueryRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

STAT_PMS_PROVIDEREND;

if (id == NULL)

{

env->ExceptionClear();

handler.processing();

// public abstract org.pegasus.jmpi.CIMInstance[] execQuery(org.pegasus.jmpi.CIMObjectPath op,

if (jVec) {

// java.lang.String query,

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

// java.lang.String ql,

JMPIjvm::checkException(env);

// org.pegasus.jmpi.CIMClass cc)

jobject jCop=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

// throws org.pegasus.jmpi.CIMException

JMPIjvm::checkException(env);

id = env->GetMethodID((jclass)pr.jProviderClass,

CIMObjectPath *cop=((CIMObjectPath*)env->CallIntMethod

"execQuery",

(jCop,JMPIjvm::jv.CIMObjectPathCInst));

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Lorg/pegasus/jmpi/CIMClass;)[Lorg/pegasus/jmpi/CIMInstance;");

JMPIjvm::checkException(env);

handler.deliver(*cop);

if (id != NULL)

}

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleExecQueryRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

handler.complete();

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleExecQueryRequest: found no method!"<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

Message * JMPIProviderManager::handleReferencesRequest(const Message * message) throw()

switch (eMethodFound)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

case METHOD_PEGASUS_24:

"JMPIProviderManager::handleReferencesRequest");

{

jint jcopref = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jcop = env->NewObject(jv->CIMObjectPathClassRef, jv->CIMObjectPathNewI, jcopref);

JMPIjvm::checkException(env);

jstring jqueryLanguage = env->NewStringUTF(request->queryLanguage.getCString());

jstring jquery = env->NewStringUTF(request->query.getCString());

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->className,

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jint jcls = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc=env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jcls);

JMPIjvm::checkException(env);

jobjectArray jAr = (jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jcop,

jquery,

jqueryLanguage,

jCc);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jAr) {

for (int i=0,m=env->GetArrayLength(jAr); i<m; i++) {

JMPIjvm::checkException(env);

jobject inst=env->GetObjectArrayElement(jAr,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(inst,JMPIjvm::jv.CIMInstanceCInst);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

JMPIjvm::checkException(env);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jcopref = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jcop = env->NewObject(jv->CIMObjectPathClassRef, jv->CIMObjectPathNewI, jcopref);

JMPIjvm::checkException(env);

jstring jqueryLanguage = env->NewStringUTF(request->queryLanguage.getCString());

jstring jquery = env->NewStringUTF(request->query.getCString());

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

request->className,

false,

true,

CIMPropertyList());

CIMClass *pcls = new CIMClass (cls);

JMPIjvm::checkException(env);

jint jcls = DEBUG_ConvertCToJava (CIMClass*, jint, pcls);

jobject jCc=env->NewObject(jv->CIMClassClassRef,jv->CIMClassNewI,jcls);

JMPIjvm::checkException(env);

jint jql = 0; // @BUG - how to convert?

jobjectArray jVec = (jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jcop,

jquery,

jql,

jCc);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject inst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(inst,JMPIjvm::jv.CIMInstanceCInst);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

JMPIjvm::checkException(env);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleExecQueryRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleAssociatorsRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleAssociatorsRequest");

HandlerIntro(Associators,message,request,response,handler,Array<CIMObject>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

HandlerIntro(References,message,request,response,

handler,Array<CIMObject>());

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"DefaultProviderManager::handleReferencesRequest - Host name: $0 Name space: $1 Class name: $2",

"JMPIProviderManager::handleAssociatorsRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorsRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->objectName.getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->objectName.getClassName());

request->objectName.getClassName(),

request->objectName.getKeyBindings());

objectPath.setKeyBindings(request->objectName.getKeyBindings());

CIMObjectPath *assocPath = new CIMObjectPath (System::getHostName(),

CIMObjectPath resultPath(

System::getHostName(),

request->nameSpace,

request->resultClass.getString());

request->assocClass.getString());

// resolve provider name

ProviderName name = _resolveProviderName(

Line 1038

Line 1721

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.associators: " + pr.getName());

"Calling provider.references: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::references"<<" role: >"<<request->role<<"< aCls "<<

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorsRequest: Calling provider associators: "<<pr.getName()<<", role: "<<request->role<<", aCls: "<<request->assocClass<<PEGASUS_STD(endl));

request->resultClass<<endl);

JvmVector *jv = 0;

JvmVector *jv;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

JMPIProvider::pm_service_op_lock op_lock(&pr);

jv->CIMObjectPathNewI,(jint)&objectPath);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract java.util.Vector associators (org.pegasus.jmpi.CIMObjectPath assocName,

// org.pegasus.jmpi.CIMObjectPath pathName,

// java.lang.String resultClass,

// java.lang.String role,

// java.lang.String resultRole,

// boolean includeQualifiers,

// boolean includeClassOrigin,

// java.lang.String[] propertyList)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"associators",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath; Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;"

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorsRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public abstract java.util.Vector associators (org.pegasus.jmpi.CIMObjectPath assocName,

// java.lang.String resultClass,

// java.lang.String role,

// java.lang.String resultRole,

// boolean includeQualifiers,

// boolean includeClassOrigin,

// java.lang.String[] propertyList)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"associators",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZ[Ljava/lang/String;)[Lorg/pegasus/jmpi/CIMInstance;"

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorsRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorsRequest: found no method!"<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

JMPIjvm::checkException(env);

jstring rRole=env->NewStringUTF(request->role.getCString());

jstring jResultClass = env->NewStringUTF(request->resultClass.getString().getCString());

jstring jRole = env->NewStringUTF(request->role.getCString());

jstring jResultRole = env->NewStringUTF(request->resultRole.getCString());

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

STAT_GETSTARTTIME;

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jResultClass,

jRole,

jResultRole,

false,

jPropertyList);

JMPIjvm::checkException(env);

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"references",

STAT_PMS_PROVIDEREND;

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;"

"ZZ[Ljava/lang/String;)Ljava/util/Vector;");

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst);

JMPIjvm::checkException(env);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

CIMClass cls = pr._cimom_handle->getClass(context,request->nameSpace,ci->getClassName(),false,true,true,CIMPropertyList());

const CIMObjectPath& op = ci->getPath();

CIMObjectPath iop = ci->buildPath(cls);

JMPIjvm::checkException(env);

iop.setNameSpace(op.getNameSpace());

ci->setPath(iop);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

JMPIjvm::checkException(env);

jint jPathNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, assocPath);

jobject jPathName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jPathNameRef);

JMPIjvm::checkException(env);

jobject jVec=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,

jstring jResultClass = env->NewStringUTF(request->resultClass.getString().getCString());

rRole,false,false,NULL);

jstring jRole = env->NewStringUTF(request->role.getCString());

jstring jResultRole = env->NewStringUTF(request->resultRole.getCString());

JMPIjvm::checkException(env);

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jPathName,

jResultClass,

jRole,

jResultRole,

false,

jPropertyList);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst);

JMPIjvm::checkException(env);

CIMInstance inst=*((CIMInstance*)env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst));

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

CIMClass cls = pr._cimom_handle->getClass(context,request->nameSpace,ci->getClassName(),false,true,true,CIMPropertyList());

const CIMObjectPath& op = ci->getPath();

CIMObjectPath iop = ci->buildPath(cls);

JMPIjvm::checkException(env);

CIMClass cls=pr._cimom_handle->getClass(context,request->nameSpace,

inst.getClassName(),false,true,true,CIMPropertyList());

const CIMObjectPath& op=inst.getPath();

CIMObjectPath iop=inst.buildPath(cls);

iop.setNameSpace(op.getNameSpace());

inst.setPath(iop);

ci->setPath(iop);

handler.deliver(inst);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorsRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

Line 1107

Line 1937

return(response);

}

Message * JMPIProviderManager::handleAssociatorNamesRequest(const Message * message) throw()

Message * JMPIProviderManager::handleReferenceNamesRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleAssociatorNamesRequest");

"JMPIProviderManager::handleReferenceNamesRequest");

HandlerIntro(ReferenceNames,message,request,response,

HandlerIntro(AssociatorNames,message,request,response,handler,Array<CIMObjectPath>());

handler,Array<CIMObjectPath>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env=NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleReferenceNamesRequest - Host name: $0 Name space: $1 Class name: $2",

"JMPIProviderManager::handleAssociatorNamesRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorNamesRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->objectName.getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath objectPath(

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

System::getHostName(),

request->nameSpace,

request->objectName.getClassName());

request->objectName.getClassName(),

request->objectName.getKeyBindings());

objectPath.setKeyBindings(request->objectName.getKeyBindings());

CIMObjectPath *assocPath = new CIMObjectPath (System::getHostName(),

CIMObjectPath resultPath(

System::getHostName(),

request->nameSpace,

request->resultClass.getString());

request->assocClass.getString());

// resolve provider name

ProviderName name = _resolveProviderName(

Line 1147

Line 1980

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

context.insert(ContentLanguageListContainer(request->contentLanguages));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

// forward request

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.associatorNames: " + pr.getName());

"Calling provider.referenceNames: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorNamesRequest: Calling provider associatorNames: "<<pr.getName()<<", role: "<<request->role<<", aCls: "<<request->assocClass<<PEGASUS_STD(endl));

DDD(cerr<<"--- JMPIProviderManager::referenceNames"<<" role: >"<<request->role<<"< aCls "<<

JvmVector *jv = 0;

request->resultClass<<endl);

JvmVector *jv;

env=JMPIjvm::attachThread(&jv);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,

JMPIProvider::pm_service_op_lock op_lock(&pr);

jv->CIMObjectPathNewI,(jint)&objectPath);

JMPIjvm::checkException(env);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract java.util.Vector associatorNames (org.pegasus.jmpi.CIMObjectPath assocName,

// org.pegasus.jmpi.CIMObjectPath pathName,

// java.lang.String resultClass,

// java.lang.String role,

// java.lang.String resultRole)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"associatorNames",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath; Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/Vector;"

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorNamesRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public abstract java.util.Vector associatorNames (org.pegasus.jmpi.CIMObjectPath assocName,

// java.lang.String resultClass,

// java.lang.String role,

// java.lang.String resultRole)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"associatorNames",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)[Lorg/pegasus/jmpi/CIMObjectPath;"

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorNamesRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorNamesRequest: found no method!"<<PEGASUS_STD(endl));

}

jstring rRole=env->NewStringUTF(request->role.getCString());

JMPIjvm::checkException(env);

JMPIProvider::pm_service_op_lock op_lock(&pr);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

STAT_GETSTARTTIME;

JMPIjvm::checkException(env);

jmethodID id=env->GetMethodID((jclass)pr.jProviderClass,"referenceNames",

jstring jResultClass = env->NewStringUTF(request->resultClass.getString().getCString());

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;)Ljava/util/Vector;");

jstring jRole = env->NewStringUTF(request->role.getCString());

jstring jResultRole = env->NewStringUTF(request->resultRole.getCString());

JMPIjvm::checkException(env);

jobject jVec=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,rRole);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jResultClass,

jRole,

jResultRole);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->CallIntMethod(jVec,JMPIjvm::jv.VectorSize); i<m; i++) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jCop=env->CallObjectMethod(jVec,JMPIjvm::jv.VectorElementAt,i);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

CIMObjectPath *cop=((CIMObjectPath*)env->CallIntMethod

(jCop,JMPIjvm::jv.CIMObjectPathCInst));

jint jCop = env->CallIntMethod(jInst,JMPIjvm::jv.CIMObjectPathCInst);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

JMPIjvm::checkException(env);

handler.deliver(*cop);

}

handler.complete();

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

case METHOD_SNIA_PROVIDER20:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

PEG_METHOD_EXIT();

JMPIjvm::checkException(env);

return(response);

jint jPathNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, assocPath);

jobject jPathName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jPathNameRef);

JMPIjvm::checkException(env);

jstring jResultClass = env->NewStringUTF(request->resultClass.getString().getCString());

jstring jRole = env->NewStringUTF(request->role.getCString());

jstring jResultRole = env->NewStringUTF(request->resultRole.getCString());

JMPIjvm::checkException(env);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jPathNameRef,

jResultClass,

jRole,

jResultRole);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCop = env->CallIntMethod(jInst,JMPIjvm::jv.CIMObjectPathCInst);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

JMPIjvm::checkException(env);

handler.deliver(*cop);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleAssociatorNamesRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleReferencesRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleReferencesRequest");

HandlerIntro(References,message,request,response,handler,Array<CIMObject>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleReferencesRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferencesRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->objectName.getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->objectName.getClassName(),

request->objectName.getKeyBindings());

CIMObjectPath *resultPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->resultClass.getString());

// resolve provider name

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

// 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

JMPIProvider &pr = ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.references: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferencesRequest: Calling provider references: "<<pr.getName()<<", role: "<<request->role<<" aCls: "<<request->resultClass<<PEGASUS_STD(endl));

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract java.util.Vector references (org.pegasus.jmpi.CIMObjectPath assocName,

// org.pegasus.jmpi.CIMObjectPath pathName,

// java.lang.String role,

// boolean includeQualifiers,

// boolean includeClassOrigin,

// java.lang.String[] propertyList)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"references",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath; Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;"

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferencesRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public abstract java.util.Vector references (org.pegasus.jmpi.CIMObjectPath assocName,

// java.lang.String role,

// boolean includeQualifiers,

// boolean includeClassOrigin,

// java.lang.String[] propertyList)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"references",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;ZZ[Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;ZZ[Ljava/lang/String;)[Lorg/pegasus/jmpi/CIMInstance;"

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferencesRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferencesRequest: found no method!"<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

JMPIjvm::checkException(env);

jstring jRole = env->NewStringUTF(request->role.getCString());

JMPIjvm::checkException(env);

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jRole,

false,

jPropertyList);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst);

JMPIjvm::checkException(env);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

ci->getClassName(),

false,

true,

CIMPropertyList());

const CIMObjectPath& op = ci->getPath();

CIMObjectPath iop = ci->buildPath(cls);

JMPIjvm::checkException(env);

iop.setNameSpace(op.getNameSpace());

ci->setPath(iop);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

JMPIjvm::checkException(env);

jint jPathNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, resultPath);

jobject jPathName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jPathNameRef);

JMPIjvm::checkException(env);

jstring jRole = env->NewStringUTF(request->role.getCString());

JMPIjvm::checkException(env);

jobjectArray jPropertyList = getList(jv,env,request->propertyList);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jPathName,

jRole,

false,

jPropertyList);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCi = env->CallIntMethod(jInst,JMPIjvm::jv.CIMInstanceCInst);

JMPIjvm::checkException(env);

CIMInstance *ci = DEBUG_ConvertJavaToC (jint, CIMInstance*, jCi);

CIMClass cls = pr._cimom_handle->getClass(context,

request->nameSpace,

ci->getClassName(),

false,

true,

CIMPropertyList());

const CIMObjectPath& op = ci->getPath();

CIMObjectPath iop = ci->buildPath(cls);

JMPIjvm::checkException(env);

iop.setNameSpace(op.getNameSpace());

ci->setPath(iop);

handler.deliver(*ci);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferencesRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleReferenceNamesRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleReferenceNamesRequest");

HandlerIntro(ReferenceNames,message,request,response,handler,Array<CIMObjectPath>());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleReferenceNamesRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->objectName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferenceNamesRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->objectName.getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->objectName.getClassName(),

request->objectName.getKeyBindings());

CIMObjectPath *resultPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->resultClass.getString());

// resolve provider name

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

// 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));

JMPIProvider &pr = ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.referenceNames: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferenceNamesRequest: Calling provider referenceNames: "<<pr.getName()<<", role: "<<request->role<<", aCls: "<<request->resultClass<<PEGASUS_STD(endl));

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract java.util.Vector referenceNames (org.pegasus.jmpi.CIMObjectPath assocName,

// org.pegasus.jmpi.CIMObjectPath pathName,

// java.lang.String role)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"referenceNames",

"(Lorg/pegasus/jmpi/CIMObjectPath;Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath; Ljava/lang/String;)Ljava/util/Vector;"

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferenceNamesRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public abstract java.util.Vector referenceNames (org.pegasus.jmpi.CIMObjectPath assocName,

// java.lang.String role)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"referenceNames",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;)Ljava/util/Vector;");

//@BUG was: "(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;)[Lorg/pegasus/jmpi/CIMObjectPath;"

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferenceNamesRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferenceNamesRequest: found no method!"<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

JMPIjvm::checkException(env);

jstring jRole = env->NewStringUTF(request->role.getCString());

JMPIjvm::checkException(env);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jRole);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCop = env->CallIntMethod(jInst,JMPIjvm::jv.CIMObjectPathCInst);

JMPIjvm::checkException(env);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

handler.deliver(*cop);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

{

jint jAssociationNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jAssociationName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jAssociationNameRef);

JMPIjvm::checkException(env);

jint jPathNameRef = DEBUG_ConvertCToJava (CIMObjectPath*, jint, resultPath);

jobject jPathName = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jPathNameRef);

JMPIjvm::checkException(env);

jstring jRole = env->NewStringUTF(request->role.getCString());

JMPIjvm::checkException(env);

jobjectArray jVec=(jobjectArray)env->CallObjectMethod((jobject)pr.jProvider,

id,

jAssociationName,

jPathName,

jRole);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jVec) {

for (int i=0,m=env->GetArrayLength(jVec); i<m; i++) {

JMPIjvm::checkException(env);

jobject jInst=env->GetObjectArrayElement(jVec,i);

JMPIjvm::checkException(env);

jint jCop = env->CallIntMethod(jInst,JMPIjvm::jv.CIMObjectPathCInst);

JMPIjvm::checkException(env);

CIMObjectPath *cop = DEBUG_ConvertJavaToC (jint, CIMObjectPath*, jCop);

handler.deliver(*cop);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleReferenceNamesRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleGetPropertyRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleGetPropertyRequest");

HandlerIntro(GetProperty,message,request,response,handler,CIMValue());

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleGetPropertyRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetPropertyRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->className.getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

// resolve provider name

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

// 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

JMPIProvider &pr = ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.getPropertyValue: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetPropertyRequest: Calling provider getPropertyValue: "<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract org.pegasus.jmpi.CIMValue getPropertyValue (org.pegasus.jmpi.CIMObjectPath cop,

// java.lang.String oclass,

// java.lang.String pName)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"getPropertyValue",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;)Lorg/pegasus/jmpi/CIMValue;");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetPropertyRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetPropertyRequest: found no method!"<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_SNIA_PROVIDER20:

{

jint jcopref = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jcop = env->NewObject(jv->CIMObjectPathClassRef, jv->CIMObjectPathNewI, jcopref);

JMPIjvm::checkException(env);

jstring joclass = env->NewStringUTF(request->instanceName.getClassName().getString().getCString());

JMPIjvm::checkException(env);

jstring jpName = env->NewStringUTF(request->propertyName.getString().getCString());

JMPIjvm::checkException(env);

STAT_GETSTARTTIME;

jobject jval = env->CallObjectMethod ((jobject)pr.jProvider,

id,

jcop,

joclass,

jpName);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

if (jval)

{

jint jvalref = env->CallIntMethod(jval,JMPIjvm::jv.CIMValueCInst);

CIMValue *cv = DEBUG_ConvertJavaToC (jint, CIMValue*, jvalref);

JMPIjvm::checkException(env);

handler.deliver(*cv);

}

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleGetPropertyRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleSetPropertyRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleSetPropertyRequest");

HandlerIntroVoid(SetProperty,message,request,response,handler);

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleSetPropertyRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleSetPropertyRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->className.getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

// resolve provider name

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

// 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

JMPIProvider &pr = ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,"Calling provider.setPropertyValue: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleSetPropertyRequest: Calling provider setPropertyValue: "<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract void setPropertyValue (org.pegasus.jmpi.CIMObjectPath cop,

// java.lang.String oclass,

// java.lang.String pName,

// org.pegasus.jmpi.CIMValue val)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"setPropertyValue",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/lang/String;Lorg/pegasus/jmpi/CIMValue;)V");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleSetPropertyRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleSetPropertyRequest: found no method!"<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_SNIA_PROVIDER20:

{

jint jcopref = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jcop = env->NewObject(jv->CIMObjectPathClassRef, jv->CIMObjectPathNewI, jcopref);

JMPIjvm::checkException(env);

jstring joclass = env->NewStringUTF(request->instanceName.getClassName().getString().getCString());

JMPIjvm::checkException(env);

jstring jpName = env->NewStringUTF(request->propertyName.getString().getCString());

JMPIjvm::checkException(env);

CIMValue *val = new CIMValue (request->newValue);

JMPIjvm::checkException(env);

jint jvalref = DEBUG_ConvertCToJava (CIMValue*, jint, val);

jobject jval = env->NewObject(jv->CIMValueClassRef, jv->CIMValueNewI, jvalref);

JMPIjvm::checkException(env);

STAT_GETSTARTTIME;

env->CallVoidMethod ((jobject)pr.jProvider,

id,

jcop,

joclass,

jpName,

jval);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleSetPropertyRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

Message * JMPIProviderManager::handleInvokeMethodRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,"JMPIProviderManager::handleInvokeMethodRequest");

HandlerIntroMethod(InvokeMethod,message,request,response,handler);

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_PEGASUS_24,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleInvokeMethodRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleInvokeMethodRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", classname = "<<request->instanceName.getClassName().getString()<<PEGASUS_STD(endl));

// make target object path

CIMObjectPath *objectPath = new CIMObjectPath (System::getHostName(),

request->nameSpace,

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

// resolve provider name

ProviderName name = _resolveProviderName(

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

// 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));

JMPIProvider &pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.invokeMethod: " + pr.getName());

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleInvokeMethodRequest: Calling provider invokeMethod: "<<pr.getName()<<PEGASUS_STD(endl));

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

jmethodID id = NULL;

// public abstract org.pegasus.jmpi.CIMValue invokeMethod (org.pegasus.jmpi.CIMObjectPath cop,

// java.lang.String name,

// java.util.Vector in,

// java.util.Vector out)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"invokeMethod",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;Ljava/util/Vector;Ljava/util/Vector;)Lorg/pegasus/jmpi/CIMValue;");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleInvokeMethodRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

if (id == NULL)

{

env->ExceptionClear();

// public org.pegasus.jmpi.CIMValue invokeMethod (org.pegasus.jmpi.CIMObjectPath op,

// java.lang.String methodName,

// org.pegasus.jmpi.CIMArgument[] inArgs,

// org.pegasus.jmpi.CIMArgument[] outArgs)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"invokeMethod",

"(Lorg/pegasus/jmpi/CIMObjectPath;Ljava/lang/String;[Lorg/pegasus/jmpi/CIMArgument;[Lorg/pegasus/jmpi/CIMArgument;)Lorg/pegasus/jmpi/CIMValue;");

if (id != NULL)

{

eMethodFound = METHOD_PEGASUS_24;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleInvokeMethodRequest: found METHOD_PEGASUS_24."<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_PEGASUS_24:

{

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

jstring jMethod=env->NewStringUTF(request->methodName.getString().getCString());

JMPIjvm::checkException(env);

Uint32 m=request->inParameters.size();

jobjectArray jArIn=(jobjectArray)env->NewObjectArray(m,jv->CIMArgumentClassRef,NULL);

for (Uint32 i=0; i<m; i++) {

CIMParamValue *parm = new CIMParamValue(request->inParameters[i]);

jint jObj = DEBUG_ConvertCToJava (CIMParamValue*, jint, parm);

jobject jArg = env->NewObject(jv->CIMArgumentClassRef,jv->CIMArgumentNewI,jObj);

env->SetObjectArrayElement(jArIn,i,jArg);

}

jobjectArray jArOut=(jobjectArray)env->NewObjectArray(24,jv->CIMArgumentClassRef,NULL);

jobject jValue=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,jMethod,jArIn,jArOut);

JMPIjvm::checkException(env);

STAT_PMS_PROVIDEREND;

handler.processing();

jint jv = env->CallIntMethod(jValue,JMPIjvm::jv.CIMValueCInst);

CIMValue *v = DEBUG_ConvertJavaToC (jint, CIMValue*, jv);

handler.deliver(*v);

for (int i=0; i<24; i++) {

jobject jArg=env->GetObjectArrayElement(jArOut,i);

JMPIjvm::checkException(env);

if (jArg==NULL) break;

jint jp = env->CallIntMethod(jArg,JMPIjvm::jv.ArgumentCInst);

CIMParamValue *p = DEBUG_ConvertJavaToC (jint, CIMParamValue*, jp);

JMPIjvm::checkException(env);

handler.deliverParamValue(*p);

}

handler.complete();

break;

}

case METHOD_SNIA_PROVIDER20:

Message * JMPIProviderManager::handleInvokeMethodRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,

jint jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, objectPath);

"JMPIProviderManager::handleInvokeMethodRequest");

HandlerIntroMethod(InvokeMethod,message,request,response,

handler);

try {

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleInvokeMethodRequest - Host name: $0 Name space: $1 Class name: $2",

System::getHostName(),

request->nameSpace.getString(),

request->instanceName.getClassName().getString());

// make target object path

jobject jRef=env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

CIMObjectPath objectPath(

JMPIjvm::checkException(env);

System::getHostName(),

request->nameSpace,

request->instanceName.getClassName(),

request->instanceName.getKeyBindings());

// resolve provider name

jstring jMethod=env->NewStringUTF(request->methodName.getString().getCString());

ProviderName name = _resolveProviderName(

JMPIjvm::checkException(env);

request->operationContext.get(ProviderIdContainer::NAME));

// get cached or load new provider module

jobject jVecIn=env->NewObject(jv->VectorClassRef,jv->VectorNew);

JMPIProvider::OpProviderHolder ph =

JMPIjvm::checkException(env);

providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);

for (int i=0,m=request->inParameters.size(); i<m; i++) {

const CIMParamValue &parm = request->inParameters[i];

const CIMValue v = parm.getValue();

CIMProperty *p = new CIMProperty(parm.getParameterName(),v,v.getArraySize());

jint jObj = DEBUG_ConvertCToJava (CIMProperty*, jint, p);

// convert arguments

jobject prop=env->NewObject(jv->CIMPropertyClassRef,jv->CIMPropertyNewI,jObj);

OperationContext context;

context.insert(IdentityContainer(request->userName));

env->CallVoidMethod(jVecIn,jv->VectorAddElement,prop);

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

}

context.insert(ContentLanguageListContainer(request->contentLanguages));

CIMObjectPath instanceReference(request->instanceName);

jobject jVecOut=env->NewObject(jv->VectorClassRef,jv->VectorNew);

JMPIjvm::checkException(env);

// ATTN: propagate namespace

jobject jValue=env->CallObjectMethod((jobject)pr.jProvider,id,jRef,jMethod,jVecIn,jVecOut);

instanceReference.setNameSpace(request->nameSpace);

JMPIjvm::checkException(env);

// forward request

STAT_PMS_PROVIDEREND;

JMPIProvider & pr=ph.GetProvider();

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

handler.processing();

"Calling provider.invokeMethod: " + pr.getName());

CMPIStatus rc={CMPI_RC_OK,NULL};

jint jv = env->CallIntMethod(jValue,JMPIjvm::jv.CIMValueCInst);

CMPI_ContextOnStack eCtx(context);

CIMValue *v = DEBUG_ConvertJavaToC (jint, CIMValue*, jv);

CMPI_ObjectPathOnStack eRef(objectPath);

CMPI_ResultOnStack eRes(handler,&pr.broker);

CMPI_ThreadContext thr(&pr.broker,&eCtx);

CMPI_ArgsOnStack eArgsIn(request->inParameters);

Array<CIMParamValue> outArgs;

CMPI_ArgsOnStack eArgsOut(outArgs);

CString mName=request->methodName.getString().getCString();

CMPIFlags flgs=0;

handler.deliver(*v);

eCtx.ft->addEntry(&eCtx,CMPIInvocationFlags,(CMPIValue*)&flgs,CMPI_uint32);

JMPIProvider::pm_service_op_lock op_lock(&pr);

for (int i=0,m=env->CallIntMethod(jVecOut,JMPIjvm::jv.VectorSize); i<m; i++) {

JMPIjvm::checkException(env);

STAT_GETSTARTTIME;

jobject jProp=env->CallObjectMethod(jVecOut,JMPIjvm::jv.VectorElementAt,i);

JMPIjvm::checkException(env);

rc=pr.miVector.methMI->ft->invokeMethod(

jint jp = env->CallIntMethod(jProp,JMPIjvm::jv.PropertyCInst);

pr.miVector.methMI,&eCtx,&eRes,&eRef,CHARS(mName),&eArgsIn,&eArgsOut);

CIMProperty *p = DEBUG_ConvertJavaToC (jint, CIMProperty*, jp);

STAT_PMS_PROVIDEREND;

JMPIjvm::checkException(env);

if (rc.rc!=CMPI_RC_OK)

handler.deliverParamValue(CIMParamValue(p->getName().getString(),p->getValue()));

throw CIMException((CIMStatusCode)rc.rc);

}

for (int i=0,s=outArgs.size(); i<s; i++)

handler.deliverParamValue(outArgs[i]);

handler.complete();

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleInvokeMethodRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}

*//*

struct indProvRecord {

indProvRecord() : enabled(false), count(1), handler(NULL) {}

Boolean enabled;

int count;

EnableIndicationsResponseHandler* handler;

};

struct indSelectRecord {

indSelectRecord() : eSelx(NULL) {}

CMPI_SelectExp *eSelx;

};

typedef HashTable<String,indProvRecord*,EqualFunc<String>,HashFunc<String> > IndProvTab;

typedef HashTable<String,indSelectRecord*,EqualFunc<String>,HashFunc<String> > IndSelectTab;

IndProvTab provTab;

IndSelectTab selxTab;

*//*

int LocateIndicationProviderNames(const CIMInstance& pInstance, const CIMInstance& pmInstance,

String& providerName, String& location)

{

Line 1324

Line 3148

Message * JMPIProviderManager::handleCreateSubscriptionRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateSubscriptionRequest");

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager::handleCreateSubscriptionRequest");

HandlerIntroInd(CreateSubscription,message,request,response,handler);

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

HandlerIntroInd(CreateSubscription,message,request,response,

handler);

try {

const CIMObjectPath &x=request->subscriptionInstance.getPath();

String providerName,

providerLocation;

CIMInstance req_provider,

req_providerModule;

ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);

req_provider = pidc.getProvider();

req_providerModule = pidc.getModule();

String providerName,providerLocation;

LocateIndicationProviderNames(req_provider, req_providerModule,providerName,providerLocation);

LocateIndicationProviderNames(request->provider, request->providerModule,

providerName,providerLocation);

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleCreateSubscriptionRequest - Host name: $0 Name space: $1 Provider name(s): $2",

Line 1341

Line 3178

request->nameSpace.getString(),

providerName);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateSubscriptionRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", providername = "<<providerName<<PEGASUS_STD(endl));

String fileName = resolveFileName(providerLocation);

// get cached or load new provider module

Line 1348

Line 3187

providerManager.getProvider(fileName, providerName, String::EMPTY);

indProvRecord *prec=NULL;

provTab.lookup(providerName,prec);

if (prec) prec->count++;

else {

if (prec)

{

prec->count++;

}

else

{

prec=new indProvRecord();

provTab.insert(providerName,prec);

}

// Save the provider instance from the request

ph.GetProvider ().setProviderInstance (req_provider);

indSelectRecord *srec=new indSelectRecord();

const CIMObjectPath &sPath=request->subscriptionInstance.getPath();

selxTab.insert(sPath.toString(),srec);

// convert arguments

OperationContext *context=new OperationContext();

context->insert(IdentityContainer(request->userName));

if (prec->ctx==NULL)

context->insert(SubscriptionInstanceContainer

{

(request->subscriptionInstance));

prec->ctx=context;

context->insert(SubscriptionFilterConditionContainer

}

(request->condition, request->queryLanguage));

context->insert(request->operationContext.get(IdentityContainer::NAME));

context->insert(SubscriptionLanguageListContainer

context->insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

(request->acceptLanguages));

context->insert(request->operationContext.get(ContentLanguageListContainer::NAME));

context->insert(AcceptLanguageListContainer(request->acceptLanguages));

context->insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));

context->insert(ContentLanguageListContainer(request->contentLanguages));

context->insert(request->operationContext.get(SubscriptionLanguageListContainer::NAME));

context->insert(request->operationContext.get(SubscriptionFilterConditionContainer::NAME));

CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();

SubscriptionFilterConditionContainer sub_cntr = request->operationContext.get

(SubscriptionFilterConditionContainer::NAME);

JMPIProvider & pr=ph.GetProvider();

CMPIStatus rc={CMPI_RC_OK,NULL};

CIMOMHandleQueryContext *qcontext=new CIMOMHandleQueryContext(CIMNamespaceName(request->nameSpace.getString()),

CMPI_ContextOnStack eCtx(*context);

*pr._cimom_handle);

CMPI_SelectExp *eSelx=new CMPI_SelectExp(*context,

qcontext,

request->query,

request->queryLanguage);

sub_cntr.getQueryLanguage());

srec->eSelx=eSelx;

CMPI_ThreadContext thr(&pr.broker,&eCtx);

srec->qContext=qcontext;

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.createSubscriptionRequest: " + pr.getName());

"Calling provider.createSubscriptionRequest: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::createSubscriptionRequest"<<endl);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateSubscriptionRequest: Calling provider createSubscriptionRequest: "<<pr.getName()<<PEGASUS_STD(endl));

for(Uint32 i = 0, n = request->classNames.size(); i < n; i++) {

CIMObjectPath className(

Line 1397

Line 3254

request->classNames[i]);

eSelx->classNames.append(className);

}

CMPI_ObjectPathOnStack eRef(eSelx->classNames[0]);

CIMPropertyList propertyList = request->propertyList;

if (!propertyList.isNull()) {

Line 1410

Line 3266

eSelx->props[pCount]=NULL;

}

Uint16 repeatNotificationPolicy = request->repeatNotificationPolicy;

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

rc=pr.miVector.indMI->ft->activateFilter(

jmethodID id = NULL;

pr.miVector.indMI,&eCtx,NULL,eSelx,

CHARS(request->nameSpace.getString().getCString()),&eRef,false);

// public void authorizeFilter (org.pegasus.jmpi.SelectExp filter,

// java.lang.String eventType,

// org.pegasus.jmpi.CIMObjectPath classPath,

// java.lang.String owner)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"activateFilter",

"(Lorg/pegasus/jmpi/SelectExp;Ljava/lang/String;Lorg/pegasus/jmpi/CIMObjectPath;Z)V");

if (id != NULL)

{

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateSubscriptionRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

}

JMPIjvm::checkException(env);

switch (eMethodFound)

{

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CMPI_SelectExp*, jint, eSelx);

jobject jSel = env->NewObject(jv->SelectExpClassRef,jv->SelectExpNewI,jObj);

JMPIjvm::checkException(env);

jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, &eSelx->classNames[0]);

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

JMPIjvm::checkException(env);

jstring jType = env->NewStringUTF(request->nameSpace.getString().getCString());

JMPIjvm::checkException(env);

env->CallVoidMethod((jobject)pr.jProvider,

id,

jSel,

jType,

jRef,

(jboolean)0);

JMPIjvm::checkException(env);

// 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)

{

prec->enabled = true;

CIMRequestMessage * request = 0;

CIMResponseMessage * response = 0;

prec->handler = new EnableIndicationsResponseHandler

(request, response, req_provider, _indicationCallback);

}

STAT_PMS_PROVIDEREND;

break;

}

case METHOD_UNKNOWN:

{

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleCreateSubscriptionRequest: should not be here!"<<PEGASUS_STD(endl));

break;

}

if (rc.rc!=CMPI_RC_OK)

throw CIMException((CIMStatusCode)rc.rc);

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

Line 1436

Line 3366

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager::handleDeleteSubscriptionRequest");

HandlerIntroInd(DeleteSubscription,message,request,response,

HandlerIntroInd(DeleteSubscription,message,request,response,handler);

handler);

typedef enum {

METHOD_UNKNOWN = 0,

METHOD_SNIA_PROVIDER20,

} METHOD_VERSION;

METHOD_VERSION eMethodFound = METHOD_UNKNOWN;

JNIEnv *env = NULL;

try {

String providerName,providerLocation;

String providerName,

LocateIndicationProviderNames(request->provider, request->providerModule,

providerLocation;

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);

Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,

"JMPIProviderManager::handleDeleteSubscriptionRequest - Host name: $0 Name space: $1 Provider name(s): $2",

Line 1449

Line 3393

request->nameSpace.getString(),

providerName);

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteSubscriptionRequest: hostname = "<<System::getHostName()<<", namespace = "<<request->nameSpace.getString()<<", providername = "<<providerName<<PEGASUS_STD(endl));

String fileName = resolveFileName(providerLocation);

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(fileName, providerName, String::EMPTY);

indProvRecord *prec=NULL;

provTab.lookup(providerName,prec);

if (--prec->count<=0) {

if (--prec->count <= 0)

{

provTab.remove(providerName);

prec=NULL;

}

Line 1466

Line 3413

indSelectRecord *srec=NULL;

const CIMObjectPath &sPath=request->subscriptionInstance.getPath();

String sPathString=sPath.toString();

selxTab.lookup(sPathString,srec);

CMPI_SelectExp *eSelx=srec->eSelx;

CMPI_ObjectPathOnStack eRef(eSelx->classNames[0]);

CIMOMHandleQueryContext *qContext = srec->qContext;

selxTab.remove(sPathString);

// convert arguments

OperationContext context;

context.insert(IdentityContainer(request->userName));

context.insert(request->operationContext.get(IdentityContainer::NAME));

context.insert(SubscriptionInstanceContainer

context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));

(request->subscriptionInstance));

context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));

context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));

context.insert(SubscriptionLanguageListContainer

context.insert(request->operationContext.get(SubscriptionLanguageListContainer::NAME));

(request->acceptLanguages));

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(ContentLanguageListContainer(request->contentLanguages));

CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();

JMPIProvider & pr=ph.GetProvider();

CMPIStatus rc={CMPI_RC_OK,NULL};

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, "Calling provider.deleteSubscriptionRequest: " + pr.getName());

CMPI_ContextOnStack eCtx(context);

CMPI_ThreadContext thr(&pr.broker,&eCtx);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

DDD(PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteSubscriptionRequest: Calling provider deleteSubscriptionRequest: "<<pr.getName()<<PEGASUS_STD(endl));

"Calling provider.deleteSubscriptionRequest: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::deleteSubscriptionRequest"<<endl);

JvmVector *jv = 0;

env = JMPIjvm::attachThread(&jv);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

rc=pr.miVector.indMI->ft->deActivateFilter(

jmethodID id = NULL;

pr.miVector.indMI,&eCtx,NULL,eSelx,

CHARS(request->nameSpace.getString().getCString()),&eRef,prec==NULL);

delete eSelx;

STAT_PMS_PROVIDEREND;

if (rc.rc!=CMPI_RC_OK)

throw CIMException((CIMStatusCode)rc.rc);

}

HandlerCatch(handler);

PEG_METHOD_EXIT();

return(response);

// public void deActivateFilter (org.pegasus.jmpi.SelectExp filter,

}

// java.lang.String eventType,

// org.pegasus.jmpi.CIMObjectPath classPath,

// boolean lastActivation)

// throws org.pegasus.jmpi.CIMException

id = env->GetMethodID((jclass)pr.jProviderClass,

"deActivateFilter",

"(Lorg/pegasus/jmpi/SelectExp;Ljava/lang/String;Lorg/pegasus/jmpi/CIMObjectPath;Z)V");

Message * JMPIProviderManager::handleEnableIndicationsRequest(const Message * message) throw()

if (id != NULL)

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager:: handleEnableIndicationsRequest");

eMethodFound = METHOD_SNIA_PROVIDER20;

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteSubscriptionRequest: found METHOD_SNIA_PROVIDER20."<<PEGASUS_STD(endl));

HandlerIntroInd(EnableIndications,message,request,response,

handler);

try {

String providerName,providerLocation;

LocateIndicationProviderNames(request->provider, request->providerModule,

providerName,providerLocation);

indProvRecord *provRec;

if (provTab.lookup(providerName,provRec)) {

provRec->enabled=true;

provRec->handler=new EnableIndicationsResponseHandler(

request, response, request->provider, _indicationCallback);

}

String fileName = resolveFileName(providerLocation);

JMPIjvm::checkException(env);

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(fileName, providerName, String::EMPTY);

// convert arguments

switch (eMethodFound)

OperationContext context;

{

case METHOD_SNIA_PROVIDER20:

{

jint jObj = DEBUG_ConvertCToJava (CMPI_SelectExp*, jint, eSelx);

jobject jSel = env->NewObject(jv->SelectExpClassRef,jv->SelectExpNewI,jObj);

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

JMPIjvm::checkException(env);

context.insert(ContentLanguageListContainer(request->contentLanguages));

JMPIProvider & pr=ph.GetProvider();

jObj = DEBUG_ConvertCToJava (CIMObjectPath*, jint, &eSelx->classNames[0]);

CMPIStatus rc={CMPI_RC_OK,NULL};

jobject jRef = env->NewObject(jv->CIMObjectPathClassRef,jv->CIMObjectPathNewI,jObj);

CMPI_ContextOnStack eCtx(context);

CMPI_ThreadContext thr(&pr.broker,&eCtx);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

JMPIjvm::checkException(env);

"Calling provider.EnableIndicationRequest: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::enableIndicationRequest"<<endl);

jstring jType = env->NewStringUTF(request->nameSpace.getString().getCString());

JMPIProvider::pm_service_op_lock op_lock(&pr);

JMPIjvm::checkException(env);

STAT_GETSTARTTIME;

env->CallVoidMethod((jobject)pr.jProvider,

id,

jSel,

jType,

jRef,

(jboolean)(prec==NULL));

pr.miVector.indMI->ft->enableIndications(

JMPIjvm::checkException(env);

pr.miVector.indMI);

STAT_PMS_PROVIDEREND;

// 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)

{

prec->enabled = false;

if (prec->handler) delete prec->handler;

prec->handler = NULL;

}

HandlerCatch(handler);

PEG_METHOD_EXIT();

STAT_PMS_PROVIDEREND;

return(response);

delete eSelx;

delete qContext;

delete srec;

break;

}

Message * JMPIProviderManager::handleDisableIndicationsRequest(const Message * message) throw()

case METHOD_UNKNOWN:

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager:: handleDisableIndicationsRequest");

DDD (PEGASUS_STD(cout)<<"--- JMPIProviderManager::handleDeleteSubscriptionRequest: should not be here!"<<PEGASUS_STD(endl));

break;

HandlerIntroInd(DisableIndications,message,request,response,

}

handler);

try {

String providerName,providerLocation;

LocateIndicationProviderNames(request->provider, request->providerModule,

providerName,providerLocation);

indProvRecord *provRec;

if (provTab.lookup(providerName,provRec)) {

provRec->enabled=false;

if (provRec->handler) delete provRec->handler;

provRec->handler=NULL;

}

String fileName = resolveFileName(providerLocation);

// get cached or load new provider module

JMPIProvider::OpProviderHolder ph =

providerManager.getProvider(fileName, providerName, String::EMPTY);

// convert arguments

OperationContext context;

context.insert(AcceptLanguageListContainer(request->acceptLanguages));

context.insert(ContentLanguageListContainer(request->contentLanguages));

JMPIProvider & pr=ph.GetProvider();

CMPIStatus rc={CMPI_RC_OK,NULL};

CMPI_ContextOnStack eCtx(context);

CMPI_ThreadContext thr(&pr.broker,&eCtx);

PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,

"Calling provider.DisableIndicationRequest: " + pr.getName());

DDD(cerr<<"--- JMPIProviderManager::disableIndicationRequest"<<endl);

JMPIProvider::pm_service_op_lock op_lock(&pr);

STAT_GETSTARTTIME;

pr.miVector.indMI->ft->disableIndications(

pr.miVector.indMI);

STAT_PMS_PROVIDEREND;

}

HandlerCatch(handler);

if (env) JMPIjvm::detachThread();

PEG_METHOD_EXIT();

return(response);

}*/

}

// Provider module status

static const Uint16 _MODULE_OK = 2;

static const Uint16 _MODULE_STOPPING = 9;

static const Uint16 _MODULE_STOPPED = 10;

Message * JMPIProviderManager::handleDisableModuleRequest(const Message * message) throw()

{

Line 1662

Line 3558

Array<Uint16> operationalStatus;

// Assume success.

operationalStatus.append(_MODULE_STOPPED);

operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_STOPPED);

// Unload providers

Array<CIMInstance> _pInstances = request->providers;

for(Uint32 i = 0, n = _pInstances.size(); i < n; i++)

{

/* temp disabled by Chip

// get the provider file name and logical name

Triad<String, String, String> triad =

getProviderRegistrar()->_getProviderRegPair(_pInstances[i], mInstance);

providerManager.unloadProvider(triad.first, triad.second);

}

CIMDisableModuleResponseMessage * response =

new CIMDisableModuleResponseMessage(

request->messageId,

Line 1712

Line 3597

PEGASUS_ASSERT(request != 0);

Array<Uint16> operationalStatus;

operationalStatus.append(_MODULE_OK);

operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);

CIMEnableModuleResponseMessage * response =

new CIMEnableModuleResponseMessage(

Line 1790

Line 3675

return(response);

}

Message * JMPIProviderManager::handleSubscriptionInitCompleteRequest (const Message * message)

{

PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,

"JMPIProviderManager::handleSubscriptionInitCompleteRequest");

CIMSubscriptionInitCompleteRequestMessage * request =

dynamic_cast <CIMSubscriptionInitCompleteRequestMessage *>

(const_cast <Message *> (message));

PEGASUS_ASSERT (request != 0);

CIMSubscriptionInitCompleteResponseMessage * response =

dynamic_cast <CIMSubscriptionInitCompleteResponseMessage *>

(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 <JMPIProvider *> enableProviders;

enableProviders = providerManager.getIndicationProvidersToEnable ();

Uint32 numProviders = enableProviders.size ();

for (Uint32 i = 0; i < numProviders; i++)

{

try

{

CIMInstance provider;

provider = enableProviders [i]->getProviderInstance ();

// Get cached or load new provider module

JMPIProvider::OpProviderHolder ph = providerManager.getProvider

(enableProviders [i]->getModule ()->getFileName (),

enableProviders [i]->getName ());

indProvRecord * prec = NULL;

provTab.lookup (enableProviders [i]->getName (), prec);

if (prec)

{

prec->enabled = true;

CIMRequestMessage * request = 0;

CIMResponseMessage * response = 0;

prec->handler = new EnableIndicationsResponseHandler

(request, response, provider, _indicationCallback);

}

catch (CIMException & e)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"CIMException: " + e.getMessage ());

}

catch (Exception & e)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"Exception: " + e.getMessage ());

}

catch(...)

{

PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,

"Unknown error in handleSubscriptionInitCompleteRequest");

}

PEG_METHOD_EXIT ();

return (response);

}

Message * JMPIProviderManager::handleUnsupportedRequest(const Message * message) throw()

{

PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "JMPIProviderManager::handleUnsupportedRequest");

PEG_METHOD_EXIT();

CIMRequestMessage* request =

dynamic_cast<CIMRequestMessage *>(const_cast<Message *>(message));

PEGASUS_ASSERT(request != 0 );

// a null response implies unsupported or unknown operation

CIMResponseMessage* response = request->buildResponse();

return(0);

response->cimException =

PEGASUS_CIM_EXCEPTION(CIM_ERR_NOT_SUPPORTED, String::EMPTY);

PEG_METHOD_EXIT();

return response;

}

ProviderName JMPIProviderManager::_resolveProviderName(

Line 1822

Line 3789

providerId.getModule().findProperty("InterfaceType")).getValue();

genericValue.get(interfaceName);

// Check if the provider module is blocked

Array<Uint16> operationalStatus;

Uint32 pos = providerId.getModule().findProperty(

CIMName("OperationalStatus"));

PEGASUS_ASSERT(pos != PEG_NOT_FOUND);

providerId.getModule().getProperty(pos).getValue().get(operationalStatus);

for(Uint32 i = 0; i < operationalStatus.size(); i++)

{

if(operationalStatus[i] == _MODULE_STOPPED ||

operationalStatus[i] == _MODULE_STOPPING)

{

throw PEGASUS_CIM_EXCEPTION_L(CIM_ERR_ACCESS_DENIED,

MessageLoaderParms(

"ProviderManager.ProviderManagerService.PROVIDER_BLOCKED",

"provider blocked."));

}

return ProviderName(providerName, fileName, interfaceName, 0);

}

Legend:

Removed from v.1.6
changed lines
	Added in v.1.27

No CVS admin address has been configured