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 chrono_set(chronometrable &chr)
static const useconds_t sc_sleep
static const int sc_expusec
bool hasExpiredWrt(Timer const &t) const
bool hasValidTimeStamp() const
const CLBCommonHeader * getCLBCommonHeader() const
void putDataGram(CLBDataGram *p)
bool write(const CLBDataGram *data, unsigned int detector_id)
bool insert(CLBDataGram *datagram)
PuzzledFrame * getEmptyPuzzledFrame()
void setDetectorId(unsigned int detector_id)
buffers_collector_t m_empty_buffers
void setTimer(const Timer &exp)
std::size_t m_max_dump_size
bool insert(CLBDataGram *datagram)
void setDataType(unsigned int datatype)
static const int sc_expsec
unsigned int m_timeslice_duration
void add(std::string const &tag)
void setFrameIndex(frame_idx_t frame_idx)
boost::atomic< bool > m_running
void put_nolock(void *pointer)
static InBufferCollector & getCollector()
void getFrame(Frame &frame)
unsigned int m_detector_id
Template Frame for ARS data.
void getFrame(Frame &frame)
void setSeqNumber(unsigned int seqnumber)