poly/pipeline.h

Go to the documentation of this file.

#ifndef GRPPI_POLY_PIPELINE_H
#define GRPPI_POLY_PIPELINE_H

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

namespace grppi {

template <typename Execution, typename Transformer,
          typename ... MoreTransformers,
          requires_arguments<Transformer> = 0>
pipeline_info<Execution,Transformer,MoreTransformers...>
transform_pipeline(Execution & ex, std::tuple<Transformer, MoreTransformers ...> && transform_ops)
{
    return pipeline_info<Execution,Transformer, MoreTransformers...> (ex,std::forward<std::tuple<Transformer,MoreTransformers...>>(transform_ops));
}




template <typename Generator, typename ... Transformers>
void pipeline_multi_impl(polymorphic_execution &, Generator &&, 
                         Transformers && ...) 
{

}

template <typename E, typename ... O,
          typename Generator, typename ... Transformers,
          internal::requires_execution_not_supported<E> = 0>
void pipeline_multi_impl(polymorphic_execution & ex, Generator && generate_op, 
                         Transformers && ... transform_ops) 
{
  pipeline_multi_impl<O...>(ex, std::forward<Generator>(generate_op), 
    std::forward<Transformers>(transform_ops) ...);
}

template <typename E, typename ... O,
          typename Generator, typename ... Transformers,
          internal::requires_execution_supported<E> = 0>
void pipeline_multi_impl(polymorphic_execution & ex, Generator && generate_op, 
                         Transformers && ... transform_ops) 
{
  if (typeid(E) == ex.type()) {
    pipeline(*ex.execution_ptr<E>(), 
      std::forward<Generator>(generate_op), 
      std::forward<Transformers>(transform_ops)...);
  }
  else {
    pipeline_multi_impl<O...>(ex, std::forward<Generator>(generate_op), 
        std::forward<Transformers>(transform_ops)...);
  }
}

template <typename Generator, typename ... Transformers,
          requires_no_arguments<Generator> = 0>
void pipeline(polymorphic_execution & ex, Generator && generate_op, 
              Transformers && ... transform_ops) 
{
  pipeline_multi_impl<
    sequential_execution,
    parallel_execution_native,
    parallel_execution_omp,
    parallel_execution_tbb
  >(ex, std::forward<Generator>(generate_op), 
      std::forward<Transformers>(transform_ops) ...);
}

} // end namespace grppi

#endif