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

Add start_writing method to H5WriteModule

Browse Source
This commit is contained in:
babic_a
2020-04-06 13:27:55 +02:00
parent 90e70049bd
commit 98d44b6dfd
1 changed files with 26 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/module/H5WriteModule.cpp
+26
View File
@@ -14,6 +14,32 @@ H5WriteModule::H5WriteModule(
{
}
void H5WriteModule::start_writing()
{
if (is_writing_ == true) {
stringstream err_msg;
using namespace date;
using namespace chrono;
err_msg << "[" << system_clock::now() << "]";
err_msg << "[H5WriteModule::start_writing]";
err_msg << " Writer already running." << endl;
throw runtime_error(err_msg.str());
}
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[H5WriteModule::start_writing]";
cout << " Start writing." << endl;
#endif
is_writing_ = true;
writing_thread_ = thread(&H5WriteModule::write_thread, this);
}
void H5WriteModule::stop_writing()
{
#ifdef DEBUG_OUTPUT