Tools/MessageQueue/InMessage.cpp

Go to the documentation of this file.

/**
* @file InMessage.cpp
*
* Implementation of class InMessageQueue, InBinaryMessage, InTextMessage,
* InConfigMessage and InMessage.
*
* @author Martin Lötzsch
*/

#include "InMessage.h"

InMessageQueue::InMessageQueue() 
: queue(0) 
{
}

bool InMessageQueue::exists() const 
{ 
  return true; 
}

bool InMessageQueue::getEof() const 
{ 
  return (queue != 0 ? queue->eof() : false); 
}

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

void InMessageQueue::readFromStream(void* p,int size) 
{ 
  if (queue != 0) queue->read(p,size); 
}

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

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

void InTextMessage::readAll(char* buf)
{
  while(!getEof())
  {
    nextChar(*this);
    if (theChar != ' ') 
    {
      if(theChar == '\\') nextChar(*this);
      *buf++ = theChar;
    }    
  }
  *buf = 0;
}

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

InMessage::InMessage(MessageQueueBase& queue) 
: queue(queue), bin(&queue), text(&queue), config(&queue) 
{
}

unsigned long InMessage::getTimeStamp() const
{ 
  return queue.getTimeStamp(); 
}

MessageID InMessage::getMessageID() const
{ 
  return queue.getMessageID(); 
}

int InMessage::getMessageSize() const
{ 
  return queue.getMessageSize(); 
}
  
Player::teamColor InMessage::getTeamColor() const
{
  return queue.getTeamColor();
}

Player::playerNumber InMessage::getPlayerNumber() const
{
  return queue.getPlayerNumber();
}

int InMessage::getRobotNumber() const
{
  if (queue.getPlayerNumber()==Player::undefinedPlayerNumber) return 8;
  if (queue.getTeamColor()==Player::undefinedTeamColor) return 8;
  return (4*queue.getTeamColor()+queue.getPlayerNumber());
}
bool InMessage::getMessageWasSentFromAPhysicalRobot() const
{
  return queue.getMessageWasSentFromAPhysicalRobot();
}

void InMessage::resetReadPosition() 
{ 
  queue.resetReadPosition(); 
  config.reset();
  text.reset();
}

const char* InMessage::getData() const
{
  return queue.getData();
}

---