---

message.cc

Go to the documentation of this file.

/*
  svas_server -- virtual World Server of Svas
  Copyright (c) 2001, 2002 David Moreno Montero
 
 
  This program is free software; you can redistribute it and/or modify
  it under the terms of the GNU General Public License as published by
  the Free Software Foundation; either version 2 of the License, or
  (at your option) any later version.
 
  This program is distributed in the hope that it will be useful, but
  WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  General Public License for more details.
 
  You should have received a copy of the GNU General Public License
  along with this program; if not, write to the Free Software
  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
  02111-1307, USA.  

*/

#include <socket.h>
#include "message.h"
#include "log.h"
#include <string.h>

/**
 * Create a Message. Be carfull as the msg pointer is memcopied, it's
 * slower but safer.
 */
Message::Message(unsigned long int _organismId,
         bool _petition, MessageType _type, unsigned long int _size,
         const char *_msg){
  organismId=_organismId;
  petition=_petition; type=_type;
  size=_size; 
  if (size!=0){
    msg=new char[size];
    if (NULL==msg)
      throw ost::Exception("Can't Allocate Memory for a Message");      
    memcpy(msg,_msg,size);
  }
  else
    msg=NULL;
}

/**
 * Create a message from a stream, the data is copied, and deleted
 * when the message is deleted, so make your own copy!
 */
Message::Message(ost::TCPStream *stream){
  unsigned char c;
  /* Now the organismId */
  organismId=0;
  stream->read(&c,1);  organismId|=c<<24;  stream->read(&c,1);  organismId|=c<<16;
  stream->read(&c,1);  organismId|=c<<8;   stream->read(&c,1);  organismId|=c;
  /* Now the message type and if it's a petition or a response */
  unsigned short int t;
  t=0;
  stream->read(&c,1);  t|=c<<8;    stream->read(&c,1);  t|=c;
  petition=(t&0x08000);
  t&=0x07FFF;
  type=MessageType(t);
  /* Size of the message */
  size=0;
  stream->read(&c,1);  size|=c<<24;    stream->read(&c,1);  size|=c<<16;
  stream->read(&c,1);  size|=c<<8;     //stream->read(&c,1);  size|=c;

  int C=stream->get();
  if (C<0)
    throw ost::Exception("Can't read data!");
  c=C;
  size|=c;


  /* The message itself */
  if (size==0)
    msg=NULL;
  else{
    msg=new char[size];
    if (NULL==msg)      throw ost::Exception("Can't Allocate Memory for a Message");
    stream->read(msg, size);
  }
  //log <<"got "<<type<<endl;
}

/**
 * Destroys the message. Just delete the msg pointer if it points to
 * any data
 */
Message::~Message(){
  if (msg!=NULL) delete msg;
};

#include <stdio.h>

/**
 * Convert the message to a printable string
 */
string Message::toString(){
  char a[256];

  sprintf(a,"organismId: %ld petition: %d type: %d size: %ld", organismId, petition, type, size);

  return string(a);
}

/**
 * Sends the message thought the stream
 */
const void Message::sendTo(ost::TCPStream *stream){
  unsigned char c;
  //log <<"send "<<type<<endl;
  /* First the organismId */
  c=(organismId>>24)&0x0FF; stream->write(&c,1);
  c=(organismId>>16)&0x0FF; stream->write(&c,1);
  c=(organismId>>8)&0x0FF; stream->write(&c,1);
  c=(organismId)&0x0FF; stream->write(&c,1);
  /* Now the message type and if it's a petition or a response */
  c=((petition==true)<<7)|((type>>8)&0x07F);
  stream->write(&c,1);
  c=(type)&0x0FF; stream->write(&c,1);
  /* Size of the message */
  c=(size>>24)&0x0FF; stream->write(&c,1);
  c=(size>>16)&0x0FF; stream->write(&c,1);
  c=(size>>8)&0x0FF; stream->write(&c,1);
  c=(size)&0x0FF; stream->write(&c,1);
  /* The message itself */
  if (size!=0)
    stream->write(msg, size);
}

---