serverDim.cpp

Go to the documentation of this file.

// $Id: serverDim.cpp,v 1.8 2007/02/05 14:59:08 fmachefe Exp $

// Include files 

#ifdef _NETWORK_
#include <dis.hxx>
#include <iostream>
#ifndef WIN32
#include <unistd.h>
#endif

//CATCore include files
#include "Fct.h"
#include "CAT.h"

//CATCmd include files
#include "Interpreter.h"

#include "serverDim.h"

serverErrorHandler::serverErrorHandler() {
  DimServer::addErrorHandler(this);
}

void serverErrorHandler::errorHandler(int severity, int code, char *msg) {
  int index = 0;
  char **services;
  std::cout << severity << " " << msg << std::endl;
#ifdef _NETWORK_
  services = DimServer::getClientServices();
  std::cout<< "from "<< DimServer::getClientName() << " services:" << std::endl;
  while(services[index])
  {
    std::cout << services[index] << std::endl;
    index++;
  }
#endif
}

ExitHandler::ExitHandler() {DimServer::addExitHandler(this);}

void ExitHandler::exitHandler(int code){
  std::cout << "exit code " << code << std::endl;
}


CmndServ::CmndServ( Interpreter *interpreter ) : 
#ifdef _NETWORK_
  DimCommand((application()->name()+"/command").c_str(),
         "C") {
#endif
  m_interpreter = interpreter;
}

void CmndServ::commandHandler() {
#ifdef _NETWORK_
  m_command = std::string ( getString() );
  msgSvc( 0, "", 
          std::string ( DimServer::getClientName() ) + "Cmnd>" + 
          std::string ( m_command ) );
  start(  );
#endif
}

void CmndServ::threadHandler() {
  //  msgSvc(INFO,"thread", m_command);
  m_interpreter-> ctrl ("");
  m_interpreter-> cmdline ( true , m_command );
}


CtrlServ::CtrlServ( Interpreter *interpreter ) : 
#ifdef _NETWORK_
  DimCommand((application()->name()+"/control").c_str(),
         "C") {
#endif
  m_interpreter = interpreter;
}

void CtrlServ::commandHandler() {
#ifdef _NETWORK_
  m_command = std::string ( getString() );
  msgSvc( DEBUG , "", 
          std::string ( DimServer::getClientName() ) + "Ctrl>" + 
          std::string ( m_command ) );
  if ( 0 == m_command.compare("stop") || 
       0 == m_command.compare("kill") || 
       0 == m_command.compare("pause") ||
       0 == m_command.compare("resume") ) {
    m_interpreter -> ctrl ( m_command ) ;
  }
#endif
}

Timer::Timer( int time , 
              DimService* srv) {
  msgSvc( INFO , "" , "Creating Timer [delay="+ 
          itos( time ) + 
          "s]" );
  m_srv = srv ;
  m_delay = time ;
  start( m_delay ); 
};

void Timer::timerHandler() {
  msgSvc( DEBUG , "Timer" , "Timer triggered server update" ); 
  m_srv->updateService ();
  start ( m_delay );
}

#endif