Sorter.cpp

Go to the documentation of this file.

#include <SEImplementation/Plugin/SourceIDs/SourceID.h>
#include <algorithm>
#include "SEMain/Sorter.h"

namespace SourceXtractor {

static unsigned int extractSourceId(const SourceInterface &i) {
  return i.getProperty<SourceID>().getId();
}

Sorter::Sorter(): m_output_next{1} {
}

void Sorter::receiveSource(std::unique_ptr<SourceGroupInterface> message) {
  std::vector<unsigned int> source_ids(message->size());
  std::transform(message->cbegin(), message->cend(), source_ids.begin(), extractSourceId);
  std::sort(source_ids.begin(), source_ids.end());

  auto first_source_id = source_ids.front();
  m_output_buffer.emplace(first_source_id, std::move(message));

  while (!m_output_buffer.empty() && m_output_buffer.begin()->first == m_output_next) {
    auto &next_group = m_output_buffer.begin()->second;
    m_output_next += next_group->size();
    sendSource(std::move(next_group));
    m_output_buffer.erase(m_output_buffer.begin());
  }
}
void Sorter::receiveProcessSignal(const ProcessSourcesEvent& event) {
  sendProcessSignal(event);
}

} // end SourceXtractor