messageserializer.cpp

Pegasus is an open-source implementationof the DMTF CIM and WBEM standards. It is designed to be por

        dynamic_cast<CIMDisableModuleRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
    validateCIMInstance(
        inMessage.providerModule, outMessage->providerModule);
    validateCIMInstanceArray(inMessage.providers, outMessage->providers);
    PEGASUS_TEST_ASSERT(
        inMessage.disableProviderOnly == outMessage->disableProviderOnly);
    PEGASUS_TEST_ASSERT(inMessage.indicationProviders.size() ==
        outMessage->indicationProviders.size());
    for (Uint32 i = 0; i < inMessage.indicationProviders.size(); i++)
    {
        PEGASUS_TEST_ASSERT(inMessage.indicationProviders[i] ==
            outMessage->indicationProviders[i]);
    }
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMEnableModuleRequestMessage
//
void testCIMEnableModuleRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMInstance& provModule,
    const QueueIdStack& qids,
    const String& auth,
    const String& user)
{
    CIMEnableModuleRequestMessage inMessage(mid, provModule, qids, auth, user);
    inMessage.operationContext = oc;
    AutoPtr<CIMEnableModuleRequestMessage> outMessage(
        dynamic_cast<CIMEnableModuleRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
    validateCIMInstance(
        inMessage.providerModule, outMessage->providerModule);
    PEGASUS_TEST_ASSERT(inMessage.authType == outMessage->authType);
    PEGASUS_TEST_ASSERT(inMessage.userName == outMessage->userName);
}

//
// testCIMStopAllProvidersRequestMessage
//
void testCIMStopAllProvidersRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const QueueIdStack& qids)
{
    CIMStopAllProvidersRequestMessage inMessage(mid, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMStopAllProvidersRequestMessage> outMessage(
        dynamic_cast<CIMStopAllProvidersRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMInitializeProviderRequestMessage
//
void testCIMInitializeProviderRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const QueueIdStack& qids)
{
    CIMInitializeProviderRequestMessage inMessage(mid, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMInitializeProviderRequestMessage> outMessage(
        dynamic_cast<CIMInitializeProviderRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMInitializeProviderAgentRequestMessage
//
void testCIMInitializeProviderAgentRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const String& home,
    const Array<Pair<String, String> >& config,
    Boolean bindVerbose,
    Boolean subsInitComplete,
    const QueueIdStack& qids)
{
    CIMInitializeProviderAgentRequestMessage inMessage(
        mid, home, config, bindVerbose, subsInitComplete, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMInitializeProviderAgentRequestMessage> outMessage(
        dynamic_cast<CIMInitializeProviderAgentRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.pegasusHome == outMessage->pegasusHome);
    PEGASUS_TEST_ASSERT(inMessage.configProperties.size() ==
        outMessage->configProperties.size());
    for (Uint32 i = 0; i < inMessage.configProperties.size(); i++)
    {
        PEGASUS_TEST_ASSERT(inMessage.configProperties[i].first ==
            outMessage->configProperties[i].first);
        PEGASUS_TEST_ASSERT(inMessage.configProperties[i].second ==
            outMessage->configProperties[i].second);
    }
    PEGASUS_TEST_ASSERT(inMessage.bindVerbose == outMessage->bindVerbose);
    PEGASUS_TEST_ASSERT(inMessage.subscriptionInitComplete ==
        outMessage->subscriptionInitComplete);
}

//
// testCIMNotifyConfigChangeRequestMessage
//
void testCIMNotifyConfigChangeRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const String& propName,
    const String& newPropValue,
    Boolean currValueModified,
    const QueueIdStack& qids)
{
    CIMNotifyConfigChangeRequestMessage inMessage(
        mid, propName, newPropValue, currValueModified, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMNotifyConfigChangeRequestMessage> outMessage(
        dynamic_cast<CIMNotifyConfigChangeRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.propertyName == outMessage->propertyName);
    PEGASUS_TEST_ASSERT(
        inMessage.newPropertyValue == outMessage->newPropertyValue);
    PEGASUS_TEST_ASSERT(inMessage.currentValueModified ==
        outMessage->currentValueModified);
}

//
// testCIMSubscriptionInitCompleteRequestMessage
//
void testCIMSubscriptionInitCompleteRequestMessage(
    const OperationContext& oc,
    const String& mid,
    const QueueIdStack& qids)
{
    CIMSubscriptionInitCompleteRequestMessage inMessage(mid, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMSubscriptionInitCompleteRequestMessage> outMessage(
        dynamic_cast<CIMSubscriptionInitCompleteRequestMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMRequestMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMGetInstanceResponseMessage
//
void testCIMGetInstanceResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const CIMInstance& inst)
{
    CIMGetInstanceResponseMessage inMessage(mid, ex, qids, inst);
    inMessage.operationContext = oc;
    AutoPtr<CIMGetInstanceResponseMessage> outMessage(
        dynamic_cast<CIMGetInstanceResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMInstance(inMessage.cimInstance, outMessage->cimInstance);
}

//
// testCIMCreateInstanceResponseMessage
//
void testCIMCreateInstanceResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const CIMObjectPath& instName)
{
    CIMCreateInstanceResponseMessage inMessage(mid, ex, qids, instName);
    inMessage.operationContext = oc;
    AutoPtr<CIMCreateInstanceResponseMessage> outMessage(
        dynamic_cast<CIMCreateInstanceResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    PEGASUS_TEST_ASSERT(inMessage.instanceName == outMessage->instanceName);
}

//
// testCIMModifyInstanceResponseMessage
//
void testCIMModifyInstanceResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMModifyInstanceResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMModifyInstanceResponseMessage> outMessage(
        dynamic_cast<CIMModifyInstanceResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMDeleteInstanceResponseMessage
//
void testCIMDeleteInstanceResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids)
{
    CIMDeleteInstanceResponseMessage inMessage(mid, ex, qids);
    inMessage.operationContext = oc;
    AutoPtr<CIMDeleteInstanceResponseMessage> outMessage(
        dynamic_cast<CIMDeleteInstanceResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
}

//
// testCIMEnumerateInstancesResponseMessage
//
void testCIMEnumerateInstancesResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMInstance>& instances)
{
    CIMEnumerateInstancesResponseMessage inMessage(mid, ex, qids, instances);
    inMessage.operationContext = oc;
    AutoPtr<CIMEnumerateInstancesResponseMessage> outMessage(
        dynamic_cast<CIMEnumerateInstancesResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMInstanceArray(
        inMessage.cimNamedInstances, outMessage->cimNamedInstances);
}

//
// testCIMEnumerateInstanceNamesResponseMessage
//
void testCIMEnumerateInstanceNamesResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMObjectPath>& instNames)
{
    CIMEnumerateInstanceNamesResponseMessage inMessage(
        mid, ex, qids, instNames);
    inMessage.operationContext = oc;
    AutoPtr<CIMEnumerateInstanceNamesResponseMessage> outMessage(
        dynamic_cast<CIMEnumerateInstanceNamesResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMObjectPathArray(
        inMessage.instanceNames, outMessage->instanceNames);
}

//
// testCIMExecQueryResponseMessage
//
void testCIMExecQueryResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMObject>& objects)
{
    CIMExecQueryResponseMessage inMessage(mid, ex, qids, objects);
    inMessage.operationContext = oc;
    AutoPtr<CIMExecQueryResponseMessage> outMessage(
        dynamic_cast<CIMExecQueryResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMObjectArray(inMessage.cimObjects, outMessage->cimObjects);
}

//
// testCIMAssociatorsResponseMessage
//
void testCIMAssociatorsResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMObject>& objArray)
{
    CIMAssociatorsResponseMessage inMessage(mid, ex, qids, objArray);
    inMessage.operationContext = oc;
    AutoPtr<CIMAssociatorsResponseMessage> outMessage(
        dynamic_cast<CIMAssociatorsResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMObjectArray(inMessage.cimObjects, outMessage->cimObjects);
}

//
// testCIMAssociatorNamesResponseMessage
//
void testCIMAssociatorNamesResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMObjectPath>& pathArray)
{
    CIMAssociatorNamesResponseMessage inMessage(mid, ex, qids, pathArray);
    inMessage.operationContext = oc;
    AutoPtr<CIMAssociatorNamesResponseMessage> outMessage(
        dynamic_cast<CIMAssociatorNamesResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMObjectPathArray(inMessage.objectNames, outMessage->objectNames);
}

//
// testCIMReferencesResponseMessage
//
void testCIMReferencesResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMObject>& objArray)
{
    CIMReferencesResponseMessage inMessage(mid, ex, qids, objArray);
    inMessage.operationContext = oc;
    AutoPtr<CIMReferencesResponseMessage> outMessage(
        dynamic_cast<CIMReferencesResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);

    validateCIMResponseMessageAttributes(&inMessage, outMessage.get());
    validateCIMObjectArray(inMessage.cimObjects, outMessage->cimObjects);
}

//
// testCIMReferenceNamesResponseMessage
//
void testCIMReferenceNamesResponseMessage(
    const OperationContext& oc,
    const String& mid,
    const CIMException& ex,
    const QueueIdStack& qids,
    const Array<CIMObjectPath>& pathArray)
{
    CIMReferenceNamesResponseMessage inMessage(mid, ex, qids, pathArray);
    inMessage.operationContext = oc;
    AutoPtr<CIMReferenceNamesResponseMessage> outMessage(
        dynamic_cast<CIMReferenceNamesResponseMessage*>(
            serializeDeserializeMessage(&inMessage)));
    PEGASUS_TEST_ASSERT(outMessage.get() != 0);