File indexing completed on 2021-02-14 14:21:19
0001 #ifndef IOPool_Streamer_FRDEventMessage_h
0002 #define IOPool_Streamer_FRDEventMessage_h
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018
0019
0020
0021
0022
0023
0024
0025
0026
0027
0028
0029
0030
0031
0032
0033
0034
0035
0036
0037
0038
0039
0040
0041
0042
0043
0044
0045
0046
0047
0048
0049
0050
0051
0052
0053
0054
0055
0056
0057
0058
0059
0060
0061
0062
0063
0064
0065
0066
0067
0068
0069
0070 #include "IOPool/Streamer/interface/MsgTools.h"
0071
0072 #include <array>
0073
0074 struct FRDEventHeader_V6 {
0075 uint16 version_;
0076 uint16 flags_;
0077 uint32 run_;
0078 uint32 lumi_;
0079 uint32 event_;
0080 uint32 eventSize_;
0081 uint32 crc32c_;
0082 };
0083
0084 struct FRDEventHeader_V5 {
0085 uint32 version_;
0086 uint32 run_;
0087 uint32 lumi_;
0088 uint32 event_;
0089 uint32 eventSize_;
0090 uint32 crc32c_;
0091 };
0092
0093 struct FRDEventHeader_V4 {
0094 uint32 version_;
0095 uint32 run_;
0096 uint32 lumi_;
0097 uint32 eventLow_;
0098 uint32 eventHigh_;
0099 uint32 eventSize_;
0100 uint32 paddingSize_;
0101 uint32 adler32_;
0102 };
0103
0104 struct FRDEventHeader_V3 {
0105 uint32 version_;
0106 uint32 run_;
0107 uint32 lumi_;
0108 uint32 event_;
0109 uint32 eventSize_;
0110 uint32 paddingSize_;
0111 uint32 adler32_;
0112 };
0113
0114 struct FRDEventHeader_V2 {
0115 uint32 version_;
0116 uint32 run_;
0117 uint32 lumi_;
0118 uint32 event_;
0119 };
0120
0121 struct FRDEventHeader_V1 {
0122 uint32 run_;
0123 uint32 event_;
0124 };
0125
0126 const uint16 FRDEVENT_MASK_ISGENDATA = 1;
0127
0128 constexpr size_t FRDHeaderMaxVersion = 6;
0129 constexpr std::array<uint32, FRDHeaderMaxVersion + 1> FRDHeaderVersionSize{{0,
0130 2 * sizeof(uint32),
0131 (4 + 1024) * sizeof(uint32),
0132 7 * sizeof(uint32),
0133 8 * sizeof(uint32),
0134 6 * sizeof(uint32),
0135 6 * sizeof(uint32)}};
0136
0137 class FRDEventMsgView {
0138 public:
0139 FRDEventMsgView(void* buf);
0140
0141 uint8* startAddress() const { return buf_; }
0142 void* payload() const { return payload_; }
0143 uint32 size() const { return size_; }
0144
0145 uint16 version() const { return version_; }
0146 uint16 flags() const { return flags_; }
0147 uint32 run() const { return run_; }
0148 uint32 lumi() const { return lumi_; }
0149 uint64 event() const { return event_; }
0150 uint32 eventSize() const { return eventSize_; }
0151 uint32 paddingSize() const { return paddingSize_; }
0152 uint32 adler32() const { return adler32_; }
0153 uint32 crc32c() const { return crc32c_; }
0154
0155 bool isRealData() const { return !(flags_ & FRDEVENT_MASK_ISGENDATA); }
0156
0157 private:
0158 uint8* buf_;
0159 void* payload_;
0160 uint32 size_;
0161 uint16 version_;
0162 uint16 flags_;
0163 uint32 run_;
0164 uint32 lumi_;
0165 uint64 event_;
0166 uint32 eventSize_;
0167 uint32 paddingSize_;
0168 uint32 adler32_;
0169 uint32 crc32c_;
0170 };
0171
0172 #endif