AlgsExecutionStates.cpp

Go to the documentation of this file.

#include "AlgsExecutionStates.h"

// A simple map to easily translate a state to its name
std::map<AlgsExecutionStates::State, std::string> AlgsExecutionStates::stateNames = {
    {INITIAL, "INITIAL"},         {CONTROLREADY, "CONTROLREADY"}, {DATAREADY, "DATAREADY"}, {SCHEDULED, "SCHEDULED"},
    {EVTACCEPTED, "EVTACCEPTED"}, {EVTREJECTED, "EVTREJECTED"},   {ERROR, "ERROR"}};

StatusCode AlgsExecutionStates::updateState( unsigned int iAlgo, State newState )
{

  MsgStream log( m_MS, "AlgExecutionStates" );
  const unsigned int states_size = m_states.size();

  if ( iAlgo >= states_size ) {
    log << MSG::ERROR << "Index out of bound (" << iAlgo << " and the size of the states vector is " << states_size
        << ")" << endmsg;

    return StatusCode::FAILURE;
  }

  switch ( newState ) {
  case INITIAL:
    log << MSG::ERROR << "[AlgIndex " << iAlgo << "] Transition to INITIAL is not defined.";
    return StatusCode::FAILURE;
  //
  case CONTROLREADY:
    if ( m_states[iAlgo] != INITIAL ) {
      log << MSG::ERROR << "[AlgIndex " << iAlgo
          << "] Transition to CONTROLREADY possible only from INITIAL state! The state is " << m_states[iAlgo]
          << endmsg;
      return StatusCode::FAILURE;
    } else {
      m_states[iAlgo] = CONTROLREADY;
      return StatusCode::SUCCESS;
    }
  //
  case DATAREADY:
    if ( m_states[iAlgo] != CONTROLREADY ) {
      log << MSG::ERROR << "[AlgIndex " << iAlgo
          << "] Transition to DATAREADY possible only from CONTROLREADY state!The state is " << m_states[iAlgo]
          << endmsg;
      return StatusCode::FAILURE;
    } else {
      m_states[iAlgo] = DATAREADY;
      return StatusCode::SUCCESS;
    }
  case SCHEDULED:
    if ( m_states[iAlgo] != DATAREADY ) {
      log << MSG::ERROR << "[AlgIndex " << iAlgo
          << "] Transition to SCHEDULED possible only from DATAREADY state! The state is " << m_states[iAlgo] << endmsg;
      return StatusCode::FAILURE;
    } else {
      m_states[iAlgo] = SCHEDULED;
      return StatusCode::SUCCESS;
    }
  //
  case EVTACCEPTED:
    if ( m_states[iAlgo] != SCHEDULED ) {
      log << MSG::ERROR << "[AlgIndex " << iAlgo
          << "] Transition to EVTACCEPTED possible only from SCHEDULED state! The state is " << m_states[iAlgo]
          << endmsg;
      return StatusCode::FAILURE;
    } else {
      m_states[iAlgo] = EVTACCEPTED;
      return StatusCode::SUCCESS;
    }
  //
  case EVTREJECTED:
    if ( m_states[iAlgo] != SCHEDULED ) {
      log << MSG::ERROR << "[AlgIndex " << iAlgo
          << "] Transition to EVTREJECT possible only from SCHEDULED state! The state is " << m_states[iAlgo] << endmsg;
      return StatusCode::FAILURE;
    } else {
      m_states[iAlgo] = EVTREJECTED;
      return StatusCode::SUCCESS;
    }
  default:
    //
    m_states[iAlgo] = ERROR;
    return StatusCode::SUCCESS;
  }

  return StatusCode::FAILURE;
}