sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-01 01:22:23 +02:00
Code Issues Packages Projects Releases Wiki Activity

correctly fill number of requested pulses in output file, stop in receiver before buffer is filled, if number of pulses is less then buffer

Browse Source
This commit is contained in:
Dmitry Ozerov
2020-05-10 00:01:41 +02:00
committed by Data Backend account
parent 85c0fff417
commit dd3d5a80c4
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_writer.cpp
+4 -1
View File
@@ -141,10 +141,13 @@ void receive_replay(
}
current_pulse_id++;
// received all frames, don't wait till all WRITER_N_FRAMES_BUFFER
if ( current_pulse_id > stop_pulse_id ) break;
}
queue.commit();
// break receiving loop
if ( current_pulse_id > stop_pulse_id ) break;
}
for (size_t i = 0; i < n_modules; i++) {
@@ -198,7 +201,7 @@ int main (int argc, char *argv[])
receive_replay, ipc_prefix, n_modules,
ref(queue), ctx, start_pulse_id, stop_pulse_id);
size_t n_frames = stop_pulse_id - start_pulse_id;
size_t n_frames = stop_pulse_id - start_pulse_id + 1;
SFWriter writer(output_file, n_frames, n_modules);
// TODO: Remove stats trash.