AlgsExecutionStates Class Reference

The AlgsExecutionStates encodes the state machine for the execution of algorithms within a single event. More...

#include <GaudiKernel/AlgsExecutionStates.h>

Collaboration diagram for AlgsExecutionStates:

Classes
class	Iterator

Public Types
enum	State : uint8_t {   INITIAL = 0, CONTROLREADY = 1, DATAREADY = 2, SCHEDULED = 3,   EVTACCEPTED = 4, EVTREJECTED = 5, ERROR = 6 }
	Execution states of the algorithms. More...

Public Member Functions
	AlgsExecutionStates (unsigned int algsNumber, SmartIF< IMessageSvc > MS)
StatusCode	set (unsigned int iAlgo, State newState)
void	reset ()
bool	contains (State state) const
	check if the collection contains at least one state of requested type More...
bool	containsAny (std::initializer_list< State > l) const
	check if the collection contains at least one state of any listed types More...
bool	containsOnly (std::initializer_list< State > l) const
	check if the collection contains only states of listed types More...
const State &	operator[] (unsigned int i) const
size_t	size () const
size_t	sizeOfSubset (State state) const
Iterator	begin (State kind)
Iterator	end (State kind)

Private Member Functions
MsgStream	log ()

Private Attributes
std::vector< State >	m_states
SmartIF< IMessageSvc >	m_MS

Detailed Description

The AlgsExecutionStates encodes the state machine for the execution of algorithms within a single event.

It is used by the concurrent schedulers

Author

Benedikt Hegner

Danilo Piparo

Version

1.0

Definition at line 26 of file AlgsExecutionStates.h.

Member Enumeration Documentation

enum AlgsExecutionStates::State : uint8_t

Execution states of the algorithms.

Enumerator
INITIAL
CONTROLREADY
DATAREADY
SCHEDULED
EVTACCEPTED
EVTREJECTED
ERROR

Definition at line 29 of file AlgsExecutionStates.h.

             : uint8_t {
    INITIAL      = 0,
    CONTROLREADY = 1,
    DATAREADY    = 2,
    SCHEDULED    = 3,
    EVTACCEPTED  = 4,
    EVTREJECTED  = 5,
    ERROR        = 6
  };

Constructor & Destructor Documentation

AlgsExecutionStates::AlgsExecutionStates ( unsigned int  algsNumber, SmartIF< IMessageSvc >  MS  )

inline

Definition at line 39 of file AlgsExecutionStates.h.

      : m_states( algsNumber, INITIAL ), m_MS( std::move( MS ) ){};

Member Function Documentation

Iterator AlgsExecutionStates::begin ( State  kind )

inline

Definition at line 103 of file AlgsExecutionStates.h.

{ return {kind, m_states, m_states.begin()}; }

bool AlgsExecutionStates::contains ( State  state ) const

inline

check if the collection contains at least one state of requested type

Definition at line 47 of file AlgsExecutionStates.h.

{ return std::find( m_states.begin(), m_states.end(), state ) != m_states.end(); }

bool AlgsExecutionStates::containsAny ( std::initializer_list< State >  l ) const

inline

check if the collection contains at least one state of any listed types

Definition at line 50 of file AlgsExecutionStates.h.

                                                         {
    return std::find_first_of( m_states.begin(), m_states.end(), l.begin(), l.end() ) != m_states.end();
  }

bool AlgsExecutionStates::containsOnly ( std::initializer_list< State >  l ) const

inline

check if the collection contains only states of listed types

Definition at line 55 of file AlgsExecutionStates.h.

                                                          {
    return std::all_of( m_states.begin(), m_states.end(),
                        [l]( State s ) { return std::find( l.begin(), l.end(), s ) != l.end(); } );
  };

Iterator AlgsExecutionStates::end ( State  kind )

inline

Definition at line 104 of file AlgsExecutionStates.h.

{ return {kind, m_states, m_states.end()}; }

MsgStream AlgsExecutionStates::log ( )

inlineprivate

Definition at line 72 of file AlgsExecutionStates.h.

{ return {m_MS, "AlgsExecutionStates"}; }

const State& AlgsExecutionStates::operator[] ( unsigned int  i ) const

inline

Definition at line 60 of file AlgsExecutionStates.h.

{ return m_states.at( i ); };

void AlgsExecutionStates::reset ( )

inline

Definition at line 44 of file AlgsExecutionStates.h.

{ std::fill( m_states.begin(), m_states.end(), INITIAL ); };

StatusCode AlgsExecutionStates::set	(	unsigned int	iAlgo,
		State	newState
	)

Definition at line 13 of file AlgsExecutionStates.cpp.

                                                                        {
  if ( iAlgo >= m_states.size() ) {
    log() << MSG::ERROR << "Index out of bound (" << iAlgo << " / " << m_states.size() << ")" << endmsg;
    return StatusCode::FAILURE;
  }

  switch ( transition( m_states[iAlgo], newState ) ) {
  case transition( INITIAL, CONTROLREADY ):   // Fallthrough
  case transition( CONTROLREADY, DATAREADY ): // Fallthrough
  case transition( DATAREADY, SCHEDULED ):    // Fallthrough
  case transition( SCHEDULED, ERROR ):        // Fallthrough
  case transition( SCHEDULED, EVTACCEPTED ):  // Fallthrough
  case transition( SCHEDULED, EVTREJECTED ):
    m_states[iAlgo] = newState;
    return StatusCode::SUCCESS;
  default:
    log() << MSG::ERROR << "[AlgIndex " << iAlgo << "] Transition from " << m_states[iAlgo] << " to " << newState
          << " is not allowed" << endmsg;
    m_states[iAlgo] = ERROR;
    return StatusCode::FAILURE;
  }
}

size_t AlgsExecutionStates::size ( ) const

inline

Definition at line 62 of file AlgsExecutionStates.h.

{ return m_states.size(); }

size_t AlgsExecutionStates::sizeOfSubset ( State  state ) const

inline

Definition at line 64 of file AlgsExecutionStates.h.

                                           {
    return std::count_if( m_states.begin(), m_states.end(), [&]( State s ) { return s == state; } );
  }

Member Data Documentation

SmartIF<IMessageSvc> AlgsExecutionStates::m_MS

private

Definition at line 70 of file AlgsExecutionStates.h.

std::vector<State> AlgsExecutionStates::m_states

private

Definition at line 69 of file AlgsExecutionStates.h.

---

The documentation for this class was generated from the following files:

• GaudiHive/src/AlgsExecutionStates.h
• GaudiHive/src/AlgsExecutionStates.cpp