Server.cpp

Go to the documentation of this file.

// $Id: Server.cpp,v 1.10 2007/06/12 11:25:53 fmachefe Exp $
// Include files 

#include <iostream>
#ifndef WIN32
#include <unistd.h>
#endif

#include <string>
#include <algorithm>
#include <time.h>

// 
#include "Application.h"
#include "Server.h"

//-----------------------------------------------------------------------------
// Implementation file for class : Server
//
// 2005-03-03 : Frédéric Machefert
//-----------------------------------------------------------------------------

//=============================================================================
// Standard constructor, initializes variables
//=============================================================================
Server::Server( Application *application ) {
  m_app = application;
#ifdef _NETWORK_
  m_updateDelay = 1;
  m_app->info("Server built.","Server::Server");
  m_servCmd    = new CmndServ ( m_app );
  m_servCtrl   = new CtrlServ ( m_app );
  m_servTimer  = 0;
  m_servState  = 0;
  m_servConfig = 0;
#else
  m_app->warning("Compilation without NETWORK capabilities","Server::Server"); 
#endif  
}

//=============================================================================
// Destructor
//=============================================================================
Server::~Server() {
#ifdef _NETWORK_
  delete m_servCmd;
  delete m_servCtrl;
  if ( 0 != m_servState ) {
    delete m_servState;
  }
  if ( 0 != m_servTimer ) {
    delete m_servTimer;
  }
  if ( 0 != m_servConfig ) {
    delete m_servConfig;
  }
  m_servCmd    = 0;
  m_servCtrl   = 0;
  m_servTimer  = 0;
  m_servState  = 0;
  m_servConfig = 0;
#endif
}

//=========================================================================
//  
//=========================================================================
StatusCode Server::updateState ( ) {
#ifdef _NETWORK_
  m_servState->updateService();
  m_app->debug("Updating state service.","Server::updateState"); 
#else
  m_app->warning("Updating server services not available (NETWORK mode off).",
                 "Server::updateState"); 
  return StatusCode::FAILURE;
#endif
  return StatusCode::SUCCESS;
}

//=========================================================================
//  
//=========================================================================
StatusCode Server::updateConfig ( ) {
#ifdef _NETWORK_
  m_servConfig->updateService();
  m_app->debug("Updating proc database service.","Server::updateConfig");
#else
  m_app->warning("Updating server services not available (NETWORK mode off).",
                 "Server::updateConfig"); 
  return StatusCode::FAILURE;
#endif
  return StatusCode::SUCCESS;
}

//=========================================================================
//  
//=========================================================================
StatusCode Server::start ( ) {
#ifdef _NETWORK_
  m_app->info("Starting CAT server " + application()->name(),"Server::start");
  DimServer::start(m_app->name().c_str());
  std::string str =  m_app->name() ;
  str = m_app->name() ;
  str.append ("/state");
  m_servState = new DimService ( str.c_str(),"I:4;C",
                                 m_app->state(),
                                 sizeof(*(m_app->state())) );
  m_servTimer = new Timer    ( updateDelay() , m_servState );
  str = application()->name() ;
  str.append ("/config"); 
  m_servConfig = new DimService ( str.c_str(),"C",
                                  m_app->config(),
                                  sizeof(*(m_app->config())) );

  m_app->procDb()->startServices();
#else
  m_app->warning("compilation without NETWORK capabilities. Cannot start server.",
                 "Server::star");
  return StatusCode::FAILURE;
#endif
  return StatusCode::SUCCESS;
}


//=========================================================================
//  
//=========================================================================
StatusCode Server::cmdline ( std::vector < std::string > cmd ){  
  if ( cmd.size()==0){
    char line[200];
    std::string tmp;
    sprintf(line,"Timer    [timer]    : %i", updateDelay() );
    m_app->info(line,"Server::cmdline");
    return StatusCode::SUCCESS;
  }
  
  transform(cmd[0].begin(),cmd[0].end(),cmd[0].begin(),tolower);

  if (cmd[0].compare("timer")==0){
    if ( cmd.size() == 2 ) {
      setUpdateDelay ( atoi(cmd[1].c_str()) );
      this -> updateConfig();
      this -> updateState();  
    }
    this -> updateConfig();
    this -> updateState();
    return StatusCode::SUCCESS;
  }
  return StatusCode::FAILURE;
}

//=============================================================================