EventSchedulingState.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_EVENTSCHEDULINGSTATE_H
#define GAUDIHIVE_EVENTSCHEDULINGSTATE_H


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

#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