dunedaq::datahandlinglibs::FileSourceBuffer Class Reference

#include <FileSourceBuffer.hpp>

Public Member Functions
	FileSourceBuffer (int input_limit, int chunk_size=0)
	FileSourceBuffer (const FileSourceBuffer &)=delete
	FileSourceBuffer is not copy-constructible.
FileSourceBuffer &	operator= (const FileSourceBuffer &)=delete
	FileSourceBuffer is not copy-assginable.
	FileSourceBuffer (FileSourceBuffer &&)=delete
	FileSourceBuffer is not move-constructible.
FileSourceBuffer &	operator= (FileSourceBuffer &&)=delete
	FileSourceBuffer is not move-assignable.
void	read (const std::string &sourcefile)
const int &	num_elements ()
std::vector< std::uint8_t > &	get ()

Private Attributes
int	m_input_limit
int	m_chunk_size
int	m_element_count
std::string	m_source_filename
std::ifstream	m_rawdata_ifs
std::vector< std::uint8_t >	m_input_buffer

Detailed Description

Definition at line 26 of file FileSourceBuffer.hpp.

Constructor & Destructor Documentation

FileSourceBuffer() [1/3]

dunedaq::datahandlinglibs::FileSourceBuffer::FileSourceBuffer ( int input_limit, int chunk_size = 0 )

inlineexplicit

Definition at line 29 of file FileSourceBuffer.hpp.

    : m_input_limit(input_limit)
    , m_chunk_size(chunk_size)
    , m_element_count(0)
    , m_source_filename("")
  {}

FileSourceBuffer() [2/3]

dunedaq::datahandlinglibs::FileSourceBuffer::FileSourceBuffer ( const FileSourceBuffer & )

delete

FileSourceBuffer is not copy-constructible.

FileSourceBuffer() [3/3]

dunedaq::datahandlinglibs::FileSourceBuffer::FileSourceBuffer ( FileSourceBuffer && )

delete

FileSourceBuffer is not move-constructible.

Member Function Documentation

get()

std::vector< std::uint8_t > & dunedaq::datahandlinglibs::FileSourceBuffer::get ( )

inline

Definition at line 89 of file FileSourceBuffer.hpp.

  {
    return std::ref(m_input_buffer);
  }

num_elements()

const int & dunedaq::datahandlinglibs::FileSourceBuffer::num_elements ( )

inline

Definition at line 87 of file FileSourceBuffer.hpp.

{ return std::ref(m_element_count); }

operator=() [1/2]

FileSourceBuffer & dunedaq::datahandlinglibs::FileSourceBuffer::operator= ( const FileSourceBuffer & )

delete

FileSourceBuffer is not copy-assginable.

operator=() [2/2]

FileSourceBuffer & dunedaq::datahandlinglibs::FileSourceBuffer::operator= ( FileSourceBuffer && )

delete

FileSourceBuffer is not move-assignable.

read()

void dunedaq::datahandlinglibs::FileSourceBuffer::read ( const std::string & sourcefile )

inline

Definition at line 41 of file FileSourceBuffer.hpp.

  {
    m_source_filename = sourcefile;
    try {
 
      // Open file
      m_rawdata_ifs.open(m_source_filename, std::ios::in | std::ios::binary);
      if (!m_rawdata_ifs) {
        throw CannotOpenFile(ERS_HERE, m_source_filename);
      }
 
      // Check file size
      m_rawdata_ifs.ignore(std::numeric_limits<std::streamsize>::max());
      std::streamsize filesize = m_rawdata_ifs.gcount();
      if (filesize > m_input_limit) { // bigger than configured limit
        std::ostringstream oss;
        oss << "File size limit exceeded, "
            << "filesize is " << filesize << ", "
            << "configured limit is " << m_input_limit << ", "
            << "filename is " << m_source_filename;
        ers::warning(GenericConfigurationError(ERS_HERE, oss.str()));
      }
 
      // Check for exact match
      if (m_chunk_size > 0) {
        int remainder = filesize % m_chunk_size;
        if (remainder > 0) {
          ers::info(FileHasExtraData(ERS_HERE, remainder, filesize, m_chunk_size, m_source_filename));
        }
        // Set usable element count
        m_element_count = filesize / m_chunk_size;
        TLOG_DEBUG(TLVL_BOOKKEEPING) << "Available elements: " << std::to_string(m_element_count);
      }
 
      // Read file into input buffer
      m_rawdata_ifs.seekg(0, std::ios::beg);
      m_input_buffer.reserve(filesize);
      m_input_buffer.insert(
        m_input_buffer.begin(), std::istreambuf_iterator<char>(m_rawdata_ifs), std::istreambuf_iterator<char>());
      TLOG_DEBUG(TLVL_BOOKKEEPING) << "Available bytes " << std::to_string(m_input_buffer.size());
 
    } catch (const std::exception& ex) {
      throw GenericConfigurationError(ERS_HERE, "Cannot read file: " + m_source_filename, ex.what());
    }
  }

Member Data Documentation

m_chunk_size

int dunedaq::datahandlinglibs::FileSourceBuffer::m_chunk_size

private

Definition at line 97 of file FileSourceBuffer.hpp.

m_element_count

int dunedaq::datahandlinglibs::FileSourceBuffer::m_element_count

private

Definition at line 98 of file FileSourceBuffer.hpp.

m_input_buffer

std::vector<std::uint8_t> dunedaq::datahandlinglibs::FileSourceBuffer::m_input_buffer

private

Definition at line 103 of file FileSourceBuffer.hpp.

m_input_limit

int dunedaq::datahandlinglibs::FileSourceBuffer::m_input_limit

private

Definition at line 96 of file FileSourceBuffer.hpp.

m_rawdata_ifs

std::ifstream dunedaq::datahandlinglibs::FileSourceBuffer::m_rawdata_ifs

private

Definition at line 102 of file FileSourceBuffer.hpp.

m_source_filename

std::string dunedaq::datahandlinglibs::FileSourceBuffer::m_source_filename

private

Definition at line 99 of file FileSourceBuffer.hpp.

---

The documentation for this class was generated from the following file:

• /github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/utils/FileSourceBuffer.hpp