Tools/MessageQueue/OutMessage.cpp

Go to the documentation of this file.

/**
* @file OutMessage.cpp
*
* Implementation of class OutMessage, OutBinaryMessage, OutTextMessage,
* OutConfigMessage and OutMessageQueue.
*
* @author Martin Lötzsch
*/

#include "OutMessage.h"
#include "Tools/Process.h"

OutMessageQueue::OutMessageQueue()
: queue(0) 
{
}

void OutMessageQueue::open(MessageQueueBase* q)
{
  if (queue == 0) queue = q;
}

void OutMessageQueue::writeToStream(const void* p,int size)
{
  if (queue != 0) queue->write(p,size);
}

OutBinaryMessage::OutBinaryMessage(MessageQueueBase* q)
{
  open(q);
}

OutTextMessage::OutTextMessage(MessageQueueBase* q)
{
  open(q);
}

OutTextRawMessage::OutTextRawMessage(MessageQueueBase* q)
{
  open(q);
}

OutMessage::OutMessage(MessageQueueBase& queue)
: queue(queue), bin(&queue), text(&queue), textRaw(&queue),
teamColorForNewMessages(Player::undefinedTeamColor),
playerNumberForNewMessages(Player::undefinedPlayerNumber)
{
}

void OutMessage::finishMessage(MessageID id)
{
#ifdef NEWDEBUGGING
  queue.finishMessage(id,Process::getFrameNumber(),
    teamColorForNewMessages,playerNumberForNewMessages);
#else
  queue.finishMessage(id,SystemCall::getCurrentSystemTime(),
    teamColorForNewMessages,playerNumberForNewMessages);
#endif

}

void OutMessage::finishMessage(MessageID id, unsigned long timeStamp,
                               Player::teamColor teamColor,
                               Player::playerNumber playerNumber,
                               bool messageWasSentFromAPhysicalRobot)
{
  queue.finishMessage(id, timeStamp,teamColor,
    playerNumber,messageWasSentFromAPhysicalRobot);
}

---