SummaryTextDataWriter.cpp

Go to the documentation of this file.

 
#include "dfmodules/SummaryTextDataWriter.hpp"
 
#include <stdexcept>
#include <string>
 
namespace dunedaq::dfmodules {
 
SummaryTextDataWriter::SummaryTextDataWriter(const std::string& file_name)
  : m_file_name(file_name)
  , m_output_file(file_name, std::ios::out | std::ios::app)
  , m_recorded_size(0)
  , m_uncompressed_raw_data_size(0)
  , m_total_file_size(0)
{
  if (!m_output_file.is_open()) {
    throw CantOpenFile(ERS_HERE, m_file_name);
  }
}
 
SummaryTextDataWriter::~SummaryTextDataWriter()
{
  if (m_output_file.is_open()) {
    m_output_file.close();
  }
}
 
void
SummaryTextDataWriter::write(const daqdataformats::TriggerRecord& tr)
{
  const auto trigger_number = tr.get_header_ref().get_trigger_number();
  write_line("TriggerRecord #" + std::to_string(trigger_number));
}
 
void
SummaryTextDataWriter::write(const daqdataformats::TimeSlice& ts)
{
  const auto timeslice_number = ts.get_header().timeslice_number;
  m_written_timeslices.insert(timeslice_number);
  write_line("TimeSlice #" + std::to_string(timeslice_number));
}
 
bool
SummaryTextDataWriter::timeslice_already_exists(const daqdataformats::TimeSlice& ts) const
{
  return m_written_timeslices.count(ts.get_header().timeslice_number) > 0;
}
 
std::string
SummaryTextDataWriter::get_file_name() const
{
  return m_file_name;
}
 
size_t
SummaryTextDataWriter::get_recorded_size() const noexcept
{
  return m_recorded_size;
}
 
size_t
SummaryTextDataWriter::get_uncompressed_raw_data_size() const noexcept
{
  return m_uncompressed_raw_data_size;
}
 
size_t
SummaryTextDataWriter::get_total_file_size() const noexcept
{
  return m_total_file_size;
}
 
void
SummaryTextDataWriter::write_line(const std::string& line)
{
  m_output_file << line << '\n';
  if (!m_output_file.good()) {
    throw CantWriteToFile(ERS_HERE, m_file_name);
  }
 
  const size_t bytes_written = line.size() + 1;
  m_recorded_size += bytes_written;
  m_uncompressed_raw_data_size += bytes_written;
  m_total_file_size += bytes_written;
}
 
} // namespace dunedaq::dfmodules