From 70062e3f14f5f16d149f0d9bbd4a2110c83fd101 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Mon, 6 Apr 2020 13:36:54 +0200 Subject: [PATCH] Pass file properties to writing thread --- core-writer/include/H5WriteModule.hpp | 11 +++++++++-- core-writer/src/module/H5WriteModule.cpp | 18 +++++++++++++++--- 2 files changed, 24 insertions(+), 5 deletions(-) diff --git a/core-writer/include/H5WriteModule.hpp b/core-writer/include/H5WriteModule.hpp index 989d9b1..f0cbbe7 100644 --- a/core-writer/include/H5WriteModule.hpp +++ b/core-writer/include/H5WriteModule.hpp @@ -16,7 +16,10 @@ class H5WriteModule { std::thread writing_thread_; protected: - void write_thread(); + void write_thread( + const std::string& output_file, + const int n_frames, + const int user_id); public: H5WriteModule( @@ -24,7 +27,11 @@ public: const header_map& header_values, const H5Format& format); - void start_writing(); + void start_writing( + const std::string& output_file, + const int n_frames = 0, + const int user_id = -1 + ); void stop_writing(); }; diff --git a/core-writer/src/module/H5WriteModule.cpp b/core-writer/src/module/H5WriteModule.cpp index 9c58394..5829926 100644 --- a/core-writer/src/module/H5WriteModule.cpp +++ b/core-writer/src/module/H5WriteModule.cpp @@ -14,7 +14,10 @@ H5WriteModule::H5WriteModule( { } -void H5WriteModule::start_writing() +void H5WriteModule::start_writing( + const string& output_file, + const int n_frames, + const int user_id) { if (is_writing_ == true) { stringstream err_msg; @@ -33,11 +36,20 @@ void H5WriteModule::start_writing() using namespace chrono; cout << "[" << system_clock::now() << "]"; cout << "[H5WriteModule::start_writing]"; - cout << " Start writing." << endl; + cout << " Start writing with parameters:" << endl; + cout << "\toutput_file: " << output_file; + cout << "\tn_frames: " << n_frames; + cout << "\tuser_id: " << user_id; + cout << endl; #endif is_writing_ = true; - writing_thread_ = thread(&H5WriteModule::write_thread, this); + + writing_thread_ = thread( + &H5WriteModule::write_thread, this, + output_file, + n_frames, + user_id); } void H5WriteModule::stop_writing()