CMS 3D CMS Logo

All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Member Functions | Public Attributes | Private Member Functions | Private Attributes
popcon::EcalTPGWeightIdMapHandler Class Reference

#include <EcalTPGWeightIdMapHandler.h>

Inheritance diagram for popcon::EcalTPGWeightIdMapHandler:
popcon::PopConSourceHandler< EcalTPGWeightIdMap >

Public Member Functions

 EcalTPGWeightIdMapHandler (edm::ParameterSet const &)
 
void getNewObjects () override
 
std::string id () const override
 
void readFromFile (const char *inputFile)
 
void writeFile (const char *inputFile)
 
 ~EcalTPGWeightIdMapHandler () override
 
- Public Member Functions inherited from popcon::PopConSourceHandler< EcalTPGWeightIdMap >
void convertFromOld ()
 
SummarydummySummary (typename OldContainer::value_type const &) const
 
void initialize (const cond::persistency::Session &dbSession, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry)
 
Ref lastPayload () const
 
cond::LogDBEntry_t const & logDBEntry () const
 
std::pair< Container const *, std::string const > operator() (const cond::persistency::Session &session, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry) const
 
 PopConSourceHandler ()
 
Container const & returnData ()
 
void sort ()
 
cond::TagInfo_t const & tagInfo () const
 
std::string const & userTextLog () const
 
virtual ~PopConSourceHandler ()
 

Public Attributes

EcalCondDBInterfaceeconn
 

Private Member Functions

std::string to_string (char value[])
 

Private Attributes

unsigned int m_firstRun
 
std::string m_gentag
 
unsigned int m_i_run_number
 
std::string m_i_tag
 
int m_i_version
 
int m_i_weightIdMap
 
unsigned int m_lastRun
 
std::string m_location
 
std::string m_locationsource
 
std::string m_name
 
std::string m_pass
 
unsigned int m_runnr
 
std::string m_runtype
 
std::string m_sid
 
std::string m_user
 
const EcalTPGWeightIdMapmyweightIdMap
 

Additional Inherited Members

- Public Types inherited from popcon::PopConSourceHandler< EcalTPGWeightIdMap >
typedef std::vector< Triplet > Container
 
typedef std::vector< std::pair< EcalTPGWeightIdMap *, cond::Time_t > > OldContainer
 
typedef PopConSourceHandler< EcalTPGWeightIdMapself
 
typedef cond::Summary Summary
 
typedef cond::Time_t Time_t
 
typedef EcalTPGWeightIdMap value_type
 
- Protected Member Functions inherited from popcon::PopConSourceHandler< EcalTPGWeightIdMap >
int add (value_type *payload, Summary *summary, Time_t time)
 
cond::persistency::SessiondbSession () const
 
- Protected Attributes inherited from popcon::PopConSourceHandler< EcalTPGWeightIdMap >
OldContainer m_to_transfer
 
std::string m_userTextLog
 

Detailed Description

Definition at line 49 of file EcalTPGWeightIdMapHandler.h.

Constructor & Destructor Documentation

popcon::EcalTPGWeightIdMapHandler::EcalTPGWeightIdMapHandler ( edm::ParameterSet const &  )

Definition at line 24 of file EcalTPGWeightIdMapHandler.cc.

References edm::ParameterSet::getParameter(), m_firstRun, m_gentag, m_lastRun, m_location, m_locationsource, m_pass, m_runtype, m_sid, m_user, and AlCaHLTBitMon_QueryRunRegistry::string.

25  : m_name(ps.getUntrackedParameter<std::string>("name","EcalTPGWeightIdMapHandler")) {
26 
27  edm::LogInfo("EcalTPGWeightIdMapHandler") << "EcalTPGWeightIdMap Source handler constructor";
28  m_firstRun=static_cast<unsigned int>(atoi( ps.getParameter<std::string>("firstRun").c_str()));
29  m_lastRun=static_cast<unsigned int>(atoi( ps.getParameter<std::string>("lastRun").c_str()));
30  m_sid= ps.getParameter<std::string>("OnlineDBSID");
31  m_user= ps.getParameter<std::string>("OnlineDBUser");
32  m_pass= ps.getParameter<std::string>("OnlineDBPassword");
33  m_locationsource= ps.getParameter<std::string>("LocationSource");
34  m_location=ps.getParameter<std::string>("Location");
35  m_gentag=ps.getParameter<std::string>("GenTag");
36  m_runtype=ps.getParameter<std::string>("RunType");
37 
38  edm::LogInfo("EcalTPGWeightIdMapHandler") << m_sid<<"/"<<m_user<<"/"<<m_location<<"/"<<m_gentag;
39 
40 }
popcon::EcalTPGWeightIdMapHandler::~EcalTPGWeightIdMapHandler ( )
override

Definition at line 42 of file EcalTPGWeightIdMapHandler.cc.

43 {
44 }

Member Function Documentation

void popcon::EcalTPGWeightIdMapHandler::getNewObjects ( )
overridevirtual

Implements popcon::PopConSourceHandler< EcalTPGWeightIdMap >.

Definition at line 47 of file EcalTPGWeightIdMapHandler.cc.

References gather_cfg::cout, createfilelist::dataset, MillePedeFileConverter_cfg::e, econn, cppFunctionSkipper::exception, Exception, EcalCondDBInterface::fetchDataSet(), EcalCondDBInterface::fetchGlobalRunListByLocation(), RunTPGConfigDat::getConfigTag(), RunList::getRuns(), RunTPGConfigDat::getVersion(), FEConfigWeightGroupDat::getWeight0(), FEConfigWeightGroupDat::getWeight1(), FEConfigWeightGroupDat::getWeight2(), FEConfigWeightGroupDat::getWeight3(), FEConfigWeightGroupDat::getWeight4(), FEConfigWeightGroupDat::getWeightGroupId(), FEConfigMainInfo::getWeiId(), cond::TagInfo_t::lastInterval, popcon::PopConSourceHandler< EcalTPGWeightIdMap >::lastPayload(), m_firstRun, m_gentag, m_i_run_number, m_i_tag, m_i_version, m_i_weightIdMap, m_lastRun, m_location, m_pass, m_runtype, m_sid, popcon::PopConSourceHandler< EcalTPGWeightIdMap >::m_to_transfer, m_user, cond::TagInfo_t::name, AlCaHLTBitMon_ParallelJobs::p, readFromFile(), IODConfig::setConfigTag(), RunTag::setGeneralTag(), FEConfigWeightInfo::setId(), LocationDef::setLocation(), RunTag::setLocationDef(), RunTypeDef::setRunType(), RunTag::setRunTypeDef(), EcalTPGWeightIdMap::setValue(), EcalTPGWeights::setValues(), FEConfigMainInfo::setVersion(), cond::TagInfo_t::size, findQualityFiles::size, AlCaHLTBitMon_QueryRunRegistry::string, popcon::PopConSourceHandler< EcalTPGWeightIdMap >::tagInfo(), w, and writeFile().

48 {
49 
50  edm::LogInfo("EcalTPGWeightIdMapHandler") << "Started GetNewObjects!!!";
51 
52  //check whats already inside of database
53  if (tagInfo().size){
54  //check whats already inside of database
55  std::cout << "got offlineInfo = " << std::endl;
56  std::cout << "tag name = " << tagInfo().name << std::endl;
57  std::cout << "size = " << tagInfo().size << std::endl;
58  } else {
59  std::cout << " First object for this tag " << std::endl;
60  }
61 
62  unsigned int max_since=0;
63  max_since=static_cast<unsigned int>(tagInfo().lastInterval.first);
64  edm::LogInfo("EcalTPGWeightIdMapHandler") << "max_since : " << max_since;
65  Ref weightIdMap_db = lastPayload();
66 
67  edm::LogInfo("EcalTPGWeightIdMapHandler") << "retrieved last payload ";
68 
69  // here we retrieve all the runs after the last from online DB
70  edm::LogInfo("EcalTPGWeightIdMapHandler") << "Retrieving run list from ONLINE DB ... ";
71 
72  edm::LogInfo("EcalTPGWeightIdMapHandler") << "Making connection...";
74  edm::LogInfo("EcalTPGWeightIdMapHandler") << "Done.";
75 
76  if (!econn)
77  {
78  std::cout << " connection parameters " <<m_sid <<"/"<<m_user<<std::endl;
79  // cerr << e.what() << std::endl;
80  throw cms::Exception("OMDS not available");
81  }
82 
83 
84  LocationDef my_locdef;
85  my_locdef.setLocation(m_location);
86 
87  RunTypeDef my_rundef;
88  my_rundef.setRunType(m_runtype);
89 
90  RunTag my_runtag;
91  my_runtag.setLocationDef( my_locdef );
92  my_runtag.setRunTypeDef( my_rundef );
93  my_runtag.setGeneralTag(m_gentag);
94 
95  readFromFile("last_tpg_weightIdMap_settings.txt");
96 
97 
98  unsigned int min_run=m_i_run_number+1;
99 
101  min_run=m_i_run_number+1;
102  } else {
103  min_run=m_firstRun;
104  }
105 
106  if(min_run<max_since) {
107  min_run=max_since+1; // we have to add 1 to the last transferred one
108  }
109 
110  std::cout<<"m_i_run_number"<< m_i_run_number <<"m_firstRun "<<m_firstRun<< "max_since " <<max_since<< std::endl;
111 
112  unsigned int max_run=m_lastRun;
113  edm::LogInfo("EcalTPGWeightIdMapHandler") << "min_run= " << min_run << "max_run= " << max_run;
114 
115  RunList my_list;
116  my_list=econn->fetchGlobalRunListByLocation(my_runtag, min_run, max_run, my_locdef);
117  // my_list=econn->fetchRunListByLocation(my_runtag,min_run,max_run,my_locdef);
118 
119  std::vector<RunIOV> run_vec= my_list.getRuns();
120  size_t num_runs=run_vec.size();
121  edm::LogInfo("EcalTPGWeightIdMapHandler") << "number of Mon runs is : "<< num_runs;
122 
123  unsigned int irun;
124  if(num_runs>0){
125  for(size_t kr=0; kr<run_vec.size(); kr++){
126 
127  irun=static_cast<unsigned int>(run_vec[kr].getRunNumber());
128 
129  std::cout<<" **************** "<<std::endl;
130  std::cout<<" **************** "<<std::endl;
131  std::cout<<" run= "<<irun<<std::endl;
132 
133  // retrieve the data :
134  std::map<EcalLogicID, RunTPGConfigDat> dataset;
135  econn->fetchDataSet(&dataset, &run_vec[kr]);
136 
137  std::string the_config_tag="";
138  int the_config_version=0;
139 
140  std::map< EcalLogicID, RunTPGConfigDat>::const_iterator it;
141 
142  int nr=0;
143  for( it=dataset.begin(); it!=dataset.end(); it++ )
144  {
145  ++nr;
146  //EcalLogicID ecalid = it->first;
147  RunTPGConfigDat dat = it->second;
148  the_config_tag=dat.getConfigTag();
149  the_config_version=dat.getVersion();
150  }
151 
152 
153  // it is all the same for all SM... get the last one
154 
155 
156  std::cout<<" run= "<<irun<<" tag "<<the_config_tag<<" version="<<the_config_version <<std::endl;
157 
158  // here we should check if it is the same as previous run.
159 
160 
161  if((the_config_tag != m_i_tag || the_config_version != m_i_version ) && nr>0 ) {
162  std::cout<<"the tag is different from last transferred run ... retrieving last config set from DB"<<std::endl;
163 
164  FEConfigMainInfo fe_main_info;
165  fe_main_info.setConfigTag(the_config_tag);
166  fe_main_info.setVersion(the_config_version);
167 
168  try{
169  std::cout << " before fetch config set" << std::endl;
170  econn-> fetchConfigSet(&fe_main_info);
171  std::cout << " after fetch config set" << std::endl;
172 
173 
174  // now get TPGWeightIdMap
175  int weightId=fe_main_info.getWeiId();
176 
177  if( weightId != m_i_weightIdMap ) {
178 
179  FEConfigWeightInfo fe_weight_info;
180  fe_weight_info.setId(weightId);
181  econn-> fetchConfigSet(&fe_weight_info);
182  std::map<EcalLogicID, FEConfigWeightGroupDat> dataset_TpgWeight;
183  econn->fetchDataSet(&dataset_TpgWeight, &fe_weight_info);
184  edm::LogInfo("EcalTPGWeightIdMapHandler") << "Got object!";
185  EcalTPGWeightIdMap* weightMap = new EcalTPGWeightIdMap;
186  typedef std::map<EcalLogicID, FEConfigWeightGroupDat>::const_iterator CIfeweight;
187  EcalLogicID ecid_xt;
189 
190  int igroups=0;
191  for (CIfeweight p = dataset_TpgWeight.begin(); p != dataset_TpgWeight.end(); p++) {
192 
193  rd_w = p->second;
194  // EB and EE data
195  EcalTPGWeights w;
196  unsigned int weight0 = static_cast<unsigned int>(rd_w.getWeight4());
197  unsigned int weight1 = static_cast<unsigned int>(rd_w.getWeight3());
198  unsigned int weight2 = static_cast<unsigned int>(rd_w.getWeight2());
199  unsigned int weight3 = static_cast<unsigned int>(rd_w.getWeight1()- 0x80);
200  unsigned int weight4 = static_cast<unsigned int>(rd_w.getWeight0());
201 
202  w.setValues(weight0,weight1,weight2,weight3,weight4);
203  weightMap->setValue(rd_w.getWeightGroupId(),w);
204 
205  ++igroups;
206  }
207 
208  edm::LogInfo("EcalTPGWeightIdMapHandler") << "found " << igroups << "Weight groups";
209 
210  Time_t snc= (Time_t) irun;
211  m_to_transfer.push_back(std::make_pair((EcalTPGWeightIdMap*)weightMap,snc));
212 
213  m_i_run_number=irun;
214  m_i_tag=the_config_tag;
215  m_i_version=the_config_version;
216  m_i_weightIdMap=weightId;
217 
218  writeFile("last_tpg_weightIdMap_settings.txt");
219 
220  } else {
221 
222  m_i_run_number=irun;
223  m_i_tag=the_config_tag;
224  m_i_version=the_config_version;
225 
226  writeFile("last_tpg_weightIdMap_settings.txt");
227 
228  std::cout<< " even if the tag/version is not the same, the weightIdMap id is the same -> no transfer needed "<< std::endl;
229 
230  }
231 
232  } catch (std::exception &e) {
233  std::cout << "ERROR: THIS CONFIG DOES NOT EXIST: tag=" <<the_config_tag
234  <<" version="<<the_config_version<< std::endl;
235  std::cout << e.what() << std::endl;
236  m_i_run_number=irun;
237 
238  }
239  std::cout<<" **************** "<<std::endl;
240 
241  } else if(nr==0) {
242  m_i_run_number=irun;
243  std::cout<< " no tag saved to RUN_TPGCONFIG_DAT by EcalSupervisor -> no transfer needed "<< std::endl;
244  std::cout<<" **************** "<<std::endl;
245  } else {
246  m_i_run_number=irun;
247  m_i_tag=the_config_tag;
248  m_i_version=the_config_version;
249  std::cout<< " the tag/version is the same -> no transfer needed "<< std::endl;
250  std::cout<<" **************** "<<std::endl;
251  writeFile("last_tpg_weightIdMap_settings.txt");
252  }
253 
254  }
255  }
256 
257  delete econn;
258 
259  edm::LogInfo("EcalTPGWeightIdMapHandler") << "Ecal - > end of getNewObjects -----------";
260 
261 }
size
Write out results.
void setRunTypeDef(const RunTypeDef &runTypeDef)
Definition: RunTag.cc:70
std::vector< RunIOV > getRuns()
Definition: RunList.cc:35
RunList fetchGlobalRunListByLocation(const RunTag &tag, int min_run, int max_run, const LocationDef &locDef) noexcept(false)
std::string getConfigTag() const
const double w
Definition: UKUtility.cc:23
int getVersion() const
Definition: RunTag.h:13
size_t size
Definition: Types.h:77
void setVersion(int id)
void fetchDataSet(std::map< EcalLogicID, DATT > *fillMap, IOVT *iov) noexcept(false)
std::string name
Definition: Types.h:73
cond::ValidityInterval lastInterval
Definition: Types.h:75
int getWeiId() const
void setLocationDef(const LocationDef &locDef)
Definition: RunTag.cc:53
void setValue(const uint32_t &id, const EcalTPGWeights &value)
void setRunType(std::string runtype)
Definition: RunTypeDef.cc:33
void setConfigTag(std::string x)
Definition: IODConfig.h:31
void setLocation(std::string loc)
Definition: LocationDef.cc:33
void setGeneralTag(std::string tag)
Definition: RunTag.cc:36
void setValues(const uint32_t &w0, const uint32_t &w1, const uint32_t &w2, const uint32_t &w3, const uint32_t &w4)
std::string popcon::EcalTPGWeightIdMapHandler::id ( ) const
inlineoverridevirtual
void popcon::EcalTPGWeightIdMapHandler::readFromFile ( const char *  inputFile)

Definition at line 263 of file EcalTPGWeightIdMapHandler.cc.

References analyzePatCleaning_cfg::inputFile, geometryCSVtoXML::line, m_i_run_number, m_i_tag, m_i_version, m_i_weightIdMap, harvestTrackValidationPlots::str, and to_string().

Referenced by getNewObjects().

263  {
264  //-------------------------------------------------------------
265 
266  m_i_tag="";
267  m_i_version=0;
268  m_i_run_number=0;
269  m_i_weightIdMap=0;
270 
271  FILE *inpFile; // input file
272  inpFile = fopen(inputFile,"r");
273  if(!inpFile) {
274  edm::LogError("EcalTPGWeightIdMapHandler")<<"*** Can not open file: "<<inputFile;
275  return;
276  }
277 
278  char line[256];
279 
280  std::ostringstream str;
281 
282  fgets(line,255,inpFile);
283  m_i_tag=to_string(line);
284  str << "gen tag " << m_i_tag << std::endl ; // should I use this?
285 
286  fgets(line,255,inpFile);
287  m_i_version=atoi(line);
288  str << "version= " << m_i_version << std::endl ;
289 
290  fgets(line,255,inpFile);
291  m_i_run_number=atoi(line);
292  str << "run_number= " << m_i_run_number << std::endl ;
293 
294  fgets(line,255,inpFile);
295  m_i_weightIdMap=atoi(line);
296  str << "weightIdMap_config= " << m_i_weightIdMap << std::endl ;
297 
298 
299  fclose(inpFile); // close inp. file
300 
301 }
std::string popcon::EcalTPGWeightIdMapHandler::to_string ( char  value[])
inlineprivate

Definition at line 66 of file EcalTPGWeightIdMapHandler.h.

References relativeConstraints::value.

Referenced by readFromFile().

66  {
67  std::ostringstream streamOut;
68  streamOut << value;
69  return streamOut.str();
70  }
void popcon::EcalTPGWeightIdMapHandler::writeFile ( const char *  inputFile)

Definition at line 303 of file EcalTPGWeightIdMapHandler.cc.

References m_i_run_number, m_i_tag, m_i_version, and m_i_weightIdMap.

Referenced by getNewObjects(), and Vispa.Main.TabController.TabController::save().

303  {
304  //-------------------------------------------------------------
305 
306 
307  std::ofstream myfile;
308  myfile.open (inputFile);
309  myfile << m_i_tag <<std::endl;
310  myfile << m_i_version <<std::endl;
311  myfile << m_i_run_number <<std::endl;
312  myfile << m_i_weightIdMap <<std::endl;
313 
314  myfile.close();
315 
316 }

Member Data Documentation

EcalCondDBInterface* popcon::EcalTPGWeightIdMapHandler::econn

Definition at line 63 of file EcalTPGWeightIdMapHandler.h.

Referenced by getNewObjects().

unsigned int popcon::EcalTPGWeightIdMapHandler::m_firstRun
private

Definition at line 74 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

std::string popcon::EcalTPGWeightIdMapHandler::m_gentag
private

Definition at line 78 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

unsigned int popcon::EcalTPGWeightIdMapHandler::m_i_run_number
private

Definition at line 88 of file EcalTPGWeightIdMapHandler.h.

Referenced by getNewObjects(), readFromFile(), and writeFile().

std::string popcon::EcalTPGWeightIdMapHandler::m_i_tag
private

Definition at line 86 of file EcalTPGWeightIdMapHandler.h.

Referenced by getNewObjects(), readFromFile(), and writeFile().

int popcon::EcalTPGWeightIdMapHandler::m_i_version
private

Definition at line 87 of file EcalTPGWeightIdMapHandler.h.

Referenced by getNewObjects(), readFromFile(), and writeFile().

int popcon::EcalTPGWeightIdMapHandler::m_i_weightIdMap
private

Definition at line 89 of file EcalTPGWeightIdMapHandler.h.

Referenced by getNewObjects(), readFromFile(), and writeFile().

unsigned int popcon::EcalTPGWeightIdMapHandler::m_lastRun
private

Definition at line 75 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

std::string popcon::EcalTPGWeightIdMapHandler::m_location
private

Definition at line 77 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

std::string popcon::EcalTPGWeightIdMapHandler::m_locationsource
private

Definition at line 82 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler().

std::string popcon::EcalTPGWeightIdMapHandler::m_name
private

Definition at line 83 of file EcalTPGWeightIdMapHandler.h.

std::string popcon::EcalTPGWeightIdMapHandler::m_pass
private

Definition at line 81 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

unsigned int popcon::EcalTPGWeightIdMapHandler::m_runnr
private

Definition at line 84 of file EcalTPGWeightIdMapHandler.h.

std::string popcon::EcalTPGWeightIdMapHandler::m_runtype
private

Definition at line 85 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

std::string popcon::EcalTPGWeightIdMapHandler::m_sid
private

Definition at line 79 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

std::string popcon::EcalTPGWeightIdMapHandler::m_user
private

Definition at line 80 of file EcalTPGWeightIdMapHandler.h.

Referenced by EcalTPGWeightIdMapHandler(), and getNewObjects().

const EcalTPGWeightIdMap* popcon::EcalTPGWeightIdMapHandler::myweightIdMap
private

Definition at line 72 of file EcalTPGWeightIdMapHandler.h.