557 l.hltdata.reserve(250);
558 l.l1data.reserve(192);
559 l.bunchlumivalue.reserve(5);
560 l.bunchlumierror.reserve(5);
561 l.bunchlumiquality.reserve(5);
562 l.beam1intensity.resize(3564,0.0);
563 l.beam2intensity.resize(3564,0.0);
572 throw cms::Exception(
"Non existing service lumi::service::DBService");
576 session->transaction().start(
true);
577 coral::ISchema&
schema=session->nominalSchema();
578 coral::AttributeList lumisummaryBindVariables;
579 lumisummaryBindVariables.extend(
"lsmin",
typeid(
unsigned int));
580 lumisummaryBindVariables.extend(
"lsmax",
typeid(
unsigned int));
581 lumisummaryBindVariables.extend(
"lumidataid",
typeid(
unsigned long long));
583 lumisummaryBindVariables[
"lsmin"].data<
unsigned int>()=luminum;
584 lumisummaryBindVariables[
"lsmax"].data<
unsigned int>()=luminum+m_cachesize;
585 coral::AttributeList lumisummaryOutput;
586 lumisummaryOutput.extend(
"CMSLSNUM",
typeid(
unsigned int));
587 lumisummaryOutput.extend(
"INSTLUMI",
typeid(
float));
588 lumisummaryOutput.extend(
"STARTORBIT",
typeid(
unsigned int));
589 lumisummaryOutput.extend(
"NUMORBIT",
typeid(
unsigned int));
590 lumisummaryOutput.extend(
"CMSBXINDEXBLOB",
typeid(coral::Blob));
591 lumisummaryOutput.extend(
"BEAMINTENSITYBLOB_1",
typeid(coral::Blob));
592 lumisummaryOutput.extend(
"BEAMINTENSITYBLOB_2",
typeid(coral::Blob));
593 lumisummaryOutput.extend(
"BXLUMIVALUE_OCC1",
typeid(coral::Blob));
594 lumisummaryOutput.extend(
"BXLUMIVALUE_OCC2",
typeid(coral::Blob));
595 lumisummaryOutput.extend(
"BXLUMIVALUE_ET",
typeid(coral::Blob));
596 coral::IQuery* lumisummaryQuery=schema.newQuery();
598 lumisummaryQuery->addToOutputList(
"CMSLSNUM");
599 lumisummaryQuery->addToOutputList(
"INSTLUMI");
600 lumisummaryQuery->addToOutputList(
"STARTORBIT");
601 lumisummaryQuery->addToOutputList(
"NUMORBIT");
602 lumisummaryQuery->addToOutputList(
"CMSBXINDEXBLOB");
603 lumisummaryQuery->addToOutputList(
"BEAMINTENSITYBLOB_1");
604 lumisummaryQuery->addToOutputList(
"BEAMINTENSITYBLOB_2");
605 lumisummaryQuery->addToOutputList(
"BXLUMIVALUE_OCC1");
606 lumisummaryQuery->addToOutputList(
"BXLUMIVALUE_OCC2");
607 lumisummaryQuery->addToOutputList(
"BXLUMIVALUE_ET");
608 lumisummaryQuery->setCondition(
"CMSLSNUM>=:lsmin AND CMSLSNUM<:lsmax AND DATA_ID=:lumidataid",lumisummaryBindVariables);
609 lumisummaryQuery->defineOutput(lumisummaryOutput);
610 coral::ICursor& lumisummarycursor=lumisummaryQuery->execute();
611 unsigned int rowcounter=0;
612 while( lumisummarycursor.next() ){
613 const coral::AttributeList& row=lumisummarycursor.currentRow();
614 unsigned int cmslsnum=row[
"CMSLSNUM"].data<
unsigned int>();
617 lsdata.lumivalue=row[
"INSTLUMI"].data<
float>();
618 lsdata.lumierror=0.0;
619 lsdata.lumiquality=0;
620 lsdata.startorbit=row[
"STARTORBIT"].data<
unsigned int>();
621 lsdata.numorbit=row[
"NUMORBIT"].data<
unsigned int>();
623 if(!row[
"CMSBXINDEXBLOB"].isNull() && !row[
"BXLUMIVALUE_OCC1"].isNull() ){
624 const coral::Blob& bxindexBlob=row[
"CMSBXINDEXBLOB"].data<coral::Blob>();
625 const void* bxindex_StartAddress=bxindexBlob.startingAddress();
626 short* bxindex=(
short*)::malloc(bxindexBlob.size());
627 const coral::Blob& beam1intensityBlob=row[
"BEAMINTENSITYBLOB_1"].data<coral::Blob>();
628 const void* beam1intensityBlob_StartAddress=beam1intensityBlob.startingAddress();
629 float* beam1intensity=(
float*)::malloc(beam1intensityBlob.size());
630 const coral::Blob& beam2intensityBlob=row[
"BEAMINTENSITYBLOB_2"].data<coral::Blob>();
631 const void* beam2intensityBlob_StartAddress=beam2intensityBlob.startingAddress();
632 float* beam2intensity=(
float*)::malloc(beam2intensityBlob.size());
633 std::memmove(bxindex,bxindex_StartAddress,bxindexBlob.size());
634 std::memmove(beam1intensity,beam1intensityBlob_StartAddress,beam1intensityBlob.size());
635 std::memmove(beam2intensity,beam2intensityBlob_StartAddress,beam2intensityBlob.size());
637 unsigned int iMax = bxindexBlob.size()/
sizeof(short);
638 unsigned int lsb1Max = lsdata.beam1intensity.size();
639 unsigned int lsb2Max = lsdata.beam2intensity.size();
640 unsigned int ib1Max = beam1intensityBlob.size()/
sizeof(float);
641 unsigned int ib2Max = beam2intensityBlob.size()/
sizeof(float);
642 for(
unsigned int i=0;
i<iMax;++
i){
643 unsigned int idx=bxindex[
i];
644 if(ib1Max>
i && lsb1Max>idx){
645 lsdata.beam1intensity.at(idx)=beam1intensity[
i];
647 if(ib2Max>
i && lsb2Max>idx){
648 lsdata.beam2intensity.at(idx)=beam2intensity[
i];
652 ::free(beam1intensity);
653 ::free(beam2intensity);
655 const coral::Blob& bxlumivalBlob_occ1=row[
"BXLUMIVALUE_OCC1"].data<coral::Blob>();
656 const void* bxlumival_occ1_StartAddress=bxlumivalBlob_occ1.startingAddress();
657 float* bxlumival_occ1=(
float*)::malloc(bxlumivalBlob_occ1.size());
658 std::memmove(bxlumival_occ1,bxlumival_occ1_StartAddress,bxlumivalBlob_occ1.size());
659 std::vector<float> bxlumivalVec_occ1(bxlumival_occ1,bxlumival_occ1+bxlumivalBlob_occ1.size()/
sizeof(float));
660 ::free(bxlumival_occ1);
661 lsdata.bunchlumivalue.push_back(std::make_pair(
std::string(
"OCC1"),bxlumivalVec_occ1));
662 lsdata.bunchlumierror.push_back(std::make_pair(
std::string(
"OCC1"),std::vector<float>(3564)));
663 lsdata.bunchlumiquality.push_back(std::make_pair(
std::string(
"OCC1"),std::vector<short>(3564)));
664 const coral::Blob& bxlumivalBlob_occ2=row[
"BXLUMIVALUE_OCC2"].data<coral::Blob>();
665 const void* bxlumival_occ2_StartAddress=bxlumivalBlob_occ2.startingAddress();
666 float* bxlumival_occ2=(
float*)::malloc(bxlumivalBlob_occ2.size());
667 std::memmove(bxlumival_occ2,bxlumival_occ2_StartAddress,bxlumivalBlob_occ2.size());
668 std::vector<float> bxlumivalVec_occ2(bxlumival_occ2,bxlumival_occ2+bxlumivalBlob_occ1.size()/
sizeof(float));
669 ::free(bxlumival_occ2);
670 lsdata.bunchlumivalue.push_back(std::make_pair(
std::string(
"OCC2"),bxlumivalVec_occ2));
671 lsdata.bunchlumierror.push_back(std::make_pair(
std::string(
"OCC2"),std::vector<float>(3564)));
672 lsdata.bunchlumiquality.push_back(std::make_pair(
std::string(
"OCC2"),std::vector<short>(3564)));
674 const coral::Blob& bxlumivalBlob_et=row[
"BXLUMIVALUE_ET"].data<coral::Blob>();
675 const void* bxlumival_et_StartAddress=bxlumivalBlob_et.startingAddress();
676 float* bxlumival_et=(
float*)::malloc(bxlumivalBlob_et.size());
677 std::memmove(bxlumival_et,bxlumival_et_StartAddress,bxlumivalBlob_et.size());
678 std::vector<float> bxlumivalVec_et(bxlumival_et,bxlumival_et+bxlumivalBlob_et.size()/
sizeof(float));
679 ::free(bxlumival_et);
680 lsdata.bunchlumivalue.push_back(std::make_pair(
std::string(
"ET"),bxlumivalVec_et));
681 lsdata.bunchlumierror.push_back(std::make_pair(
std::string(
"ET"),std::vector<float>(3564)));
682 lsdata.bunchlumiquality.push_back(std::make_pair(
std::string(
"ET"),std::vector<short>(3564)));
690 delete lumisummaryQuery;
695 coral::AttributeList trgBindVariables;
696 trgBindVariables.extend(
"lsmin",
typeid(
unsigned int));
697 trgBindVariables.extend(
"lsmax",
typeid(
unsigned int));
698 trgBindVariables.extend(
"trgdataid",
typeid(
unsigned long long));
699 trgBindVariables[
"lsmin"].data<
unsigned int>()=luminum;
700 trgBindVariables[
"lsmax"].data<
unsigned int>()=luminum+m_cachesize;
702 coral::AttributeList trgOutput;
703 trgOutput.extend(
"CMSLSNUM",
typeid(
unsigned int));
704 trgOutput.extend(
"DEADTIMECOUNT",
typeid(
unsigned long long));
705 trgOutput.extend(
"BITZEROCOUNT",
typeid(
unsigned int));
706 trgOutput.extend(
"BITZEROPRESCALE",
typeid(
unsigned int));
707 trgOutput.extend(
"PRESCALEBLOB",
typeid(coral::Blob));
708 trgOutput.extend(
"TRGCOUNTBLOB",
typeid(coral::Blob));
710 coral::IQuery* trgQuery=schema.newQuery();
712 trgQuery->addToOutputList(
"CMSLSNUM");
713 trgQuery->addToOutputList(
"DEADTIMECOUNT");
714 trgQuery->addToOutputList(
"BITZEROCOUNT");
715 trgQuery->addToOutputList(
"BITZEROPRESCALE");
716 trgQuery->addToOutputList(
"PRESCALEBLOB");
717 trgQuery->addToOutputList(
"TRGCOUNTBLOB");
718 trgQuery->setCondition(
"CMSLSNUM>=:lsmin AND CMSLSNUM<:lsmax AND DATA_ID=:trgdataid",trgBindVariables);
719 trgQuery->defineOutput(trgOutput);
720 coral::ICursor& trgcursor=trgQuery->execute();
721 while( trgcursor.next() ){
722 const coral::AttributeList& row=trgcursor.currentRow();
723 unsigned int cmslsnum=row[
"CMSLSNUM"].data<
unsigned int>();
725 lsdata.deadcount=row[
"DEADTIMECOUNT"].data<
unsigned long long>();
726 lsdata.bitzerocount=row[
"BITZEROCOUNT"].data<
unsigned int>();
727 lsdata.bitzeroprescale=row[
"BITZEROPRESCALE"].data<
unsigned int>();
728 if(!row[
"PRESCALEBLOB"].isNull()){
729 const coral::Blob& prescaleblob=row[
"PRESCALEBLOB"].data<coral::Blob>();
730 const void* prescaleblob_StartAddress=prescaleblob.startingAddress();
731 unsigned int*
prescales=(
unsigned int*)::malloc(prescaleblob.size());
732 std::memmove(prescales,prescaleblob_StartAddress,prescaleblob.size());
733 const coral::Blob& trgcountblob=row[
"TRGCOUNTBLOB"].data<coral::Blob>();
734 const void* trgcountblob_StartAddress=trgcountblob.startingAddress();
735 unsigned int* trgcounts=(
unsigned int*)::malloc(trgcountblob.size());
736 std::memmove(trgcounts,trgcountblob_StartAddress,trgcountblob.size());
737 for(
unsigned int i=0;
i<
sizeof(trgcounts)/
sizeof(
unsigned int);++
i){
740 l1tmp.prescale=prescales[
i];
741 l1tmp.ratecount=trgcounts[
i];
742 lsdata.l1data.push_back(l1tmp);
752 coral::AttributeList hltBindVariables;
753 hltBindVariables.extend(
"lsmin",
typeid(
unsigned int));
754 hltBindVariables.extend(
"lsmax",
typeid(
unsigned int));
755 hltBindVariables.extend(
"hltdataid",
typeid(
unsigned long long));
756 hltBindVariables[
"lsmin"].data<
unsigned int>()=luminum;
757 hltBindVariables[
"lsmax"].data<
unsigned int>()=luminum+m_cachesize;
759 coral::AttributeList hltOutput;
760 hltOutput.extend(
"CMSLSNUM",
typeid(
unsigned int));
761 hltOutput.extend(
"HLTCOUNTBLOB",
typeid(coral::Blob));
762 hltOutput.extend(
"HLTACCEPTBLOB",
typeid(coral::Blob));
763 hltOutput.extend(
"PRESCALEBLOB",
typeid(coral::Blob));
764 coral::IQuery* hltQuery=schema.newQuery();
766 hltQuery->addToOutputList(
"CMSLSNUM");
767 hltQuery->addToOutputList(
"HLTCOUNTBLOB");
768 hltQuery->addToOutputList(
"HLTACCEPTBLOB");
769 hltQuery->addToOutputList(
"PRESCALEBLOB");
770 hltQuery->setCondition(
"CMSLSNUM>=:lsmin AND CMSLSNUM<:lsmax AND DATA_ID=:hltdataid",hltBindVariables);
771 hltQuery->defineOutput(hltOutput);
772 coral::ICursor& hltcursor=hltQuery->execute();
773 while( hltcursor.next() ){
774 const coral::AttributeList& row=hltcursor.currentRow();
775 unsigned int cmslsnum=row[
"CMSLSNUM"].data<
unsigned int>();
777 if(!row[
"PRESCALEBLOB"].isNull()){
778 const coral::Blob& hltprescaleblob=row[
"PRESCALEBLOB"].data<coral::Blob>();
779 const void* hltprescaleblob_StartAddress=hltprescaleblob.startingAddress();
780 unsigned int* hltprescales=(
unsigned int*)::malloc(hltprescaleblob.size());
781 std::memmove(hltprescales,hltprescaleblob_StartAddress,hltprescaleblob.size());
782 const coral::Blob& hltcountblob=row[
"HLTCOUNTBLOB"].data<coral::Blob>();
783 const void* hltcountblob_StartAddress=hltcountblob.startingAddress();
784 unsigned int* hltcounts=(
unsigned int*)::malloc(hltcountblob.size());
785 std::memmove(hltcounts,hltcountblob_StartAddress,hltcountblob.size());
786 const coral::Blob& hltacceptblob=row[
"HLTACCEPTBLOB"].data<coral::Blob>();
787 const void* hltacceptblob_StartAddress=hltacceptblob.startingAddress();
788 unsigned int* hltaccepts=(
unsigned int*)::malloc(hltacceptblob.size());
789 std::memmove(hltaccepts,hltacceptblob_StartAddress,hltacceptblob.size());
790 unsigned int nhltaccepts =
sizeof(hltaccepts)/
sizeof(
unsigned int);
793 <<
" hltaccepts, but the run chache is empty. hltdata will not be written";
797 for(
unsigned int i=0;
i<
sizeof(hltaccepts)/
sizeof(
unsigned int);++
i){
800 hlttmp.prescale=hltprescales[
i];
801 hlttmp.l1passcount=hltcounts[
i];
802 hlttmp.acceptcount=hltaccepts[
i];
803 lsdata.hltdata.push_back(hlttmp);
805 ::free(hltprescales);
811 session->transaction().commit();
813 session->transaction().rollback();
static const std::string lshltTableName()
unsigned long long m_cachedhltdataid
static const std::string lstrgTableName()
unsigned long long m_cachedtrgdataid
void disconnect(coral::ISessionProxy *session)
unsigned long long m_cachedlumidataid
tuple idx
DEBUGGING if hasattr(process,"trackMonIterativeTracking2012"): print "trackMonIterativeTracking2012 D...
std::map< unsigned int, PerLSData > m_lscache
std::vector< std::string > TRGBitNames
static const std::string lumisummaryv2TableName()
coral::ISessionProxy * connectReadOnly(const std::string &connectstring)
std::vector< std::string > HLTPathNames