|
|
|
Classes | |
| struct | hltinfo |
Public Types | |
| typedef std::map< unsigned int, std::string, std::less < unsigned int > > | HltPathMap |
| typedef std::vector< std::map < unsigned int, HLTV32DB::hltinfo, std::less < unsigned int > > > | HltResult |
Public Member Functions | |
| virtual const std::string | dataType () const |
| HLTV32DB (const std::string &dest) | |
| virtual void | retrieveData (unsigned int) |
| virtual const std::string | sourceType () const |
| void | writeHltData (coral::ISessionProxy *lumisession, unsigned int irunnumber, const std::string &source, unsigned int npath, HltResult::iterator hltBeg, HltResult::iterator hltEnd, unsigned int commitintv) |
| void | writeHltDataToSchema2 (coral::ISessionProxy *lumisession, unsigned int irunnumber, const std::string &source, unsigned int npath, HltResult::iterator hltBeg, HltResult::iterator hltEnd, HltPathMap &hltpathmap, unsigned int commitintv) |
| virtual | ~HLTV32DB () |
Static Public Attributes | |
| static const unsigned int | COMMITINTERVAL = 200 |
| static const unsigned int | COMMITLSINTERVAL = 500 |
Definition at line 34 of file HLTV32DB.cc.
| typedef std::map< unsigned int, std::string , std::less<unsigned int> > lumi::HLTV32DB::HltPathMap |
Definition at line 52 of file HLTV32DB.cc.
| typedef std::vector< std::map<unsigned int,HLTV32DB::hltinfo,std::less<unsigned int> > > lumi::HLTV32DB::HltResult |
Definition at line 53 of file HLTV32DB.cc.
| lumi::HLTV32DB::HLTV32DB | ( | const std::string & | dest | ) | [explicit] |
Definition at line 76 of file HLTV32DB.cc.
| lumi::HLTV32DB::~HLTV32DB | ( | ) | [virtual] |
Definition at line 506 of file HLTV32DB.cc.
{}
| const std::string lumi::HLTV32DB::dataType | ( | ) | const [virtual] |
| void lumi::HLTV32DB::retrieveData | ( | unsigned int | runnumber | ) | [virtual] |
retrieve hlt info with 3 queries from runinfo 1. select distinct ( PATHID ) from HLT_SUPERVISOR_TRIGGERPATHS where runnumber=158878; 2. retrieve hltpath map with n query from cms_hlt (n=number of pathids) select name from cms_hlt.paths where pathid=:pathid 3. select min(lsnumber),max(lsnumber) from HLT_SUPERVISOR_LUMISECTIONS_V3 where runnumber=158878; 4. select tr.lsnumber,tr.pathid,tr.l1pass,tr.paccept,ls.psindex,sm.psvalue from hlt_supervisor_triggerpaths tr,hlt_supervisor_lumisections_v3 ls,hlt_supervisor_scalar_map_v2 sm where tr.runnumber=ls.runnumber and tr.lsnumber=ls.lsnumber and sm.runnumber=tr.runnumber and sm.pathid=tr.pathid and sm.psindex=ls.psindex and tr.runnumber=157805 order by tr.lsnumber;
Implements lumi::DataPipe.
Definition at line 77 of file HLTV32DB.cc.
References trackerHits::c, lumi::HLTV32DB::hltinfo::cmsluminr, COMMITINTERVAL, COMMITLSINTERVAL, gather_cfg::cout, python::DBCopy::destsession, Exception, lumi::HLTV32DB::hltinfo::hltaccept, lumi::HLTV32DB::hltinfo::hltinput, i, lumi::DataPipe::m_authpath, lumi::DataPipe::m_dest, lumi::DataPipe::m_mode, lumi::DataPipe::m_source, timingPdfMaker::pathname, lumi::HLTV32DB::hltinfo::pathname, lumi::HLTV32DB::hltinfo::prescale, q1, lumi::DBConfig::setAuthentication(), python::CommonUtils::svc, writeHltData(), and writeHltDataToSchema2().
{
std::string confdbschema("CMS_HLT");
std::string hltschema("CMS_RUNINFO");
std::string confdbpathtabname("PATHS");
std::string triggerpathtabname("HLT_SUPERVISOR_TRIGGERPATHS");
std::string lstabname("HLT_SUPERVISOR_LUMISECTIONS_V3");
std::string maptabname("HLT_SUPERVISOR_SCALAR_MAP_V2");
coral::ConnectionService* svc=new coral::ConnectionService;
lumi::DBConfig dbconf(*svc);
if(!m_authpath.empty()){
dbconf.setAuthentication(m_authpath);
}
//std::cout<<"m_source "<<m_source<<std::endl;
//std::cout<<"m_source "<<m_source<<std::endl;
std::string::size_type cutpos=m_source.find(';');
std::string dbsource=m_source;
std::string csvsource("");
if(cutpos!=std::string::npos){
dbsource=m_source.substr(0,cutpos);
csvsource=m_source.substr(cutpos+1);
}
//std::cout<<"dbsource: "<<dbsource<<" , csvsource: "<<csvsource<<std::endl;
coral::ISessionProxy* srcsession=svc->connect(dbsource, coral::ReadOnly);
coral::ITypeConverter& tpc=srcsession->typeConverter();
tpc.setCppTypeForSqlType("unsigned int","NUMBER(11)");
srcsession->transaction().start(true);
coral::ISchema& hltSchemaHandle=srcsession->schema(hltschema);
coral::ISchema& confdbSchemaHandle=srcsession->schema(confdbschema);
if( !hltSchemaHandle.existsTable(triggerpathtabname) || !hltSchemaHandle.existsTable(lstabname) || !hltSchemaHandle.existsTable(maptabname) ){
throw lumi::Exception("missing hlt tables" ,"retrieveData","HLTV32DB");
}
HltPathMap hltpathmap;
coral::AttributeList bindVariableList;
bindVariableList.extend("runnumber",typeid(unsigned int));
bindVariableList["runnumber"].data<unsigned int>()=runnumber;
coral::IQuery* q1=hltSchemaHandle.tableHandle(triggerpathtabname).newQuery();
coral::AttributeList hltpathid;
hltpathid.extend("hltpathid",typeid(unsigned int));
q1->addToOutputList("distinct PATHID","hltpathid");
q1->setCondition("RUNNUMBER =:runnumber",bindVariableList);
q1->defineOutput(hltpathid);
coral::ICursor& c=q1->execute();
unsigned int npc=0;
while( c.next() ){
npc++;
unsigned int hid=c.currentRow()["hltpathid"].data<unsigned int>();
hltpathmap.insert(std::make_pair(hid,""));
}
delete q1;
HltPathMap::iterator mpit;
HltPathMap::iterator mpitBeg=hltpathmap.begin();
HltPathMap::iterator mpitEnd=hltpathmap.end();
for( mpit=mpitBeg;mpit!=mpitEnd;++mpit){
coral::IQuery* mq=confdbSchemaHandle.newQuery();
coral::AttributeList mqbindVariableList;
mqbindVariableList.extend("pathid",typeid(unsigned int));
mqbindVariableList["pathid"].data<unsigned int>()=mpit->first;
mq->addToTableList(confdbpathtabname);
mq->addToOutputList("NAME","hltpathname");
mq->setCondition("PATHID=:pathid",mqbindVariableList);
coral::ICursor& mqcursor=mq->execute();
while( mqcursor.next() ){
std::string pathname=mqcursor.currentRow()["hltpathname"].data<std::string>();
hltpathmap[mpit->first]=pathname;
}
delete mq;
}
//for( mpit=mpitBeg;mpit!=mpitEnd;++mpit){
// std::cout<<mpit->first<<" "<<mpit->second<<std::endl;
//}
unsigned int maxls=0;
unsigned int minls=0;
unsigned int nls=0;
coral::IQuery* nq=hltSchemaHandle.tableHandle(lstabname).newQuery();
coral::AttributeList nqbindVariableList;
coral::AttributeList nqout;
nqout.extend("minls",typeid(unsigned int));
nqout.extend("maxls",typeid(unsigned int));
nqbindVariableList.extend("runnumber",typeid(unsigned int));
nqbindVariableList["runnumber"].data<unsigned int>()=runnumber;
nq->addToOutputList("min(lsnumber)","minls");
nq->addToOutputList("max(lsnumber)","maxls");
nq->setCondition("RUNNUMBER =:runnumber",nqbindVariableList);
nq->defineOutput(nqout);
coral::ICursor& nqcursor=nq->execute();
while( nqcursor.next() ){
minls=nqcursor.currentRow()["minls"].data<unsigned int>();
maxls=nqcursor.currentRow()["maxls"].data<unsigned int>();
}
delete nq;
//std::cout<<"nls "<<nls<<std::endl;
HltResult hltresult;
nls=maxls-minls+1;
std::cout<<"nls "<<nls<<std::endl;
hltresult.reserve(nls);//
//fix all size
for(unsigned int i=minls;i<=maxls;++i){
if (i==0) continue; //skip ls=0
std::map<unsigned int, HLTV32DB::hltinfo> allpaths;
HltPathMap::iterator aIt;
HltPathMap::iterator aItBeg=hltpathmap.begin();
HltPathMap::iterator aItEnd=hltpathmap.end();
for(aIt=aItBeg;aIt!=aItEnd;++aIt){
HLTV32DB::hltinfo ct;
ct.cmsluminr=i;
ct.pathname=aIt->second;
ct.hltinput=0;
ct.hltaccept=0;
ct.prescale=0;
allpaths.insert(std::make_pair(aIt->first,ct));
}
hltresult.push_back(allpaths);
}
//std::cout<<"book hltresult size "<<hltresult.size()<<std::endl;
coral::IQuery* jq=hltSchemaHandle.newQuery();
coral::AttributeList jqbindVariableList;
jqbindVariableList.extend("runnumber",typeid(unsigned int));
jqbindVariableList["runnumber"].data<unsigned int>()=runnumber;
coral::AttributeList jqoutput;
jqoutput.extend("lsnumber",typeid(unsigned int));
jqoutput.extend("pathid",typeid(unsigned int));
jqoutput.extend("l1pass",typeid(unsigned int));
jqoutput.extend("paccept",typeid(unsigned int));
jqoutput.extend("psvalue",typeid(unsigned int));
jq->addToTableList(triggerpathtabname,"tr");
jq->addToTableList(lstabname,"ls");
jq->addToTableList(maptabname,"sm");
jq->addToOutputList("tr.LSNUMBER","lsnumber");
jq->addToOutputList("tr.PATHID","pathid");
jq->addToOutputList("tr.L1PASS","l1pass");
jq->addToOutputList("tr.PACCEPT","paccept");
jq->addToOutputList("sm.PSVALUE","psvalue");
jq->setCondition("tr.RUNNUMBER=ls.RUNNUMBER AND tr.LSNUMBER=ls.LSNUMBER and sm.RUNNUMBER=tr.RUNNUMBER and sm.PATHID=tr.PATHID and sm.PSINDEX=ls.PSINDEX and tr.RUNNUMBER=:runnumber",jqbindVariableList);
jq->defineOutput(jqoutput);
jq->addToOrderList("tr.LSNUMBER");
jq->setRowCacheSize(10692);
coral::ICursor& jqcursor=jq->execute();
bool lscountfromzero=false;
while( jqcursor.next() ){
const coral::AttributeList& row=jqcursor.currentRow();
unsigned int currentLumiSection=row["lsnumber"].data<unsigned int>();
if (currentLumiSection==0){
lscountfromzero=true;
}else{
std::map<unsigned int,hltinfo>& allpathinfo=hltresult.at(currentLumiSection-1);
unsigned int pathid=row["pathid"].data<unsigned int>();
//std::cout<<"look for path id "<<pathid<<std::endl;
hltinfo& pathcontent=allpathinfo[pathid];
pathcontent.hltinput=row["l1pass"].data<unsigned int>();
pathcontent.hltaccept=row["paccept"].data<unsigned int>();
pathcontent.prescale=row["psvalue"].data<unsigned int>();
}
}
if(lscountfromzero) {
std::cout<<"hlt ls count from 0 , we skip/dodge/parry it!"<<std::endl;
}
delete jq;
srcsession->transaction().commit();
delete srcsession;
//
// Write into DB
//
unsigned int npath=hltpathmap.size();
coral::ISessionProxy* destsession=svc->connect(m_dest,coral::Update);
coral::ITypeConverter& lumitpc=destsession->typeConverter();
lumitpc.setCppTypeForSqlType("unsigned int","NUMBER(7)");
lumitpc.setCppTypeForSqlType("unsigned int","NUMBER(10)");
lumitpc.setCppTypeForSqlType("unsigned long long","NUMBER(20)");
//for(hltIt=hltItBeg;hltIt!=hltItEnd;++hltIt){
// std::map<unsigned int,HLTV32DB::hltinfo>::iterator pathIt;
// std::map<unsigned int,HLTV32DB::hltinfo>::iterator pathItBeg=hltIt->begin();
// std::map<unsigned int,HLTV32DB::hltinfo>::iterator pathItEnd=hltIt->end();
// for(pathIt=pathItBeg;pathIt!=pathItEnd;++pathIt){
// std::cout<<"cmslsnr "<<pathIt->second.cmsluminr<<" "<<pathIt->second.pathname<<" "<<pathIt->second.hltinput<<" "<<pathIt->second.hltaccept<<" "<<pathIt->second.prescale<<std::endl;
// }
//}
unsigned int totalcmsls=hltresult.size();
std::cout<<"inserting totalhltls "<<totalcmsls<<" total path "<<npath<<std::endl;
//HltResult::iterator hltItBeg=hltresult.begin();
//HltResult::iterator hltItEnd=hltresult.end();
try{
if(m_mode=="loadoldschema"){
std::cout<<"writing hlt data to old hlt table"<<std::endl;
writeHltData(destsession,runnumber,dbsource,npath,hltresult.begin(),hltresult.end(),COMMITINTERVAL);
std::cout<<"done"<<std::endl;
}
std::cout<<"writing hlt data to new lshlt table"<<std::endl;
writeHltDataToSchema2(destsession,runnumber,dbsource,npath,hltresult.begin(),hltresult.end(), hltpathmap,COMMITLSINTERVAL);
std::cout<<"done"<<std::endl;
delete destsession;
delete svc;
}catch( const coral::Exception& er){
std::cout<<"database problem "<<er.what()<<std::endl;
destsession->transaction().rollback();
delete destsession;
delete svc;
throw er;
}
}
| const std::string lumi::HLTV32DB::sourceType | ( | ) | const [virtual] |
| void lumi::HLTV32DB::writeHltData | ( | coral::ISessionProxy * | lumisession, |
| unsigned int | irunnumber, | ||
| const std::string & | source, | ||
| unsigned int | npath, | ||
| HltResult::iterator | hltBeg, | ||
| HltResult::iterator | hltEnd, | ||
| unsigned int | commitintv | ||
| ) |
Definition at line 288 of file HLTV32DB.cc.
References estimatePileup2::cmslsnum, gather_cfg::cout, lumi::idDealer::generateNextIDForTable(), lumi::LumiNames::hltTableName(), i, and timingPdfMaker::pathname.
Referenced by retrieveData().
{
std::map< unsigned long long, std::vector<unsigned long long> > idallocationtable;
unsigned int hltlscount=0;
unsigned int totalcmsls=std::distance(hltItBeg,hltItEnd);
std::cout<<"\t allocating total ids "<<totalcmsls*npath<<std::endl;
lumisession->transaction().start(false);
lumi::idDealer idg(lumisession->nominalSchema());
unsigned long long hltID = idg.generateNextIDForTable(LumiNames::hltTableName(),totalcmsls*npath)-totalcmsls*npath;
for(HltResult::iterator hltIt=hltItBeg;hltIt!=hltItEnd;++hltIt,++hltlscount){
std::vector<unsigned long long> pathvec;
pathvec.reserve(npath);
for(unsigned int i=0;i<npath;++i,++hltID){
pathvec.push_back(hltID);
}
idallocationtable.insert(std::make_pair(hltlscount,pathvec));
}
std::cout<<"\t all ids allocated"<<std::endl;
coral::AttributeList hltData;
hltData.extend("HLT_ID",typeid(unsigned long long));
hltData.extend("RUNNUM",typeid(unsigned int));
hltData.extend("CMSLSNUM",typeid(unsigned int));
hltData.extend("PATHNAME",typeid(std::string));
hltData.extend("INPUTCOUNT",typeid(unsigned int));
hltData.extend("ACCEPTCOUNT",typeid(unsigned int));
hltData.extend("PRESCALE",typeid(unsigned int));
//loop over lumi LS
unsigned long long& hlt_id=hltData["HLT_ID"].data<unsigned long long>();
unsigned int& hltrunnum=hltData["RUNNUM"].data<unsigned int>();
unsigned int& cmslsnum=hltData["CMSLSNUM"].data<unsigned int>();
std::string& pathname=hltData["PATHNAME"].data<std::string>();
unsigned int& inputcount=hltData["INPUTCOUNT"].data<unsigned int>();
unsigned int& acceptcount=hltData["ACCEPTCOUNT"].data<unsigned int>();
unsigned int& prescale=hltData["PRESCALE"].data<unsigned int>();
hltlscount=0;
coral::IBulkOperation* hltInserter=0;
unsigned int comittedls=0;
for(HltResult::iterator hltIt=hltItBeg;hltIt!=hltItEnd;++hltIt,++hltlscount){
std::map<unsigned int,HLTV32DB::hltinfo>::const_iterator pathIt;
std::map<unsigned int,HLTV32DB::hltinfo>::const_iterator pathBeg=hltIt->begin();
std::map<unsigned int,HLTV32DB::hltinfo>::const_iterator pathEnd=hltIt->end();
if(!lumisession->transaction().isActive()){
lumisession->transaction().start(false);
coral::ITable& hlttable=lumisession->nominalSchema().tableHandle(LumiNames::hltTableName());
hltInserter=hlttable.dataEditor().bulkInsert(hltData,npath);
}else{
if(hltIt==hltItBeg){
coral::ITable& hlttable=lumisession->nominalSchema().tableHandle(LumiNames::hltTableName());
hltInserter=hlttable.dataEditor().bulkInsert(hltData,npath);
}
}
unsigned int hltpathcount=0;
for(pathIt=pathBeg;pathIt!=pathEnd;++pathIt,++hltpathcount){
hlt_id = idallocationtable[hltlscount].at(hltpathcount);
hltrunnum = irunnumber;
cmslsnum = pathIt->second.cmsluminr;
pathname = pathIt->second.pathname;
inputcount = pathIt->second.hltinput;
acceptcount = pathIt->second.hltaccept;
prescale = pathIt->second.prescale;
hltInserter->processNextIteration();
}
hltInserter->flush();
++comittedls;
if(comittedls==commitintv){
std::cout<<"\t committing in LS chunck "<<comittedls<<std::endl;
delete hltInserter; hltInserter=0;
lumisession->transaction().commit();
comittedls=0;
std::cout<<"\t committed "<<std::endl;
}else if( hltlscount==(totalcmsls-1) ){
std::cout<<"\t committing at the end"<<std::endl;
delete hltInserter; hltInserter=0;
lumisession->transaction().commit();
std::cout<<"\t done"<<std::endl;
}
}
}
| void lumi::HLTV32DB::writeHltDataToSchema2 | ( | coral::ISessionProxy * | lumisession, |
| unsigned int | irunnumber, | ||
| const std::string & | source, | ||
| unsigned int | npath, | ||
| HltResult::iterator | hltBeg, | ||
| HltResult::iterator | hltEnd, | ||
| HltPathMap & | hltpathmap, | ||
| unsigned int | commitintv | ||
| ) |
Definition at line 374 of file HLTV32DB.cc.
References lumi::RevisionDML::addEntry(), lumi::RevisionDML::addRevision(), lumi::RevisionDML::bookNewEntry(), lumi::RevisionDML::bookNewRevision(), estimatePileup2::cmslsnum, gather_cfg::cout, lumi::RevisionDML::Entry::data_id, lumi::RevisionDML::Entry::entry_id, lumi::RevisionDML::Entry::entry_name, lumi::RevisionDML::getEntryInBranchByName(), nameDealer::hltdataTableName(), dataDML::hltrundata, lumi::RevisionDML::insertHltRunData(), lumi::LumiNames::lshltTableName(), lumi::RevisionDML::HltEntry::npath, lumiPlot::pathnames, lumi::RevisionDML::HltEntry::pathnames, makeHLTPrescaleTable::prescales, lumi::RevisionDML::Entry::revision_id, lumi::RevisionDML::HltEntry::runnumber, lumi::RevisionDML::HltEntry::source, and LaserTracksInput_cfi::source.
Referenced by retrieveData().
{
HltResult::iterator hltIt;
unsigned int totalcmsls=std::distance(hltItBeg,hltItEnd);
std::cout<<"inserting totalcmsls "<<totalcmsls<<std::endl;
coral::AttributeList lshltData;
lshltData.extend("DATA_ID",typeid(unsigned long long));
lshltData.extend("RUNNUM",typeid(unsigned int));
lshltData.extend("CMSLSNUM",typeid(unsigned int));
lshltData.extend("PRESCALEBLOB",typeid(coral::Blob));
lshltData.extend("HLTCOUNTBLOB",typeid(coral::Blob));
lshltData.extend("HLTACCEPTBLOB",typeid(coral::Blob));
unsigned long long& data_id=lshltData["DATA_ID"].data<unsigned long long>();
unsigned int& hltrunnum=lshltData["RUNNUM"].data<unsigned int>();
unsigned int& cmslsnum=lshltData["CMSLSNUM"].data<unsigned int>();
coral::Blob& prescaleblob=lshltData["PRESCALEBLOB"].data<coral::Blob>();
coral::Blob& hltcountblob=lshltData["HLTCOUNTBLOB"].data<coral::Blob>();
coral::Blob& hltacceptblob=lshltData["HLTACCEPTBLOB"].data<coral::Blob>();
unsigned long long branch_id=3;
std::string branch_name("DATA");
lumi::RevisionDML revisionDML;
lumi::RevisionDML::HltEntry hltrundata;
std::stringstream op;
op<<irunnumber;
std::string runnumberStr=op.str();
lumisession->transaction().start(false);
hltrundata.entry_name=runnumberStr;
hltrundata.source=source;
hltrundata.runnumber=irunnumber;
hltrundata.npath=npath;
std::string pathnames;
HltPathMap::iterator hltpathmapIt;
HltPathMap::iterator hltpathmapItBeg=hltpathmap.begin();
HltPathMap::iterator hltpathmapItEnd=hltpathmap.end();
for(hltpathmapIt=hltpathmapItBeg;hltpathmapIt!=hltpathmapItEnd;++hltpathmapIt){
if(hltpathmapIt!=hltpathmapItBeg){
pathnames+=std::string(",");
}
pathnames+=hltpathmapIt->second;
}
std::cout<<"\tpathnames "<<pathnames<<std::endl;
hltrundata.pathnames=pathnames;
hltrundata.entry_id=revisionDML.getEntryInBranchByName(lumisession->nominalSchema(),lumi::LumiNames::hltdataTableName(),runnumberStr,branch_name);
if(hltrundata.entry_id==0){
revisionDML.bookNewEntry(lumisession->nominalSchema(),LumiNames::hltdataTableName(),hltrundata);
std::cout<<"hltrundata revision_id "<<hltrundata.revision_id<<" entry_id "<<hltrundata.entry_id<<" data_id "<<hltrundata.data_id<<std::endl;
revisionDML.addEntry(lumisession->nominalSchema(),LumiNames::hltdataTableName(),hltrundata,branch_id,branch_name);
}else{
revisionDML.bookNewRevision(lumisession->nominalSchema(),LumiNames::hltdataTableName(),hltrundata);
std::cout<<"hltrundata revision_id "<<hltrundata.revision_id<<" entry_id "<<hltrundata.entry_id<<" data_id "<<hltrundata.data_id<<std::endl;
revisionDML.addRevision(lumisession->nominalSchema(),LumiNames::hltdataTableName(),hltrundata,branch_id,branch_name);
}
std::cout<<"inserting hltrundata"<<std::endl;
revisionDML.insertHltRunData(lumisession->nominalSchema(),hltrundata);
std::cout<<"inserting lshlt data"<<std::endl;
unsigned int hltlscount=0;
coral::IBulkOperation* hltInserter=0;
unsigned int comittedls=0;
for(HltResult::iterator hltIt=hltItBeg;hltIt!=hltItEnd;++hltIt,++hltlscount){
unsigned int cmslscount=hltlscount+1;
std::map<unsigned int,HLTV32DB::hltinfo,std::less<unsigned int> >::const_iterator pathIt;
std::map<unsigned int,HLTV32DB::hltinfo,std::less<unsigned int> >::const_iterator pathBeg=hltIt->begin();
std::map<unsigned int,HLTV32DB::hltinfo,std::less<unsigned int> >::const_iterator pathEnd=hltIt->end();
if(!lumisession->transaction().isActive()){
lumisession->transaction().start(false);
coral::ITable& hlttable=lumisession->nominalSchema().tableHandle(LumiNames::lshltTableName());
hltInserter=hlttable.dataEditor().bulkInsert(lshltData,npath);
}else{
if(hltIt==hltItBeg){
coral::ITable& hlttable=lumisession->nominalSchema().tableHandle(LumiNames::lshltTableName());
hltInserter=hlttable.dataEditor().bulkInsert(lshltData,npath);
}
}
data_id = hltrundata.data_id;
hltrunnum = irunnumber;
cmslsnum = cmslscount;
std::vector<unsigned int> prescales; prescales.reserve(npath);
std::vector<unsigned int> hltcounts; hltcounts.reserve(npath);
std::vector<unsigned int> hltaccepts; hltaccepts.reserve(npath);
for(pathIt=pathBeg;pathIt!=pathEnd;++pathIt){
unsigned int hltcount=pathIt->second.hltinput;
//std::cout<<"hltcount "<<hltcount<<std::endl;
hltcounts.push_back(hltcount);
unsigned int hltaccept=pathIt->second.hltaccept;
//std::cout<<"hltaccept "<<hltaccept<<std::endl;
hltaccepts.push_back(hltaccept);
unsigned int prescale=pathIt->second.prescale;
//std::cout<<"prescale "<<prescale<<std::endl;
prescales.push_back(prescale);
}
prescaleblob.resize(sizeof(unsigned int)*npath);
void* prescaleblob_StartAddress = prescaleblob.startingAddress();
std::memmove(prescaleblob_StartAddress,&prescales[0],sizeof(unsigned int)*npath);
hltcountblob.resize(sizeof(unsigned int)*npath);
void* hltcountblob_StartAddress = hltcountblob.startingAddress();
std::memmove(hltcountblob_StartAddress,&hltcounts[0],sizeof(unsigned int)*npath);
hltacceptblob.resize(sizeof(unsigned int)*npath);
void* hltacceptblob_StartAddress = hltacceptblob.startingAddress();
std::memmove(hltacceptblob_StartAddress,&hltaccepts[0],sizeof(unsigned int)*npath);
hltInserter->processNextIteration();
hltInserter->flush();
++comittedls;
if(comittedls==commitintv){
std::cout<<"\t committing in LS chunck "<<comittedls<<std::endl;
delete hltInserter; hltInserter=0;
lumisession->transaction().commit();
comittedls=0;
std::cout<<"\t committed "<<std::endl;
}else if( hltlscount==(totalcmsls-1) ){
std::cout<<"\t committing at the end"<<std::endl;
delete hltInserter; hltInserter=0;
lumisession->transaction().commit();
std::cout<<"\t done"<<std::endl;
}
}
}
const unsigned int lumi::HLTV32DB::COMMITINTERVAL = 200 [static] |
Definition at line 37 of file HLTV32DB.cc.
Referenced by retrieveData().
const unsigned int lumi::HLTV32DB::COMMITLSINTERVAL = 500 [static] |
Definition at line 38 of file HLTV32DB.cc.
Referenced by retrieveData().
1.7.3