From 98d44b6dfd1c8b58bf3e1c8954b208c0399d62d4 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Mon, 6 Apr 2020 13:27:55 +0200 Subject: [PATCH] Add start_writing method to H5WriteModule --- core-writer/src/module/H5WriteModule.cpp | 26 ++++++++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/core-writer/src/module/H5WriteModule.cpp b/core-writer/src/module/H5WriteModule.cpp index 773e1da..9c58394 100644 --- a/core-writer/src/module/H5WriteModule.cpp +++ b/core-writer/src/module/H5WriteModule.cpp @@ -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