Buffer Class Reference

Collaboration diagram for Buffer:

Public Member Functions
	Buffer (std::unique_ptr< EventStorage::DataReader > &&reader, size_t size)
std::optional< std::reference_wrapper< const Event > >	peek () const
Event	next ()
unsigned int	eventsInFile ()
const EventStorage::DataReader &	reader () const

Private Member Functions
void	sort ()
EventStorage::DRError	fillBuffer ()

Private Attributes
std::unique_ptr< EventStorage::DataReader >	m_reader
size_t	m_size {0}
std::vector< Event >	m_events

Detailed Description

Definition at line 114 of file trigbs_orderedMerge.cxx.

Constructor & Destructor Documentation

Buffer()

Buffer::Buffer ( std::unique_ptr< EventStorage::DataReader > && reader, size_t size )

inline

Definition at line 140 of file trigbs_orderedMerge.cxx.

  : m_reader(std::move(reader)), m_size(size) {
    fillBuffer();
    if (s_debugLogging) {
      std::cout << "Constructed a Buffer with " << m_events.size() << " events loaded, global_id range: ["
                << m_events.front().frag.global_id() << ", " << m_events.back().frag.global_id() << "]" << std::endl;
    }
  }

Member Function Documentation

eventsInFile()

unsigned int Buffer::eventsInFile ( )

inline

Definition at line 159 of file trigbs_orderedMerge.cxx.

                              {
    return m_reader->eventsInFile();
  }

fillBuffer()

EventStorage::DRError Buffer::fillBuffer ( )

inlineprivate

Definition at line 124 of file trigbs_orderedMerge.cxx.

                                   {
    while (m_reader->good() && m_events.size() < m_size) {
      char* blobChars{nullptr};
      unsigned int blobCharsSize{0};
      if (const EventStorage::DRError err_code = m_reader->getData(blobCharsSize, &blobChars); err_code != EventStorage::DRError::DROK) {
        std::cerr << "Error code " << err_code << " from EventStorage::DataReader::getData" << std::endl;
        return err_code;
      }
      const uint32_t* blobWords = reinterpret_cast<const uint32_t*>(blobChars);
      m_events.emplace_back(std::unique_ptr<const uint32_t[]>(blobWords));
    }
    sort();
    return EventStorage::DRError::DROK;
  }

next()

Event Buffer::next ( )

inline

Definition at line 152 of file trigbs_orderedMerge.cxx.

               {
    Event event{std::move(m_events[0].blob)};
    m_events[0].blob.reset();
    m_events.erase(m_events.begin());
    fillBuffer();
    return event;
  }

peek()

std::optional< std::reference_wrapper< const Event > > Buffer::peek ( ) const

inline

Definition at line 148 of file trigbs_orderedMerge.cxx.

                                                              {
    if (m_events.empty()) {return std::nullopt;}
    return m_events.at(0);
  }

reader()

const EventStorage::DataReader & Buffer::reader ( ) const

inline

Definition at line 162 of file trigbs_orderedMerge.cxx.

                                               {
    return *m_reader;
  }

sort()

void Buffer::sort ( )

inlineprivate

Definition at line 119 of file trigbs_orderedMerge.cxx.

              {
    std::sort(m_events.begin(), m_events.end(), [](const Event& a, const Event& b){
      return a.frag.global_id() < b.frag.global_id();
    });
  }

Member Data Documentation

m_events

std::vector<Event> Buffer::m_events

private

Definition at line 118 of file trigbs_orderedMerge.cxx.

m_reader

std::unique_ptr<EventStorage::DataReader> Buffer::m_reader

private

Definition at line 116 of file trigbs_orderedMerge.cxx.

m_size

size_t Buffer::m_size {0}

private

Definition at line 117 of file trigbs_orderedMerge.cxx.

{0};

---

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

• trigbs_orderedMerge.cxx