|
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
|
#include "EventFilter/L1TRawToDigi/interface/OmtfRpcUnpacker.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "EventFilter/RPCRawToDigi/interface/RPCRecordFormatter.h"
#include "EventFilter/RPCRawToDigi/interface/RPCPackingModule.h"
#include "EventFilter/RPCRawToDigi/interface/DebugDigisPrintout.h"
#include "CondFormats/RPCObjects/interface/RPCEMap.h"
#include "CondFormats/DataRecord/interface/RPCEMapRcd.h"
#include "EventFilter/L1TRawToDigi/interface/OmtfRpcDataWord64.h"
#include "DataFormats/RPCDigi/interface/DataRecord.h"
#include "DataFormats/RPCDigi/interface/RecordBX.h"
#include "DataFormats/RPCDigi/interface/RecordSLD.h"
#include "DataFormats/RPCDigi/interface/RecordCD.h"
namespace omtf {
void RpcUnpacker::initCabling(const RPCEMap& readoutMapping) {
thePactCabling.reset(readoutMapping.convert());
LogDebug("OmtfUnpacker") << " Has PACT readout map, VERSION: " << thePactCabling->version() << std::endl;
}
void RpcUnpacker::init(const RPCEMap& readoutMapping, const RPCAMCLinkMap& linkMap) {
initCabling(readoutMapping);
RpcLinkMap omtfLink2Ele;
omtfLink2Ele.init(linkMap);
theOmtf2Pact = translateOmtf2Pact(omtfLink2Ele, thePactCabling.get());
}
void RpcUnpacker::init(const RPCEMap& readoutMapping, const std::string& connectionFile) {
initCabling(readoutMapping);
RpcLinkMap omtfLink2Ele;
omtfLink2Ele.init(connectionFile);
theOmtf2Pact = translateOmtf2Pact(omtfLink2Ele, thePactCabling.get());
}
void RpcUnpacker::unpack(
int triggerBX, unsigned int fed, unsigned int amc, const RpcDataWord64& data, RPCDigiCollection* prod) {
LogTrace("RpcUnpacker:") << data;
// EleIndex omtfEle(fedHeader.sourceID(), bh.getAMCNumber()/2+1, data.linkNum());
EleIndex omtfEle(fed, amc, data.linkNum());
LinkBoardElectronicIndex rpcEle = theOmtf2Pact.at(omtfEle);
RPCRecordFormatter formater(rpcEle.dccId, thePactCabling.get());
rpcrawtodigi::EventRecords records(triggerBX);
rpcrawtodigi::RecordBX recordBX(triggerBX + data.bxNum() - 3);
records.add(recordBX); // warning: event records must be added in right order
rpcrawtodigi::RecordSLD recordSLD(rpcEle.tbLinkInputNum, rpcEle.dccInputChannelNum);
records.add(recordSLD); // warning: event records must be added in right order
for (unsigned int iframe = 1; iframe <= 3; iframe++) {
uint16_t frame = (iframe == 1) ? data.frame1() : ((iframe == 2) ? data.frame2() : data.frame3());
if (frame == 0)
continue;
rpcrawtodigi::RecordCD recordCD(frame);
records.add(recordCD);
LogTrace("") << "OMTF->RPC Event isComplete: " << records.complete()
<< records.print(rpcrawtodigi::DataRecord::StartOfBXData); // << std::endl;
LogTrace("") << "OMTF->RPC Event: "
<< records.print(rpcrawtodigi::DataRecord::StartOfTbLinkInputNumberData) << std::endl;
LogTrace("") << "OMTF->RPC Event: " << records.print(rpcrawtodigi::DataRecord::ChamberData)
<< " lb:" << recordCD.lbInLink() << " part: " << recordCD.partitionNumber()
<< " partData: " << recordCD.partitionData() << std::endl
<< std::endl;
if (records.complete())
formater.recordUnpack(records, prod, nullptr, nullptr);
}
}
} // namespace omtf
|