CMRPTMessage.cpp

Go to the documentation of this file.

/* +------------------------------------------------------------------------+
   |                     Mobile Robot Programming Toolkit (MRPT)            |
   |                          http://www.mrpt.org/                          |
   |                                                                        |
   | Copyright (c) 2005-2017, Individual contributors, see AUTHORS file     |
   | See: http://www.mrpt.org/Authors - All rights reserved.                |
   | Released under BSD License. See details in http://www.mrpt.org/License |
   +------------------------------------------------------------------------+ */

#include "base-precomp.h"  // Precompiled headers

#include <mrpt/utils/CSerializable.h>
#include <mrpt/utils/CMessage.h>
#include <mrpt/system/os.h>
#include <mrpt/utils/CMemoryStream.h>
#include <cstring>

using namespace mrpt::utils;

/*---------------------------------------------------------------
                                        serializeObject
 ---------------------------------------------------------------*/
void CMessage::serializeObject(const CSerializable* obj)
{
        MRPT_START
        CMemoryStream auxStream;

        // Dump the object in the memory stream:
        auxStream.WriteObject(obj);

        // Copy data to message:
        content.resize(auxStream.getTotalBytesCount());
        memcpy(
                &content[0],  // Dest
                auxStream.getRawBufferData(),  // Src
                content.size());

        MRPT_END
}

/*---------------------------------------------------------------
                                deserializeIntoExistingObject
 ---------------------------------------------------------------*/
void CMessage::deserializeIntoExistingObject(CSerializable* obj)
{
        MRPT_START
        CMemoryStream auxStream;

        // Copy data into the stream:
        auxStream.WriteBuffer(&content[0], content.size());
        auxStream.Seek(0);

        // Try to parse data into existing object:
        auxStream.ReadObject(obj);

        MRPT_END
}

/*---------------------------------------------------------------
                                deserializeIntoNewObject
 ---------------------------------------------------------------*/
void CMessage::deserializeIntoNewObject(CSerializable::Ptr& obj)
{
        MRPT_START
        CMemoryStream auxStream;

        // Copy data into the stream:
        if (!content.empty())
        {
                auxStream.WriteBuffer(&content[0], content.size());
                auxStream.Seek(0);

                // Try to parse data into a new object:
                obj = auxStream.ReadObject();
        }
        else
                obj.reset();

        MRPT_END
}

/*---------------------------------------------------------------
                                setContentFromString
 ---------------------------------------------------------------*/
void CMessage::setContentFromString(const std::string& str)
{
        content.resize(str.size());
        if (content.size() > 0) memcpy(&content[0], str.c_str(), str.size());
}

/*---------------------------------------------------------------
                                getContentAsString
 ---------------------------------------------------------------*/
void CMessage::getContentAsString(std::string& str)
{
        str.resize(content.size());
        if (content.size() > 0) memcpy(&str[0], &content[0], str.size());
}

/*---------------------------------------------------------------
                                setContentFromPointer
 ---------------------------------------------------------------*/
void CMessage::setContentFromPointer(void* ptr)
{
        content.resize(sizeof(void*));
        void** ptrPtr = reinterpret_cast<void**>(&content[0]);
        *ptrPtr = ptr;
}

/*---------------------------------------------------------------
                                getContentAsPointer
 ---------------------------------------------------------------*/
void* CMessage::getContentAsPointer() const
{
        MRPT_START
        ASSERT_(content.size() == sizeof(void*));

        return *reinterpret_cast<void**>(const_cast<unsigned char*>(&content[0]));

        MRPT_END
}