jaus++/2.0/src/jaus/core/events/event.cpp

Go to the documentation of this file.

#include "jaus/core/events/event.h"

using namespace JAUS;


Event::Event(const Address& dest, const Address& src) : Message(EVENT, dest, src)
{
    mEventID = mSequenceNumber = 0;
    mReportCode = 0;
}


Event::Event(const Event& message) : Message(EVENT)
{
    mEventID = mSequenceNumber = 0;
    mReportCode = 0;
    *this = message;
}


Event::~Event()
{
}


bool Event::SetReportMessage(const Message* reportMessage)
{
    if(reportMessage && reportMessage->WriteMessageBody(mReportMessage) >= 0)
    {
        mReportCode = reportMessage->GetMessageCode();
        return true;
    }
    return false;
}


bool Event::SetReportMessage(const UShort messageCode, const Packet& reportPayload)
{
    mReportCode = messageCode;
    mReportMessage = reportPayload;
    return true;
}


int Event::WriteMessageBody(Packet& packet) const
{
    int expected = (int)(BYTE_SIZE*2 + USHORT_SIZE + UINT_SIZE + mReportMessage.Size());
    int written = 0;

    written += packet.Write(mEventID);
    written += packet.Write(mSequenceNumber);
    written += packet.Write((UInt)(mReportMessage.Size() + USHORT_SIZE));
    written += packet.Write(mReportCode);
    if(mReportMessage.Size() > 0)
    {
        written += packet.Write(mReportMessage);
    }

    return written == expected ? written : -1;
}


int Event::ReadMessageBody(const Packet& packet)
{
    int expected = (int)(BYTE_SIZE*2 + USHORT_SIZE + UINT_SIZE);
    int read = 0;
    UInt payloadSize = 0;
    
    read += packet.Read(mEventID);
    read += packet.Read(mSequenceNumber);
    read += packet.Read(payloadSize);
    
    if(payloadSize >= USHORT_SIZE)
    {
        expected += payloadSize - USHORT_SIZE;
        read += packet.Read(mReportCode);
        read += packet.Read(mReportMessage, payloadSize - USHORT_SIZE);
    }

    return read == expected ? read : -1;
}


void Event::ClearMessageBody()
{
    mEventID = mSequenceNumber = 0;
    mReportCode = 0;
    mReportMessage.Clear();
}


bool Event::IsLargeDataSet(const unsigned int maxPayloadSize) const
{
    unsigned int size = BYTE_SIZE*2 + USHORT_SIZE + UINT_SIZE + mReportMessage.Size();
    return size > maxPayloadSize;
}


Event& Event::operator =(const Event& message)
{
    if(this != &message)
    {
        CopyHeaderData(&message);
        mEventID = message.mEventID;
        mReportCode = message.mReportCode;
        mSequenceNumber = message.mSequenceNumber;
        mReportMessage = message.mReportMessage;
    }
    return *this;
}

/*  End of File */