CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
RPCVmonSH.cc
Go to the documentation of this file.
1 /*
2  * See headers for a description
3  *
4  * \author D. Pagano - Dip. Fis. Nucl. e Teo. & INFN Pavia
5  */
6 
11 
12 #include<iostream>
13 
15  m_name(pset.getUntrackedParameter<std::string>("name","RpcData")),
16  host(pset.getUntrackedParameter<std::string>("host", "source db host")),
17  user(pset.getUntrackedParameter<std::string>("user", "source username")),
18  passw(pset.getUntrackedParameter<std::string>("passw", "source password")),
19  m_since(pset.getUntrackedParameter<unsigned long long>("since",5)),
20  m_till(pset.getUntrackedParameter<unsigned long long>("till",0)){
21 }
22 
24 {
25 }
26 
28 
29  std::cout << "------- " << m_name << " - > getNewObjects\n"
30  << "got offlineInfo "<< tagInfo().name
31  << ", size " << tagInfo().size << ", last object valid since "
32  << tagInfo().lastInterval.first << " token "
33  << tagInfo().lastPayloadToken << std::endl;
34 
35  std::cout << " ------ last entry info regarding the payload (if existing): "
36  << logDBEntry().usertext << "last record with the correct tag has been written in the db: "
37  << logDBEntry().destinationDB << std::endl;
38 
39  // snc = tagInfo().lastInterval.first;
40 
41  std::cout << std::endl << "=============================================" << std::endl;
42  std::cout << std::endl << "=================== VMON ==================" << std::endl;
43  std::cout << std::endl << "=============================================" << std::endl << std::endl;
44  snc = m_since;
45  std::cout << ">> Range mode [" << snc << ", " << m_till << "]" << std::endl;
46  std::cout << std::endl << "=============================================" << std::endl << std::endl;
47 
48 
49  RPCFw caen ( host, user, passw );
50  std::vector<RPCObVmon::V_Item> Vcheck;
51 
52 
53  Vcheck = caen.createVMON(snc, m_till);
54  Vdata = new RPCObVmon();
55  RPCObVmon::V_Item Vfill;
56  std::vector<RPCObVmon::V_Item>::iterator Vit;
57  for(Vit = Vcheck.begin(); Vit != Vcheck.end(); Vit++)
58  {
59  Vfill = *(Vit);
60  Vdata->ObVmon_rpc.push_back(Vfill);
61  }
62  std::cout << " >> Final object size: " << Vdata->ObVmon_rpc.size() << std::endl;
63 
64  if (Vdata->ObVmon_rpc.size() > 0) {
65  niov = snc;
66  } else {
67  niov = snc;
68  std::cout << "NO DATA TO BE STORED" << std::endl;
69  }
70 
71  ::timeval tv;
72  tv.tv_sec = niov;
73  tv.tv_usec = 0;
74  edm::Timestamp tmstamp((unsigned long long)tv.tv_sec*1000000+(unsigned long long)tv.tv_usec);
75  std::cout << "UNIX time = " << tmstamp.value() << std::endl;
76 
77  edm::TimeValue_t daqtime=0LL;
78  daqtime=tv.tv_sec;
79  daqtime=(daqtime<<32)+tv.tv_usec;
80  edm::Timestamp daqstamp(daqtime);
81  edm::TimeValue_t dtime = daqstamp.value();
82  std::cout<<"DAQ time = " << dtime <<std::endl;
83 
84  niov = dtime;
85 
86  std::cout << "===> New IOV: since is = " << niov << std::endl;
87  m_to_transfer.push_back(std::make_pair((RPCObVmon*)Vdata,niov));
88 }
89 
void getNewObjects()
Definition: RPCVmonSH.cc:27
Definition: RPCFw.h:32
std::vector< RPCObVmon::V_Item > createVMON(long long from, long long till)
Definition: RPCFw.cc:133
unsigned long long TimeValue_t
Definition: Timestamp.h:28
string host
Definition: query.py:114
RpcDataV(const edm::ParameterSet &pset)
Definition: RPCVmonSH.cc:14
tuple cout
Definition: gather_cfg.py:121
TimeValue_t value() const
Definition: Timestamp.h:56