log_module.h

/*
 * Developer : Alexey Zakharov (alexey.zakharov@vectioneer.com)
 * All rights reserved. Copyright (c) 2016 VECTIONEER.
 */
 
#ifndef LOG_MODULE_H
#define LOG_MODULE_H
 
#include "ct_module.h"
#include <chrono>
#include <cstdio>
 
namespace mcx {
 
namespace log {
 
class Module : public mcx::container::Module {
  static constexpr unsigned int MAX_LOG_STR_LENGTH{256};
  static constexpr unsigned int MAX_LOG_BUFFER_LENGTH{1024};
  static constexpr unsigned int MAX_PIPE_BUFFER_LENGTH{1048576};
public:
  Module(const std::string& folder, FILE* stream = stdout);
 
  Module(const Module& orig) = delete;
 
  ~Module() override;
 
  static bool readLine(const char* buffer, size_t& buffer_offset, size_t buffer_max_len,
                       char* line, size_t& line_offset, size_t max_line_len, bool& ignore);
 
private:
 
  static FILE* createNewFile(const std::string& path);
 
  void create_(const char* name, mcx::parameter_server::Parameter* parameter_server,
               uint64_t dt_micro_s) override;
 
  bool initPhase1_() override;
 
  bool initPhase2_() override;
 
  bool startOp_() override;
 
  bool stopOp_() override;
 
  bool iteratePreOp_(const mcx::container::TaskTime& system_time, mcx::container::UserTime* user_time) override;
 
  bool iterateOp_(const mcx::container::TaskTime& system_time, mcx::container::UserTime* user_time) override;
 
  std::array<char, MAX_LOG_STR_LENGTH> log_str_{};
  std::array<char, MAX_LOG_STR_LENGTH> log_marker_{};
  std::array<char, MAX_LOG_BUFFER_LENGTH> buffer_str_{};
  size_t buffer_offset_{};
  size_t buffer_len_{};
  size_t line_offset_{};
 
  FILE* log_stream_{};
  FILE* file_input_{};
  int out_pipe_[2]{};
  bool ignore_control_char_{};
 
  mcx::parameter_server::ParamHandle log_out_handle_;
  mcx::parameter_server::ParamHandle log_marker_in_handle_;
 
  long timer24_{};
  std::string folder_;
  bool log_is_empty_{};
 
};
 
}  // namespace log
 
}  // namespace mcx
 
#endif /* LOG_MODULE_H */