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

Adjust main in live writer for metadata writes

Browse Source
This commit is contained in:
babic_a
2021-02-25 10:26:59 +01:00
parent 6ad5b9538d
commit 9a3df07331
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jf-live-writer/src/main.cpp
+12 -10
View File
@@ -61,21 +61,23 @@ int main (int argc, char *argv[])
}
if (meta.op_code == OP_END) {
writer.close_run(meta.run_id);
writer.close_run();
continue;
}
if (meta.i_image % n_writers != i_writer) {
continue;
// Fair distribution of images among writers.
if (meta.i_image % n_writers == i_writer) {
char* data = ram_buffer.read_image(meta.image_metadata.pulse_id);
stats.start_image_write();
writer.write_data(meta.run_id, meta.i_image, data);
stats.end_image_write();
}
char* data = ram_buffer.read_image(meta.image_metadata.pulse_id);
stats.start_image_write();
writer.write(meta.run_id, meta.image_metadata, data);
stats.end_image_write();
// Only the first instance writes metadata.
if (i_writer == 0) {
writer.write_meta(meta.run_id, meta.i_image, meta.image_metadata);
}
}
MPI_Finalize();