1 #ifndef DATAQUEUE_FRAMEFACTORY_FRAME_FARM_HH
2 #define DATAQUEUE_FRAMEFACTORY_FRAME_FARM_HH
4 #include <boost/atomic.hpp>
5 #include <boost/thread/mutex.hpp>
55 uint64_t run_start_time,
56 std::size_t max_dump_size,
107 #endif // DATAQUEUE_FRAMEFACTORY_FRAME_FARM_HH
unsigned int detectorId(unsigned int detector_id)
std::map< frame_idx_t, PuzzledFrame * > container_t
FrameFarm(unsigned int DeltaTS, uint64_t run_start_time, std::size_t max_dump_size, const std::string &dump_prefix, const std::string &dump_postfix)
PuzzledFrame * getEmptyPuzzledFrame()
buffers_collector_t m_empty_buffers
std::size_t m_max_dump_size
bool insert(CLBDataGram *datagram)
unsigned int m_timeslice_duration
std::deque< PuzzledFrame * > buffers_collector_t
boost::atomic< bool > m_running
void getFrame(Frame &frame)
unsigned int m_detector_id
Template Frame for ARS data.
unsigned int getTimeSliceDuration()