GrPPI  0.3.1
Generic and Reusable Parallel Pattern Interface
Classes | Functions | Variables
grppi::detail_ff Namespace Reference

Classes

struct  ff_arena_t
 Tag type for fastflow allocation. This empty type is used to select the overloaded placement new and delete operators that invoke the fastflow allocation routines. More...
 
class  filter_collector
 Colletor node for a filter. More...
 
class  filter_emitter
 Emitter for a filter stage. More...
 
class  filter_worker
 Worker that passes a value to next stage if the predicate is satisfied or the filtered_value constant otherwise. More...
 
class  iteration_worker
 
class  node_impl
 Fastflow node for a pipeline transformation stage. More...
 
class  node_impl< Input, void, Consumer >
 Fastflow node for a pipeline consumer stage. More...
 
class  node_impl< void, Output, Generator >
 Fastflow node for a pipeline generation stage. More...
 
class  ordered_stream_filter
 
class  ordered_stream_reduce
 Ordered stream reduce for FastFlow. More...
 
class  reduce_collector
 Reduce collector. More...
 
class  reduce_emitter
 Reduce emitter. More...
 
class  reduce_worker
 Reduce worker. More...
 
class  unordered_stream_filter
 
class  unordered_stream_reduce
 

Functions

template<typename T >
constexpr T * filtered_value ()
 Get a pointer representation of the filter constant to be used as special value when a value is filtered out. More...
 

Variables

constexpr ff_arena_t ff_arena
 Fastflow arena object. This object will be passed to placement new/delete to use FastFlow allocation strategy. More...
 
 workers_ {}
 
 p_emitter_ {std::make_unique<emitter_type>(reducer.window_size(), reducer.offset())}
 

Function Documentation

template<typename T >
constexpr T* grppi::detail_ff::filtered_value ( )

Get a pointer representation of the filter constant to be used as special value when a value is filtered out.

Variable Documentation

constexpr ff_arena_t grppi::detail_ff::ff_arena

Fastflow arena object. This object will be passed to placement new/delete to use FastFlow allocation strategy.

grppi::detail_ff::p_emitter_ {std::make_unique<emitter_type>(reducer.window_size(), reducer.offset())}
grppi::detail_ff::workers_ {}