|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/*
* See header file for a description of this class.
*
* $Date: 2008/02/15 18:14:45 $
* $Revision: 1.3 $
* \author Paolo Ronchese INFN Padova
*
*/
//-----------------------
// This Class' Header --
//-----------------------
#include "CondTools/DT/interface/DTPerformanceHandler.h"
//-------------------------------
// Collaborating Class Headers --
//-------------------------------
#include "CondFormats/DTObjects/interface/DTPerformance.h"
//---------------
// C++ Headers --
//---------------
#include <iostream>
#include <fstream>
//-------------------
// Initializations --
//-------------------
//----------------
// Constructors --
//----------------
DTPerformanceHandler::DTPerformanceHandler(const edm::ParameterSet& ps)
: dataTag(ps.getParameter<std::string>("tag")),
fileName(ps.getParameter<std::string>("file")),
runNumber(ps.getParameter<unsigned int>("run")) {}
//--------------
// Destructor --
//--------------
DTPerformanceHandler::~DTPerformanceHandler() {}
//--------------
// Operations --
//--------------
void DTPerformanceHandler::getNewObjects() {
//to access the information on the tag inside the offline database:
cond::TagInfo_t const& ti = tagInfo();
cond::Time_t last = ti.lastInterval.since;
//to access the information on last successful log entry for this tag:
// cond::LogDBEntry const & lde = logDBEntry();
//to access the lastest payload (Ref is a smart pointer)
// Ref payload = lastPayload();
/*
int irun = event.id().run();
int ievt = event.id().event();
std::cout << "================ "
<< irun << " " << ievt << std::endl;
// edm::Service<cond::service::PoolDBOutputService> dbservice;
std::map<std::string, popcon::PayloadIOV> mp = getOfflineInfo();
std::map<std::string, popcon::PayloadIOV>::iterator iter = mp.begin();
std::map<std::string, popcon::PayloadIOV>::iterator iend = mp.end();
std::cout << "list of all tags: " << std::endl;
while ( iter != iend ) {
std::cout << "Tag: " << iter->first
<< " , last object valid since " << iter->second.last_since
<< " to " << iter->second.last_till
<< std::endl;
iter++;
}
std::cout << "look for tag " << dataTag << std::endl;
std::map<std::string, popcon::PayloadIOV>::iterator itag =
mp.find( dataTag );
*/
if (runNumber <= last) {
std::cout << "More recent data already present - skipped" << std::endl;
return;
}
DTPerformance* dtPerf = new DTPerformance(dataTag);
int status = 0;
std::ifstream ifile(fileName.c_str());
int whe;
int sta;
int sec;
int qua;
float meanT0;
float meanTtrig;
float meanMtime;
float meanNoise;
float meanAfterPulse;
float meanResolution;
float meanEfficiency;
while (ifile >> whe >> sta >> sec >> qua >> meanT0 >> meanTtrig >> meanMtime >> meanNoise >> meanAfterPulse >>
meanResolution >> meanEfficiency) {
status = dtPerf->set(whe,
sta,
sec,
qua,
meanT0,
meanTtrig,
meanMtime,
meanNoise,
meanAfterPulse,
meanResolution,
meanEfficiency,
DTTimeUnits::counts);
std::cout << whe << " " << sta << " " << sec << " " << qua << std::endl
<< " === " << meanT0 << " " << meanTtrig << " " << meanMtime << " " << meanNoise << " " << meanAfterPulse
<< " " << meanResolution << " " << meanEfficiency << std::endl
<< " -> ";
std::cout << "insert status: " << status << std::endl;
}
/*
unsigned int runf = irun;
unsigned int runl = 0xffffffff;
popcon::IOVPair iop = { runf, runl };
std::cout << "APPEND NEW OBJECT: "
<< runf << " " << runl << " " << dtPerf << std::endl;
m_to_transfer->push_back( std::make_pair( dtPerf, iop ) );
*/
//for each payload provide IOV information (say in this case we use since)
m_to_transfer.emplace_back(dtPerf, runNumber);
}
std::string DTPerformanceHandler::id() const { return dataTag; }
|