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

Implemented kill flag with format

Browse Source
This commit is contained in:
babic_a
2018-01-24 16:26:38 +01:00
parent 8dfca2f49b
commit 31f97b3a1b
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/h5_zmq_writer.cpp
+10 -1
View File
@@ -54,7 +54,16 @@ void write_h5(WriterManager *manager, RingBuffer *ring_buffer, string output_fil
cout << "[h5_zmq_writer::write] Writing file format." << endl;
#endif
H5Format::write_format(writer.get_h5_file(), manager->get_parameters(), get_frames_dataset_name());
// Wait until all parameters are set or writer is killed.
while (!manager->are_all_parameters_set() && !manager->is_killed()) {
boost::this_thread::sleep_for(boost::chrono::milliseconds(config::parameters_read_retry_interval));
}
// Need to check again if we have all parameters to write down the format.
if (manager->are_all_parameters_set()) {
auto parameters = manager->get_parameters();
H5Format::write_format(writer.get_h5_file(), parameters, get_frames_dataset_name());
}
}
#ifdef DEBUG_OUTPUT