diff --git a/lib/src/WriterManager.cpp b/lib/src/WriterManager.cpp index 428fa34..cfa8e91 100644 --- a/lib/src/WriterManager.cpp +++ b/lib/src/WriterManager.cpp @@ -48,15 +48,14 @@ void writer_utils::create_destination_folder(const string& output_file) } } -WriterManager::WriterManager(const unordered_map& parameters_type, - const string& output_file, uint64_t n_frames): - parameters_type(parameters_type), output_file(output_file), n_frames(n_frames), - running_flag(true), killed_flag(false), n_received_frames(0), n_written_frames(0), n_lost_frames(0) +WriterManager::WriterManager(const unordered_map& parameters_type): + parameters_type(parameters_type), running_flag(true), killed_flag(false), + n_received_frames(0), n_written_frames(0), n_lost_frames(0) { #ifdef DEBUG_OUTPUT using namespace date; cout << "[" << std::chrono::system_clock::now() << "]"; - cout << "[WriterManager::WriterManager] Writer manager for n_frames " << n_frames << endl; + cout << "[WriterManager::WriterManager] Writer manager initialized." << endl; #endif } @@ -99,11 +98,6 @@ string WriterManager::get_status() } } -string WriterManager::get_output_file() const -{ - return output_file; -} - unordered_map WriterManager::get_statistics() const { unordered_map result = {{"n_received_frames", n_received_frames.load()}, @@ -207,4 +201,4 @@ bool WriterManager::are_all_parameters_set() size_t WriterManager::get_n_frames() { return n_frames; -} \ No newline at end of file +} diff --git a/lib/src/WriterManager.hpp b/lib/src/WriterManager.hpp index 111e790..e072a86 100644 --- a/lib/src/WriterManager.hpp +++ b/lib/src/WriterManager.hpp @@ -21,12 +21,9 @@ class WriterManager { std::unordered_map parameters = {}; - std::mutex parameters_mutex; // Initialize in constructor. const std::unordered_map& parameters_type; - std::string output_file; - size_t n_frames; std::atomic_bool running_flag; std::atomic_bool killed_flag; std::atomic n_received_frames; @@ -34,27 +31,26 @@ class WriterManager std::atomic n_lost_frames; public: - WriterManager(const std::unordered_map& parameters_type, const std::string& output_file, uint64_t n_frames=0); + WriterManager(const std::unordered_map& parameters_type); virtual ~WriterManager(); + void start(const std::unordered_map& parameters); + const std::unordered_map& get_parameters_type() const; void stop(); void kill(); + std::string get_status(); + std::unordered_map get_statistics() const; + bool is_running(); bool is_killed() const; - std::string get_status(); bool are_all_parameters_set(); std::string get_output_file() const; - const std::unordered_map& get_parameters_type() const; std::unordered_map get_parameters(); - void set_parameters(const std::unordered_map& new_parameters); - std::unordered_map get_statistics() const; void received_frame(size_t frame_index); void written_frame(size_t frame_index); void lost_frame(size_t frame_index); - - size_t get_n_frames(); }; -#endif \ No newline at end of file +#endif