|
|
|
#include <EcalTPGPhysicsConstHandler.h>
Public Member Functions | |
| EcalTPGPhysicsConstHandler (edm::ParameterSet const &) | |
| void | getNewObjects () |
| std::string | id () const |
| void | readFromFile (const char *inputFile) |
| void | writeFile (const char *inputFile) |
| ~EcalTPGPhysicsConstHandler () | |
Public Attributes | |
| EcalCondDBInterface * | econn |
Private Member Functions | |
| std::string | to_string (char value[]) |
Private Attributes | |
| unsigned int | m_firstRun |
| std::string | m_gentag |
| int | m_i_physCfgr |
| int | m_i_physClin |
| int | m_i_physClut |
| unsigned int | m_i_run_number |
| std::string | m_i_tag |
| int | m_i_version |
| unsigned int | m_lastRun |
| std::string | m_location |
| std::string | m_locationsource |
| std::string | m_name |
| std::string | m_pass |
| const EcalTPGPhysicsConst * | m_physicsConst |
| unsigned int | m_runnr |
| std::string | m_runtype |
| std::string | m_sid |
| std::string | m_user |
Definition at line 49 of file EcalTPGPhysicsConstHandler.h.
| popcon::EcalTPGPhysicsConstHandler::EcalTPGPhysicsConstHandler | ( | edm::ParameterSet const & | ps | ) |
Definition at line 14 of file EcalTPGPhysicsConstHandler.cc.
References edm::ParameterSet::getParameter(), m_firstRun, m_gentag, m_lastRun, m_location, m_locationsource, m_pass, m_runtype, m_sid, and m_user.
: m_name(ps.getUntrackedParameter<std::string>("name","EcalTPGPhysicsConstHandler")) { edm::LogInfo("EcalTPGPhysicsConstHandler") << "EcalTPGPhysicsConst Source handler constructor."; m_firstRun=static_cast<unsigned int>(atoi( ps.getParameter<std::string>("firstRun").c_str())); m_lastRun=static_cast<unsigned int>(atoi( ps.getParameter<std::string>("lastRun").c_str())); m_sid= ps.getParameter<std::string>("OnlineDBSID"); m_user= ps.getParameter<std::string>("OnlineDBUser"); m_pass= ps.getParameter<std::string>("OnlineDBPassword"); m_locationsource= ps.getParameter<std::string>("LocationSource"); m_location=ps.getParameter<std::string>("Location"); m_gentag=ps.getParameter<std::string>("GenTag"); m_runtype=ps.getParameter<std::string>("RunType"); edm::LogInfo("EcalTPGPhysicsConstHandler")<< m_sid<<"/"<<m_user<<"/"<<m_location<<"/"<<m_gentag; }
| popcon::EcalTPGPhysicsConstHandler::~EcalTPGPhysicsConstHandler | ( | ) |
Definition at line 32 of file EcalTPGPhysicsConstHandler.cc.
{
}
| void popcon::EcalTPGPhysicsConstHandler::getNewObjects | ( | ) | [virtual] |
Implements popcon::PopConSourceHandler< EcalTPGPhysicsConst >.
Definition at line 37 of file EcalTPGPhysicsConstHandler.cc.
References prof2calltree::count, gather_cfg::cout, dtDQMMerge_cfg::dataset, alignCSCRings::e, DetId::Ecal, EcalBarrel, EcalEndcap, EcalTPGPhysicsConst::Item::EtSat, exception, Exception, EcalTPGPhysicsConst::Item::FG_highRatio, EcalTPGPhysicsConst::Item::FG_highThreshold, EcalTPGPhysicsConst::Item::FG_lowRatio, EcalTPGPhysicsConst::Item::FG_lowThreshold, RunTPGConfigDat::getConfigTag(), FEConfigLinParamDat::getETSat(), FEConfigLUTParamDat::getETSat(), FEConfigFgrParamDat::getFGhighratio(), FEConfigFgrParamDat::getFGhighthresh(), FEConfigFgrParamDat::getFGlowratio(), FEConfigFgrParamDat::getFGlowthresh(), FEConfigMainInfo::getFgrId(), FEConfigMainInfo::getLinId(), FEConfigMainInfo::getLUTId(), EcalLogicID::getName(), RunList::getRuns(), FEConfigLUTParamDat::getTTThreshhigh(), FEConfigLUTParamDat::getTTThreshlow(), RunTPGConfigDat::getVersion(), p1, p2, DetId::rawId(), IODConfig::setConfigTag(), RunTag::setGeneralTag(), FEConfigLUTInfo::setId(), FEConfigLinInfo::setId(), FEConfigFgrInfo::setId(), LocationDef::setLocation(), RunTag::setLocationDef(), RunTypeDef::setRunType(), RunTag::setRunTypeDef(), EcalTPGPhysicsConst::setValue(), FEConfigMainInfo::setVersion(), findQualityFiles::size, EcalTPGPhysicsConst::Item::ttf_threshold_High, and EcalTPGPhysicsConst::Item::ttf_threshold_Low.
{
edm::LogInfo("EcalTPGPhysicsConstHandler") << "Started GetNewObjects!!!";
//check whats already inside of database
if (tagInfo().size){
//check whats already inside of database
std::cout << "got offlineInfo = " << std::endl;
std::cout << "tag name = " << tagInfo().name << std::endl;
std::cout << "size = " << tagInfo().size << std::endl;
} else {
std::cout << " First object for this tag " << std::endl;
}
unsigned int max_since=0;
max_since=static_cast<unsigned int>(tagInfo().lastInterval.first);
edm::LogInfo("EcalTPGPhysicsConstHandler") << "max_since : " << max_since;
Ref physC_db = lastPayload();
edm::LogInfo("EcalTPGPhysicsConstHandler") << "retrieved last payload ";
// here we retrieve all the runs after the last from online DB
edm::LogInfo("EcalTPGPhysicsConstHandler") << "Retrieving run list from ONLINE DB ... ";
edm::LogInfo("EcalTPGPhysicsConstHandler") << "Making connection...";
econn = new EcalCondDBInterface( m_sid, m_user, m_pass );
edm::LogInfo("EcalTPGPhysicsConstHandler") << "Done.";
if (!econn)
{
std::cout << " connection parameters " <<m_sid <<"/"<<m_user<<std::endl;
// cerr << e.what() << std::endl;
throw cms::Exception("OMDS not available");
}
LocationDef my_locdef;
my_locdef.setLocation(m_location);
RunTypeDef my_rundef;
my_rundef.setRunType(m_runtype);
RunTag my_runtag;
my_runtag.setLocationDef( my_locdef );
my_runtag.setRunTypeDef( my_rundef );
my_runtag.setGeneralTag(m_gentag);
readFromFile("last_tpg_physC_settings.txt");
unsigned int min_run=m_i_run_number+1;
if(m_firstRun<m_i_run_number) {
min_run=m_i_run_number+1;
} else {
min_run=m_firstRun;
}
std::cout<<"m_i_run_number"<< m_i_run_number <<"m_firstRun "<<m_firstRun<< "max_since " <<max_since<< std::endl;
if(min_run<max_since) {
min_run= max_since+1; // we have to add 1 to the last transferred one
}
unsigned int max_run=m_lastRun;
edm::LogInfo("EcalTPGPhysicsConstHandler") << "min_run= " << min_run << "max_run= " << max_run;
RunList my_list;
my_list=econn->fetchGlobalRunListByLocation(my_runtag, min_run, max_run, my_locdef);
// my_list=econn->fetchRunListByLocation(my_runtag,min_run,max_run,my_locdef);
std::vector<RunIOV> run_vec= my_list.getRuns();
size_t num_runs=run_vec.size();
std::cout <<"number of runs is : "<< num_runs<< std::endl;
unsigned int irun;
if(num_runs>0){
for(size_t kr=0; kr<run_vec.size(); kr++){
irun=static_cast<unsigned int>(run_vec[kr].getRunNumber());
std::cout<<" **************** "<<std::endl;
std::cout<<" **************** "<<std::endl;
std::cout<<" run= "<<irun<<std::endl;
// retrieve the data :
std::map<EcalLogicID, RunTPGConfigDat> dataset;
econn->fetchDataSet(&dataset, &run_vec[kr]);
std::string the_config_tag="";
int the_config_version=0;
std::map< EcalLogicID, RunTPGConfigDat>::const_iterator it;
int nr=0;
for( it=dataset.begin(); it!=dataset.end(); it++ )
{
++nr;
//EcalLogicID ecalid = it->first;
RunTPGConfigDat dat = it->second;
the_config_tag=dat.getConfigTag();
the_config_version=dat.getVersion();
}
// it is all the same for all SM... get the last one
std::cout<<" run= "<<irun<<" tag "<<the_config_tag<<" version="<<the_config_version <<std::endl;
// here we should check if it is the same as previous run.
if((the_config_tag != m_i_tag || the_config_version != m_i_version ) && nr>0 ) {
std::cout<<"the tag is different from last transferred run ... retrieving last config set from DB"<<std::endl;
FEConfigMainInfo fe_main_info;
fe_main_info.setConfigTag(the_config_tag);
fe_main_info.setVersion(the_config_version);
try{
std::cout << " before fetch config set" << std::endl;
econn-> fetchConfigSet(&fe_main_info);
std::cout << " after fetch config set" << std::endl;
// now get TPGPhysicsConst
int linId=fe_main_info.getLinId();
int fgrId=fe_main_info.getFgrId();
int lutId=fe_main_info.getLUTId();
if ((linId != m_i_physClin) || (fgrId != m_i_physCfgr) || (lutId != m_i_physClut) ) {
std::cout<<"one of the parameters: linId, LutId or fgrId is different from" <<std::endl;
std::cout<<"last transferred run ..."<<std::endl;
FEConfigLinInfo fe_physLin_info;
FEConfigFgrInfo fe_physFgr_info;
FEConfigLUTInfo fe_physLut_info;
fe_physLin_info.setId(linId);
fe_physFgr_info.setId(fgrId);
fe_physLut_info.setId(lutId);
econn-> fetchConfigSet(&fe_physLin_info);
econn-> fetchConfigSet(&fe_physFgr_info);
econn-> fetchConfigSet(&fe_physLut_info);
std::map<EcalLogicID, FEConfigLinParamDat> dataset_TpgPhysicsLin;
std::map<EcalLogicID, FEConfigLUTParamDat> dataset_TpgPhysicsLut;
std::map<EcalLogicID, FEConfigFgrParamDat> dataset_TpgPhysicsFgr;
econn->fetchDataSet(&dataset_TpgPhysicsLin, &fe_physLin_info);
econn->fetchDataSet(&dataset_TpgPhysicsLut, &fe_physLut_info);
econn->fetchDataSet(&dataset_TpgPhysicsFgr, &fe_physFgr_info);
EcalTPGPhysicsConst* physC = new EcalTPGPhysicsConst;
typedef std::map<EcalLogicID, FEConfigLinParamDat>::const_iterator CIfeLin;
typedef std::map<EcalLogicID, FEConfigLUTParamDat>::const_iterator CIfeLUT;
typedef std::map<EcalLogicID, FEConfigFgrParamDat>::const_iterator CIfeFgr;
EcalLogicID ecidLin_xt;
EcalLogicID ecidLut_xt;
EcalLogicID ecidFgr_xt;
FEConfigLinParamDat rd_physLin;
FEConfigLUTParamDat rd_physLut;
FEConfigFgrParamDat rd_physFgr;
std::map<int,float> EtSatLinEB;
std::map<int,float> EtSatLinEE;
typedef std::map<int,float>::const_iterator itEtSat;
std::map<int,EcalTPGPhysicsConst::Item> temporaryMapEB;
std::map<int,EcalTPGPhysicsConst::Item> temporaryMapEE;
typedef std::map<int,EcalTPGPhysicsConst::Item>::iterator iterEB;
typedef std::map<int,EcalTPGPhysicsConst::Item>::iterator iterEE;
for (CIfeLin p0 = dataset_TpgPhysicsLin.begin(); p0 != dataset_TpgPhysicsLin.end(); p0++)
{
ecidLin_xt = p0->first;
rd_physLin = p0->second;
std::string ecid_nameLin=ecidLin_xt.getName();
if(ecid_nameLin=="EB") {
DetId eb(DetId::Ecal, EcalBarrel);
EtSatLinEB.insert(std::make_pair(eb.rawId(),rd_physLin.getETSat()));
}
else if (ecid_nameLin=="EE"){
DetId ee(DetId::Ecal, EcalEndcap);
EtSatLinEE.insert(std::make_pair(ee.rawId(),rd_physLin.getETSat()));
}
}
int icells=0;
for (CIfeLUT p1 = dataset_TpgPhysicsLut.begin(); p1 != dataset_TpgPhysicsLut.end(); p1++)
{
ecidLut_xt = p1->first;
rd_physLut = p1->second;
std::string ecid_nameLut=ecidLut_xt.getName();
// Ecal barrel detector
if(ecid_nameLut=="EB") {
DetId eb(DetId::Ecal, EcalBarrel);
for (itEtSat it1 = EtSatLinEB.begin() ; it1 != EtSatLinEB.end(); it1++){
if (it1->first == (int)eb.rawId()){
float ETSatLin = it1->second;
if (rd_physLut.getETSat() == ETSatLin) {
EcalTPGPhysicsConst::Item item;
item.EtSat=rd_physLut.getETSat();
item.ttf_threshold_Low=rd_physLut.getTTThreshlow();
item.ttf_threshold_High=rd_physLut.getTTThreshhigh();
item.FG_lowThreshold=0;
item.FG_highThreshold=0;
item.FG_lowRatio=0;
item.FG_highRatio=0;
temporaryMapEB.insert(std::make_pair(eb.rawId(),item));
}
else throw cms::Exception("The values of the ETSatLin and ETSatLut are different.");
}
}
++icells;
}
else if (ecid_nameLut=="EE") {
// Ecal endcap detector
DetId ee(DetId::Ecal, EcalEndcap);
for (itEtSat it2 = EtSatLinEE.begin(); it2 != EtSatLinEE.end(); it2++){
if (it2->first == (int)ee.rawId()){
float ETSatLin = it2->second;
if (rd_physLut.getETSat() == ETSatLin) {
EcalTPGPhysicsConst::Item item;
item.EtSat=rd_physLut.getETSat();
item.ttf_threshold_Low=rd_physLut.getTTThreshlow();
item.ttf_threshold_High=rd_physLut.getTTThreshhigh();
item.FG_lowThreshold=0;
item.FG_highThreshold=0;
item.FG_lowRatio=0;
item.FG_highRatio=0;
temporaryMapEE.insert( std::make_pair(ee.rawId(),item) );
}
else throw cms::Exception("The values of the ETSatLin and ETSatLut are different.");
}
}
++icells;
}
}
int icellsEB=0;
int icellsEE=0;
for (CIfeFgr p2 = dataset_TpgPhysicsFgr.begin(); p2 != dataset_TpgPhysicsFgr.end(); p2++)
{
ecidFgr_xt = p2->first;
rd_physFgr = p2->second;
std::string ecid_nameFgr=ecidFgr_xt.getName();
// Ecal barrel detector
if(ecid_nameFgr=="EB") {
DetId eb(DetId::Ecal, EcalBarrel);
int count;
for ( iterEB itt=temporaryMapEB.begin() ; itt != temporaryMapEB.end() ; itt++ ){
if (itt->first == (int)eb.rawId()){
(itt->second).FG_lowThreshold=rd_physFgr.getFGlowthresh();
(itt->second).FG_highThreshold=rd_physFgr.getFGhighthresh();
(itt->second).FG_lowRatio=rd_physFgr.getFGlowratio();
(itt->second).FG_highRatio= rd_physFgr.getFGhighratio();
physC->setValue(eb.rawId(),itt->second);
}
count++;
}
++icellsEB;
}
else if (ecid_nameFgr=="EE") {
// Ecal endcap detector
DetId ee(DetId::Ecal, EcalEndcap);
int countEE = 0;
for ( iterEE itEE=temporaryMapEE.begin() ; itEE != temporaryMapEE.end() ; itEE++ ){
if (itEE->first == (int)ee.rawId()){
(itEE->second).FG_lowThreshold=rd_physFgr.getFGlowthresh();
(itEE->second).FG_highThreshold=rd_physFgr.getFGhighthresh();
// the last two is empty for the EE
(itEE->second).FG_lowRatio=rd_physFgr.getFGlowratio();
(itEE->second).FG_highRatio= rd_physFgr.getFGhighratio();
physC->setValue(ee.rawId(),itEE->second);
}
countEE++;
}
++icellsEE;
}
}
Time_t snc= (Time_t) irun ;
m_to_transfer.push_back(std::make_pair((EcalTPGPhysicsConst*)physC,snc));
m_i_run_number=irun;
m_i_tag=the_config_tag;
m_i_version=the_config_version;
m_i_physClin=linId;
m_i_physClut=lutId;
m_i_physCfgr=fgrId;
writeFile("last_tpg_physC_settings.txt");
} else {
m_i_run_number=irun;
m_i_tag=the_config_tag;
m_i_version=the_config_version;
writeFile("last_tpg_physC_settings.txt");
std::cout<< " even if the tag/version is not the same, the physics constants id is the same -> no transfer needed "<< std::endl;
}
}
catch (std::exception &e) {
std::cout << "ERROR: THIS CONFIG DOES NOT EXIST: tag=" <<the_config_tag
<<" version="<<the_config_version<< std::endl;
std::cout << e.what() << std::endl;
m_i_run_number=irun;
}
std::cout<<" **************** "<<std::endl;
} else if(nr==0) {
m_i_run_number=irun;
std::cout<< " no tag saved to RUN_TPGCONFIG_DAT by EcalSupervisor -> no transfer needed "<< std::endl;
std::cout<<" **************** "<<std::endl;
} else {
m_i_run_number=irun;
m_i_tag=the_config_tag;
m_i_version=the_config_version;
std::cout<< " the tag/version is the same -> no transfer needed "<< std::endl;
std::cout<<" **************** "<<std::endl;
writeFile("last_tpg_physC_settings.txt");
}
}
}
delete econn;
edm::LogInfo("EcalTPGPhysicsConstHandler") << "Ecal - > end of getNewObjects -----------";
}
| std::string popcon::EcalTPGPhysicsConstHandler::id | ( | void | ) | const [inline, virtual] |
Implements popcon::PopConSourceHandler< EcalTPGPhysicsConst >.
Definition at line 58 of file EcalTPGPhysicsConstHandler.h.
References m_name.
{ return m_name;}
| void popcon::EcalTPGPhysicsConstHandler::readFromFile | ( | const char * | inputFile | ) |
Definition at line 423 of file EcalTPGPhysicsConstHandler.cc.
References analyzePatCleaning_cfg::inputFile, geometryCSVtoXML::line, and cond::to_string().
{
//-------------------------------------------------------------
m_i_tag="";
m_i_version=0;
m_i_run_number=0;
m_i_physClin=0;
m_i_physClut=0;
m_i_physCfgr=0;
FILE *inpFile; // input file
inpFile = fopen(inputFile,"r");
if(!inpFile) {
edm::LogError("EcalTPGPhysicsConstHandler")<<"*** Can not open file: "<<inputFile;
}
char line[256];
std::ostringstream str;
fgets(line,255,inpFile);
m_i_tag=to_string(line);
str << "gen tag " << m_i_tag << std::endl ; // should I use this?
fgets(line,255,inpFile);
m_i_version=atoi(line);
str << "version= " << m_i_version << std::endl ;
fgets(line,255,inpFile);
m_i_run_number=atoi(line);
str << "run_number= " << m_i_run_number << std::endl ;
fgets(line,255,inpFile);
m_i_physClin=atoi(line);
str << "physClin_config= " << m_i_physClin << std::endl ;
fgets(line,255,inpFile);
m_i_physClut=atoi(line);
str << "physClut_config= " << m_i_physClut << std::endl ;
fgets(line,255,inpFile);
m_i_physCfgr=atoi(line);
str << "physCfgr_config= " << m_i_physCfgr << std::endl ;
fclose(inpFile); // close inp. file
}
| std::string popcon::EcalTPGPhysicsConstHandler::to_string | ( | char | value[] | ) | [inline, private] |
Definition at line 68 of file EcalTPGPhysicsConstHandler.h.
References relativeConstraints::value.
{
std::ostringstream streamOut;
streamOut << value;
return streamOut.str();
}
| void popcon::EcalTPGPhysicsConstHandler::writeFile | ( | const char * | inputFile | ) |
Definition at line 471 of file EcalTPGPhysicsConstHandler.cc.
{
//-------------------------------------------------------------
std::ofstream myfile;
myfile.open (inputFile);
myfile << m_i_tag <<std::endl;
myfile << m_i_version <<std::endl;
myfile << m_i_run_number <<std::endl;
myfile << m_i_physClin <<std::endl;
myfile << m_i_physClut <<std::endl;
myfile << m_i_physCfgr <<std::endl;
myfile.close();
}
Definition at line 64 of file EcalTPGPhysicsConstHandler.h.
unsigned int popcon::EcalTPGPhysicsConstHandler::m_firstRun [private] |
Definition at line 76 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
std::string popcon::EcalTPGPhysicsConstHandler::m_gentag [private] |
Definition at line 80 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
int popcon::EcalTPGPhysicsConstHandler::m_i_physCfgr [private] |
Definition at line 93 of file EcalTPGPhysicsConstHandler.h.
int popcon::EcalTPGPhysicsConstHandler::m_i_physClin [private] |
Definition at line 91 of file EcalTPGPhysicsConstHandler.h.
int popcon::EcalTPGPhysicsConstHandler::m_i_physClut [private] |
Definition at line 92 of file EcalTPGPhysicsConstHandler.h.
unsigned int popcon::EcalTPGPhysicsConstHandler::m_i_run_number [private] |
Definition at line 90 of file EcalTPGPhysicsConstHandler.h.
std::string popcon::EcalTPGPhysicsConstHandler::m_i_tag [private] |
Definition at line 88 of file EcalTPGPhysicsConstHandler.h.
int popcon::EcalTPGPhysicsConstHandler::m_i_version [private] |
Definition at line 89 of file EcalTPGPhysicsConstHandler.h.
unsigned int popcon::EcalTPGPhysicsConstHandler::m_lastRun [private] |
Definition at line 77 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
std::string popcon::EcalTPGPhysicsConstHandler::m_location [private] |
Definition at line 79 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
std::string popcon::EcalTPGPhysicsConstHandler::m_locationsource [private] |
Definition at line 84 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
std::string popcon::EcalTPGPhysicsConstHandler::m_name [private] |
Definition at line 85 of file EcalTPGPhysicsConstHandler.h.
Referenced by id().
std::string popcon::EcalTPGPhysicsConstHandler::m_pass [private] |
Definition at line 83 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
const EcalTPGPhysicsConst* popcon::EcalTPGPhysicsConstHandler::m_physicsConst [private] |
Definition at line 74 of file EcalTPGPhysicsConstHandler.h.
unsigned int popcon::EcalTPGPhysicsConstHandler::m_runnr [private] |
Definition at line 86 of file EcalTPGPhysicsConstHandler.h.
std::string popcon::EcalTPGPhysicsConstHandler::m_runtype [private] |
Definition at line 87 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
std::string popcon::EcalTPGPhysicsConstHandler::m_sid [private] |
Definition at line 81 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
std::string popcon::EcalTPGPhysicsConstHandler::m_user [private] |
Definition at line 82 of file EcalTPGPhysicsConstHandler.h.
Referenced by EcalTPGPhysicsConstHandler().
1.7.3