Go to the documentation of this file.
67 boost::mutex::scoped_lock lock(
m_mutex);
104 <<
"Time-unreliable datagram detected: "
106 <<
"time stamp secs: " << header->
timeStamp().
sec() <<
", "
113 LOG_ERROR <<
"Impossible to write time-unreliable data to dump file";
127 if (!seq_num.second) {
128 LOG_DEBUG <<
"Discarding data which timestamp is before the run start time. "
130 <<
"seq_num: " << seq_num.first <<
", "
132 <<
"time stamp secs: " << header->
timeStamp().
sec() <<
", "
145 LOG_DEBUG <<
"Discarding data which run number ("
147 <<
") is different from the one of the current run: "
161 boost::mutex::scoped_lock lock(
m_mutex);
165 container_t::const_iterator
const it =
m_container.find(idx);
170 insert_value = it->second->insert(datagram);
179 insert_value = pframe->
insert(datagram);
181 container_t::value_type
const pair(idx, pframe);
void add(std::string const &tag)
bool insert(CLBDataGram *datagram)
void setSeqNumber(unsigned int seqnumber)
const CLBCommonHeader * getCLBCommonHeader() const
void putDataGram(CLBDataGram *p)
void setDetectorId(unsigned int detector_id)
Template Frame for ARS data.
void setDataType(unsigned int datatype)
void chrono_set(chronometrable &chr)
unsigned int m_timeslice_duration
void getFrame(Frame &frame)
static const useconds_t sc_sleep
static const int sc_expusec
bool insert(CLBDataGram *datagram)
void getFrame(Frame &frame)
std::size_t m_max_dump_size
bool hasValidTimeStamp() const
void setTimer(const Timer &exp)
bool hasExpiredWrt(Timer const &t) const
void setFrameIndex(frame_idx_t frame_idx)
static InBufferCollector & getCollector()
buffers_collector_t m_empty_buffers
void put_nolock(void *pointer)
bool write(const CLBDataGram *data, unsigned int detector_id)
unsigned int m_detector_id
PuzzledFrame * getEmptyPuzzledFrame()
boost::atomic< bool > m_running
static const int sc_expsec