Sorter.cpp

Go to the documentation of this file.

 
#include "SEMain/Sorter.h"
#include <SEImplementation/Plugin/SourceIDs/SourceID.h>
#include <algorithm>
#include <vector>
 
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