poly/stream_reduce.h

Go to the documentation of this file.

#ifndef GRPPI_POLY_STREAM_REDUCE_H
#define GRPPI_POLY_STREAM_REDUCE_H

#include "polymorphic_execution.h"
#include "../common/support.h"

namespace grppi {

template <typename Identity, typename Combiner, typename Consumer, typename Generator>
void stream_reduce_multi_impl(polymorphic_execution & ex, int window_size, int offset, 
                              Identity identity, Generator && generate_op, 
                              Combiner && combine_op, Consumer && consume_op)
{
}

template <typename E, typename ... O, typename Identity, 
          typename Generator, typename Combiner, typename Consumer,
          internal::requires_execution_not_supported<E> = 0>
void stream_reduce_multi_impl(polymorphic_execution & ex, int windowsize, int offset, 
                              Identity identity, Generator && gen, 
                              Combiner && comb, Consumer && cons) 
{
  stream_reduce_multi_impl<O...>(ex, 
    windowsize, offset, identity,
    std::forward<Generator>(gen), 
    std::forward<Combiner>(comb), 
    std::forward<Consumer>(cons)
  );
}

template <typename E, typename ... O, typename Identity, 
          typename Generator, typename Combiner, typename Consumer,
          internal::requires_execution_supported<E> = 0>
void stream_reduce_multi_impl(polymorphic_execution & ex, int windowsize, int offset,
                              Identity identity, Generator && gen, 
                              Combiner && comb, Consumer && cons) 
{
  if (typeid(E) == ex.type()) {
    stream_reduce(*ex.execution_ptr<E>(), 
      windowsize, offset, identity,
      std::forward<Generator>(gen),
      std::forward<Combiner>(comb), 
      std::forward<Consumer>(cons)
    );
  }
  else {
    stream_reduce_multi_impl<O...>(ex, 
      windowsize, offset, identity,
      std::forward<Generator>(gen),
      std::forward<Combiner>(comb), 
      std::forward<Consumer>(cons)
    );
  }
}

template <typename Identity, typename Generator, typename Combiner, typename Consumer>
void stream_reduce(polymorphic_execution & ex, 
      int windowsize, int offset, Identity identity,
      Generator && gen, Combiner && comb, Consumer && cons) 
{
  stream_reduce_multi_impl<
    sequential_execution,
    parallel_execution_native,
    parallel_execution_omp,
    parallel_execution_tbb
  >(ex, windowsize, offset, identity,
      std::forward<Generator>(gen),
      std::forward<Combiner>(comb), 
      std::forward<Consumer>(cons)
   );
}

} // end namespace grppi

#endif