Fill metaDataStore and ntuples.
157 auto piovComplete = std::make_unique<xAOD::LumiBlockRangeContainer>();
158 auto piovCompleteAux = std::make_unique<xAOD::LumiBlockRangeAuxContainer>();
159 piovComplete->setStore( piovCompleteAux.get() );
161 auto piovUnfinished = std::make_unique<xAOD::LumiBlockRangeContainer>();
162 auto piovUnfinishedAux = std::make_unique<xAOD::LumiBlockRangeAuxContainer>();
163 piovUnfinished->setStore( piovUnfinishedAux.get() );
165 auto piovSuspect = std::make_unique<xAOD::LumiBlockRangeContainer>();
166 auto piovSuspectAux = std::make_unique<xAOD::LumiBlockRangeAuxContainer>();
167 piovSuspect->setStore( piovSuspectAux.get() );
172 auto iovr = std::make_unique<xAOD::LumiBlockRange>(*
range);
173 piovSuspect->push_back(std::move(iovr));
184 tempLBColl.setStore( p_tempAuxLBColl );
194 << (*i)->startRunNumber() <<
" LB " << (*i)->startLumiBlockNumber() <<
" events seen "
195 << (*ilast)->eventsSeen() <<
" expected " << (*i)->eventsExpected());
198 if( ((*i)->startRunNumber()==(*ilast)->startRunNumber()) &&
199 ((*i)->stopRunNumber()==(*ilast)->stopRunNumber()) &&
200 ((*i)->startLumiBlockNumber()==(*ilast)->startLumiBlockNumber()) &&
201 ((*i)->stopLumiBlockNumber()==(*ilast)->stopLumiBlockNumber()) ) {
203 if((*ilast)->eventsExpected()!=(*i)->eventsExpected()) {
204 ATH_MSG_WARNING(
"Error: tmpLBColl with run " << (*i)->startRunNumber() <<
" LB " << (*i)->startLumiBlockNumber() <<
" events expected "
205 << (*ilast)->eventsExpected() <<
" and " << (*i)->eventsExpected() );
208 ATH_MSG_VERBOSE(
"Merge Run " << (*i)->startRunNumber() <<
" LB " << (*i)->startLumiBlockNumber()
209 <<
" events seen " << iovr->
eventsSeen() <<
"+"
210 << (*i)->eventsSeen() <<
" and events expected "
229 for (
const auto range : tempLBColl) {
230 auto iovr = std::make_unique<xAOD::LumiBlockRange>(*
range);
231 if(
range->eventsSeen() ==
range->eventsExpected() ) {
232 piovComplete->push_back(std::move(iovr));
234 else if(
range->eventsSeen() >
range->eventsExpected() ) {
235 piovSuspect->push_back(std::move(iovr));
238 piovUnfinished->push_back(std::move(iovr));
244 if(!piovComplete->empty()) {
245 ATH_MSG_DEBUG(
"Number of Complete LumiBlocks:" << piovComplete->size() );
246 for (
const auto range : *piovComplete) {
248 <<
range->startRunNumber() <<
"," <<
range->startLumiBlockNumber()
250 <<
range->startRunNumber() <<
"," <<
range->startLumiBlockNumber()
251 <<
") eventsSeen = " <<
range->eventsSeen()
252 <<
", eventsExpected = " <<
range->eventsExpected()
257 if(!piovUnfinished->empty()) {
258 ATH_MSG_DEBUG(
"Number of Unfinished LumiBlocks:" << piovUnfinished->size() );
259 for (
const auto range : *piovUnfinished) {
261 <<
range->startRunNumber() <<
"," <<
range->startLumiBlockNumber()
263 <<
range->startRunNumber() <<
"," <<
range->startLumiBlockNumber()
264 <<
") eventsSeen = " <<
range->eventsSeen()
265 <<
", eventsExpected = " <<
range->eventsExpected()
269 if(!piovSuspect->empty()) {
270 ATH_MSG_DEBUG(
"Number of Suspect LumiBlocks:" << piovSuspect->size() );
271 for (
const auto range : *piovSuspect) {
273 <<
range->startRunNumber() <<
"," <<
range->startLumiBlockNumber()
275 <<
range->startRunNumber() <<
"," <<
range->startLumiBlockNumber()
276 <<
") eventsSeen = " <<
range->eventsSeen()
277 <<
", eventsExpected = " <<
range->eventsExpected()
284 if (!piovComplete->empty()) {
285 ATH_MSG_INFO(
"Write Complete LumiBlocks with size " << piovComplete->size());
289 "Complete LumiBlocks container with key "
291 <<
" already exists. Updating if there are missing LumiBlocks.");
295 for (
const auto range : *piovComplete) {
298 for (
const auto existing : *complete) {
299 if ((existing->startRunNumber() ==
range->startRunNumber()) &&
300 (existing->stopRunNumber() ==
range->stopRunNumber()) &&
301 (existing->startLumiBlockNumber() ==
range->startLumiBlockNumber()) &&
302 (existing->stopLumiBlockNumber() ==
range->stopLumiBlockNumber()) &&
303 (existing->eventsSeen() ==
range->eventsSeen()) &&
304 (existing->eventsExpected() ==
range->eventsExpected())) {
314 "Copying LumiBlock: [ ("
315 <<
range->startRunNumber() <<
"," <<
range->stopLumiBlockNumber()
316 <<
"):(" <<
range->startRunNumber() <<
","
317 <<
range->stopLumiBlockNumber()
318 <<
") eventsSeen = " <<
range->eventsSeen()
319 <<
", eventsExpected = " <<
range->eventsExpected() <<
" ]");
321 complete->push_back(
out);
327 <<
" LumiBlockRangeContainer in output MetaDataStore");
333 if (!piovUnfinished->empty()) {
334 ATH_MSG_INFO(
"Write Unfinished LumiBlocks with size " << piovUnfinished->size());
338 "Unfinished LumiBlocks container with key "
340 <<
" already exists. Updating if there are missing LumiBlocks.");
344 for (
const auto range : *piovUnfinished) {
347 for (
const auto existing : *unfinished) {
348 if ((existing->startRunNumber() ==
range->startRunNumber()) &&
349 (existing->stopRunNumber() ==
range->stopRunNumber()) &&
350 (existing->startLumiBlockNumber() ==
range->startLumiBlockNumber()) &&
351 (existing->stopLumiBlockNumber() ==
range->stopLumiBlockNumber()) &&
352 (existing->eventsSeen() ==
range->eventsSeen()) &&
353 (existing->eventsExpected() ==
range->eventsExpected())) {
363 "Copying LumiBlock: [ ("
364 <<
range->startRunNumber() <<
"," <<
range->stopLumiBlockNumber()
365 <<
"):(" <<
range->startRunNumber() <<
","
366 <<
range->stopLumiBlockNumber()
367 <<
") eventsSeen = " <<
range->eventsSeen()
368 <<
", eventsExpected = " <<
range->eventsExpected() <<
" ]");
370 unfinished->push_back(
out);
376 <<
" LumiBlockRangeContainer in output MetaDataStore");
382 if (!piovSuspect->empty()) {
383 ATH_MSG_INFO(
"Write Suspect LumiBlocks with size " << piovSuspect->size());
387 "Suspect LumiBlocks container with key "
389 <<
" already exists. Updating if there are missing LumiBlocks.");
393 for (
const auto range : *piovSuspect) {
396 for (
const auto existing : *suspect) {
397 if ((existing->startRunNumber() ==
range->startRunNumber()) &&
398 (existing->stopRunNumber() ==
range->stopRunNumber()) &&
399 (existing->startLumiBlockNumber() ==
range->startLumiBlockNumber()) &&
400 (existing->stopLumiBlockNumber() ==
range->stopLumiBlockNumber()) &&
401 (existing->eventsSeen() ==
range->eventsSeen()) &&
402 (existing->eventsExpected() ==
range->eventsExpected())) {
412 "Copying LumiBlock: [ ("
413 <<
range->startRunNumber() <<
"," <<
range->stopLumiBlockNumber()
414 <<
"):(" <<
range->startRunNumber() <<
","
415 <<
range->stopLumiBlockNumber()
416 <<
") eventsSeen = " <<
range->eventsSeen()
417 <<
", eventsExpected = " <<
range->eventsExpected() <<
" ]");
419 suspect->push_back(
out);
425 <<
" LumiBlockRangeContainer in output MetaDataStore");
431 return(StatusCode::SUCCESS);