pegasus/src/Pegasus/Common/AnonymousPipe.cpp - diff

Return to AnonymousPipe.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/AnonymousPipe.cpp between version 1.14 and 1.15

version 1.14, 2008/08/28 17:24:36

version 1.15, 2008/11/12 17:22:32

Line 31

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

#if defined(PEGASUS_ENABLE_INTERNAL_BINARY_PROTOCOL)

# include <Pegasus/Common/CIMBinMsgSerializer.h>

# include <Pegasus/Common/CIMBinMsgDeserializer.h>

#else

#include <Pegasus/Common/CIMMessageSerializer.h>

#include <Pegasus/Common/CIMMessageDeserializer.h>

#endif

#include <Pegasus/Common/MessageLoader.h>

#include <Pegasus/Common/Exception.h>

#include <Pegasus/Common/Tracer.h>

Line 50

Line 56

# error "Unsupported platform"

#endif

PEGASUS_NAMESPACE_BEGIN

AnonymousPipe::Status AnonymousPipe::writeMessage (CIMMessage * message)

Line 59

Line 66

// Serialize the request

#if defined(PEGASUS_ENABLE_INTERNAL_BINARY_PROTOCOL)

CIMBuffer messageBuffer(4096);

#else

Buffer messageBuffer;

messageBuffer.reserveCapacity (4096);

#endif

try

{

#if defined(PEGASUS_ENABLE_INTERNAL_BINARY_PROTOCOL)

CIMBinMsgSerializer::serialize(messageBuffer, message);

#else

CIMMessageSerializer::serialize (messageBuffer, message);

#endif

}

catch (Exception & e)

{

Line 122

Line 138

// Read the message data

#if defined(PEGASUS_ENABLE_INTERNAL_BINARY_PROTOCOL)

// CIMBuffer uses realloc() and free() so the buffer must be allocated

// with malloc().

AutoPtr<char, FreeCharPtr> messageBuffer((char*)malloc(messageLength + 1));

#else

AutoArrayPtr <char> messageBuffer (new char [messageLength + 1]);

#endif

// We know a message is coming

Line 144

Line 166

// De-serialize the message

#if defined(PEGASUS_ENABLE_INTERNAL_BINARY_PROTOCOL)

// CIMBuffer frees messageBuffer upon destruction.

CIMBuffer buf(messageBuffer.release(), messageLength);

message = CIMBinMsgDeserializer::deserialize(buf, messageLength);

if (!message)

{

throw CIMException(CIM_ERR_FAILED, "deserialize() failed");

}

#else

message = CIMMessageDeserializer::deserialize (messageBuffer.get ());

#endif

}

catch (Exception & e)

{

Legend:

Removed from v.1.14
changed lines
	Added in v.1.15

No CVS admin address has been configured