|
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
|
#include "CondTools/RPC/interface/RPCDCCLinkMapHandler.h"
#include <fstream>
#include <memory>
#include <sstream>
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Utilities/interface/Exception.h"
#include "CondCore/CondDB/interface/Types.h"
#include "RelationalAccess/ICursor.h"
#include "RelationalAccess/IQuery.h"
#include "RelationalAccess/IQueryDefinition.h"
#include "RelationalAccess/ISchema.h"
#include "RelationalAccess/ISessionProxy.h"
#include "RelationalAccess/ITransaction.h"
#include "CoralBase/Attribute.h"
#include "CoralBase/AttributeList.h"
#include "CondTools/RPC/interface/RPCLBLinkNameParser.h"
RPCDCCLinkMapHandler::RPCDCCLinkMapHandler(edm::ParameterSet const& config)
: id_(config.getParameter<std::string>("identifier")),
data_tag_(config.getParameter<std::string>("dataTag")),
since_run_(config.getParameter<unsigned long long>("sinceRun")),
txt_file_(config.getUntrackedParameter<std::string>("txtFile", "")),
connect_(config.getParameter<std::string>("connect")) {
edm::LogInfo("RPCDCCLinkMapHandler") << "Configuring Input Connection";
connection_.setParameters(config.getParameter<edm::ParameterSet>("DBParameters"));
connection_.configure();
}
RPCDCCLinkMapHandler::~RPCDCCLinkMapHandler() {}
void RPCDCCLinkMapHandler::getNewObjects() {
edm::LogInfo("RPCDCCLinkMapHandler") << "getNewObjects";
cond::TagInfo_t const& tag_info = tagInfo();
if (since_run_ < tag_info.lastInterval.since)
throw cms::Exception("RPCDCCLinkMapHandler") << "Refuse to create RPCDCCLinkMap for run " << since_run_
<< ", older than most recent tag" << tag_info.lastInterval.since;
edm::LogInfo("RPCDCCLinkMapHandler") << "Opening read-only Input Session";
auto input_session = connection_.createCoralSession(connect_, false); // writeCapable
edm::LogInfo("RPCDCCLinkMapHandler") << "Started Input Transaction";
input_session->transaction().start(true); // readOnly
std::unique_ptr<coral::IQuery> query(input_session->schema("CMS_RPC_CONF").newQuery());
query->addToTableList("DCCBOARD");
query->addToTableList("TRIGGERBOARD");
query->addToTableList("BOARDBOARDCONN");
query->addToTableList("BOARD");
query->addToOutputList("DCCBOARD.FEDNUMBER", "DCC");
query->addToOutputList("TRIGGERBOARD.DCCINPUTCHANNELNUM", "DCC_INPUT");
query->addToOutputList("BOARDBOARDCONN.COLLECTORBOARDINPUTNUM", "TB_INPUT");
query->addToOutputList("BOARD.NAME", "LB_NAME");
coral::AttributeList query_condition_data;
query->setCondition(
"TRIGGERBOARD.DCCBOARD_DCCBOARDID=DCCBOARD.DCCBOARDID"
" AND BOARDBOARDCONN.BOARD_COLLECTORBOARDID=TRIGGERBOARD.TRIGGERBOARDID"
" AND BOARD.BOARDID=BOARDBOARDCONN.BOARD_BOARDID",
query_condition_data);
int dcc(0), dcc_input(0), tb_input(0);
std::string lb_name("");
std::unique_ptr<RPCDCCLinkMap> dcc_link_map_object(new RPCDCCLinkMap());
RPCDCCLinkMap::map_type& dcc_link_map = dcc_link_map_object->getMap();
RPCLBLink lb_link;
edm::LogInfo("RPCDCCLinkMapHandler") << "Execute query";
coral::ICursor& cursor(query->execute());
while (cursor.next()) {
coral::AttributeList const& row(cursor.currentRow());
// RPCLBLink
lb_name = row["LB_NAME"].data<std::string>();
RPCLBLinkNameParser::parse(lb_name, lb_link);
if (lb_name != lb_link.getName())
edm::LogWarning("RPCDCCLinkMapHandler") << "Mismatch LinkBoard Name: " << lb_name << " vs " << lb_link;
lb_link.setLinkBoard().setConnector(); // MLB to link
dcc = row["DCC"].data<long long>();
dcc_input = row["DCC_INPUT"].data<long long>();
tb_input = row["TB_INPUT"].data<long long>();
dcc_link_map.insert(std::pair<RPCDCCLink, RPCLBLink>(RPCDCCLink(dcc, dcc_input, tb_input), lb_link));
}
cursor.close();
input_session->transaction().commit();
if (!txt_file_.empty()) {
edm::LogInfo("RPCDCCLinkMapHandler") << "Fill txtFile";
std::ofstream ofstream(txt_file_);
for (auto const& link : dcc_link_map) {
ofstream << link.first << ": " << link.second << std::endl;
}
}
edm::LogInfo("RPCDCCLinkMapHandler") << "Add to transfer list";
m_to_transfer.push_back(std::make_pair(dcc_link_map_object.release(), since_run_));
}
std::string RPCDCCLinkMapHandler::id() const { return id_; }
|