servemsg.cc

Go to the documentation of this file.

/*
Copyright (C) 2000-2002 The Exult Team

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.
*/

#ifdef HAVE_CONFIG_H
#  include <config.h>
#endif

#include <unistd.h>
#include <iostream>     /* For debugging msgs. */
#include "servemsg.h"
#ifndef ALPHA_LINUX_CXX
  #include <cstring>
#endif

#ifdef WIN32
#include "servewin32.h"
#endif

using std::cout;
using std::cerr;
using std::endl;

namespace Exult_server
{

/*
 *  Send data.
 *
 *  Output: -1 if error.
 */

int Send_data
  (
  int socket,
  Msg_type id,
  unsigned char *data,
  int datalen
  )
  {
#ifdef USE_EXULTSTUDIO
  unsigned char buf[maxlength + hdrlength];
  buf[0] = magic&0xff;    // Store magic (low-byte first).
  buf[1] = (magic>>8)&0xff;
  buf[2] = datalen&0xff;    // Data length.
  buf[3] = (datalen>>8)&0xff;
  buf[4] = id;
  if (datalen > 0)
    std::memcpy(&buf[5], data, datalen);  // The data itself.
  int len = datalen + hdrlength;

  return (write(socket, buf, len) == len ? 0 : -1);
#else  /* USE_EXULTSTUDIO */
  return -1;
#endif  /* USE_EXULTSTUDIO */
  }

/*
 *  Read message from client.
 *
 *  Output: Length of data, else -1.
 */

int Receive_data
  (
  int& socket,      // Closed, set to -1 if disconnected.
  Msg_type& id,     // ID returned.
  unsigned char *data,
  int datalen
  )
  {
#ifdef USE_EXULTSTUDIO
  unsigned char buf[hdrlength];
  int len = read(socket, buf, 2); // Get magic.
  if (!len)     // Closed?
    {
    close(socket);
    socket = -1;
    return -1;
    }
  if (len == -1)      // Nothing available?
    return -1;
  int magic = buf[0] + (buf[1]<<8);
  if (magic != Exult_server::magic)
    {
    cout << "Bad magic read" << endl;
    return -1;
    }
  if (read(socket, buf, 3) != 3)
    {
    cout << "Couldn't read length+type" << endl;
    return -1;
    }
  int dlen = buf[0] | (buf[1]<<8);
          // Message type.
  id = (Exult_server::Msg_type) buf[2];
  if (dlen > Exult_server::maxlength || dlen > datalen)
    {
    cout << "Length " << datalen << " exceeds max" << endl;
    //+++++++++Eat the chars.
    return -1;
    }
  datalen = read(socket, data, dlen); // Read data.

  if (datalen < dlen)
    {
    cout << "Failed to read all " << dlen << " bytes" << endl;
    return -1;
    }
  return datalen;
#else  /* USE_EXULTSTUDIO */
  return -1;
#endif  /* USE_EXULTSTUDIO */
  }



bool wait_for_response(int socket, int ms)
{
#if defined(WIN32) && defined(USE_EXULTSTUDIO)
  int ticks = GetTickCount();
  while(GetTickCount() < ticks+ms) {
    if (peek_pipe() > 0) return true;
    SleepEx(1, TRUE);
  }
  if (peek_pipe() > 0) return true;
  return false;
#endif
  return true;
}

}

---