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

Diff for /pegasus/src/Pegasus/ExportClient/CIMExportRequestEncoder.cpp between version 1.35 and 1.36

version 1.35, 2007/03/16 17:16:53 version 1.36, 2007/03/27 20:03:17
Line 48 
Line 48 
    MessageQueue* outputQueue,    MessageQueue* outputQueue,
    const String& hostName,    const String& hostName,
    ClientAuthenticator* authenticator)    ClientAuthenticator* authenticator)
    :      : MessageQueue(PEGASUS_QUEUENAME_EXPORTREQENCODER),
    MessageQueue(PEGASUS_QUEUENAME_EXPORTREQENCODER),  
    _outputQueue(outputQueue),    _outputQueue(outputQueue),
    _hostName(hostName.getCString()),    _hostName(hostName.getCString()),
    _authenticator(authenticator)    _authenticator(authenticator)
 { {
     PEG_METHOD_ENTER (TRC_EXPORT_CLIENT, "CIMExportRequestEncoder::CIMExportRequestEncoder()");      PEG_METHOD_ENTER(TRC_EXPORT_CLIENT,
           "CIMExportRequestEncoder::CIMExportRequestEncoder()");
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
 } }
  
 CIMExportRequestEncoder::~CIMExportRequestEncoder() CIMExportRequestEncoder::~CIMExportRequestEncoder()
 { {
     PEG_METHOD_ENTER (TRC_EXPORT_CLIENT, "CIMExportRequestEncoder::~CIMExportRequestEncoder()");      PEG_METHOD_ENTER(TRC_EXPORT_CLIENT,
           "CIMExportRequestEncoder::~CIMExportRequestEncoder()");
      _authenticator.release();      _authenticator.release();
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
 } }
  
 void CIMExportRequestEncoder::handleEnqueue() void CIMExportRequestEncoder::handleEnqueue()
 { {
    PEG_METHOD_ENTER (TRC_EXPORT_CLIENT, "CIMExportRequestEncoder::handleEnqueue()");      PEG_METHOD_ENTER(TRC_EXPORT_CLIENT,
           "CIMExportRequestEncoder::handleEnqueue()");
    Message* message = dequeue();    Message* message = dequeue();
  
    PEGASUS_ASSERT(message != 0);    PEGASUS_ASSERT(message != 0);
Line 77 
Line 79 
    switch (message->getType())    switch (message->getType())
    {    {
       case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:       case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:
          _encodeExportIndicationRequest((CIMExportIndicationRequestMessage*)message);              _encodeExportIndicationRequest(
                   (CIMExportIndicationRequestMessage*)message);
          break;          break;
         default:         default:
             PEGASUS_ASSERT(0);             PEGASUS_ASSERT(0);
Line 97 
Line 100 
 void CIMExportRequestEncoder::_encodeExportIndicationRequest( void CIMExportRequestEncoder::_encodeExportIndicationRequest(
    CIMExportIndicationRequestMessage* message)    CIMExportIndicationRequestMessage* message)
 { {
    PEG_METHOD_ENTER (TRC_EXPORT_CLIENT, "CIMExportRequestEncoder::_encodeExportIndicationRequest()");      PEG_METHOD_ENTER(TRC_EXPORT_CLIENT,
           "CIMExportRequestEncoder::_encodeExportIndicationRequest()");
    Buffer params;    Buffer params;
  
    XmlWriter::appendInstanceEParameter(    XmlWriter::appendInstanceEParameter(
       params, "NewIndication", message->indicationInstance);       params, "NewIndication", message->indicationInstance);
  
 // l10n  
    // Note:  Accept-Language will not be set in the request    // Note:  Accept-Language will not be set in the request
    // We will accept the default language of the export server.    // We will accept the default language of the export server.
    Buffer buffer = XmlWriter::formatSimpleEMethodReqMessage(    Buffer buffer = XmlWriter::formatSimpleEMethodReqMessage(
Line 114 
Line 117 
       message->getHttpMethod(),       message->getHttpMethod(),
       _authenticator->buildRequestAuthHeader(),       _authenticator->buildRequestAuthHeader(),
       AcceptLanguageList(),       AcceptLanguageList(),
          ((ContentLanguageListContainer)message->operationContext.get(ContentLanguageListContainer::NAME)).getLanguages(),          ((ContentLanguageListContainer)message->operationContext.get(
               ContentLanguageListContainer::NAME)).getLanguages(),
       params);       params);
  
    HTTPMessage* httpMessage = new HTTPMessage(buffer);    HTTPMessage* httpMessage = new HTTPMessage(buffer);
    PEG_TRACE_CSTRING(      PEG_TRACE_CSTRING(TRC_XML_IO, Tracer::LEVEL2,
        TRC_XML_IO,  
        Tracer::LEVEL2,  
        httpMessage->message.getData());        httpMessage->message.getData());
  
    _outputQueue->enqueue(httpMessage);    _outputQueue->enqueue(httpMessage);

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