Implements methods for a function node that takes a type Input as input. More...

#include <_flow_graph_node_impl.h>

Inheritance diagram for internal::multifunction_input< Input, OutputPortSet, Policy, A >:

Collaboration diagram for internal::multifunction_input< Input, OutputPortSet, Policy, A >:

Public Types
typedef Input	input_type

typedef OutputPortSet	output_ports_type

typedef multifunction_body< input_type, output_ports_type >	multifunction_body_type

typedef multifunction_input< Input, OutputPortSet, Policy, A >	my_class

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

typedef function_input_queue< input_type, A >	input_queue_type

Public Types inherited from internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >
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, A >	input_queue_type

typedef tbb::internal::allocator_rebind< A, input_queue_type >::type	queue_allocator_type

Public Member Functions
template<typename Body >
	multifunction_input (graph &g, size_t max_concurrency,)

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

	~multifunction_input ()

template<typename Body >
Body	copy_function_object ()

task *	apply_body_impl_bypass (const input_type &i)

output_ports_type &	output_ports ()

Public Member Functions inherited from internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >
	__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

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 >
virtual	~receiver ()
	Destructor. More...

bool	try_put (const Input &t)
	Put an item to the receiver. More...

virtual __TBB_DEPRECATED bool	register_predecessor (predecessor_type &)
	Add a predecessor to the node. More...

virtual __TBB_DEPRECATED bool	remove_predecessor (predecessor_type &)
	Remove a predecessor from the node. More...

Static Public Attributes
static const int	N = tbb::flow::tuple_size<OutputPortSet>::value

Protected Member Functions
void	reset (reset_flags f)

Protected Member Functions inherited from internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >
void	reset_function_input_base (reset_flags f)

void	reset_receiver (reset_flags f) __TBB_override

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 void	reset_receiver (reset_flags f=rf_reset_protocol)=0
	put receiver back in initial state More...

virtual bool	is_continue_receiver ()

Protected Attributes
multifunction_body_type *	my_body

multifunction_body_type *	my_init_body

output_ports_type	my_output_ports

Protected Attributes inherited from internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >
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

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 sender< Input >	predecessor_type
	The predecessor type for this node. More...

Detailed Description

template<typename Input, typename OutputPortSet, typename Policy, typename A>
class internal::multifunction_input< Input, OutputPortSet, Policy, A >

Implements methods for a function node that takes a type Input as input.

Definition at line 638 of file _flow_graph_node_impl.h.

Member Typedef Documentation

◆ base_type

template<typename Input , typename OutputPortSet , typename Policy , typename A >

typedef function_input_base<Input, Policy, A, my_class> internal::multifunction_input< Input, OutputPortSet, Policy, A >::base_type

Definition at line 645 of file _flow_graph_node_impl.h.

◆ input_queue_type

template<typename Input , typename OutputPortSet , typename Policy , typename A >

typedef function_input_queue<input_type, A> internal::multifunction_input< Input, OutputPortSet, Policy, A >::input_queue_type

Definition at line 646 of file _flow_graph_node_impl.h.

◆ input_type

template<typename Input , typename OutputPortSet , typename Policy , typename A >

typedef Input internal::multifunction_input< Input, OutputPortSet, Policy, A >::input_type

Definition at line 641 of file _flow_graph_node_impl.h.

◆ multifunction_body_type

template<typename Input , typename OutputPortSet , typename Policy , typename A >

typedef multifunction_body<input_type, output_ports_type> internal::multifunction_input< Input, OutputPortSet, Policy, A >::multifunction_body_type

Definition at line 643 of file _flow_graph_node_impl.h.

◆ my_class

template<typename Input , typename OutputPortSet , typename Policy , typename A >

typedef multifunction_input<Input, OutputPortSet, Policy, A> internal::multifunction_input< Input, OutputPortSet, Policy, A >::my_class

Definition at line 644 of file _flow_graph_node_impl.h.

◆ output_ports_type

template<typename Input , typename OutputPortSet , typename Policy , typename A >

typedef OutputPortSet internal::multifunction_input< Input, OutputPortSet, Policy, A >::output_ports_type

Definition at line 642 of file _flow_graph_node_impl.h.

Constructor & Destructor Documentation

◆ multifunction_input() [1/2]

template<typename Input , typename OutputPortSet , typename Policy , typename A >

template<typename Body >

internal::multifunction_input< Input, OutputPortSet, Policy, A >::multifunction_input	(	graph &	g,
		size_t	max_concurrency
	)

inline

Definition at line 650 of file _flow_graph_node_impl.h.

           : base_type(g, __TBB_FLOW_GRAPH_PRIORITY_ARG1(max_concurrency, priority))
           , my_body( new internal::multifunction_body_leaf<input_type, output_ports_type, Body>(body) )
           , my_init_body( new internal::multifunction_body_leaf<input_type, output_ports_type, Body>(body) )
           , my_output_ports(init_output_ports<output_ports_type>::call(g, my_output_ports)){
         }

◆ multifunction_input() [2/2]

template<typename Input , typename OutputPortSet , typename Policy , typename A >

internal::multifunction_input< Input, OutputPortSet, Policy, A >::multifunction_input ( const multifunction_input< Input, OutputPortSet, Policy, A > & src )

inline

Copy constructor.

Definition at line 659 of file _flow_graph_node_impl.h.

                                                               :
                 base_type(src),
                 my_body( src.my_init_body->clone() ),
                 my_init_body(src.my_init_body->clone() ),
                 my_output_ports( init_output_ports<output_ports_type>::call(src.my_graph_ref, my_output_ports) ) {
         }

◆ ~multifunction_input()

template<typename Input , typename OutputPortSet , typename Policy , typename A >

internal::multifunction_input< Input, OutputPortSet, Policy, A >::~multifunction_input ( )

inline

Definition at line 666 of file _flow_graph_node_impl.h.

                                {
             delete my_body;
             delete my_init_body;
         }

Member Function Documentation

◆ apply_body_impl_bypass()

template<typename Input , typename OutputPortSet , typename Policy , typename A >

task* internal::multifunction_input< Input, OutputPortSet, Policy, A >::apply_body_impl_bypass ( const input_type & i )

inline

Definition at line 680 of file _flow_graph_node_impl.h.

                                                             {
             tbb::internal::fgt_begin_body( my_body );
             (*my_body)(i, my_output_ports);
             tbb::internal::fgt_end_body( my_body );
             task* ttask = NULL;
             if(base_type::my_max_concurrency != 0) {
                 ttask = base_type::try_get_postponed_task(i);
             }
             return ttask ? ttask : SUCCESSFULLY_ENQUEUED;
         }

◆ copy_function_object()

template<typename Input , typename OutputPortSet , typename Policy , typename A >

template<typename Body >

Body internal::multifunction_input< Input, OutputPortSet, Policy, A >::copy_function_object ( )

inline

Definition at line 672 of file _flow_graph_node_impl.h.

                                     {
             multifunction_body_type &body_ref = *this->my_body;
             return *static_cast<Body*>(dynamic_cast< internal::multifunction_body_leaf<input_type, output_ports_type, Body> & >(body_ref).get_body_ptr());
         }

◆ output_ports()

template<typename Input , typename OutputPortSet , typename Policy , typename A >

output_ports_type& internal::multifunction_input< Input, OutputPortSet, Policy, A >::output_ports ( )

inline

Definition at line 691 of file _flow_graph_node_impl.h.

691 { return my_output_ports; }

◆ reset()

template<typename Input , typename OutputPortSet , typename Policy , typename A >

void internal::multifunction_input< Input, OutputPortSet, Policy, A >::reset ( reset_flags f )

inlineprotected

Definition at line 700 of file _flow_graph_node_impl.h.

                                   {
             base_type::reset_function_input_base(f);
             if(f & rf_clear_edges)clear_element<N>::clear_this(my_output_ports);
             if(f & rf_reset_bodies) {
                 multifunction_body_type *tmp = my_init_body->clone();
                 delete my_body;
                 my_body = tmp;
             }
             __TBB_ASSERT(!(f & rf_clear_edges) || clear_element<N>::this_empty(my_output_ports), "multifunction_node reset failed");
         }

Referenced by tbb::flow::interface11::multifunction_node< Input, tuple< Output >, queueing_lightweight, __TBB_DEFAULT_NODE_ALLOCATOR(Input) >::reset_node().

Here is the caller graph for this function:

Member Data Documentation

◆ my_body

template<typename Input , typename OutputPortSet , typename Policy , typename A >

multifunction_body_type* internal::multifunction_input< Input, OutputPortSet, Policy, A >::my_body

protected

Definition at line 711 of file _flow_graph_node_impl.h.

◆ my_init_body

template<typename Input , typename OutputPortSet , typename Policy , typename A >

multifunction_body_type* internal::multifunction_input< Input, OutputPortSet, Policy, A >::my_init_body

protected

Definition at line 712 of file _flow_graph_node_impl.h.

Referenced by internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::reset(), and internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::~multifunction_input().

◆ my_output_ports

template<typename Input , typename OutputPortSet , typename Policy , typename A >

output_ports_type internal::multifunction_input< Input, OutputPortSet, Policy, A >::my_output_ports

protected

Definition at line 713 of file _flow_graph_node_impl.h.

Referenced by internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::apply_body_impl_bypass(), internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::output_ports(), and internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::reset().

◆ N

template<typename Input , typename OutputPortSet , typename Policy , typename A >

const int internal::multifunction_input< Input, OutputPortSet, Policy, A >::N = tbb::flow::tuple_size<OutputPortSet>::value

static

Definition at line 640 of file _flow_graph_node_impl.h.

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

_flow_graph_node_impl.h

Public Types

Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

template<typename Input, typename OutputPortSet, typename Policy, typename A> class internal::multifunction_input< Input, OutputPortSet, Policy, A >

Member Typedef Documentation

◆ base_type

◆ input_queue_type

◆ input_type

◆ multifunction_body_type

◆ my_class

◆ output_ports_type

Constructor & Destructor Documentation

◆ multifunction_input() [1/2]

◆ multifunction_input() [2/2]

◆ ~multifunction_input()

Member Function Documentation

◆ apply_body_impl_bypass()

◆ copy_function_object()

◆ output_ports()

◆ reset()

Member Data Documentation

◆ my_body

◆ my_init_body

◆ my_output_ports

◆ N

template<typename Input, typename OutputPortSet, typename Policy, typename A>
class internal::multifunction_input< Input, OutputPortSet, Policy, A >