|
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
|
#include "EffSourceHandler.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ParameterSet/interface/ParameterSetfwd.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
//#include<iostream>
#include <memory>
#include <sstream>
#include <vector>
#include <string>
#include <sstream>
#include <typeinfo>
#include "CondCore/CondDB/interface/Serialization.h"
namespace cond {
template <>
std::unique_ptr<condex::Efficiency> deserialize<condex::Efficiency>(const std::string& payloadType,
const Binary& payloadData,
const Binary& streamerInfoData) {
// DESERIALIZE_BASE_CASE( condex::Efficiency ); abstract
DESERIALIZE_POLIMORPHIC_CASE(condex::Efficiency, condex::ParametricEfficiencyInPt);
DESERIALIZE_POLIMORPHIC_CASE(condex::Efficiency, condex::ParametricEfficiencyInEta);
// here we come if none of the deserializations above match the payload type:
throwException(std::string("Type mismatch, target object is type \"") + payloadType + "\"", "deserialize<>");
}
} // namespace cond
popcon::ExEffSource::ExEffSource(const edm::ParameterSet& pset)
: m_name(pset.getUntrackedParameter<std::string>("name", "ExEffSource")),
m_since(pset.getUntrackedParameter<long long>("since", 5)),
m_type(pset.getUntrackedParameter<std::string>("type", "NULL")),
m_params(pset.getUntrackedParameter<std::vector<double> >("params", std::vector<double>())) {}
popcon::ExEffSource::~ExEffSource() {}
void popcon::ExEffSource::getNewObjects() {
edm::LogInfo("ExEffSource") << "------- " << m_name
<< " - > getNewObjects\n"
//check whats already inside of database
<< "got offlineInfo" << tagInfo().name << ", size " << tagInfo().size
<< ", last object valid since " << tagInfo().lastInterval.since << " token "
<< tagInfo().lastInterval.payloadId << std::endl;
//
//edm::LogInfo ("ExEffsSource")<< " ------ last entry info regarding the payload (if existing): " <<logDBEntry().usertext<<
// "; last record with the correct tag (if existing) has been written in the db: " <<logDBEntry().destinationDB<< std::endl;
if (tagInfo().size > 0) {
Ref payload = lastPayload();
edm::LogInfo("ExEffsSource") << " type of last payload " << typeid(value_type).name() << std::endl;
}
std::cout << "since = " << m_since << std::endl;
// the most stupid factory It shall be not be anymore in fase with "record name"
condex::Efficiency* p0 = 0;
if (m_type.find("Eta") != std::string::npos)
p0 = new condex::ParametricEfficiencyInEta(m_params[0], m_params[1], m_params[2], m_params[3]);
else
p0 = new condex::ParametricEfficiencyInPt(m_params[0], m_params[1], m_params[2], m_params[3]);
if (p0 == 0) {
edm::LogInfo("ExEffsSource") << " unable to build " << m_type << std::endl;
return;
}
if ((unsigned long long)m_since > tagInfo().lastInterval.since) {
m_to_transfer.push_back(std::make_pair(p0, (unsigned long long)m_since));
std::ostringstream ss;
ss << "type=" << m_type << ",since=" << m_since;
m_userTextLog = ss.str() + ";";
}
edm::LogInfo("ExEffsSource") << "------- " << m_name << " - > getNewObjects" << std::endl;
}
#include "CondCore/PopCon/interface/PopConAnalyzer.h"
#include "FWCore/Framework/interface/MakerMacros.h"
typedef popcon::PopConAnalyzer<popcon::ExEffSource> ExPopConEfficiency;
//define this as a plug-in
DEFINE_FWK_MODULE(ExPopConEfficiency);
|