---

commcenter.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 <thread.h>
#include <math.h>
#include <stdlib.h>
#include "commcenter.h"
#include "baseClient.h"
#include "client.h"
#include "controlClient.h"
#include "graphicClient.h"
#include "log.h"
#include "world.h"
#include <unistd.h>
#include <persist.h>
#include <sched.h>

/**
 * Creates the communication center. It opens several ports to accept
 * incomming conections; these ports include: 
 *
 * * client port (2002)
 * * graphic client port (3003)
 * * control client port (3004)
 * * server port (8888)
 */
CommCenter::CommCenter(){
  try{
    clientPort=new ost::TCPSocket(ost::InetAddress(), 2002);
    graphicClientPort=new ost::TCPSocket(ost::InetAddress(), 3003);
    controlClientPort=new ost::TCPSocket(ost::InetAddress(), 3004);
    
    serverPort=new ost::TCPSocket(ost::InetAddress(), 8888);
  }
  catch(...){
    log <<"Can't bind one of the TCPSockets, desired ports are 2002, 3003, 3004 and 8888"<<endl;
    throw ost::Exception("Can't Bind socket");
  }

  world=new World(this);
  if (NULL==world){
    log <<"Can't create a world!"<<endl;
    throw ost::Exception("No world, no fun");
  }
  
}

/**
 * Destroys the comm center; the open ports are closed.
 */
CommCenter::~CommCenter(){
  delete clientPort;
  delete graphicClientPort;
  delete controlClientPort;

  delete serverPort;

  log<<"Deleting clients"<<endl;

  /// A bug here, in deleting clients, it blocks. FIXME
  unsigned int i;
  for (i=0;i<clients.size();i++)
    delete clients[i];
  
  clients.clear();

  log<<"Goodbye!"<<endl;
}

/**
 * Loops thruogh the open ports to check for new conections; if one
 * appears the correct handler is called
 */
void CommCenter::loop(){
  log <<"Entering in the main thread loop"<<endl;

  while (world->getQuit()==false){
    checkForConections();

    waitForClients();

    makeMovements();
    if (clients.size()!=0)
      andTimePasses(); // Only if there is anyone to look at it...
  }

  log <<"Quitting the main thread loop"<<endl;
}

/** 
 * Creates a new client, and starts it.
 */
void CommCenter::newClient(){
  Client *cl;
  clients.push_back(cl=new Client(*clientPort,world));
  cl->Start();
  clientMap[cl->getName()].push_back(cl); // Add it to the dictionary of AgentClients

  //  clients[clients.size()-1]->dontWalk();
}

/** 
 * Creates a new graphic client, starts it, and stop it's execution (I
 * can ensure that it's safe to let it run any time before dontWalk is
 * issued
 */
void CommCenter::newGraphicClient(){
  clients.push_back(new GraphicClient(*graphicClientPort,world));
  clients[clients.size()-1]->Start();
  //  clients[clients.size()-1]->dontWalk();
}

/** 
 * Creates a new control client, and starts it.
 */
void CommCenter::newControlClient(){
  clients.push_back(new ControlClient(*controlClientPort,world));
  clients[clients.size()-1]->Start();
  //  clients[clients.size()-1]->dontWalk();
}

/** 
 * Creates a new server channel, and starts it.
 */
void CommCenter::newServer(){
  log <<"New Server"<<endl;
}


/**
 * Checks if there are new conections on any of the client ports, or
 * in the server port, and creates the threads and clients 
 */
void CommCenter::checkForConections(){
  if (clientPort->isPendingConnection(0)) newClient();
  if (graphicClientPort->isPendingConnection(0)) newGraphicClient();
  if (controlClientPort->isPendingConnection(0)) newControlClient();
  if (serverPort->isPendingConnection(0)) newServer();
}

/** 
 * Checks if there are dead clients, and decrements the numClients to
 * wait
 */
void CommCenter::checkForDeadClients(){
  unsigned int i;
  for (i=0;i<clients.size();i++)
    if (!clients[i]->isAlive())
      --(world->numClients);
}

/**
 * Deletes not Alive clients
 */
void CommCenter::removeDeadClients(){
  unsigned int i;
  for (i=clients.size();i--;)
    if (!clients[i]->isAlive()){
      delete clients[i];
      clients.erase(&clients[i]);
    }
}

/** 
 * Waits till all clients have finished the run cycle
 */
void CommCenter::waitForClients(){
  /// First Wake up clients
  world->numClients=clients.size();
  unsigned int i;
  for (i=clients.size();i--;)
    clients[i]->walk();


  /// Poll till all clients sleep again, or if none, just yield
  /// (usleep(3) yields, see sched_yield(2))
  do{
    checkForDeadClients();
    //sched_yield();
    usleep(10000);
    //usleep(1000);
  }while (world->numClients>0);
  if (clients.size()==0)
    usleep(10);

  /// Remove dead clients
  removeDeadClients();
}

/**
 * Make the movements done
 */
void CommCenter::makeMovements(){
  world->step();
}

/**
 * Searches a suitable client for migration of an agent
 *
 * Actually it does it selecting one pseudo-random agentClient from
 * the list of clients with the same name of actual agent
 */
Client *CommCenter::getClientForMigration(string name){
  static unsigned int i=0;
  if (clientMap.count(name)!=0){
    unsigned int n=(i++)%clientMap[name].size();
    log <<"Migration to number "<<n<<" of "<<clientMap[name].size()<<"("<<i<<")"<<endl;
    return clientMap[name][n];
  }
  return NULL;
}

---