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

Simplify the write thread flow

Browse Source
This commit is contained in:
babic_a
2020-04-06 15:48:56 +02:00
parent 7ceaa2cb4b
commit af816bd541
1 changed files with 10 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/module/H5WriteModule.cpp
+10 -23
View File
@@ -198,31 +198,18 @@ void H5WriteModule::write_thread(
writer.write_metadata_to_file();
write_h5_format(writer.get_h5_file());
writer.close_file();
}
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[H5WriteModule::write_thread]";
cout << " Closing file " << output_file << endl;
#endif
writer.close_file();
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[H5WriteModule::write_thread]";
cout << " Writer thread stopped." << endl;
#endif
writing_completed();
} catch (const exception& ex) {
writing_error(ex.what());
}
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[H5WriteModule::write_thread]";
cout << " Write thread stopped." << endl;
#endif
}