EventSchedulingState Class Reference

#include <GaudiHive/EventSchedulingState.h>

Public Member Functions
	EventSchedulingState (const unsigned int &n_algos, const unsigned int &n_products)
	~EventSchedulingState ()
void	algoFinished ()
void	algoStarts (unsigned int &index)
bool	hasStarted (unsigned int &index) const
bool	hasFinished () const
const state_type &	state () const
void	update_state (unsigned int &product_index)

Private Attributes
std::atomic_uint	m_algosInFlight
	Number of algos in flight. More...
std::atomic_uint	m_algosFinished
	Number of finished algos. More...
unsigned int	m_numberOfAlgos
	Total number of algos. More...
state_type	m_eventState
	Event state recording which products are there. More...
tbb::concurrent_vector< bool >	m_algosStarted
	Register of algorithms started. More...

Detailed Description

Definition at line 12 of file EventSchedulingState.h.

Constructor & Destructor Documentation

EventSchedulingState::EventSchedulingState	(	const unsigned int &	n_algos,
		const unsigned int &	n_products
	)

Definition at line 3 of file EventSchedulingState.cpp.

    : m_numberOfAlgos( n_algos ), m_eventState( n_products )
{
  m_algosInFlight = 0;
  m_algosFinished = 0;
  m_algosStarted.resize( n_algos );
  std::fill( m_algosStarted.begin(), m_algosStarted.end(), false );
}

EventSchedulingState::~EventSchedulingState ( )

inline

Definition at line 16 of file EventSchedulingState.h.

{};

Member Function Documentation

void EventSchedulingState::algoFinished

(

)

Definition at line 12 of file EventSchedulingState.cpp.

{
  --m_algosInFlight;
  ++m_algosFinished;
}

void EventSchedulingState::algoStarts

(

unsigned int &

index

)

Definition at line 20 of file EventSchedulingState.cpp.

{
  ++m_algosInFlight;
  m_algosStarted[index] = true;
}

bool EventSchedulingState::hasFinished ( ) const

inline

Definition at line 21 of file EventSchedulingState.h.

{ return ( m_algosFinished == m_numberOfAlgos ); }

bool EventSchedulingState::hasStarted

(

unsigned int &

index

)

const

Definition at line 18 of file EventSchedulingState.cpp.

{ return m_algosStarted[index]; }

const state_type& EventSchedulingState::state ( ) const

inline

Definition at line 22 of file EventSchedulingState.h.

{ return m_eventState; }

void EventSchedulingState::update_state

(

unsigned int &

product_index

)

Definition at line 26 of file EventSchedulingState.cpp.

{ m_eventState[product_index] = true; }

Member Data Documentation

std::atomic_uint EventSchedulingState::m_algosFinished

private

Number of finished algos.

Definition at line 29 of file EventSchedulingState.h.

std::atomic_uint EventSchedulingState::m_algosInFlight

private

Number of algos in flight.

Definition at line 27 of file EventSchedulingState.h.

tbb::concurrent_vector<bool> EventSchedulingState::m_algosStarted

private

Register of algorithms started.

Definition at line 35 of file EventSchedulingState.h.

state_type EventSchedulingState::m_eventState

private

Event state recording which products are there.

Definition at line 33 of file EventSchedulingState.h.

unsigned int EventSchedulingState::m_numberOfAlgos

private

Total number of algos.

Definition at line 31 of file EventSchedulingState.h.

---

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

• GaudiHive/GaudiHive/EventSchedulingState.h
• GaudiHive/src/EventSchedulingState.cpp