EventSchedulingState.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_EVENTSCHEDULINGSTATE_H
#define GAUDIHIVE_EVENTSCHEDULINGSTATE_H

#include "boost/dynamic_bitset.hpp"
#include "tbb/concurrent_vector.h"

#include <atomic>

// typedef for the event and algo state
typedef boost::dynamic_bitset<> state_type;

class EventSchedulingState
{
public:
  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 { return ( m_algosFinished == m_numberOfAlgos ); }
  const state_type& state() const { return m_eventState; }
  void update_state( unsigned int& product_index );

private:
  std::atomic_uint m_algosInFlight;
  std::atomic_uint m_algosFinished;
  unsigned int m_numberOfAlgos;
  state_type m_eventState;
  tbb::concurrent_vector<bool> m_algosStarted;
};

#endif // GAUDIHIVE_EVENTSCHEDULINGSTATE_H