Servidor.cpp

Ir a la documentación de este archivo.

/*
   MUnDoCAAD MUD Engine
   Copyright (C) 2002-2005 José Manuel Ferrer Ortiz

   *****************************************************************************
   *                                                                           *
   *  This program is free software; you can redistribute it and/or modify it  *
   *  under the terms of the GNU General Public License version 2, as          *
   *  published by the Free Software Foundation.                               *
   *                                                                           *
   *  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 version 2 for more details.                       *
   *                                                                           *
   *  You should have received a copy of the GNU General Public License        *
   *  version 2 along with this program; if not, write to the Free Software    *
   *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA  *
   *                                                                           *
   *****************************************************************************
*/


#include <QTextStream>

#include "config.hpp"
#include "Log.hpp"
#include "Mensajero.hpp"
#include "Servidor.hpp"


extern Mensajero *miMensaj;


// Clase Conexion

Conexion::Conexion (int desc)
{
  setSocketDescriptor (desc);

  descriptor = desc;
  direccion  = new QString (peerAddress().toString());

  connect (this, SIGNAL (disconnected()), SLOT (ConexionCerrada()));
  connect (this, SIGNAL (readyRead()),    SLOT (Lee()));
}

Conexion::~Conexion ()
{
  qDebug ("Destructor de Conexion");

  delete direccion;
}

void Conexion::ConexionCerrada ()
{
  emit (EliminarConexion (this));
}

void Conexion::Lee ()
{
  QTextStream stream (this);

  if (canReadLine())
  {
    QString linea = stream.readLine();
    miMensaj->NuevaLinea (socketDescriptor(), linea);
  }
}

void Conexion::Escribe (const QString &texto)
{
  QTextStream stream (this);

  stream << texto;
}


// Clase Servidor

Servidor::Servidor ()
{
  setMaxPendingConnections (NUM_MAX_CONXS_PENDS);

  if (!listen (QHostAddress::Any, NUM_PUERTO))
    qFatal ("El servidor no se ha podido asociar al puerto %d.", NUM_PUERTO);

  QString puerto;
  puerto.setNum (NUM_PUERTO);
  Log (8, "Servidor a la espera de nuevas conexiones en el puerto " + puerto +
       ".\n");
}

Servidor::~Servidor ()
{
  qDebug ("Destructor de Servidor");

  // Eliminamos todas las conexiones
  foreach (Conexion *con, conexiones)
    delete (con);
}

void Servidor::CierraConexion (const int descriptor)
{
  if (!conexiones.contains (descriptor))
    qFatal ("Intento de cerrar la conexión de un descriptor no presente.");

  Conexion *con = conexiones.value (descriptor);

  EliminarConexion (con);
}

void Servidor::EliminarConexion (Conexion *con)
{
  Log (6, "Cerrando conexión");
  Log (5, " procedente de la dirección IP: " + *con->direccion);
  Log (6, "\n");
  miMensaj->EliminaCanal (con->descriptor);
  conexiones.remove (con->descriptor);
  delete con;

  QString num_conexiones;
  num_conexiones.setNum (conexiones.count());
  Log (4, "Ahora mismo hay " + num_conexiones + " conexiones abiertas.\n");
}

void Servidor::Escribe (const int descriptor, const QString &texto)
{
  if (!conexiones.contains (descriptor))
    qFatal ("Intento de escritura hacia un descriptor no presente.");

  Conexion *destino = conexiones.value (descriptor);

  destino->Escribe (texto);
}

void Servidor::incomingConnection (const int descriptor)
{
  Conexion *entrante = new Conexion (descriptor);

  // Añadimos la nueva conexión a la lista de conexiones entrantes
  conexiones.insert (descriptor, entrante);

  connect (entrante, SIGNAL (EliminarConexion (Conexion *)), this,
           SLOT (EliminarConexion (Conexion *)));

  miMensaj->NuevoCanal (descriptor);

  Log (6, "Nueva conexión entrante aceptada.\n");
  Log (5, "La conexión proviene de la dirección IP: " + *entrante->direccion +
       "\n");

  QString num_conexiones;
  num_conexiones.setNum (conexiones.count());
  Log (4, "Ahora mismo hay " + num_conexiones);
  if (conexiones.count() == 1)
    Log (4, " conexión abierta.\n");
  else
    Log (4, " conexiones abiertas.\n");
}

---