|
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
|
// system include files
#include <memory>
#include <sstream>
// user include files
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "CondFormats/SiPixelObjects/interface/SiPixelFedCablingMap.h"
#include "CondFormats/SiPixelObjects/interface/SiPixelFedCablingTree.h"
#include "CalibTracker/SiPixelConnectivity/interface/SiPixelFedCablingMapBuilder.h"
using namespace std;
using namespace edm;
using namespace sipixelobjects;
class SiPixelFedCablingMapWriter : public edm::one::EDAnalyzer<> {
public:
explicit SiPixelFedCablingMapWriter(const edm::ParameterSet& cfg);
~SiPixelFedCablingMapWriter();
virtual void beginJob();
virtual void endJob();
virtual void analyze(const edm::Event&, const edm::EventSetup&);
private:
SiPixelFedCablingTree* cabling;
string record_;
//string pixelToFedAssociator_;
string fileName_;
//bool phase1_;
};
SiPixelFedCablingMapWriter::SiPixelFedCablingMapWriter(const edm::ParameterSet& cfg)
: record_(cfg.getParameter<std::string>("record")),
//pixelToFedAssociator_(cfg.getUntrackedParameter<std::string>("associator","PixelToFEDAssociateFromAscii")),
//phase1_(cfg.getUntrackedParameter<bool>("phase1",false)),
fileName_(cfg.getUntrackedParameter<std::string>("fileName", "pixelToLNK.ascii")) {
stringstream out;
out << " record: " << record_ << endl;
out << " input file name " << fileName_ << endl;
//out << " phase " << phase1_ << endl;
LogInfo("initialisation: ") << out.str();
}
SiPixelFedCablingMapWriter::~SiPixelFedCablingMapWriter() = default;
void SiPixelFedCablingMapWriter::analyze(const edm::Event& iEvent, const edm::EventSetup& iSetup) {
static int first(1);
if (1 == first) {
first = 0;
//std::cout << "-------HERE-----------" << endl;
//cabling = SiPixelFedCablingMapBuilder(pixelToFedAssociator_).produce(iSetup);
//cabling = SiPixelFedCablingMapBuilder(fileName_,phase1_).produce(iSetup);
cabling = SiPixelFedCablingMapBuilder(consumesCollector(), fileName_).produce(iSetup);
//std::cout << "-------Print Map ----------- DOES NOT WORK for phase1 " << endl;
edm::LogInfo("PRINTING MAP (Does not work for phase1: ") << cabling->print(3);
}
}
void SiPixelFedCablingMapWriter::beginJob() {}
void SiPixelFedCablingMapWriter::endJob() {
SiPixelFedCablingMap result(cabling);
LogInfo("Now NEW writing to DB");
edm::Service<cond::service::PoolDBOutputService> mydbservice;
if (!mydbservice.isAvailable()) {
edm::LogInfo("db service unavailable");
//std::cout<<"db service unavailable"<<std::endl;
return;
} else {
//std::cout<<"OK"<<std::endl;
edm::LogInfo("Writing finished ");
}
try {
if (mydbservice->isNewTagRequest(record_)) {
mydbservice->createOneIOV<SiPixelFedCablingMap>(result, mydbservice->beginOfTime(), record_);
} else {
mydbservice->appendOneIOV<SiPixelFedCablingMap>(result, mydbservice->currentTime(), record_);
}
} catch (std::exception& e) {
LogError("std::exception: ") << e.what();
} catch (...) {
LogError("Unknown error caught ");
}
LogInfo("... all done, end");
}
//define this as a plug-in
#include "FWCore/Framework/interface/MakerMacros.h"
DEFINE_FWK_MODULE(SiPixelFedCablingMapWriter);
|