version 1.11.2.7, 2014/03/18 14:37:49
|
version 1.12, 2011/01/27 13:03:34
|
|
|
#include <Pegasus/Common/XmlReader.h> | #include <Pegasus/Common/XmlReader.h> |
#include <Pegasus/Common/OperationContextInternal.h> | #include <Pegasus/Common/OperationContextInternal.h> |
#include <Pegasus/Common/System.h> | #include <Pegasus/Common/System.h> |
#include <Pegasus/Common/Tracer.h> |
|
| |
#include "CIMBinMsgDeserializer.h" | #include "CIMBinMsgDeserializer.h" |
| |
|
|
CIMBuffer& in, | CIMBuffer& in, |
size_t size) | size_t size) |
{ | { |
PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMBinMsgDeserializer::deserialize"); |
|
|
|
if (size == 0) | if (size == 0) |
return 0; | return 0; |
| |
|
|
if (!in.getBoolean(binaryResponse)) | if (!in.getBoolean(binaryResponse)) |
return 0; | return 0; |
| |
Boolean internalOperation; |
|
|
|
if (!in.getBoolean(internalOperation)) |
|
return 0; |
|
// [type] | // [type] |
| |
MessageType type; | MessageType type; |
|
|
Uint64 serverStartTimeMicroseconds; | Uint64 serverStartTimeMicroseconds; |
| |
if (!in.getUint64(serverStartTimeMicroseconds)) | if (!in.getUint64(serverStartTimeMicroseconds)) |
return 0; |
return false; |
| |
// [providerTimeMicroseconds] | // [providerTimeMicroseconds] |
Uint64 providerTimeMicroseconds; | Uint64 providerTimeMicroseconds; |
| |
if (!in.getUint64(providerTimeMicroseconds)) | if (!in.getUint64(providerTimeMicroseconds)) |
return 0; |
return false; |
| |
#endif | #endif |
| |
|
|
Boolean isComplete; | Boolean isComplete; |
| |
if (!in.getBoolean(isComplete)) | if (!in.getBoolean(isComplete)) |
return 0; |
return false; |
| |
// [index] | // [index] |
| |
Uint32 index; | Uint32 index; |
| |
if (!in.getUint32(index)) | if (!in.getUint32(index)) |
return 0; |
return false; |
| |
// [operationContext] | // [operationContext] |
| |
|
|
msg->setComplete(isComplete); | msg->setComplete(isComplete); |
msg->setIndex(index); | msg->setIndex(index); |
msg->operationContext = operationContext; | msg->operationContext = operationContext; |
msg->internalOperation = internalOperation; |
|
|
|
PEG_TRACE((TRC_DISPATCHER, Tracer::LEVEL4, |
|
"Serialize Message id %s type %s binary req %s" |
|
" binary resp %s iscomplete %s internal %s", |
|
(const char*)msg->messageId.getCString(), |
|
MessageTypeToString(msg->getType()), |
|
boolToString(msg->binaryRequest), |
|
boolToString(msg->binaryResponse), |
|
boolToString(msg->isComplete()), |
|
boolToString(msg->internalOperation) |
|
)); |
|
| |
PEG_METHOD_EXIT(); |
|
return msg; | return msg; |
} | } |
| |
|
|
oreq = _getEnumerateInstancesRequestMessage(in); | oreq = _getEnumerateInstancesRequestMessage(in); |
break; | break; |
case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE: | case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE: |
oreq = _getEnumerateInstanceNamesRequestMessage(); |
oreq = _getEnumerateInstanceNamesRequestMessage(in); |
break; | break; |
case CIM_EXEC_QUERY_REQUEST_MESSAGE: | case CIM_EXEC_QUERY_REQUEST_MESSAGE: |
oreq = _getExecQueryRequestMessage(in); | oreq = _getExecQueryRequestMessage(in); |
|
|
oreq = _getInvokeMethodRequestMessage(in); | oreq = _getInvokeMethodRequestMessage(in); |
break; | break; |
default: | default: |
PEGASUS_UNREACHABLE(PEGASUS_ASSERT(0);) |
PEGASUS_ASSERT(0); |
break; | break; |
} | } |
| |
|
|
ireq = _getDeleteSubscriptionRequestMessage(in); | ireq = _getDeleteSubscriptionRequestMessage(in); |
break; | break; |
default: | default: |
PEGASUS_UNREACHABLE(PEGASUS_ASSERT(0);) |
PEGASUS_ASSERT(0); |
break; | break; |
} | } |
| |
|
|
msg = _getNotifyConfigChangeRequestMessage(in); | msg = _getNotifyConfigChangeRequestMessage(in); |
break; | break; |
case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE: | case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE: |
msg = _getSubscriptionInitCompleteRequestMessage(); |
msg = _getSubscriptionInitCompleteRequestMessage(in); |
break; | break; |
case CIM_INDICATION_SERVICE_DISABLED_REQUEST_MESSAGE: | case CIM_INDICATION_SERVICE_DISABLED_REQUEST_MESSAGE: |
msg = _getIndicationServiceDisabledRequestMessage(); |
msg = _getIndicationServiceDisabledRequestMessage(in); |
break; | break; |
case PROVAGT_GET_SCMOCLASS_REQUEST_MESSAGE: | case PROVAGT_GET_SCMOCLASS_REQUEST_MESSAGE: |
msg = _getProvAgtGetScmoClassRequestMessage(in); | msg = _getProvAgtGetScmoClassRequestMessage(in); |
|
|
| |
| |
default: | default: |
PEGASUS_UNREACHABLE(PEGASUS_ASSERT(0);) |
PEGASUS_ASSERT(0); |
break; | break; |
} | } |
| |
|
|
msg = _getGetInstanceResponseMessage(in, binaryResponse); | msg = _getGetInstanceResponseMessage(in, binaryResponse); |
break; | break; |
case CIM_DELETE_INSTANCE_RESPONSE_MESSAGE: | case CIM_DELETE_INSTANCE_RESPONSE_MESSAGE: |
msg = _getDeleteInstanceResponseMessage(); |
msg = _getDeleteInstanceResponseMessage(in); |
break; | break; |
case CIM_CREATE_INSTANCE_RESPONSE_MESSAGE: | case CIM_CREATE_INSTANCE_RESPONSE_MESSAGE: |
msg = _getCreateInstanceResponseMessage(in); | msg = _getCreateInstanceResponseMessage(in); |
break; | break; |
case CIM_MODIFY_INSTANCE_RESPONSE_MESSAGE: | case CIM_MODIFY_INSTANCE_RESPONSE_MESSAGE: |
msg = _getModifyInstanceResponseMessage(); |
msg = _getModifyInstanceResponseMessage(in); |
break; | break; |
case CIM_ENUMERATE_INSTANCES_RESPONSE_MESSAGE: | case CIM_ENUMERATE_INSTANCES_RESPONSE_MESSAGE: |
msg = _getEnumerateInstancesResponseMessage(in, binaryResponse); | msg = _getEnumerateInstancesResponseMessage(in, binaryResponse); |
|
|
msg = _getGetPropertyResponseMessage(in); | msg = _getGetPropertyResponseMessage(in); |
break; | break; |
case CIM_SET_PROPERTY_RESPONSE_MESSAGE: | case CIM_SET_PROPERTY_RESPONSE_MESSAGE: |
msg = _getSetPropertyResponseMessage(); |
msg = _getSetPropertyResponseMessage(in); |
break; | break; |
case CIM_ASSOCIATORS_RESPONSE_MESSAGE: | case CIM_ASSOCIATORS_RESPONSE_MESSAGE: |
msg = _getAssociatorsResponseMessage(in, binaryResponse); | msg = _getAssociatorsResponseMessage(in, binaryResponse); |
|
|
msg = _getInvokeMethodResponseMessage(in); | msg = _getInvokeMethodResponseMessage(in); |
break; | break; |
case CIM_CREATE_SUBSCRIPTION_RESPONSE_MESSAGE: | case CIM_CREATE_SUBSCRIPTION_RESPONSE_MESSAGE: |
msg = _getCreateSubscriptionResponseMessage(); |
msg = _getCreateSubscriptionResponseMessage(in); |
break; | break; |
case CIM_MODIFY_SUBSCRIPTION_RESPONSE_MESSAGE: | case CIM_MODIFY_SUBSCRIPTION_RESPONSE_MESSAGE: |
msg = _getModifySubscriptionResponseMessage(); |
msg = _getModifySubscriptionResponseMessage(in); |
break; | break; |
case CIM_DELETE_SUBSCRIPTION_RESPONSE_MESSAGE: | case CIM_DELETE_SUBSCRIPTION_RESPONSE_MESSAGE: |
msg = _getDeleteSubscriptionResponseMessage(); |
msg = _getDeleteSubscriptionResponseMessage(in); |
break; | break; |
case CIM_EXPORT_INDICATION_RESPONSE_MESSAGE: | case CIM_EXPORT_INDICATION_RESPONSE_MESSAGE: |
msg = _getExportIndicationResponseMessage(); |
msg = _getExportIndicationResponseMessage(in); |
break; | break; |
case CIM_PROCESS_INDICATION_RESPONSE_MESSAGE: | case CIM_PROCESS_INDICATION_RESPONSE_MESSAGE: |
msg = _getProcessIndicationResponseMessage(); |
msg = _getProcessIndicationResponseMessage(in); |
break; | break; |
case CIM_DISABLE_MODULE_RESPONSE_MESSAGE: | case CIM_DISABLE_MODULE_RESPONSE_MESSAGE: |
msg = _getDisableModuleResponseMessage(in); | msg = _getDisableModuleResponseMessage(in); |
|
|
msg = _getEnableModuleResponseMessage(in); | msg = _getEnableModuleResponseMessage(in); |
break; | break; |
case CIM_STOP_ALL_PROVIDERS_RESPONSE_MESSAGE: | case CIM_STOP_ALL_PROVIDERS_RESPONSE_MESSAGE: |
msg = _getStopAllProvidersResponseMessage(); |
msg = _getStopAllProvidersResponseMessage(in); |
break; | break; |
case CIM_INITIALIZE_PROVIDER_AGENT_RESPONSE_MESSAGE: | case CIM_INITIALIZE_PROVIDER_AGENT_RESPONSE_MESSAGE: |
msg = | msg = |
_getInitializeProviderAgentResponseMessage(); |
_getInitializeProviderAgentResponseMessage(in); |
break; | break; |
case CIM_NOTIFY_CONFIG_CHANGE_RESPONSE_MESSAGE: | case CIM_NOTIFY_CONFIG_CHANGE_RESPONSE_MESSAGE: |
msg = _getNotifyConfigChangeResponseMessage(); |
msg = _getNotifyConfigChangeResponseMessage(in); |
break; | break; |
case CIM_SUBSCRIPTION_INIT_COMPLETE_RESPONSE_MESSAGE: | case CIM_SUBSCRIPTION_INIT_COMPLETE_RESPONSE_MESSAGE: |
msg = _getSubscriptionInitCompleteResponseMessage(); |
msg = _getSubscriptionInitCompleteResponseMessage(in); |
break; | break; |
case CIM_INDICATION_SERVICE_DISABLED_RESPONSE_MESSAGE: | case CIM_INDICATION_SERVICE_DISABLED_RESPONSE_MESSAGE: |
msg = _getIndicationServiceDisabledResponseMessage(); |
msg = _getIndicationServiceDisabledResponseMessage(in); |
break; | break; |
case PROVAGT_GET_SCMOCLASS_RESPONSE_MESSAGE: | case PROVAGT_GET_SCMOCLASS_RESPONSE_MESSAGE: |
msg = _getProvAgtGetScmoClassResponseMessage(in); | msg = _getProvAgtGetScmoClassResponseMessage(in); |
break; | break; |
| |
default: | default: |
PEGASUS_UNREACHABLE(PEGASUS_ASSERT(0);) |
PEGASUS_ASSERT(0); |
break; | break; |
} | } |
| |
|
|
operationContext.insert(CachedClassDefinitionContainer(cc)); | operationContext.insert(CachedClassDefinitionContainer(cc)); |
} | } |
| |
// [UserRoleContainer] |
|
|
|
if (!in.getPresent(present)) |
|
return false; |
|
|
|
if (present) |
|
{ |
|
String userRole; |
|
|
|
if (!in.getString(userRole)) |
|
return false; |
|
|
|
operationContext.insert(UserRoleContainer(userRole)); |
|
} |
|
|
|
return true; | return true; |
} | } |
| |
|
|
CIMPropertyList propertyList; | CIMPropertyList propertyList; |
| |
if (!_getInstance(in, modifiedInstance)) | if (!_getInstance(in, modifiedInstance)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeQualifiers)) | if (!in.getBoolean(includeQualifiers)) |
return 0; |
return false; |
| |
if (!_getPropertyList(in, propertyList)) | if (!_getPropertyList(in, propertyList)) |
return 0; |
return false; |
| |
return new CIMModifyInstanceRequestMessage( | return new CIMModifyInstanceRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMPropertyList propertyList; | CIMPropertyList propertyList; |
| |
if (!in.getBoolean(deepInheritance)) | if (!in.getBoolean(deepInheritance)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeQualifiers)) | if (!in.getBoolean(includeQualifiers)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeClassOrigin)) | if (!in.getBoolean(includeClassOrigin)) |
return 0; |
return false; |
| |
if (!_getPropertyList(in, propertyList)) | if (!_getPropertyList(in, propertyList)) |
return 0; |
return false; |
| |
return new CIMEnumerateInstancesRequestMessage( | return new CIMEnumerateInstancesRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMEnumerateInstanceNamesRequestMessage* | CIMEnumerateInstanceNamesRequestMessage* |
CIMBinMsgDeserializer::_getEnumerateInstanceNamesRequestMessage() |
CIMBinMsgDeserializer::_getEnumerateInstanceNamesRequestMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMEnumerateInstanceNamesRequestMessage( | return new CIMEnumerateInstanceNamesRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
String query; | String query; |
| |
if (!in.getString(queryLanguage) || !in.getString(query)) | if (!in.getString(queryLanguage) || !in.getString(query)) |
return 0; |
return false; |
| |
return new CIMExecQueryRequestMessage( | return new CIMExecQueryRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMPropertyList propertyList; | CIMPropertyList propertyList; |
| |
if (!_getObjectPath(in, objectName)) | if (!_getObjectPath(in, objectName)) |
return 0; |
return false; |
| |
if (!_getName(in, assocClass)) | if (!_getName(in, assocClass)) |
return 0; |
return false; |
| |
if (!_getName(in, resultClass)) | if (!_getName(in, resultClass)) |
return 0; |
return false; |
| |
if (!in.getString(role)) | if (!in.getString(role)) |
return 0; |
return false; |
| |
if (!in.getString(resultRole)) | if (!in.getString(resultRole)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeQualifiers)) | if (!in.getBoolean(includeQualifiers)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeClassOrigin)) | if (!in.getBoolean(includeClassOrigin)) |
return 0; |
return false; |
| |
if (!_getPropertyList(in, propertyList)) | if (!_getPropertyList(in, propertyList)) |
return 0; |
return false; |
| |
return new CIMAssociatorsRequestMessage( | return new CIMAssociatorsRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
String resultRole; | String resultRole; |
| |
if (!_getObjectPath(in, objectName)) | if (!_getObjectPath(in, objectName)) |
return 0; |
return false; |
| |
if (!_getName(in, assocClass)) | if (!_getName(in, assocClass)) |
return 0; |
return false; |
| |
if (!_getName(in, resultClass)) | if (!_getName(in, resultClass)) |
return 0; |
return false; |
| |
if (!in.getString(role)) | if (!in.getString(role)) |
return 0; |
return false; |
| |
if (!in.getString(resultRole)) | if (!in.getString(resultRole)) |
return 0; |
return false; |
| |
return new CIMAssociatorNamesRequestMessage( | return new CIMAssociatorNamesRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMPropertyList propertyList; | CIMPropertyList propertyList; |
| |
if (!_getObjectPath(in, objectName)) | if (!_getObjectPath(in, objectName)) |
return 0; |
return false; |
| |
if (!_getName(in, resultClass)) | if (!_getName(in, resultClass)) |
return 0; |
return false; |
| |
if (!in.getString(role)) | if (!in.getString(role)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeQualifiers)) | if (!in.getBoolean(includeQualifiers)) |
return 0; |
return false; |
| |
if (!in.getBoolean(includeClassOrigin)) | if (!in.getBoolean(includeClassOrigin)) |
return 0; |
return false; |
| |
if (!_getPropertyList(in, propertyList)) | if (!_getPropertyList(in, propertyList)) |
return 0; |
return false; |
| |
return new CIMReferencesRequestMessage( | return new CIMReferencesRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
String role; | String role; |
| |
if (!_getObjectPath(in, objectName)) | if (!_getObjectPath(in, objectName)) |
return 0; |
return false; |
| |
if (!_getName(in, resultClass)) | if (!_getName(in, resultClass)) |
return 0; |
return false; |
| |
if (!in.getString(role)) | if (!in.getString(role)) |
return 0; |
return false; |
| |
return new CIMReferenceNamesRequestMessage( | return new CIMReferenceNamesRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMName propertyName; | CIMName propertyName; |
| |
if (!_getObjectPath(in, instanceName)) | if (!_getObjectPath(in, instanceName)) |
return 0; |
return false; |
| |
if (!_getName(in, propertyName)) | if (!_getName(in, propertyName)) |
return 0; |
return false; |
| |
return new CIMGetPropertyRequestMessage( | return new CIMGetPropertyRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMParamValue newValue; | CIMParamValue newValue; |
| |
if (!_getObjectPath(in, instanceName)) | if (!_getObjectPath(in, instanceName)) |
return 0; |
return false; |
| |
if (!_getParamValue(in, newValue)) | if (!_getParamValue(in, newValue)) |
return 0; |
return false; |
| |
return new CIMSetPropertyRequestMessage( | return new CIMSetPropertyRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
Array<CIMParamValue> inParameters; | Array<CIMParamValue> inParameters; |
| |
if (!_getObjectPath(in, instanceName)) | if (!_getObjectPath(in, instanceName)) |
return 0; |
return false; |
| |
if (!_getName(in, methodName)) | if (!_getName(in, methodName)) |
return 0; |
return false; |
| |
if (!in.getParamValueA(inParameters)) | if (!in.getParamValueA(inParameters)) |
return 0; |
return false; |
| |
return new CIMInvokeMethodRequestMessage( | return new CIMInvokeMethodRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
String query; | String query; |
| |
if (!_getNamespaceName(in, nameSpace)) | if (!_getNamespaceName(in, nameSpace)) |
return 0; |
return false; |
| |
if (!_getInstance(in, subscriptionInstance)) | if (!_getInstance(in, subscriptionInstance)) |
return 0; |
return false; |
| |
if (!in.getNameA(classNames)) | if (!in.getNameA(classNames)) |
return 0; |
return false; |
| |
if (!_getPropertyList(in, propertyList)) | if (!_getPropertyList(in, propertyList)) |
return 0; |
return false; |
| |
if (!in.getUint16(repeatNotificationPolicy)) | if (!in.getUint16(repeatNotificationPolicy)) |
return 0; |
return false; |
| |
if (!in.getString(query)) | if (!in.getString(query)) |
return 0; |
return false; |
| |
return new CIMCreateSubscriptionRequestMessage( | return new CIMCreateSubscriptionRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
String query; | String query; |
| |
if (!_getNamespaceName(in, nameSpace)) | if (!_getNamespaceName(in, nameSpace)) |
return 0; |
return false; |
| |
if (!_getInstance(in, subscriptionInstance)) | if (!_getInstance(in, subscriptionInstance)) |
return 0; |
return false; |
| |
if (!in.getNameA(classNames)) | if (!in.getNameA(classNames)) |
return 0; |
return false; |
| |
if (!_getPropertyList(in, propertyList)) | if (!_getPropertyList(in, propertyList)) |
return 0; |
return false; |
| |
if (!in.getUint16(repeatNotificationPolicy)) | if (!in.getUint16(repeatNotificationPolicy)) |
return 0; |
return false; |
| |
if (!in.getString(query)) | if (!in.getString(query)) |
return 0; |
return false; |
| |
return new CIMModifySubscriptionRequestMessage( | return new CIMModifySubscriptionRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
Array<CIMName> classNames; | Array<CIMName> classNames; |
| |
if (!_getNamespaceName(in, nameSpace)) | if (!_getNamespaceName(in, nameSpace)) |
return 0; |
return false; |
| |
if (!_getInstance(in, subscriptionInstance)) | if (!_getInstance(in, subscriptionInstance)) |
return 0; |
return false; |
| |
if (!in.getNameA(classNames)) | if (!in.getNameA(classNames)) |
return 0; |
return false; |
| |
return new CIMDeleteSubscriptionRequestMessage( | return new CIMDeleteSubscriptionRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMInstance indicationInstance; | CIMInstance indicationInstance; |
| |
if (!_getUserInfo(in, authType, userName)) | if (!_getUserInfo(in, authType, userName)) |
return 0; |
return false; |
| |
if (!in.getString(destinationPath)) | if (!in.getString(destinationPath)) |
return 0; |
return false; |
| |
if (!_getInstance(in, indicationInstance)) | if (!_getInstance(in, indicationInstance)) |
return 0; |
return false; |
| |
return new CIMExportIndicationRequestMessage( | return new CIMExportIndicationRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMInstance indicationInstance; | CIMInstance indicationInstance; |
Array<CIMObjectPath> subscriptionInstanceNames; | Array<CIMObjectPath> subscriptionInstanceNames; |
CIMInstance provider; | CIMInstance provider; |
Uint32 timeoutMilliSec; |
|
| |
if (!_getNamespaceName(in, nameSpace)) | if (!_getNamespaceName(in, nameSpace)) |
return 0; |
return false; |
| |
if (!_getInstance(in, indicationInstance)) | if (!_getInstance(in, indicationInstance)) |
return 0; |
return false; |
| |
if (!in.getObjectPathA(subscriptionInstanceNames)) | if (!in.getObjectPathA(subscriptionInstanceNames)) |
return 0; |
return false; |
| |
if (!_getInstance(in, provider)) | if (!_getInstance(in, provider)) |
return 0; |
return false; |
|
|
if (!in.getUint32(timeoutMilliSec)) |
|
return 0; |
|
| |
return new CIMProcessIndicationRequestMessage( | return new CIMProcessIndicationRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
indicationInstance, | indicationInstance, |
subscriptionInstanceNames, | subscriptionInstanceNames, |
provider, | provider, |
QueueIdStack(), |
QueueIdStack()); |
timeoutMilliSec); |
|
} | } |
| |
CIMDisableModuleRequestMessage* | CIMDisableModuleRequestMessage* |
|
|
Array<Boolean> indicationProviders; | Array<Boolean> indicationProviders; |
| |
if (!_getUserInfo(in, authType, userName)) | if (!_getUserInfo(in, authType, userName)) |
return 0; |
return false; |
| |
if (!_getInstance(in, providerModule)) | if (!_getInstance(in, providerModule)) |
return 0; |
return false; |
| |
if (!in.getInstanceA(providers)) | if (!in.getInstanceA(providers)) |
return 0; |
return false; |
| |
if (!in.getBoolean(disableProviderOnly)) | if (!in.getBoolean(disableProviderOnly)) |
return 0; |
return false; |
| |
if (!in.getBooleanA(indicationProviders)) | if (!in.getBooleanA(indicationProviders)) |
return 0; |
return false; |
| |
return new CIMDisableModuleRequestMessage( | return new CIMDisableModuleRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMInstance providerModule; | CIMInstance providerModule; |
| |
if (!_getUserInfo(in, authType, userName)) | if (!_getUserInfo(in, authType, userName)) |
return 0; |
return false; |
| |
if (!_getInstance(in, providerModule)) | if (!_getInstance(in, providerModule)) |
return 0; |
return false; |
| |
return new CIMEnableModuleRequestMessage( | return new CIMEnableModuleRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMBinMsgDeserializer::_getStopAllProvidersRequestMessage( | CIMBinMsgDeserializer::_getStopAllProvidersRequestMessage( |
CIMBuffer& in) | CIMBuffer& in) |
{ | { |
Uint32 shutdownTimeout; |
|
|
|
if (!in.getUint32(shutdownTimeout)) |
|
return 0; |
|
|
|
return new CIMStopAllProvidersRequestMessage( | return new CIMStopAllProvidersRequestMessage( |
String::EMPTY, | String::EMPTY, |
QueueIdStack(), |
QueueIdStack()); |
shutdownTimeout); |
|
} | } |
| |
CIMInitializeProviderAgentRequestMessage* | CIMInitializeProviderAgentRequestMessage* |
|
|
Boolean subscriptionInitComplete; | Boolean subscriptionInitComplete; |
| |
if (!in.getString(pegasusHome)) | if (!in.getString(pegasusHome)) |
return 0; |
return false; |
| |
if (!in.getUint32(size)) | if (!in.getUint32(size)) |
return 0; |
return false; |
| |
for (Uint32 i = 0; i < size; i++) | for (Uint32 i = 0; i < size; i++) |
{ | { |
|
|
String second; | String second; |
| |
if (!in.getString(first) || !in.getString(second)) | if (!in.getString(first) || !in.getString(second)) |
return 0; |
return false; |
| |
configProperties.append(ConfigPair(first, second)); | configProperties.append(ConfigPair(first, second)); |
} | } |
| |
if (!in.getBoolean(bindVerbose)) | if (!in.getBoolean(bindVerbose)) |
return 0; |
return false; |
| |
if (!in.getBoolean(subscriptionInitComplete)) | if (!in.getBoolean(subscriptionInitComplete)) |
return 0; |
return false; |
| |
return new CIMInitializeProviderAgentRequestMessage( | return new CIMInitializeProviderAgentRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
Boolean currentValueModified; | Boolean currentValueModified; |
| |
if (!in.getString(propertyName)) | if (!in.getString(propertyName)) |
return 0; |
return false; |
| |
if (!in.getString(newPropertyValue)) | if (!in.getString(newPropertyValue)) |
return 0; |
return false; |
| |
if (!in.getBoolean(currentValueModified)) | if (!in.getBoolean(currentValueModified)) |
return 0; |
return false; |
| |
return new CIMNotifyConfigChangeRequestMessage( | return new CIMNotifyConfigChangeRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMIndicationServiceDisabledRequestMessage* | CIMIndicationServiceDisabledRequestMessage* |
CIMBinMsgDeserializer::_getIndicationServiceDisabledRequestMessage() |
CIMBinMsgDeserializer::_getIndicationServiceDisabledRequestMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMIndicationServiceDisabledRequestMessage( | return new CIMIndicationServiceDisabledRequestMessage( |
String(), | String(), |
|
|
} | } |
| |
CIMSubscriptionInitCompleteRequestMessage* | CIMSubscriptionInitCompleteRequestMessage* |
CIMBinMsgDeserializer::_getSubscriptionInitCompleteRequestMessage() |
CIMBinMsgDeserializer::_getSubscriptionInitCompleteRequestMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMSubscriptionInitCompleteRequestMessage( | return new CIMSubscriptionInitCompleteRequestMessage( |
String::EMPTY, | String::EMPTY, |
|
|
{ | { |
CIMName className; | CIMName className; |
CIMNamespaceName nsName; | CIMNamespaceName nsName; |
String messageID; |
|
|
|
if (!in.getString(messageID)) |
|
return 0; |
|
| |
if (!in.getNamespaceName(nsName)) | if (!in.getNamespaceName(nsName)) |
return 0; |
return false; |
| |
if (!in.getName(className)) | if (!in.getName(className)) |
return 0; |
return false; |
| |
return new ProvAgtGetScmoClassRequestMessage( | return new ProvAgtGetScmoClassRequestMessage( |
messageID, |
String::EMPTY, |
nsName, | nsName, |
className, | className, |
QueueIdStack()); | QueueIdStack()); |
|
|
} | } |
| |
CIMDeleteInstanceResponseMessage* | CIMDeleteInstanceResponseMessage* |
CIMBinMsgDeserializer::_getDeleteInstanceResponseMessage() |
CIMBinMsgDeserializer::_getDeleteInstanceResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMDeleteInstanceResponseMessage( | return new CIMDeleteInstanceResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
CIMObjectPath instanceName; | CIMObjectPath instanceName; |
| |
if (!_getObjectPath(in, instanceName)) | if (!_getObjectPath(in, instanceName)) |
return 0; |
return false; |
| |
return new CIMCreateInstanceResponseMessage( | return new CIMCreateInstanceResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMModifyInstanceResponseMessage* | CIMModifyInstanceResponseMessage* |
CIMBinMsgDeserializer::_getModifyInstanceResponseMessage() |
CIMBinMsgDeserializer::_getModifyInstanceResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMModifyInstanceResponseMessage( | return new CIMModifyInstanceResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
delete(msg); | delete(msg); |
return 0; | return 0; |
} | } |
|
|
return msg; | return msg; |
} | } |
else | else |
|
|
delete(msg); | delete(msg); |
return 0; | return 0; |
} | } |
|
|
return msg; | return msg; |
} | } |
} | } |
|
|
CIMParamValue value; | CIMParamValue value; |
| |
if (!_getParamValue(in, value)) | if (!_getParamValue(in, value)) |
return 0; |
return false; |
| |
return new CIMGetPropertyResponseMessage( | return new CIMGetPropertyResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMSetPropertyResponseMessage* | CIMSetPropertyResponseMessage* |
CIMBinMsgDeserializer::_getSetPropertyResponseMessage() |
CIMBinMsgDeserializer::_getSetPropertyResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMSetPropertyResponseMessage( | return new CIMSetPropertyResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
Array<CIMParamValue> outParameters; | Array<CIMParamValue> outParameters; |
| |
if (!_getParamValue(in, retValue)) | if (!_getParamValue(in, retValue)) |
return 0; |
return false; |
| |
if (!in.getParamValueA(outParameters)) | if (!in.getParamValueA(outParameters)) |
return 0; |
return false; |
| |
if (!_getName(in, methodName)) | if (!_getName(in, methodName)) |
return 0; |
return false; |
| |
return new CIMInvokeMethodResponseMessage( | return new CIMInvokeMethodResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMCreateSubscriptionResponseMessage* | CIMCreateSubscriptionResponseMessage* |
CIMBinMsgDeserializer::_getCreateSubscriptionResponseMessage() |
CIMBinMsgDeserializer::_getCreateSubscriptionResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMCreateSubscriptionResponseMessage( | return new CIMCreateSubscriptionResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMModifySubscriptionResponseMessage* | CIMModifySubscriptionResponseMessage* |
CIMBinMsgDeserializer::_getModifySubscriptionResponseMessage() |
CIMBinMsgDeserializer::_getModifySubscriptionResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMModifySubscriptionResponseMessage( | return new CIMModifySubscriptionResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMDeleteSubscriptionResponseMessage* | CIMDeleteSubscriptionResponseMessage* |
CIMBinMsgDeserializer::_getDeleteSubscriptionResponseMessage() |
CIMBinMsgDeserializer::_getDeleteSubscriptionResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMDeleteSubscriptionResponseMessage( | return new CIMDeleteSubscriptionResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMExportIndicationResponseMessage* | CIMExportIndicationResponseMessage* |
CIMBinMsgDeserializer::_getExportIndicationResponseMessage() |
CIMBinMsgDeserializer::_getExportIndicationResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMExportIndicationResponseMessage( | return new CIMExportIndicationResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMProcessIndicationResponseMessage* | CIMProcessIndicationResponseMessage* |
CIMBinMsgDeserializer::_getProcessIndicationResponseMessage() |
CIMBinMsgDeserializer::_getProcessIndicationResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMProcessIndicationResponseMessage( | return new CIMProcessIndicationResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
Array<Uint16> operationalStatus; | Array<Uint16> operationalStatus; |
| |
if (!in.getUint16A(operationalStatus)) | if (!in.getUint16A(operationalStatus)) |
return 0; |
return false; |
| |
return new CIMDisableModuleResponseMessage( | return new CIMDisableModuleResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
Array<Uint16> operationalStatus; | Array<Uint16> operationalStatus; |
| |
if (!in.getUint16A(operationalStatus)) | if (!in.getUint16A(operationalStatus)) |
return 0; |
return false; |
| |
return new CIMEnableModuleResponseMessage( | return new CIMEnableModuleResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMStopAllProvidersResponseMessage* | CIMStopAllProvidersResponseMessage* |
CIMBinMsgDeserializer::_getStopAllProvidersResponseMessage() |
CIMBinMsgDeserializer::_getStopAllProvidersResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMStopAllProvidersResponseMessage( | return new CIMStopAllProvidersResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMInitializeProviderAgentResponseMessage* | CIMInitializeProviderAgentResponseMessage* |
CIMBinMsgDeserializer::_getInitializeProviderAgentResponseMessage() |
CIMBinMsgDeserializer::_getInitializeProviderAgentResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMInitializeProviderAgentResponseMessage( | return new CIMInitializeProviderAgentResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMNotifyConfigChangeResponseMessage* | CIMNotifyConfigChangeResponseMessage* |
CIMBinMsgDeserializer::_getNotifyConfigChangeResponseMessage() |
CIMBinMsgDeserializer::_getNotifyConfigChangeResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMNotifyConfigChangeResponseMessage( | return new CIMNotifyConfigChangeResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMSubscriptionInitCompleteResponseMessage* | CIMSubscriptionInitCompleteResponseMessage* |
CIMBinMsgDeserializer::_getSubscriptionInitCompleteResponseMessage() |
CIMBinMsgDeserializer::_getSubscriptionInitCompleteResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMSubscriptionInitCompleteResponseMessage( | return new CIMSubscriptionInitCompleteResponseMessage( |
String::EMPTY, | String::EMPTY, |
|
|
} | } |
| |
CIMIndicationServiceDisabledResponseMessage* | CIMIndicationServiceDisabledResponseMessage* |
CIMBinMsgDeserializer::_getIndicationServiceDisabledResponseMessage() |
CIMBinMsgDeserializer::_getIndicationServiceDisabledResponseMessage( |
|
CIMBuffer& in) |
{ | { |
return new CIMIndicationServiceDisabledResponseMessage( | return new CIMIndicationServiceDisabledResponseMessage( |
String(), | String(), |
|
|
CIMBuffer& in) | CIMBuffer& in) |
{ | { |
SCMOClass theClass("",""); | SCMOClass theClass("",""); |
String messageID; |
|
| |
if (!in.getString(messageID)) |
|
return 0; |
|
| |
if (!in.getSCMOClass(theClass)) | if (!in.getSCMOClass(theClass)) |
return 0; |
return false; |
| |
return new ProvAgtGetScmoClassResponseMessage( | return new ProvAgtGetScmoClassResponseMessage( |
messageID, |
String::EMPTY, |
CIMException(), | CIMException(), |
QueueIdStack(), | QueueIdStack(), |
theClass); | theClass); |