101{
103
106 << "Time-unreliable datagram detected: "
108 <<
"time stamp secs: " << header->
timeStamp().
sec() <<
", "
111
114 if (!ok) {
115 LOG_ERROR <<
"Impossible to write time-unreliable data to dump file";
116 }
117 }
118
121 return false;
122 }
123
125 *header,
128
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() <<
", "
138
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() <<
", "
146
149 return false;
150 }
151
152 if (
155 ) {
156 LOG_DEBUG <<
"Discarding data which run number ("
158 << ") is different from the one of the current run: "
162 return false;
163 }
164
166 *header,
169
170 bool insert_value;
171
172 boost::mutex::scoped_lock lock(
m_mutex);
173
175
176 container_t::const_iterator
const it =
m_container.find(idx);
177
179
181 insert_value = it->second->insert(datagram);
182 } else {
184
187
190 insert_value = pframe->
insert(datagram);
191
192 container_t::value_type const pair(idx, pframe);
193
195 }
196
197 return insert_value;
198}
const CLBCommonHeader * getCLBCommonHeader() const
bool hasValidTimeStamp() const
bool write(const CLBDataGram *data, unsigned int detector_id)
PuzzledFrame * getEmptyPuzzledFrame()
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)
bool insert(CLBDataGram *datagram)
void setDataType(unsigned int datatype)
static const int error_tf
uint64_t inMilliSeconds() const