86 unsigned int triggernr = 0xFFFFFFFF;
88 auto current_offset = ftell(
fh);
94 unsigned int get_size(
void) {
return (
unsigned int) size + (((
unsigned int)(header & 0x000F)) << 16);};
95 unsigned int get_size_group(
void) {
return (
unsigned int) size + (((
unsigned int)((header & 0x003F) ^ 0x0020)) << 16);};
96 unsigned int get_header12(
void) {
return (header & 0xFFF0);};
97 unsigned int get_header10(
void) {
return (header & 0xFFC0);};
98 unsigned int get_header8(
void) {
return (header & 0xFF00);};
109 if (br <= 0)
return br;
110 unsigned int chunk_size = 0;
111 if (evt->get_header8() == 0) {
112 B2DEBUG(29,
"Group Header $" << std::hex << evt->get_header10() <<
" Chunk size " << std::dec << evt->get_size());
113 chunk_size = evt->get_size_group();
115 B2DEBUG(29,
"Header $" << std::hex << evt->get_header12() <<
" Chunk size " << std::dec << evt->get_size());
116 chunk_size = evt->get_size();
118 if (chunk_size <= 1)
return 0;
119 br =
read_data(data + 4, chunk_size * 4 - 4);
120 if (br <= 0)
return br;
121 if (evt->get_header12() == 0xe230) {
122 B2DEBUG(29,
"File info " << std::hex << evt->get_header12() <<
" Events " << std::dec << data32[1]);
124 }
else if (evt->get_header12() == 0xe100) {
125 B2DEBUG(29,
"Info Event " << std::hex << evt->get_header12() <<
" RunNr $" << std::hex << data32[1]);
128 }
else if (evt->get_header10() == 0x0000) {
129 B2DEBUG(29,
"Run Event Group " << std::hex << evt->get_header10() <<
" Magic $" << std::hex << data32[1]);
131 }
else if (evt->get_header12() == 0xbb00) {
132 B2DEBUG(29,
"Run Event " << std::hex << evt->get_header12() <<
" Magic $" << std::hex << data32[1]);
134 }
else if (evt->get_header10() == 0x0080) {
135 int togo = chunk_size;
136 B2DEBUG(29,
"Data Event Group " << std::hex << evt->get_header10() <<
" TriggerNr $" << std::hex << data32[1]);
137 triggernr = data32[1];
142 B2DEBUG(29,
"TOGO: " << togo);
143 B2DEBUG(29,
" ............... " << std::hex << data32[0] <<
" TriggerNr $" << std::hex << data32[1]);
144 if (triggernr != data32[1]) B2ERROR(
"Trigger Nr does not match!");
145 B2DEBUG(29,
" ............... " << std::hex << data32[2]);
149 if ((data32[0] & 0xFFFF0000) == 0xCAFE0000) {
150 int frames = (data32[0] & 0x3FF);
151 B2DEBUG(29,
"Frames: " << frames);
153 bool nocrc = (data32[0] & 0x8000) != 0;
155 if ((data32[0] & 0x4000) == 0) B2FATAL(
"large data fields not supported");
161 std::vector <unsigned int> m_onsen_header;
164 std::vector <std::vector <unsigned char>> m_onsen_payload;
165 int offset = ((frames + 1) & ~1);
174 for (
int i = 0; i < frames; i++) {
179 std::vector <unsigned char> m_current_frame;
181 for (
int j = 0; j < (int)table16[i] * 2; j++) {
182 unsigned short w = data16[offset++];
183 m_current_frame.push_back((
unsigned char)(w >> 8));
184 m_current_frame.push_back((
unsigned char)(w));
188 dhe_crc_32_type current_crc;
189 current_crc.process_bytes(m_current_frame.data(), m_current_frame.size());
190 unsigned int w = current_crc.checksum();
191 m_current_frame.push_back((
unsigned char)(w >> 24));
192 m_current_frame.push_back((
unsigned char)(w >> 16));
193 m_current_frame.push_back((
unsigned char)(w >> 8));
194 m_current_frame.push_back((
unsigned char)(w));
197 m_onsen_header.push_back(m_current_frame.size());
198 m_onsen_payload.push_back(m_current_frame);
200 togo -= ((frames + 1) & ~1) / 2 + size;
201 data32 += ((frames + 1) & ~1) / 2 + size;
202 data16 += ((frames + 1) & ~1) + size * 2;
210 if (rettriggernr == triggernr)
m_rawPXD.appendNew(m_onsen_header, m_onsen_payload);
214 rettriggernr = triggernr;
217 current_offset = ftell(
fh);
222 B2ERROR(
"Undefine Header $" << std::hex << evt->get_header12());
228 rettriggernr = 0xFFFFFFFF;