File indexing completed on 2024-05-31 04:19:41
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 namespace edm::streamer {
0075 struct FRDEventHeader_V6 {
0076 uint16 version_;
0077 uint16 flags_;
0078 uint32 run_;
0079 uint32 lumi_;
0080 uint32 event_;
0081 uint32 eventSize_;
0082 uint32 crc32c_;
0083 };
0084
0085 struct FRDEventHeader_V5 {
0086 uint32 version_;
0087 uint32 run_;
0088 uint32 lumi_;
0089 uint32 event_;
0090 uint32 eventSize_;
0091 uint32 crc32c_;
0092 };
0093
0094 struct FRDEventHeader_V4 {
0095 uint32 version_;
0096 uint32 run_;
0097 uint32 lumi_;
0098 uint32 eventLow_;
0099 uint32 eventHigh_;
0100 uint32 eventSize_;
0101 uint32 paddingSize_;
0102 uint32 adler32_;
0103 };
0104
0105 struct FRDEventHeader_V3 {
0106 uint32 version_;
0107 uint32 run_;
0108 uint32 lumi_;
0109 uint32 event_;
0110 uint32 eventSize_;
0111 uint32 paddingSize_;
0112 uint32 adler32_;
0113 };
0114
0115 struct FRDEventHeader_V2 {
0116 uint32 version_;
0117 uint32 run_;
0118 uint32 lumi_;
0119 uint32 event_;
0120 };
0121
0122 struct FRDEventHeader_V1 {
0123 uint32 run_;
0124 uint32 event_;
0125 };
0126
0127 const uint16 FRDEVENT_MASK_ISGENDATA = 1;
0128
0129 constexpr size_t FRDHeaderMaxVersion = 6;
0130 constexpr std::array<uint32, FRDHeaderMaxVersion + 1> FRDHeaderVersionSize{{0,
0131 2 * sizeof(uint32),
0132 (4 + 1024) * sizeof(uint32),
0133 7 * sizeof(uint32),
0134 8 * sizeof(uint32),
0135 6 * sizeof(uint32),
0136 6 * sizeof(uint32)}};
0137
0138 class FRDEventMsgView {
0139 public:
0140 FRDEventMsgView(void* buf);
0141
0142 uint8* startAddress() const { return buf_; }
0143 void* payload() const { return payload_; }
0144 uint32 size() const { return size_; }
0145
0146 uint16 version() const { return version_; }
0147 uint16 flags() const { return flags_; }
0148 uint32 run() const { return run_; }
0149 uint32 lumi() const { return lumi_; }
0150 uint64 event() const { return event_; }
0151 uint32 eventSize() const { return eventSize_; }
0152 uint32 paddingSize() const { return paddingSize_; }
0153 uint32 adler32() const { return adler32_; }
0154 uint32 crc32c() const { return crc32c_; }
0155
0156 bool isRealData() const { return !(flags_ & FRDEVENT_MASK_ISGENDATA); }
0157
0158 private:
0159 uint8* buf_;
0160 void* payload_;
0161 uint32 size_;
0162 uint16 version_;
0163 uint16 flags_;
0164 uint32 run_;
0165 uint32 lumi_;
0166 uint64 event_;
0167 uint32 eventSize_;
0168 uint32 paddingSize_;
0169 uint32 adler32_;
0170 uint32 crc32c_;
0171 };
0172 }
0173 #endif