#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >:

Collaboration diagram for tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >:

Classes
class	key_matching_FE_operation

Public Types
typedef OutputTuple	output_type

typedef InputTuple	input_type

typedef K	key_type

typedef tbb::internal::strip< key_type >::type	unref_key_type

typedef KHash	key_hash_compare

typedef count_element< unref_key_type >	count_element_type

typedef key_to_count_functor< unref_key_type >	key_to_count_func

typedef internal::type_to_key_function_body< count_element_type, unref_key_type & >	TtoK_function_body_type

typedef internal::type_to_key_function_body_leaf< count_element_type, unref_key_type &, key_to_count_func >	TtoK_function_body_leaf_type

typedef hash_buffer< unref_key_type &, count_element_type, TtoK_function_body_type, key_hash_compare >	key_to_count_buffer_type

typedef item_buffer< output_type >	output_buffer_type

typedef join_node_base< key_matching< key_type, key_hash_compare >, InputTuple, OutputTuple >	base_node_type

typedef matching_forwarding_base< key_type >	forwarding_base_type

Public Types inherited from tbb::flow::interface11::internal::matching_forwarding_base< K >
typedef tbb::internal::strip< K >::type	current_key_type

Public Types inherited from tbb::flow::interface11::internal::hash_buffer< tbb::internal::strip< K >::type &, count_element< tbb::internal::strip< K >::type >, internal::type_to_key_function_body< count_element< tbb::internal::strip< K >::type >, tbb::internal::strip< K >::type & >, KHash >
typedef count_element< tbb::internal::strip< K >::type >	value_type

typedef buffer_element_type< value_type >::type	element_type

typedef value_type *	pointer_type

typedef element_type *	list_array_type

typedef list_array_type *	pointer_array_type

typedef tbb::cache_aligned_allocator< typename aligned_pair< count_element< tbb::internal::strip< K >::type >, void * >::type > ::template rebind< list_array_type >::other	pointer_array_allocator_type

typedef tbb::cache_aligned_allocator< typename aligned_pair< count_element< tbb::internal::strip< K >::type >, void * >::type > ::template rebind< element_type >::other	elements_array_allocator

typedef tbb::internal::strip< tbb::internal::strip< K >::type & >::type	Knoref

Public Types inherited from tbb::flow::interface11::internal::item_buffer< OutputTuple >
enum	buffer_item_state

typedef OutputTuple	item_type

Public Member Functions
template<typename FunctionTuple >
	join_node_FE (graph &g, FunctionTuple &TtoK_funcs)

	join_node_FE (const join_node_FE &other)

void	set_my_node (base_node_type *new_my_node)

void	reset_port_count ()

task *	increment_key_count (unref_key_type const &t, bool handle_task) __TBB_override

task *	decrement_port_count (bool) __TBB_override

void	increment_port_count () __TBB_override

input_type &	input_ports ()

Public Member Functions inherited from tbb::flow::interface11::internal::matching_forwarding_base< K >
	matching_forwarding_base (graph &g)

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

virtual	~forwarding_base ()

Public Member Functions inherited from tbb::internal::no_assign
void	operator= (const no_assign &)=delete

	no_assign (const no_assign &)=default

	no_assign ()=default

Public Member Functions inherited from tbb::flow::interface11::internal::hash_buffer< tbb::internal::strip< K >::type &, count_element< tbb::internal::strip< K >::type >, internal::type_to_key_function_body< count_element< tbb::internal::strip< K >::type >, tbb::internal::strip< K >::type & >, KHash >
	hash_buffer ()

	~hash_buffer ()

void	reset ()

void	set_key_func (internal::type_to_key_function_body< count_element< tbb::internal::strip< K >::type >, tbb::internal::strip< K >::type &> *vtk)

internal::type_to_key_function_body< count_element< tbb::internal::strip< K >::type >, tbb::internal::strip< K >::type &> *	get_key_func ()

bool	insert_with_key (const value_type &v)

bool	find_ref_with_key (const Knoref &k, pointer_type &v)

bool	find_with_key (const Knoref &k, value_type &v)

void	delete_with_key (const Knoref &k)

Public Member Functions inherited from tbb::flow::interface11::internal::item_buffer< OutputTuple >
	item_buffer ()
	Constructor. More...

	~item_buffer ()

void	reset ()

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

Static Public Attributes inherited from tbb::flow::interface11::internal::hash_buffer< tbb::internal::strip< K >::type &, count_element< tbb::internal::strip< K >::type >, internal::type_to_key_function_body< count_element< tbb::internal::strip< K >::type >, tbb::internal::strip< K >::type & >, KHash >
static const size_t	INITIAL_SIZE

Protected Member Functions
void	reset (reset_flags f)

bool	tuple_build_may_succeed ()

bool	try_to_make_tuple (output_type &out)

void	tuple_accepted ()

void	tuple_rejected ()

Protected Member Functions inherited from tbb::flow::interface11::internal::item_buffer< OutputTuple >
bool	buffer_empty () const

buffer_item_type &	item (size_type i)

const buffer_item_type &	item (size_type i) const

bool	my_item_valid (size_type i) const

bool	my_item_reserved (size_type i) const

const item_type &	get_my_item (size_t i) const

void	set_my_item (size_t i, const item_type &o)

void	fetch_item (size_t i, item_type &o)

void	move_item (size_t to, size_t from)

bool	place_item (size_t here, const item_type &me)

void	swap_items (size_t i, size_t j)

void	destroy_item (size_type i)

const item_type &	front () const

const item_type &	back () const

void	reserve_item (size_type i)

void	release_item (size_type i)

void	destroy_front ()

void	destroy_back ()

size_type	size (size_t new_tail=0)

size_type	capacity ()

bool	buffer_full ()

void	grow_my_array (size_t minimum_size)
	Grows the internal array. More...

bool	push_back (item_type &v)

bool	pop_back (item_type &v)

bool	pop_front (item_type &v)

void	clean_up_buffer (bool reset_pointers)

Protected Attributes
input_type	my_inputs

base_node_type *	my_node

Protected Attributes inherited from tbb::flow::interface11::internal::item_buffer< OutputTuple >
buffer_item_type *	my_array

size_type	my_array_size

size_type	my_head

size_type	my_tail

Private Types
enum	op_type { res_count, inc_count, may_succeed, try_make }

typedef join_node_FE< key_matching< key_type, key_hash_compare >, InputTuple, OutputTuple >	class_type

typedef internal::aggregating_functor< class_type, key_matching_FE_operation >	handler_type

Private Member Functions
task *	fill_output_buffer (unref_key_type &t, bool should_enqueue, bool handle_task)

void	handle_operations (key_matching_FE_operation *op_list)

Private Attributes
aggregator< handler_type, key_matching_FE_operation >	my_aggregator

Friends
class	internal::aggregating_functor< class_type, key_matching_FE_operation >

Additional Inherited Members
Public Attributes inherited from tbb::flow::interface11::internal::matching_forwarding_base< K >
current_key_type	current_key

Public Attributes inherited from tbb::flow::interface11::internal::forwarding_base
graph &	graph_ref

Protected Types inherited from tbb::flow::interface11::internal::item_buffer< OutputTuple >
typedef size_t	size_type

typedef aligned_pair< item_type, buffer_item_state >::type	buffer_item_type

typedef tbb::internal::allocator_rebind< cache_aligned_allocator< OutputTuple >, buffer_item_type >::type	allocator_type

Static Protected Attributes inherited from tbb::flow::interface11::internal::item_buffer< OutputTuple >
static const size_type	initial_buffer_size

Detailed Description

template<typename InputTuple, typename OutputTuple, typename K, typename KHash>
class tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >

Definition at line 1034 of file flow_graph.h.

Member Typedef Documentation

◆ base_node_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef join_node_base<key_matching<key_type,key_hash_compare>, InputTuple, OutputTuple> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::base_node_type

Definition at line 1063 of file flow_graph.h.

◆ class_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef join_node_FE<key_matching<key_type,key_hash_compare>, InputTuple, OutputTuple> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::class_type

private

Definition at line 1071 of file flow_graph.h.

◆ count_element_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef count_element<unref_key_type> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::count_element_type

Definition at line 1053 of file flow_graph.h.

◆ forwarding_base_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef matching_forwarding_base<key_type> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::forwarding_base_type

Definition at line 1064 of file flow_graph.h.

◆ handler_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef internal::aggregating_functor<class_type, key_matching_FE_operation> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::handler_type

private

Definition at line 1089 of file flow_graph.h.

◆ input_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef InputTuple tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::input_type

Definition at line 1048 of file flow_graph.h.

◆ key_hash_compare

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef KHash tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::key_hash_compare

Definition at line 1051 of file flow_graph.h.

◆ key_to_count_buffer_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef hash_buffer< unref_key_type&, count_element_type, TtoK_function_body_type, key_hash_compare > tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::key_to_count_buffer_type

Definition at line 1061 of file flow_graph.h.

◆ key_to_count_func

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef key_to_count_functor<unref_key_type> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::key_to_count_func

Definition at line 1055 of file flow_graph.h.

◆ key_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef K tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::key_type

Definition at line 1049 of file flow_graph.h.

◆ output_buffer_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef item_buffer<output_type> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::output_buffer_type

Definition at line 1062 of file flow_graph.h.

◆ output_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef OutputTuple tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::output_type

Definition at line 1047 of file flow_graph.h.

◆ TtoK_function_body_leaf_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef internal::type_to_key_function_body_leaf<count_element_type, unref_key_type&, key_to_count_func> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::TtoK_function_body_leaf_type

Definition at line 1057 of file flow_graph.h.

◆ TtoK_function_body_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef internal::type_to_key_function_body< count_element_type, unref_key_type&> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::TtoK_function_body_type

Definition at line 1056 of file flow_graph.h.

◆ unref_key_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

typedef tbb::internal::strip<key_type>::type tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::unref_key_type

Definition at line 1050 of file flow_graph.h.

Member Enumeration Documentation

◆ op_type

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

enum tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::op_type

private

Enumerator
res_count
inc_count
may_succeed
try_make

Definition at line 1070 of file flow_graph.h.

1074 {

Constructor & Destructor Documentation

◆ join_node_FE() [1/2]

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

template<typename FunctionTuple >

tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::join_node_FE	(	graph &	g,
		FunctionTuple &	TtoK_funcs
	)

inline

Definition at line 1174 of file flow_graph.h.

1180 : tbb::flow::source_node is deprecated, use tbb::flow::input_node." )

tbb::flow::interface11::source_node

An executable node that acts as a source, i.e. it has no predecessors.

Definition: flow_graph.h:1179

tbb::flow::interface11::input_node

An executable node that acts as a source, i.e. it has no predecessors.

Definition: flow_graph.h:903

◆ join_node_FE() [2/2]

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::join_node_FE ( const join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple > & other )

inline

Definition at line 1182 of file flow_graph.h.

       :
     typedef Output output_type;
 
     typedef typename sender<output_type>::successor_type successor_type;
 
     //Source node has no input type
     typedef null_type input_type;

Member Function Documentation

◆ decrement_port_count()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

task* tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::decrement_port_count ( bool )

inlinevirtual

Implements tbb::flow::interface11::internal::forwarding_base.

Definition at line 1209 of file flow_graph.h.

◆ fill_output_buffer()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

task* tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::fill_output_buffer	(	unref_key_type &	t,
		bool	should_enqueue,
		bool	handle_task
	)

inlineprivate

Definition at line 1096 of file flow_graph.h.

        :
     spin_mutex my_mutex;
     bool my_active;
     internal::source_body<output_type> *my_body;
     internal::source_body<output_type> *my_init_body;
     internal::broadcast_cache< output_type > my_successors;
     bool my_reserved;
     bool my_has_cached_item;
     output_type my_cached_item;
 
     // used by apply_body_bypass, can invoke body of node.
     bool try_reserve_apply_body(output_type &v) {
         spin_mutex::scoped_lock lock(my_mutex);
         if ( my_reserved ) {
             return false;
         }
         if ( !my_has_cached_item ) {
             tbb::internal::fgt_begin_body( my_body );
             bool r = (*my_body)(my_cached_item);
             tbb::internal::fgt_end_body( my_body );
             if (r) {
                 my_has_cached_item = true;
             }

◆ handle_operations()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::handle_operations ( key_matching_FE_operation * op_list )

inlineprivate

Definition at line 1122 of file flow_graph.h.

                                   {
             v = my_cached_item;
             my_reserved = true;
             return true;
         } else {
             return false;
         }
     }
 
     task* create_put_task() {
         return ( new ( task::allocate_additional_child_of( *(this->my_graph.root_task()) ) )
                         internal:: source_task_bypass < input_node< output_type > >( *this ) );
     }
 
     void spawn_put( ) {
         if(internal::is_graph_active(this->my_graph)) {
             internal::spawn_in_graph_arena(this->my_graph, *create_put_task());
         }
     }
 
     friend class internal::source_task_bypass< input_node< output_type > >;
     task * apply_body_bypass( ) {
         output_type v;
         if ( !try_reserve_apply_body(v) )
             return NULL;
 
         task *last_task = my_successors.try_put_task(v);
         if ( last_task )
             try_consume();
         else
             try_release();
         return last_task;
     }
 };  // class input_node
 
 #if TBB_USE_SOURCE_NODE_AS_ALIAS
 template < typename Output >
 class source_node : public input_node <Output> {
 public:
     template< typename Body >
      __TBB_NOINLINE_SYM source_node( graph &g, Body body )
          : input_node<Output>(g, body)
     {
     }
 

◆ increment_key_count()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

task* tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::increment_key_count	(	unref_key_type const &	t,
		bool	handle_task
	)

inlinevirtual

Implements tbb::flow::interface11::internal::matching_forwarding_base< K >.

Definition at line 1203 of file flow_graph.h.

References CODEPTR, tbb::internal::fgt_node_with_body(), and tbb::flow::interface11::internal::successor_cache< T, M >::set_owner().

     {
         my_successors.set_owner(this);
         tbb::internal::fgt_node_with_body( CODEPTR(), tbb::internal::FLOW_SOURCE_NODE, &this->my_graph,
                                            static_cast<sender<output_type> *>(this), this->my_body );

Here is the call graph for this function:

◆ increment_port_count()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::increment_port_count ( )

inlinevirtual

Implements tbb::flow::interface11::internal::forwarding_base.

Definition at line 1211 of file flow_graph.h.

◆ input_ports()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

input_type& tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::input_ports ( )

inline

Definition at line 1213 of file flow_graph.h.

1213 : source_node(successors.graph_reference(), body, is_active) {

◆ reset()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::reset ( reset_flags f )

inlineprotected

Definition at line 1217 of file flow_graph.h.

                                                              :
         graph_node(src.my_graph), sender<Output>(),
         my_active(src.init_my_active),
         init_my_active(src.init_my_active), my_body( src.my_init_body->clone() ), my_init_body(src.my_init_body->clone() ),
         my_reserved(false), my_has_cached_item(false)

◆ reset_port_count()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::reset_port_count ( )

inline

Definition at line 1195 of file flow_graph.h.

1200 : graph_node(g), my_active(is_active), init_my_active(is_active),

◆ set_my_node()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::set_my_node ( base_node_type * new_my_node )

inline

Definition at line 1193 of file flow_graph.h.

◆ try_to_make_tuple()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

bool tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::try_to_make_tuple ( output_type & out )

inlineprotected

Definition at line 1244 of file flow_graph.h.

1249 {

◆ tuple_accepted()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::tuple_accepted ( )

inlineprotected

Definition at line 1250 of file flow_graph.h.

1257 { return my_successors.built_successors(); }

◆ tuple_build_may_succeed()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

bool tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::tuple_build_may_succeed ( )

inlineprotected

Definition at line 1236 of file flow_graph.h.

1240 {

◆ tuple_rejected()

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

void tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::tuple_rejected ( )

inlineprotected

Definition at line 1254 of file flow_graph.h.

1257 { return my_successors.built_successors(); }

Friends And Related Function Documentation

◆ internal::aggregating_functor< class_type, key_matching_FE_operation >

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

friend class internal::aggregating_functor< class_type, key_matching_FE_operation >

friend

Definition at line 1090 of file flow_graph.h.

Member Data Documentation

◆ my_aggregator

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

aggregator<handler_type, key_matching_FE_operation> tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::my_aggregator

private

Definition at line 1091 of file flow_graph.h.

◆ my_inputs

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

input_type tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::my_inputs

protected

Definition at line 1258 of file flow_graph.h.

◆ my_node

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

base_node_type* tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::my_node

protected

Definition at line 1259 of file flow_graph.h.

◆ N

template<typename InputTuple , typename OutputTuple , typename K , typename KHash >

const int tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >::N = tbb::flow::tuple_size<OutputTuple>::value

static

Definition at line 1046 of file flow_graph.h.

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

flow_graph.h

Classes

Public Types

Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

template<typename InputTuple, typename OutputTuple, typename K, typename KHash> class tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >

Member Typedef Documentation

◆ base_node_type

◆ class_type

◆ count_element_type

◆ forwarding_base_type

◆ handler_type

◆ input_type

◆ key_hash_compare

◆ key_to_count_buffer_type

◆ key_to_count_func

◆ key_type

◆ output_buffer_type

◆ output_type

◆ TtoK_function_body_leaf_type

◆ TtoK_function_body_type

◆ unref_key_type

Member Enumeration Documentation

◆ op_type

Constructor & Destructor Documentation

◆ join_node_FE() [1/2]

◆ join_node_FE() [2/2]

Member Function Documentation

◆ decrement_port_count()

◆ fill_output_buffer()

◆ handle_operations()

◆ increment_key_count()

◆ increment_port_count()

◆ input_ports()

◆ reset()

◆ reset_port_count()

◆ set_my_node()

◆ try_to_make_tuple()

◆ tuple_accepted()

◆ tuple_build_may_succeed()

◆ tuple_rejected()

Friends And Related Function Documentation

◆ internal::aggregating_functor< class_type, key_matching_FE_operation >

Member Data Documentation

◆ my_aggregator

◆ my_inputs

◆ my_node

◆ N

template<typename InputTuple, typename OutputTuple, typename K, typename KHash>
class tbb::flow::interface11::internal::join_node_FE< key_matching< K, KHash >, InputTuple, OutputTuple >