SourceXtractorPlusPlus  0.14
Please provide a description of the project.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Sorter.cpp
Go to the documentation of this file.
1 
18 #include <algorithm>
19 #include "SEMain/Sorter.h"
20 
21 namespace SourceXtractor {
22 
23 static unsigned int extractSourceId(const SourceInterface &i) {
24  return i.getProperty<SourceID>().getId();
25 }
26 
27 Sorter::Sorter(): m_output_next{1} {
28 }
29 
31  std::vector<unsigned int> source_ids(message->size());
32  std::transform(message->cbegin(), message->cend(), source_ids.begin(), extractSourceId);
33  std::sort(source_ids.begin(), source_ids.end());
34 
35  auto first_source_id = source_ids.front();
36  m_output_buffer.emplace(first_source_id, message);
37 
38  while (!m_output_buffer.empty() && m_output_buffer.begin()->first == m_output_next) {
39  auto &next_group = m_output_buffer.begin()->second;
40  m_output_next += next_group->size();
41  notifyObservers(next_group);
42  m_output_buffer.erase(m_output_buffer.begin());
43  }
44 }
45 
46 
47 } // end SourceXtractor
const PropertyType & getProperty(unsigned int index=0) const
Convenience template method to call getProperty() with a more user-friendly syntax.
void notifyObservers(const std::shared_ptr< SourceGroupInterface > &message) const
Definition: Observable.h:71
void handleMessage(const std::shared_ptr< SourceGroupInterface > &message) override
Definition: Sorter.cpp:30
std::map< int, std::shared_ptr< SourceGroupInterface > > m_output_buffer
Definition: Sorter.h:42
STL class.
T sort(T...args)
T transform(T...args)
static unsigned int extractSourceId(const SourceInterface &i)
Definition: Sorter.cpp:23
The SourceInterface is an abstract &quot;source&quot; that has properties attached to it.