CMS 3D CMS Logo

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

#include <EcalTPGLinConstHandler.h>

Inheritance diagram for popcon::EcalTPGLinConstHandler:
popcon::PopConSourceHandler< EcalTPGLinearizationConst >

Public Member Functions

 EcalTPGLinConstHandler (edm::ParameterSet const &)
 
void getNewObjects () override
 
std::string id () const override
 
void readFromFile (const char *inputFile)
 
void writeFile (const char *inputFile)
 
 ~EcalTPGLinConstHandler () override
 
- Public Member Functions inherited from popcon::PopConSourceHandler< EcalTPGLinearizationConst >
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 ()
 
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
 
int m_i_lin
 
unsigned int m_i_run_number
 
std::string m_i_tag
 
int m_i_version
 
unsigned int m_lastRun
 
const EcalTPGLinearizationConstm_linearizationConst
 
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
 

Additional Inherited Members

- Public Types inherited from popcon::PopConSourceHandler< EcalTPGLinearizationConst >
typedef std::map< Time_t,
std::shared_ptr
< EcalTPGLinearizationConst > > 
Container
 
typedef std::unique_ptr
< EcalTPGLinearizationConst
Ref
 
typedef PopConSourceHandler
< EcalTPGLinearizationConst
self
 
typedef cond::Time_t Time_t
 
typedef EcalTPGLinearizationConst value_type
 
- Protected Member Functions inherited from popcon::PopConSourceHandler< EcalTPGLinearizationConst >
cond::persistency::SessiondbSession () const
 
- Protected Attributes inherited from popcon::PopConSourceHandler< EcalTPGLinearizationConst >
Container m_iovs
 
std::vector< std::pair
< EcalTPGLinearizationConst
*, Time_t > > 
m_to_transfer
 
std::string m_userTextLog
 

Detailed Description

Definition at line 44 of file EcalTPGLinConstHandler.h.

Constructor & Destructor Documentation

popcon::EcalTPGLinConstHandler::EcalTPGLinConstHandler ( edm::ParameterSet const &  ps)

Definition at line 22 of file EcalTPGLinConstHandler.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.

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

Definition at line 38 of file EcalTPGLinConstHandler.cc.

38 {}

Member Function Documentation

void popcon::EcalTPGLinConstHandler::getNewObjects ( )
overridevirtual

Implements popcon::PopConSourceHandler< EcalTPGLinearizationConst >.

Definition at line 40 of file EcalTPGLinConstHandler.cc.

References gather_cfg::cout, dat, writedatasetfile::dataset, alignCSCRings::e, test_db_connect::econn, cppFunctionSkipper::exception, Exception, RunTPGConfigDat::getConfigTag(), EcalLogicID::getID1(), EcalLogicID::getID2(), EcalLogicID::getID3(), FEConfigMainInfo::getLinId(), FEConfigLinDat::getMultX1(), FEConfigLinDat::getMultX12(), FEConfigLinDat::getMultX6(), EcalLogicID::getName(), RunList::getRuns(), FEConfigLinDat::getShift1(), FEConfigLinDat::getShift12(), FEConfigLinDat::getShift6(), RunTPGConfigDat::getVersion(), EcalCondObjectContainer< T >::insert(), B2GTnPMonitor_cfi::item, test_db_connect::my_locdef, test_db_connect::my_rundef, AlCaHLTBitMon_ParallelJobs::p, DetId::rawId(), l1tpf_impl::readFromFile(), IODConfig::setConfigTag(), RunTag::setGeneralTag(), FEConfigLinInfo::setId(), LocationDef::setLocation(), RunTag::setLocationDef(), RunTypeDef::setRunType(), RunTag::setRunTypeDef(), FEConfigMainInfo::setVersion(), findQualityFiles::size, EBDetId::SMCRYSTALMODE, AlCaHLTBitMon_QueryRunRegistry::string, dumpRecoGeometry_cfg::tagInfo, x, EEDetId::XYMODE, y, and z.

40  {
41  edm::LogInfo("EcalTPGLinConstHandler") << "Started getNewObjects";
42 
43  if (tagInfo().size) {
44  //check whats already inside of database
45  std::cout << "got offlineInfo = " << std::endl;
46  std::cout << "tag name = " << tagInfo().name << std::endl;
47  std::cout << "size = " << tagInfo().size << std::endl;
48  } else {
49  std::cout << " First object for this tag " << std::endl;
50  }
51 
52  unsigned int max_since = 0;
53  max_since = static_cast<unsigned int>(tagInfo().lastInterval.since);
54  edm::LogInfo("EcalTPGLinConstHandler") << "max_since = " << max_since;
55  edm::LogInfo("EcalTPGLinConstHandler") << "Retrieved last payload ";
56 
57  // here we retrieve all the runs after the last from online DB
58  edm::LogInfo("EcalTPGLinConstHandler") << "Retrieving run list from ONLINE DB ... " << std::endl;
59 
60  edm::LogInfo("EcalTPGLinConstHandler") << "Making connection..." << std::flush;
62  edm::LogInfo("EcalTPGLinConstHandler") << "Done." << std::endl;
63 
64  if (!econn) {
65  std::cout << " connection parameters " << m_sid << "/" << m_user << std::endl;
66  // cerr << e.what() << std::endl;
67  throw cms::Exception("OMDS not available");
68  }
69 
71  my_locdef.setLocation(m_location);
72 
74  my_rundef.setRunType(m_runtype);
75 
76  RunTag my_runtag;
77  my_runtag.setLocationDef(my_locdef);
78  my_runtag.setRunTypeDef(my_rundef);
79  my_runtag.setGeneralTag(m_gentag);
80 
81  readFromFile("last_tpg_lin_settings.txt");
82 
83  unsigned int min_run;
84 
85  if (m_firstRun < m_i_run_number) {
86  min_run = m_i_run_number + 1; // we have to add 1 to the last transferred one
87  } else {
88  min_run = m_firstRun;
89  }
90 
91  if (min_run < max_since) {
92  min_run = max_since + 1; // we have to add 1 to the last transferred one
93  }
94 
95  std::cout << "m_i_run_number" << m_i_run_number << "m_firstRun " << m_firstRun << "max_since " << max_since
96  << std::endl;
97 
98  unsigned int max_run = m_lastRun;
99  edm::LogInfo("EcalTPGLinConstHandler") << "min_run= " << min_run << "max_run = " << max_run;
100 
101  RunList my_list;
102  my_list = econn->fetchGlobalRunListByLocation(my_runtag, min_run, max_run, my_locdef);
103  // my_list=econn->fetchRunListByLocation(my_runtag, min_run, max_run, my_locdef);
104 
105  std::vector<RunIOV> run_vec = my_list.getRuns();
106  size_t num_runs = run_vec.size();
107 
108  std::cout << "number of runs is : " << num_runs << std::endl;
109 
110  unsigned int irun = 0;
111  if (num_runs > 0) {
112  for (size_t kr = 0; kr < run_vec.size(); kr++) {
113  irun = static_cast<unsigned int>(run_vec[kr].getRunNumber());
114  std::cout << " **************** " << std::endl;
115  std::cout << " **************** " << std::endl;
116  std::cout << " run= " << irun << std::endl;
117 
118  // retrieve the data :
119  std::map<EcalLogicID, RunTPGConfigDat> dataset;
120  econn->fetchDataSet(&dataset, &run_vec[kr]);
121 
122  std::string the_config_tag = "";
123  int the_config_version = 0;
124 
125  std::map<EcalLogicID, RunTPGConfigDat>::const_iterator it;
126 
127  int nr = 0;
128  for (it = dataset.begin(); it != dataset.end(); it++) {
129  ++nr;
130  //EcalLogicID ecalid = it->first;
131 
132  RunTPGConfigDat dat = it->second;
133  the_config_tag = dat.getConfigTag();
134  the_config_version = dat.getVersion();
135  }
136 
137  // it is all the same for all SM... get the last one
138 
139  std::cout << " run= " << irun << " tag " << the_config_tag << " version=" << the_config_version << std::endl;
140 
141  // here we should check if it is the same as previous run.
142 
143  if ((the_config_tag != m_i_tag || the_config_version != m_i_version) && nr > 0) {
144  std::cout << "the tag is different from last transferred run ... retrieving last config set from DB"
145  << std::endl;
146 
147  FEConfigMainInfo fe_main_info;
148  fe_main_info.setConfigTag(the_config_tag);
149  fe_main_info.setVersion(the_config_version);
150 
151  try {
152  std::cout << " before fetch config set" << std::endl;
153  econn->fetchConfigSet(&fe_main_info);
154  std::cout << " after fetch config set" << std::endl;
155 
156  // now get TPGLinConst
157  int linId = fe_main_info.getLinId();
158 
159  if (linId != m_i_lin) {
160  FEConfigLinInfo fe_lin_info;
161  fe_lin_info.setId(linId);
162  econn->fetchConfigSet(&fe_lin_info);
163  std::map<EcalLogicID, FEConfigLinDat> dataset_TpgLin;
164  econn->fetchDataSet(&dataset_TpgLin, &fe_lin_info);
165 
167  typedef std::map<EcalLogicID, FEConfigLinDat>::const_iterator CIfelin;
168  EcalLogicID ecid_xt;
169  FEConfigLinDat rd_lin;
170  int icells = 0;
171 
172  for (CIfelin p = dataset_TpgLin.begin(); p != dataset_TpgLin.end(); p++) {
173  ecid_xt = p->first;
174  rd_lin = p->second;
175  std::string ecid_name = ecid_xt.getName();
176 
177  //EB data
178  if (ecid_name == "EB_crystal_number") {
179  int sm_num = ecid_xt.getID1();
180  int xt_num = ecid_xt.getID2();
181  EBDetId ebdetid(sm_num, xt_num, EBDetId::SMCRYSTALMODE);
182 
184  item.mult_x1 = rd_lin.getMultX1();
185  item.mult_x6 = rd_lin.getMultX6();
186  item.mult_x12 = rd_lin.getMultX12();
187  item.shift_x1 = rd_lin.getShift1();
188  item.shift_x6 = rd_lin.getShift6();
189  item.shift_x12 = rd_lin.getShift12();
190 
191  linC->insert(std::make_pair(ebdetid.rawId(), item));
192  ++icells;
193  } else {
194  //EE data
195  int z = ecid_xt.getID1();
196  int x = ecid_xt.getID2();
197  int y = ecid_xt.getID3();
198  EEDetId eedetid(x, y, z, EEDetId::XYMODE);
199 
201 
202  item.mult_x1 = rd_lin.getMultX1();
203  item.mult_x6 = rd_lin.getMultX6();
204  item.mult_x12 = rd_lin.getMultX12();
205  item.shift_x1 = rd_lin.getShift1();
206  item.shift_x6 = rd_lin.getShift6();
207  item.shift_x12 = rd_lin.getShift12();
208 
209  linC->insert(std::make_pair(eedetid.rawId(), item));
210  ++icells;
211  }
212  }
213 
214  Time_t snc = (Time_t)irun;
215  m_to_transfer.push_back(std::make_pair((EcalTPGLinearizationConst *)linC, snc));
216 
217  m_i_run_number = irun;
218  m_i_tag = the_config_tag;
219  m_i_version = the_config_version;
220  m_i_lin = linId;
221 
222  writeFile("last_tpg_lin_settings.txt");
223 
224  } else {
225  m_i_run_number = irun;
226  m_i_tag = the_config_tag;
227  m_i_version = the_config_version;
228 
229  writeFile("last_tpg_lin_settings.txt");
230 
231  std::cout << " even if the tag/version is not the same, the linearization constants id is the same -> no "
232  "transfer needed "
233  << std::endl;
234  }
235  } catch (std::exception &e) {
236  std::cout << "ERROR: THIS CONFIG DOES NOT EXIST: tag=" << the_config_tag << " version=" << the_config_version
237  << std::endl;
238  std::cout << e.what() << std::endl;
239  m_i_run_number = irun;
240  }
241  std::cout << " **************** " << std::endl;
242 
243  } else if (nr == 0) {
244  m_i_run_number = irun;
245  std::cout << " no tag saved to RUN_TPGCONFIG_DAT by EcalSupervisor -> no transfer needed " << std::endl;
246  std::cout << " **************** " << std::endl;
247  } else {
248  m_i_run_number = irun;
249  m_i_tag = the_config_tag;
250  m_i_version = the_config_version;
251  std::cout << " the tag/version is the same -> no transfer needed " << std::endl;
252  std::cout << " **************** " << std::endl;
253  writeFile("last_tpg_lin_settings.txt");
254  }
255  }
256  }
257 
258  delete econn;
259 
260  edm::LogInfo("EcalTPGLinConstHandler") << "Ecal - > end of getNewObjects -----------";
261 }
void setRunTypeDef(const RunTypeDef &runTypeDef)
Definition: RunTag.cc:42
std::vector< RunIOV > getRuns()
Definition: RunList.cc:25
RunList fetchGlobalRunListByLocation(const RunTag &tag, int min_run, int max_run, const LocationDef &locDef) noexcept(false)
std::string getConfigTag() const
Iov_t lastInterval
Definition: Types.h:73
int getVersion() const
Definition: RunTag.h:13
Time_t since
Definition: Types.h:53
static const int XYMODE
Definition: EEDetId.h:335
size_t size
Definition: Types.h:74
int getMultX12() const
void fetchConfigSet(ICONF *iconf) noexcept(false)
void setVersion(int id)
void fetchDataSet(std::map< EcalLogicID, DATT > *fillMap, IOVT *iov) noexcept(false)
std::string name
Definition: Types.h:72
void setId(int id)
int getID2() const
Definition: EcalLogicID.cc:32
int getMultX1() const
std::string getName() const
Definition: EcalLogicID.cc:26
int getShift6() const
std::vector< std::pair< EcalTPGLinearizationConst *, Time_t > > m_to_transfer
int getLinId() const
int getID1() const
Definition: EcalLogicID.cc:30
int getShift12() const
int getMultX6() const
void setLocationDef(const LocationDef &locDef)
Definition: RunTag.cc:33
void insert(std::pair< uint32_t, Item > const &a)
Log< level::Info, false > LogInfo
void readFromFile(const char *inputFile)
void setRunType(std::string runtype)
Definition: RunTypeDef.cc:21
static std::vector< std::string > checklist dat
void setConfigTag(std::string x)
Definition: IODConfig.h:29
void writeFile(const char *inputFile)
void setLocation(std::string loc)
Definition: LocationDef.cc:20
tuple cout
Definition: gather_cfg.py:144
int getID3() const
Definition: EcalLogicID.cc:34
void setGeneralTag(std::string tag)
Definition: RunTag.cc:24
static const int SMCRYSTALMODE
Definition: EBDetId.h:159
tuple size
Write out results.
int getShift1() const
EcalTPGLinearizationConstMap EcalTPGLinearizationConst
std::string popcon::EcalTPGLinConstHandler::id ( ) const
inlineoverridevirtual
void popcon::EcalTPGLinConstHandler::readFromFile ( const char *  inputFile)

Definition at line 263 of file EcalTPGLinConstHandler.cc.

References writeEcalDQMStatus::inputFile, geometryCSVtoXML::line, str, and cond::impl::to_string().

263  {
264  //-------------------------------------------------------------
265 
266  m_i_tag = "";
267  m_i_version = 0;
268  m_i_run_number = 0;
269  m_i_lin = 0;
270 
271  FILE *inpFile; // input file
272  inpFile = fopen(inputFile, "r");
273  if (!inpFile) {
274  edm::LogError("EcalTPGLinConstHandler") << "*** 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_lin = atoi(line);
296  str << "lin_config= " << m_i_lin << std::endl;
297 
298  fclose(inpFile); // close inp. file
299 }
std::string to_string(char value[])
Log< level::Error, false > LogError
#define str(s)
std::string popcon::EcalTPGLinConstHandler::to_string ( char  value[])
inlineprivate

Definition at line 59 of file EcalTPGLinConstHandler.h.

References relativeConstraints::value.

59  {
60  std::ostringstream streamOut;
61  streamOut << value;
62  return streamOut.str();
63  }
void popcon::EcalTPGLinConstHandler::writeFile ( const char *  inputFile)

Definition at line 301 of file EcalTPGLinConstHandler.cc.

301  {
302  //-------------------------------------------------------------
303 
304  std::ofstream myfile;
305  myfile.open(inputFile);
306  myfile << m_i_tag << std::endl;
307  myfile << m_i_version << std::endl;
308  myfile << m_i_run_number << std::endl;
309  myfile << m_i_lin << std::endl;
310 
311  myfile.close();
312 }

Member Data Documentation

EcalCondDBInterface* popcon::EcalTPGLinConstHandler::econn

Definition at line 56 of file EcalTPGLinConstHandler.h.

unsigned int popcon::EcalTPGLinConstHandler::m_firstRun
private

Definition at line 67 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

std::string popcon::EcalTPGLinConstHandler::m_gentag
private

Definition at line 71 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

int popcon::EcalTPGLinConstHandler::m_i_lin
private

Definition at line 82 of file EcalTPGLinConstHandler.h.

unsigned int popcon::EcalTPGLinConstHandler::m_i_run_number
private

Definition at line 81 of file EcalTPGLinConstHandler.h.

std::string popcon::EcalTPGLinConstHandler::m_i_tag
private

Definition at line 79 of file EcalTPGLinConstHandler.h.

int popcon::EcalTPGLinConstHandler::m_i_version
private

Definition at line 80 of file EcalTPGLinConstHandler.h.

unsigned int popcon::EcalTPGLinConstHandler::m_lastRun
private

Definition at line 68 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

const EcalTPGLinearizationConst* popcon::EcalTPGLinConstHandler::m_linearizationConst
private

Definition at line 65 of file EcalTPGLinConstHandler.h.

std::string popcon::EcalTPGLinConstHandler::m_location
private

Definition at line 70 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

std::string popcon::EcalTPGLinConstHandler::m_locationsource
private

Definition at line 75 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

std::string popcon::EcalTPGLinConstHandler::m_name
private

Definition at line 76 of file EcalTPGLinConstHandler.h.

Referenced by id().

std::string popcon::EcalTPGLinConstHandler::m_pass
private

Definition at line 74 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

unsigned int popcon::EcalTPGLinConstHandler::m_runnr
private

Definition at line 77 of file EcalTPGLinConstHandler.h.

std::string popcon::EcalTPGLinConstHandler::m_runtype
private

Definition at line 78 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

std::string popcon::EcalTPGLinConstHandler::m_sid
private

Definition at line 72 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().

std::string popcon::EcalTPGLinConstHandler::m_user
private

Definition at line 73 of file EcalTPGLinConstHandler.h.

Referenced by EcalTPGLinConstHandler().