source: code/branches/FICN_test/src/network/Server.cc @ 767

//
// C++ Implementation: Server
//
// Description:
//
//
// Author:  Oliver Scheuss, (C) 2007
//
// Copyright: See COPYING file that comes with this distribution
//
//


#include "Server.h"

namespace network{

  /**
   * Constructor for default values (bindaddress is set to ENET_HOST_ANY
   *
   */
  Server::Server(){
    packet_gen = PacketGenerator();
    clients = new ClientInformation(true);
    connection = new ConnectionManager(clients);
    gamestates = new GameStateManager(clients);
  }

  /**
   * Constructor
   * @param port Port to listen on
   * @param bindAddress Address to listen on
   */
  Server::Server(int port, std::string bindAddress){
    packet_gen = PacketGenerator();
    clients = new ClientInformation();
    connection = new ConnectionManager(port, bindAddress, clients);
    gamestates = new GameStateManager(clients);
  }

  /**
   * Constructor
   * @param port Port to listen on
   * @param bindAddress Address to listen on
   */
  Server::Server(int port, const char *bindAddress){
    packet_gen = PacketGenerator();
    clients = new ClientInformation();
    connection = new ConnectionManager(port, bindAddress, clients);
    gamestates = new GameStateManager(clients);
  }

  /**
   * This function opens the server by creating the listener thread
   */
  void Server::open(){
    connection->createListener();
    return;
  }

  /**
   * This function closes the server
   */
  void Server::close(){
    connection->quitListener();
    return;
  }

  /**
   * This function sends out a message to all clients
   * @param msg message
   * @return true/false
   */
  bool Server::sendMSG(std::string msg){
    ENetPacket *packet = packet_gen.chatMessage(msg.c_str());
    //std::cout <<"adding packets" << std::endl;
    connection->addPacketAll(packet);
    //std::cout <<"added packets" << std::endl;
    return connection->sendPackets();
  }
  /**
   * This function sends out a message to all clients
   * @param msg message
   * @return true/false
   */
  bool Server::sendMSG(const char *msg){
    ENetPacket *packet = packet_gen.chatMessage(msg);
    std::cout <<"adding Packets" << std::endl;
    connection->addPacketAll(packet);
    //std::cout <<"added packets" << std::endl;
    if (connection->sendPackets()){
        std::cout << "Sucessfully" << std::endl;
        return true;
    }
    return false;
  }

  /**
   * Run this function once every tick
   * calls processQueue and updateGamestate
   * @param time time since last tick
   */
  void Server::tick(float time){
    processQueue();
    updateGamestate();
    return;
  }

  /**
   * processes all the packets waiting in the queue
   */
  void Server::processQueue(){
    ENetPacket *packet;
    int clientID=-1;
    while(!connection->queueEmpty()){
      //std::cout << "Client " << clientID << " sent: " << std::endl;
      packet = connection->getPacket(clientID);
      elaborate(packet, clientID);
    }
  }

  /**
   * takes a new snapshot of the gamestate and sends it to the clients
   */
  void Server::updateGamestate(){
    gamestates->update();
    //std::cout << "updated gamestate, sending it" << std::endl;
    sendGameState();
    //std::cout << "sent gamestate" << std::endl;
  }

  /**
   * sends the gamestate
   */
  bool Server::sendGameState(){
    std::cout << "starting gamestate" << std::endl;
    ClientInformation *temp = clients;
    bool added=false;
    while(temp!=NULL){
      if(temp->head){
        temp=temp->next();
        continue;
      }
      if( !(temp->getSynched()) ){
        std::cout << "not sending gamestate" << std::endl;
        temp=temp->next();
        continue;
      }
      std::cout << "doing gamestate" << std::endl;
      int gid = temp->getGamestateID();
      int cid = temp->getID();
      std::cout << "server, got acked ID: " << gid << std::endl;
      GameStateCompressed *gs = &(gamestates->popGameState(cid)); // FIXME: taking address of temporary, check if correct
      //std::cout << "adding gamestate" << std::endl;
      connection->addPacket(packet_gen.gstate(gs), cid);
      //std::cout << "added gamestate" << std::endl;
      added=true;
      temp=temp->next();
    }
    if(added)
      return connection->sendPackets();
    else return false;
    //return true;
  }

  void Server::processAck( ack *data, int clientID){
    clients->findClient(clientID)->setGamestateID(data->a);
  }

}