(file) Return to CIMOperationResponseEncoder.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Server

Diff for /pegasus/src/Pegasus/Server/CIMOperationResponseEncoder.cpp between version 1.13 and 1.14

version 1.13, 2002/03/28 20:39:19 version 1.14, 2002/03/29 21:40:40
Line 65 
Line 65 
    Uint32 queueId,    Uint32 queueId,
    Array<Sint8>& message)    Array<Sint8>& message)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::sendResponse()");     PEG_METHOD_ENTER(TRC_DISPATCHER,
                       "CIMOperationResponseEncoder::sendResponse()");
    MessageQueue* queue = MessageQueue::lookup(queueId);    MessageQueue* queue = MessageQueue::lookup(queueId);
  
    if (queue)    if (queue)
Line 87 
Line 88 
                     "Invalid queueId = %i, response not sent.", queueId);                     "Invalid queueId = %i, response not sent.", queueId);
    }    }
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::sendResponse()");     PEG_METHOD_EXIT();
 } }
  
 // Code is duplicated in CIMOperationRequestDecoder // Code is duplicated in CIMOperationRequestDecoder
Line 98 
Line 99 
    CIMStatusCode code,    CIMStatusCode code,
    const String& description)    const String& description)
 { {
     PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"      PEG_METHOD_ENTER(TRC_DISPATCHER,
                    "sendIMethodError()");                       "CIMOperationResponseEncoder::sendIMethodError()");
  
     Array<Sint8> message;     Array<Sint8> message;
     message = XmlWriter::formatSimpleIMethodErrorRspMessage(     message = XmlWriter::formatSimpleIMethodErrorRspMessage(
Line 110 
Line 111 
  
     sendResponse(queueId, message);     sendResponse(queueId, message);
  
     PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"      PEG_METHOD_EXIT();
                   "sendIMethodError()");  
 } }
  
 void CIMOperationResponseEncoder::sendIMethodError( void CIMOperationResponseEncoder::sendIMethodError(
    CIMResponseMessage* response,    CIMResponseMessage* response,
    const String& cimMethodName)    const String& cimMethodName)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "sendIMethodError()");                      "CIMOperationResponseEncoder::sendIMethodError()");
  
    Uint32 queueId = response->queueIds.top();    Uint32 queueId = response->queueIds.top();
    response->queueIds.pop();    response->queueIds.pop();
Line 131 
Line 131 
       response->errorCode,       response->errorCode,
       response->errorDescription);       response->errorDescription);
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "sendIMethodError()");  
 } }
  
 void CIMOperationResponseEncoder::sendMethodError( void CIMOperationResponseEncoder::sendMethodError(
Line 142 
Line 141 
    CIMStatusCode code,    CIMStatusCode code,
    const String& description)    const String& description)
 { {
     PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"      PEG_METHOD_ENTER(TRC_DISPATCHER,
                    "sendMethodError()");                       "CIMOperationResponseEncoder::sendMethodError()");
  
     Array<Sint8> message;     Array<Sint8> message;
     message = XmlWriter::formatSimpleMethodErrorRspMessage(     message = XmlWriter::formatSimpleMethodErrorRspMessage(
Line 154 
Line 153 
  
     sendResponse(queueId, message);     sendResponse(queueId, message);
  
     PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"      PEG_METHOD_EXIT();
                   "sendMethodError()");  
 } }
  
 void CIMOperationResponseEncoder::sendMethodError( void CIMOperationResponseEncoder::sendMethodError(
    CIMResponseMessage* response,    CIMResponseMessage* response,
    const String& cimMethodName)    const String& cimMethodName)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "sendMethodError()");                      "CIMOperationResponseEncoder::sendMethodError()");
  
    Uint32 queueId = response->queueIds.top();    Uint32 queueId = response->queueIds.top();
    response->queueIds.pop();    response->queueIds.pop();
Line 174 
Line 172 
       cimMethodName,       cimMethodName,
       response->errorCode,       response->errorCode,
       response->errorDescription);       response->errorDescription);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "sendMethodError()");  
 } }
  
 void CIMOperationResponseEncoder::handleEnqueue(Message *message) void CIMOperationResponseEncoder::handleEnqueue(Message *message)
 { {
      PEG_METHOD_ENTER(TRC_DISPATCHER,
                       "CIMOperationResponseEncoder::handleEnqueue()");
   
    if (!message)    if (!message)
    {    {
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "handleEnqueue()");  
       return;       return;
    }    }
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"  
                   "handleEnqueue()");  
  
    switch (message->getType())    switch (message->getType())
    {    {
Line 251 
Line 248 
             (CIMEnumerateInstanceNamesResponseMessage*)message);             (CIMEnumerateInstanceNamesResponseMessage*)message);
          break;          break;
  
          // ATTN: implement this!  
       case CIM_EXEC_QUERY_RESPONSE_MESSAGE:       case CIM_EXEC_QUERY_RESPONSE_MESSAGE:
            encodeExecQueryResponse(
               (CIMExecQueryResponseMessage*)message);
          break;          break;
  
       case CIM_ASSOCIATORS_RESPONSE_MESSAGE:       case CIM_ASSOCIATORS_RESPONSE_MESSAGE:
Line 313 
Line 311 
  
    delete message;    delete message;
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "handleEnqueue()");  
  
    return;    return;
  
Line 337 
Line 334 
 void CIMOperationResponseEncoder::encodeCreateClassResponse( void CIMOperationResponseEncoder::encodeCreateClassResponse(
    CIMCreateClassResponseMessage* response)    CIMCreateClassResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeCreateClassResponse()");                      "CIMOperationResponseEncoder::encodeCreateClassResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "CreateClass");       sendIMethodError(response, "CreateClass");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeCreateClassResponse()");  
       return;       return;
    }    }
  
Line 355 
Line 351 
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeCreateClassResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeGetClassResponse( void CIMOperationResponseEncoder::encodeGetClassResponse(
    CIMGetClassResponseMessage* response)    CIMGetClassResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeGetClassResponse()");                      "CIMOperationResponseEncoder::encodeGetClassResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "GetClass");       sendIMethodError(response, "GetClass");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeGetClassResponse()");  
       return;       return;
    }    }
  
Line 381 
Line 375 
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeGetClassResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeModifyClassResponse( void CIMOperationResponseEncoder::encodeModifyClassResponse(
    CIMModifyClassResponseMessage* response)    CIMModifyClassResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeModifyClassResponse()");                      "CIMOperationResponseEncoder::encodeModifyClassResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "ModifyClass");       sendIMethodError(response, "ModifyClass");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeModifyClassResponse()");  
       return;       return;
    }    }
  
Line 406 
Line 398 
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeModifyClassResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeEnumerateClassNamesResponse( void CIMOperationResponseEncoder::encodeEnumerateClassNamesResponse(
    CIMEnumerateClassNamesResponseMessage* response)    CIMEnumerateClassNamesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeEnumerateClassNamesResponse()");                   "encodeEnumerateClassNamesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "EnumerateClassNames");       sendIMethodError(response, "EnumerateClassNames");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeEnumerateClassNamesResponse()");  
       return;       return;
    }    }
  
Line 434 
Line 424 
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
  
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeEnumerateClassNamesResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeEnumerateClassesResponse( void CIMOperationResponseEncoder::encodeEnumerateClassesResponse(
    CIMEnumerateClassesResponseMessage* response)    CIMEnumerateClassesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeEnumerateClassesResponse()");                   "encodeEnumerateClassesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "EnumerateClasses");       sendIMethodError(response, "EnumerateClasses");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeEnumerateClassesResponse()");  
       return;       return;
    }    }
  
Line 461 
Line 449 
       "EnumerateClasses", response->messageId, body);       "EnumerateClasses", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeEnumerateClassesResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeDeleteClassResponse( void CIMOperationResponseEncoder::encodeDeleteClassResponse(
    CIMDeleteClassResponseMessage* response)    CIMDeleteClassResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeDeleteClassResponse()");                      "CIMOperationResponseEncoder::encodeDeleteClassResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "DeleteClass");       sendIMethodError(response, "DeleteClass");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeDeleteClassResponse()");  
       return;       return;
    }    }
  
Line 485 
Line 471 
       "DeleteClass", response->messageId, body);       "DeleteClass", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeDeleteClassResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeCreateInstanceResponse( void CIMOperationResponseEncoder::encodeCreateInstanceResponse(
    CIMCreateInstanceResponseMessage* response)    CIMCreateInstanceResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeCreateInstanceResponse()");                   "encodeCreateInstanceResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "CreateInstance");       sendIMethodError(response, "CreateInstance");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeCreateInstanceResponse()");  
       return;       return;
    }    }
  
Line 511 
Line 495 
       "CreateInstance", response->messageId, body);       "CreateInstance", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeCreateInstanceResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeGetInstanceResponse( void CIMOperationResponseEncoder::encodeGetInstanceResponse(
    CIMGetInstanceResponseMessage* response)    CIMGetInstanceResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeGetInstanceResponse()");                   "encodeGetInstanceResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "GetInstance");       sendIMethodError(response, "GetInstance");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeGetInstanceResponse()");  
       return;       return;
    }    }
  
Line 536 
Line 518 
       "GetInstance", response->messageId, body);       "GetInstance", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeGetInstanceResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeModifyInstanceResponse( void CIMOperationResponseEncoder::encodeModifyInstanceResponse(
    CIMModifyInstanceResponseMessage* response)    CIMModifyInstanceResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeModifyInstanceResponse()");                   "encodeModifyInstanceResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "ModifyInstance");       sendIMethodError(response, "ModifyInstance");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeModifyInstanceResponse()");  
       return;       return;
    }    }
  
Line 560 
Line 540 
       "ModifyInstance", response->messageId, body);       "ModifyInstance", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeModifyInstanceResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeEnumerateInstancesResponse( void CIMOperationResponseEncoder::encodeEnumerateInstancesResponse(
    CIMEnumerateInstancesResponseMessage* response)    CIMEnumerateInstancesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeEnumerateInstancesResponse()");                   "encodeEnumerateInstancesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "EnumerateInstances");       sendIMethodError(response, "EnumerateInstances");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeEnumerateInstanceResponse()");  
       return;       return;
    }    }
  
Line 587 
Line 565 
       "EnumerateInstances", response->messageId, body);       "EnumerateInstances", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeEnumerateInstanceResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeEnumerateInstanceNamesResponse( void CIMOperationResponseEncoder::encodeEnumerateInstanceNamesResponse(
    CIMEnumerateInstanceNamesResponseMessage* response)    CIMEnumerateInstanceNamesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeEnumerateInstanceNamesResponse()");                   "encodeEnumerateInstanceNamesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "EnumerateInstanceNames");       sendIMethodError(response, "EnumerateInstanceNames");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeEnumerateInstanceNamesResponse()");  
       return;       return;
    }    }
  
Line 614 
Line 590 
       "EnumerateInstanceNames", response->messageId, body);       "EnumerateInstanceNames", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeEnumerateInstanceNamesResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeDeleteInstanceResponse( void CIMOperationResponseEncoder::encodeDeleteInstanceResponse(
    CIMDeleteInstanceResponseMessage* response)    CIMDeleteInstanceResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeDeleteInstanceResponse()");                   "encodeDeleteInstanceResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "DeleteInstance");       sendIMethodError(response, "DeleteInstance");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeDeleteInstanceResponse()");  
       return;       return;
    }    }
  
Line 638 
Line 612 
       "DeleteInstance", response->messageId, body);       "DeleteInstance", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeDeleteInstanceResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeGetPropertyResponse( void CIMOperationResponseEncoder::encodeGetPropertyResponse(
    CIMGetPropertyResponseMessage* response)    CIMGetPropertyResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeGetPropertyResponse()");                      "CIMOperationResponseEncoder::encodeGetPropertyResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "GetProperty");       sendIMethodError(response, "GetProperty");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeGetPropertyResponse()");  
       return;       return;
    }    }
  
Line 666 
Line 638 
       "GetProperty", response->messageId, body);       "GetProperty", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeGetPropertyResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeSetPropertyResponse( void CIMOperationResponseEncoder::encodeSetPropertyResponse(
    CIMSetPropertyResponseMessage* response)    CIMSetPropertyResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeSetPropertyResponse()");                      "CIMOperationResponseEncoder::encodeSetPropertyResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "SetProperty");       sendIMethodError(response, "SetProperty");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeSetPropertyResponse()");  
       return;       return;
    }    }
  
Line 690 
Line 660 
       "SetProperty", response->messageId, body);       "SetProperty", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeSetPropertyResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeSetQualifierResponse( void CIMOperationResponseEncoder::encodeSetQualifierResponse(
    CIMSetQualifierResponseMessage* response)    CIMSetQualifierResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeSetQualifierResponse()");                   "encodeSetQualifierResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "SetQualifier");       sendIMethodError(response, "SetQualifier");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeSetQualifierResponse()");  
       return;       return;
    }    }
  
Line 714 
Line 682 
       "SetQualifier", response->messageId, body);       "SetQualifier", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeSetQualifierResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeGetQualifierResponse( void CIMOperationResponseEncoder::encodeGetQualifierResponse(
    CIMGetQualifierResponseMessage* response)    CIMGetQualifierResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeGetQualifierResponse()");                   "encodeGetQualifierResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "GetQualifier");       sendIMethodError(response, "GetQualifier");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeGetQualifierResponse()");  
       return;       return;
    }    }
  
Line 739 
Line 705 
       "GetQualifier", response->messageId, body);       "GetQualifier", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeGetQualifierResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeEnumerateQualifiersResponse( void CIMOperationResponseEncoder::encodeEnumerateQualifiersResponse(
    CIMEnumerateQualifiersResponseMessage* response)    CIMEnumerateQualifiersResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeEnumerateQualifierResponse()");                   "encodeEnumerateQualifierResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "EnumerateQualifiers");       sendIMethodError(response, "EnumerateQualifiers");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeEnumerateQualifierResponse()");  
       return;       return;
    }    }
  
Line 766 
Line 730 
       "EnumerateQualifiers", response->messageId, body);       "EnumerateQualifiers", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeEnumerateQualifierResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeDeleteQualifierResponse( void CIMOperationResponseEncoder::encodeDeleteQualifierResponse(
    CIMDeleteQualifierResponseMessage* response)    CIMDeleteQualifierResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeDeleteQualifierResponse()");                   "encodeDeleteQualifierResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "DeleteQualifier");       sendIMethodError(response, "DeleteQualifier");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeDeleteQualifierResponse()");  
       return;       return;
    }    }
  
Line 790 
Line 752 
       "DeleteQualifier", response->messageId, body);       "DeleteQualifier", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeDeleteQualifierResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeReferenceNamesResponse( void CIMOperationResponseEncoder::encodeReferenceNamesResponse(
    CIMReferenceNamesResponseMessage* response)    CIMReferenceNamesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeReferenceNamesResponse()");                   "encodeReferenceNamesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "ReferenceNames");       sendIMethodError(response, "ReferenceNames");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeReferenceNamesResponse()");  
       return;       return;
    }    }
  
Line 821 
Line 781 
       "ReferenceNames", response->messageId, body);       "ReferenceNames", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeReferenceNamesResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeReferencesResponse( void CIMOperationResponseEncoder::encodeReferencesResponse(
    CIMReferencesResponseMessage* response)    CIMReferencesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeReferencesResponse()");                      "CIMOperationResponseEncoder::encodeReferencesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "References");       sendIMethodError(response, "References");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeReferencesResponse()");  
       return;       return;
    }    }
  
Line 848 
Line 806 
       "References", response->messageId, body);       "References", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeReferencesResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeAssociatorNamesResponse( void CIMOperationResponseEncoder::encodeAssociatorNamesResponse(
    CIMAssociatorNamesResponseMessage* response)    CIMAssociatorNamesResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeAssociatorNamesResponse()");                   "encodeAssociatorNamesResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "AssociatorNames");       sendIMethodError(response, "AssociatorNames");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeAssociatorNamesResponse()");  
       return;       return;
    }    }
  
Line 879 
Line 835 
       "AssociatorNames", response->messageId, body);       "AssociatorNames", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeAssociatorNamesResponse()");  
 } }
  
 void CIMOperationResponseEncoder::encodeAssociatorsResponse( void CIMOperationResponseEncoder::encodeAssociatorsResponse(
    CIMAssociatorsResponseMessage* response)    CIMAssociatorsResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER,
                   "encodeAssociatorsResponse()");                      "CIMOperationResponseEncoder::encodeAssociatorsResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendIMethodError(response, "Associators");       sendIMethodError(response, "Associators");
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeAssociatorsResponse()");  
       return;       return;
    }    }
  
Line 906 
Line 860 
       "Associators", response->messageId, body);       "Associators", response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeAssociatorsResponse()");  }
   
   void CIMOperationResponseEncoder::encodeExecQueryResponse(
      CIMExecQueryResponseMessage* response)
   {
      PEG_METHOD_ENTER(TRC_DISPATCHER,
                       "CIMOperationResponseEncoder::encodeExecQueryResponse()");
   
      if (response->errorCode != CIM_ERR_SUCCESS)
      {
         sendIMethodError(response, "ExecQuery");
         PEG_METHOD_EXIT();
         return;
      }
   
      Array<Sint8> body;
   
      for (Uint32 i = 0; i < response->cimInstances.size(); i++)
         response->cimInstances[i].toXml(body);
   
      Array<Sint8> message = XmlWriter::formatSimpleIMethodRspMessage(
         "ExecQuery", response->messageId, body);
   
      sendResponse(response->queueIds.top(), message);
      PEG_METHOD_EXIT();
 } }
  
 void CIMOperationResponseEncoder::encodeInvokeMethodResponse( void CIMOperationResponseEncoder::encodeInvokeMethodResponse(
    CIMInvokeMethodResponseMessage* response)    CIMInvokeMethodResponseMessage* response)
 { {
    PEG_FUNC_ENTER(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_ENTER(TRC_DISPATCHER, "CIMOperationResponseEncoder::"
                   "encodeInvokeMethodResponse()");                   "encodeInvokeMethodResponse()");
  
    if (response->errorCode != CIM_ERR_SUCCESS)    if (response->errorCode != CIM_ERR_SUCCESS)
    {    {
       sendMethodError(response, response->methodName);       sendMethodError(response, response->methodName);
       PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"        PEG_METHOD_EXIT();
                     "encodeInvokeMethodResponse()");  
       return;       return;
    }    }
  
Line 939 
Line 916 
       _CString(response->methodName), response->messageId, body);       _CString(response->methodName), response->messageId, body);
  
    sendResponse(response->queueIds.top(), message);    sendResponse(response->queueIds.top(), message);
    PEG_FUNC_EXIT(TRC_DISPATCHER,"CIMOperationResponseEncoder::"     PEG_METHOD_EXIT();
                  "encodeInvokeMethodResponse()");  
 } }
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

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