83 unsigned int triggernr = 0xFFFFFFFF;
85 auto current_offset = ftell(
fh);
91 unsigned int get_size(
void) {
return (
unsigned int) size + (((
unsigned int)(header & 0x000F)) << 16);};
92 unsigned int get_size_group(
void) {
return (
unsigned int) size + (((
unsigned int)((header & 0x003F) ^ 0x0020)) << 16);};
93 unsigned int get_header12(
void) {
return (header & 0xFFF0);};
94 unsigned int get_header10(
void) {
return (header & 0xFFC0);};
95 unsigned int get_header8(
void) {
return (header & 0xFF00);};
106 if (br <= 0)
return br;
107 unsigned int chunk_size = 0;
108 if (evt->get_header8() == 0) {
109 B2DEBUG(29,
"Group Header $" << std::hex << evt->get_header10() <<
" Chunk size " << std::dec << evt->get_size());
110 chunk_size = evt->get_size_group();
112 B2DEBUG(29,
"Header $" << std::hex << evt->get_header12() <<
" Chunk size " << std::dec << evt->get_size());
113 chunk_size = evt->get_size();
115 if (chunk_size <= 1)
return 0;
116 br =
read_data(data + 4, chunk_size * 4 - 4);
117 if (br <= 0)
return br;
118 if (evt->get_header12() == 0xe230) {
119 B2DEBUG(29,
"File info " << std::hex << evt->get_header12() <<
" Events " << std::dec << data32[1]);
121 }
else if (evt->get_header12() == 0xe100) {
122 B2DEBUG(29,
"Info Event " << std::hex << evt->get_header12() <<
" RunNr $" << std::hex << data32[1]);
125 }
else if (evt->get_header10() == 0x0000) {
126 B2DEBUG(29,
"Run Event Group " << std::hex << evt->get_header10() <<
" Magic $" << std::hex << data32[1]);
128 }
else if (evt->get_header12() == 0xbb00) {
129 B2DEBUG(29,
"Run Event " << std::hex << evt->get_header12() <<
" Magic $" << std::hex << data32[1]);
131 }
else if (evt->get_header10() == 0x0080) {
132 int togo = chunk_size;
133 B2DEBUG(29,
"Data Event Group " << std::hex << evt->get_header10() <<
" TriggerNr $" << std::hex << data32[1]);
134 triggernr = data32[1];
139 B2DEBUG(29,
"TOGO: " << togo);
140 B2DEBUG(29,
" ............... " << std::hex << data32[0] <<
" TriggerNr $" << std::hex << data32[1]);
141 if (triggernr != data32[1]) B2ERROR(
"Trigger Nr does not match!");
142 B2DEBUG(29,
" ............... " << std::hex << data32[2]);
146 if ((data32[0] & 0xFFFF0000) == 0xCAFE0000) {
147 int frames = (data32[0] & 0x3FF);
148 B2DEBUG(29,
"Frames: " << frames);
150 bool nocrc = (data32[0] & 0x8000) != 0;
152 if ((data32[0] & 0x4000) == 0) B2FATAL(
"large data fields not supported");
158 std::vector <unsigned int> m_onsen_header;
161 std::vector <std::vector <unsigned char>> m_onsen_payload;
162 int offset = ((frames + 1) & ~1);
171 for (
int i = 0; i < frames; i++) {
176 std::vector <unsigned char> m_current_frame;
178 for (
int j = 0; j < (int)table16[i] * 2; j++) {
179 unsigned short w = data16[offset++];
180 m_current_frame.push_back((
unsigned char)(w >> 8));
181 m_current_frame.push_back((
unsigned char)(w));
185 dhe_crc_32_type current_crc;
186 current_crc.process_bytes(m_current_frame.data(), m_current_frame.size());
187 unsigned int w = current_crc.checksum();
188 m_current_frame.push_back((
unsigned char)(w >> 24));
189 m_current_frame.push_back((
unsigned char)(w >> 16));
190 m_current_frame.push_back((
unsigned char)(w >> 8));
191 m_current_frame.push_back((
unsigned char)(w));
194 m_onsen_header.push_back(m_current_frame.size());
195 m_onsen_payload.push_back(m_current_frame);
197 togo -= ((frames + 1) & ~1) / 2 + size;
198 data32 += ((frames + 1) & ~1) / 2 + size;
199 data16 += ((frames + 1) & ~1) + size * 2;
207 if (rettriggernr == triggernr)
m_rawPXD.appendNew(m_onsen_header, m_onsen_payload);
211 rettriggernr = triggernr;
214 current_offset = ftell(
fh);
219 B2ERROR(
"Undefine Header $" << std::hex << evt->get_header12());
225 rettriggernr = 0xFFFFFFFF;