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

Go to the documentation of this file.

#include "jaus/core/events/rejecteventrequest.h"
#include <cstring>

using namespace JAUS;


RejectEventRequest::RejectEventRequest(const Address& dest,
                                       const Address& src) : Message(REJECT_EVENT_REQUEST, dest, src)
{
    mRequestID = mPresenceVector = 0;
    mResponseCode = MessageNotSupported;
}


RejectEventRequest::RejectEventRequest(const RejectEventRequest& message) : Message(REJECT_EVENT_REQUEST)
{
    mRequestID = mPresenceVector = 0;
    mResponseCode = MessageNotSupported;
    *this = message;
}


RejectEventRequest::~RejectEventRequest()
{

}


bool RejectEventRequest::SetErrorMessage(const std::string& errorMessage)
{
    if(errorMessage.size() <= 80)
    {
        mErrorMessage = errorMessage;
        mPresenceVector |= PresenceVector::ErrorMessage;
        return true;
    }
    mPresenceVector = 0;
    return false;
}


int RejectEventRequest::WriteMessageBody(Packet& packet) const
{
    int total = 0;
    int expected = BYTE_SIZE*3;
    total += packet.Write(mPresenceVector);
    total += packet.Write(mRequestID);
    total += packet.WriteByte((Byte)mResponseCode);
    if( (mPresenceVector & PresenceVector::ErrorMessage) > 0)
    {
        expected += 80;
        char buffer[81];
        memset(buffer, 0, 81);
        memcpy(buffer, mErrorMessage.c_str(), mErrorMessage.size());
        total += packet.Write((const unsigned char *)buffer, 80);
    }
    return total == expected ? total : -1;
}


int RejectEventRequest::ReadMessageBody(const Packet& packet) 
{
    int total = 0;
    int expected = BYTE_SIZE*3;
    total += packet.Read(mPresenceVector);
    total += packet.Read(mRequestID);
    total += packet.Read((Byte &)mResponseCode);
    if( (mPresenceVector & PresenceVector::ErrorMessage) > 0)
    {
        expected += 80;
        char buffer[81];
        memset(buffer, 0, 81);
        total += packet.Read((unsigned char *)buffer, 80);
        mErrorMessage = buffer;        
    }
    return total == expected ? total : -1;
}


void RejectEventRequest::ClearMessageBody()
{
    mRequestID = mPresenceVector = 0;
    mResponseCode = MessageNotSupported;
    mErrorMessage.clear();
}


RejectEventRequest& RejectEventRequest::operator =(const RejectEventRequest& message)
{
    if(this != &message)
    {
        CopyHeaderData(&message);
        mRequestID = message.mRequestID;
        mPresenceVector = message.mPresenceVector;
        mErrorMessage = message.mErrorMessage;
        mResponseCode = message.mResponseCode;
    }
    return *this;
}


/*  End of File */