implements a function node that supports Input -> (set of outputs) More...

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >:

Collaboration diagram for tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >:

Public Types
typedef Input	input_type

typedef null_type	output_type

typedef internal::wrap_tuple_elements < N, internal::multifunction_output, Output >::type	output_ports_type

typedef internal::multifunction_input < input_type, output_ports_type, Policy, internals_allocator >	input_impl_type

typedef internal::function_input_queue < input_type, internals_allocator >	input_queue_type

Public Types inherited from tbb::flow::interface11::internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > >
typedef Input	input_type

typedef internal::wrap_tuple_elements < tbb::flow::tuple_size < Output >::value, internal::multifunction_output, Output >::type	output_ports_type

typedef multifunction_body < input_type, output_ports_type >	multifunction_body_type

typedef multifunction_input < Input, internal::wrap_tuple_elements < tbb::flow::tuple_size < Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > >	my_class

typedef function_input_base < Input, Policy, cache_aligned_allocator< Input > , my_class >	base_type

typedef function_input_queue < input_type, cache_aligned_allocator< Input > >	input_queue_type

Public Types inherited from tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > > >
typedef Input	input_type
	The input type of this receiver. More...

typedef receiver< input_type > ::predecessor_type	predecessor_type

typedef predecessor_cache < input_type, null_mutex >	predecessor_cache_type

typedef function_input_queue < input_type, cache_aligned_allocator< Input > >	input_queue_type

typedef tbb::internal::allocator_rebind < cache_aligned_allocator < Input >, input_queue_type > ::type	queue_allocator_type

Public Types inherited from tbb::flow::interface11::internal::untyped_receiver
typedef untyped_sender	predecessor_type
	The predecessor type for this node. More...

Public Member Functions
template<typename Body >
__TBB_NOINLINE_SYM	multifunction_node (graph &g, size_t concurrency,)

__TBB_NOINLINE_SYM	multifunction_node (const multifunction_node &other)

Public Member Functions inherited from tbb::flow::interface11::graph_node
	graph_node (graph &g)

virtual	~graph_node ()

Public Member Functions inherited from tbb::flow::interface11::internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > >
	multifunction_input (graph &g, size_t max_concurrency,)

	multifunction_input (const multifunction_input &src)
	Copy constructor. More...

	~multifunction_input ()

Body	copy_function_object ()

task *	apply_body_impl_bypass (const input_type &i)

output_ports_type &	output_ports ()

Public Member Functions inherited from tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > > >
	__TBB_STATIC_ASSERT (!((internal::has_policy< queueing, Policy >::value)&&(internal::has_policy< rejecting, Policy >::value)),"queueing and rejecting policies can't be specified simultaneously")

	function_input_base (graph &g, __TBB_FLOW_GRAPH_PRIORITY_ARG1(size_t max_concurrency, node_priority_t priority))
	Constructor for function_input_base. More...

	function_input_base (const function_input_base &src)
	Copy constructor. More...

virtual	~function_input_base ()
	Destructor. More...

task *	try_put_task (const input_type &t) __TBB_override
	Put item to successor; return task to run the successor if possible. More...

bool	register_predecessor (predecessor_type &src) __TBB_override
	Adds src to the list of cached predecessors. More...

bool	remove_predecessor (predecessor_type &src) __TBB_override
	Removes src from the list of cached predecessors. More...

Public Member Functions inherited from tbb::flow::interface11::receiver< Input >
bool	try_put (const typename internal::async_helpers< Input >::filtered_type &t)
	Put an item to the receiver. More...

bool	try_put (const typename internal::async_helpers< Input >::async_type &t)

Public Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
virtual	~untyped_receiver ()
	Destructor. More...

template<typename X >
bool	try_put (const X &t)
	Put an item to the receiver. More...

Protected Member Functions
void	reset_node (reset_flags f) __TBB_override

Protected Member Functions inherited from tbb::flow::interface11::internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > >
void	reset (reset_flags f)

Protected Member Functions inherited from tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > > >
void	reset_function_input_base (reset_flags f)

void	reset_receiver (reset_flags f) __TBB_override
	put receiver back in initial state More...

graph &	graph_reference () const __TBB_override

task *	try_get_postponed_task (const input_type &i)

Protected Member Functions inherited from tbb::flow::interface11::receiver< Input >
virtual task *	try_put_task_wrapper (const void *p, bool is_async) __TBB_override

Protected Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
template<typename X >
task *	try_put_task (const X &t)

virtual bool	is_continue_receiver ()

Static Protected Attributes
static const int	N = tbb::flow::tuple_size<Output>::value

Private Types
typedef cache_aligned_allocator< Input >	internals_allocator

Private Member Functions
	__TBB_STATIC_ASSERT ((tbb::internal::is_same_type< Allocator, null_type >::value),"Allocator template parameter for flow graph nodes is deprecated and will be removed. ""Specify TBB_DEPRECATED_FLOW_NODE_ALLOCATOR to temporary enable the deprecated interface.")

Additional Inherited Members
Public Attributes inherited from tbb::flow::interface11::receiver< Input >
__TBB_DEPRECATED typedef Input	input_type
	The input type of this receiver. More...

__TBB_DEPRECATED typedef internal::async_helpers< Input > ::filtered_type	filtered_type

Static Public Attributes inherited from tbb::flow::interface11::internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > >
static const int	N

Protected Attributes inherited from tbb::flow::interface11::graph_node
graph &	my_graph

graph_node *	next

graph_node *	prev

Protected Attributes inherited from tbb::flow::interface11::internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > >
multifunction_body_type *	my_body

multifunction_body_type *	my_init_body

output_ports_type	my_output_ports

Protected Attributes inherited from tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > > >
graph &	my_graph_ref

const size_t	my_max_concurrency

size_t	my_concurrency

input_queue_type *	my_queue

predecessor_cache< input_type, null_mutex >	my_predecessors

Detailed Description

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
class tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >

implements a function node that supports Input -> (set of outputs)

Definition at line 1568 of file flow_graph.h.

Member Typedef Documentation

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

typedef internal::multifunction_input< input_type, output_ports_type, Policy, internals_allocator> tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::input_impl_type

Definition at line 1604 of file flow_graph.h.

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

typedef internal::function_input_queue<input_type, internals_allocator> tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::input_queue_type

Definition at line 1605 of file flow_graph.h.

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

typedef Input tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::input_type

Definition at line 1600 of file flow_graph.h.

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

typedef cache_aligned_allocator<Input> tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::internals_allocator

private

Definition at line 1588 of file flow_graph.h.

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

typedef internal::wrap_tuple_elements<N,internal::multifunction_output, Output>::type tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::output_ports_type

Definition at line 1602 of file flow_graph.h.

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

typedef null_type tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::output_type

Definition at line 1601 of file flow_graph.h.

Constructor & Destructor Documentation

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

template<typename Body >

__TBB_NOINLINE_SYM tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::multifunction_node	(	graph &	g,
		size_t	concurrency
	)

inline

Definition at line 1610 of file flow_graph.h.

       : graph_node(g), input_impl_type(g, concurrency, __TBB_FLOW_GRAPH_PRIORITY_ARG1(body, priority)) {
         tbb::internal::fgt_multioutput_node_with_body<N>(
             CODEPTR(), tbb::internal::FLOW_MULTIFUNCTION_NODE,
             &this->my_graph, static_cast<receiver<input_type> *>(this),
             this->output_ports(), this->my_body
         );
     }

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

__TBB_NOINLINE_SYM tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::multifunction_node ( const multifunction_node< Input, Output, Policy, Allocator > & other )

inline

Definition at line 1646 of file flow_graph.h.

                                                                             :
         graph_node(other.my_graph), input_impl_type(other) {
         tbb::internal::fgt_multioutput_node_with_body<N>( CODEPTR(), tbb::internal::FLOW_MULTIFUNCTION_NODE,
                 &this->my_graph, static_cast<receiver<input_type> *>(this),
                 this->output_ports(), this->my_body );
     }

Member Function Documentation

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::__TBB_STATIC_ASSERT	(	(tbb::internal::is_same_type< Allocator, null_type >::value)	,
		"Allocator template parameter for flow graph nodes is deprecated and will be removed. ""Specify TBB_DEPRECATED_FLOW_NODE_ALLOCATOR to temporary enable the deprecated interface."
	)

private

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

void tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::reset_node ( reset_flags f )

inlineprotectedvirtual

Implements tbb::flow::interface11::graph_node.

Definition at line 1667 of file flow_graph.h.

1667 { input_impl_type::reset(f); }

tbb::flow::interface11::internal::multifunction_input::reset

void reset(reset_flags f)

Definition: flow_graph.h:700

Member Data Documentation

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>

const int tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >::N = tbb::flow::tuple_size<Output>::value

staticprotected

Definition at line 1598 of file flow_graph.h.

The documentation for this class was generated from the following file:

flow_graph.h

Public Types

Public Member Functions

Protected Member Functions

Static Protected Attributes

Private Types

Private Member Functions

Additional Inherited Members

Detailed Description

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)> class tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

template<typename Input, typename Output, typename Policy = queueing, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
class tbb::flow::interface11::multifunction_node< Input, Output, Policy, Allocator >