69 boost::mutex::scoped_lock lock(
m_mutex);
106 <<
"Time-unreliable datagram detected: "
108 <<
"time stamp secs: " << header->
timeStamp().
sec() <<
", "
115 LOG_ERROR <<
"Impossible to write time-unreliable data to dump file";
129 if (!seq_num.second) {
131 LOG_ERROR <<
"Discarding data which timestamp is before the run start time. "
133 <<
"seq_num: " << seq_num.first <<
", "
135 <<
"time stamp secs: " << header->
timeStamp().
sec() <<
", "
139 else LOG_DEBUG <<
"Discarding data which timestamp is before the run start time. "
141 <<
"seq_num: " << seq_num.first <<
", "
143 <<
"time stamp secs: " << header->
timeStamp().
sec() <<
", "
156 LOG_DEBUG <<
"Discarding data which run number ("
158 <<
") is different from the one of the current run: "
172 boost::mutex::scoped_lock lock(
m_mutex);
176 container_t::const_iterator
const it =
m_container.find(idx);
181 insert_value = it->second->insert(datagram);
190 insert_value = pframe->
insert(datagram);
192 container_t::value_type
const pair(idx, pframe);
const CLBCommonHeader * getCLBCommonHeader() const
bool hasValidTimeStamp() const
bool write(const CLBDataGram *data, unsigned int detector_id)
void getFrame(Frame &frame)
std::size_t m_max_dump_size
unsigned int m_detector_id
bool insert(CLBDataGram *datagram)
PuzzledFrame * getEmptyPuzzledFrame()
unsigned int m_timeslice_duration
boost::atomic< bool > m_running
buffers_collector_t m_empty_buffers
Template Frame for ARS data.
void putDataGram(CLBDataGram *p)
static InBufferCollector & getCollector()
void add(std::string const &tag)
void setDetectorId(unsigned int detector_id)
void setSeqNumber(unsigned int seqnumber)
void setFrameIndex(frame_idx_t frame_idx)
void getFrame(Frame &frame)
bool insert(CLBDataGram *datagram)
void setDataType(unsigned int datatype)
bool hasExpiredWrt(Timer const &t) const
void setTimer(const Timer &exp)
void put_nolock(void *pointer)
static const int sc_expusec
static const int error_tf
static const useconds_t sc_sleep
static const int sc_expsec
void chrono_set(chronometrable &chr)
uint64_t inMilliSeconds() const