#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.

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.

          : input_node<Output>(g, body)
     {
     }
 
 #if __TBB_PREVIEW_FLOW_GRAPH_NODE_SET
     template <typename Body, typename... Successors>
     source_node( const node_set<internal::order::preceding, Successors...>& successors, Body body )

◆ 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.

                                  : tbb::flow::source_node is deprecated, use tbb::flow::input_node." )
 source_node : public graph_node, public sender< Output > {
 public:

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::input_body<output_type> *my_body;
     internal::input_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 );
 
 #if TBB_DEPRECATED_INPUT_NODE_BODY
             bool r = (*my_body)(my_cached_item);
             if (r) {

◆ 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> {

◆ 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.

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

◆ 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.

1212 {

◆ 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.

◆ 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.

         : source_node(successors.graph_reference(), body, is_active) {
         make_edges(*this, successors);
     }

◆ 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.

◆ 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.

1248 {

◆ 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 {

◆ 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.

1239 { delete my_body; delete my_init_body; }

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 {

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 >