#include <_flow_graph_indexer_impl.h>

Inheritance diagram for internal::indexer_node_base< InputTuple, OutputType, StructTypes >:

Collaboration diagram for internal::indexer_node_base< InputTuple, OutputType, StructTypes >:

Classes
class	indexer_node_base_operation

Public Types
typedef OutputType	output_type

typedef StructTypes	tuple_types

typedef sender< output_type >::successor_type	successor_type

typedef indexer_node_FE< InputTuple, output_type, StructTypes >	input_ports_type

Public Types inherited from internal::indexer_node_FE< InputTuple, OutputType, StructTypes >
typedef OutputType	output_type

typedef InputTuple	input_type

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

Public Member Functions
	indexer_node_base (graph &g)

	indexer_node_base (const indexer_node_base &other)

bool	register_successor (successor_type &r) __TBB_override
	Add a new successor to this node. More...

bool	remove_successor (successor_type &r) __TBB_override
	Removes a successor from this node. More...

task *	try_put_task (output_type const *v)

Public Member Functions inherited from internal::indexer_node_FE< InputTuple, OutputType, StructTypes >
	indexer_node_FE ()

input_type &	input_ports ()

Public Member Functions inherited from tbb::flow::interface11::sender< OutputType >
virtual bool	try_get (OutputType &)
	Request an item from the sender. More...

virtual bool	try_reserve (OutputType &)
	Reserves an item in the sender. More...

Public Member Functions inherited from tbb::flow::interface11::internal::untyped_sender
virtual	~untyped_sender ()

virtual bool	try_release ()
	Releases the reserved item. More...

virtual bool	try_consume ()
	Consumes the reserved item. More...

Static Public Attributes
static const size_t	N = tbb::flow::tuple_size<InputTuple>::value

Static Public Attributes inherited from internal::indexer_node_FE< InputTuple, OutputType, StructTypes >
static const int	N = tbb::flow::tuple_size<InputTuple>::value

Protected Member Functions
void	reset_node (reset_flags f) __TBB_override

Protected Member Functions inherited from tbb::flow::interface11::sender< OutputType >
virtual bool	try_get_wrapper (void *p, bool is_async) __TBB_override

virtual bool	try_reserve_wrapper (void *p, bool is_async) __TBB_override

Protected Member Functions inherited from tbb::flow::interface11::internal::untyped_sender
template<typename X >
bool	try_get (X &t)
	Request an item from the sender. More...

template<typename X >
bool	try_reserve (X &t)
	Reserves an item in the sender. More...

Private Types
enum	op_type { reg_succ, rem_succ, try__put_task }

typedef indexer_node_base< InputTuple, output_type, StructTypes >	class_type

typedef internal::aggregating_functor< class_type, indexer_node_base_operation >	handler_type

Private Member Functions
void	handle_operations (indexer_node_base_operation *op_list)

Private Attributes
aggregator< handler_type, indexer_node_base_operation >	my_aggregator

broadcast_cache< output_type, null_rw_mutex >	my_successors

Friends
class	internal::aggregating_functor< class_type, indexer_node_base_operation >

Additional Inherited Members
Public Attributes inherited from tbb::flow::interface11::sender< OutputType >
__TBB_DEPRECATED typedef OutputType	output_type
	The output type of this sender. More...

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

Protected Attributes inherited from internal::indexer_node_FE< InputTuple, OutputType, StructTypes >
input_type	my_inputs

Detailed Description

template<typename InputTuple, typename OutputType, typename StructTypes>
class internal::indexer_node_base< InputTuple, OutputType, StructTypes >

indexer_node_base

Definition at line 169 of file _flow_graph_indexer_impl.h.

Member Typedef Documentation

◆ class_type

template<typename InputTuple , typename OutputType , typename StructTypes >

typedef indexer_node_base<InputTuple,output_type,StructTypes> internal::indexer_node_base< InputTuple, OutputType, StructTypes >::class_type

private

Definition at line 192 of file _flow_graph_indexer_impl.h.

◆ handler_type

template<typename InputTuple , typename OutputType , typename StructTypes >

typedef internal::aggregating_functor<class_type, indexer_node_base_operation> internal::indexer_node_base< InputTuple, OutputType, StructTypes >::handler_type

private

Definition at line 213 of file _flow_graph_indexer_impl.h.

◆ input_ports_type

template<typename InputTuple , typename OutputType , typename StructTypes >

typedef indexer_node_FE<InputTuple, output_type,StructTypes> internal::indexer_node_base< InputTuple, OutputType, StructTypes >::input_ports_type

Definition at line 178 of file _flow_graph_indexer_impl.h.

◆ output_type

template<typename InputTuple , typename OutputType , typename StructTypes >

typedef OutputType internal::indexer_node_base< InputTuple, OutputType, StructTypes >::output_type

Definition at line 175 of file _flow_graph_indexer_impl.h.

◆ successor_type

template<typename InputTuple , typename OutputType , typename StructTypes >

typedef sender<output_type>::successor_type internal::indexer_node_base< InputTuple, OutputType, StructTypes >::successor_type

Definition at line 177 of file _flow_graph_indexer_impl.h.

◆ tuple_types

template<typename InputTuple , typename OutputType , typename StructTypes >

typedef StructTypes internal::indexer_node_base< InputTuple, OutputType, StructTypes >::tuple_types

Definition at line 176 of file _flow_graph_indexer_impl.h.

Member Enumeration Documentation

◆ op_type

template<typename InputTuple , typename OutputType , typename StructTypes >

enum internal::indexer_node_base::op_type

private

Enumerator
reg_succ
rem_succ
try__put_task

Definition at line 186 of file _flow_graph_indexer_impl.h.

                      { reg_succ, rem_succ, try__put_task
 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
             , add_blt_succ, del_blt_succ,
              blt_succ_cnt, blt_succ_cpy
 #endif
         };

Constructor & Destructor Documentation

◆ indexer_node_base() [1/2]

template<typename InputTuple , typename OutputType , typename StructTypes >

internal::indexer_node_base< InputTuple, OutputType, StructTypes >::indexer_node_base ( graph & g )

inline

Definition at line 261 of file _flow_graph_indexer_impl.h.

                                     : graph_node(g), input_ports_type() {
             indexer_helper<StructTypes,N>::set_indexer_node_pointer(this->my_inputs, this, g);
             my_successors.set_owner(this);
             my_aggregator.initialize_handler(handler_type(this));
         }

References internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_aggregator, internal::indexer_node_FE< InputTuple, OutputType, StructTypes >::my_inputs, internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_successors, internal::indexer_helper< TupleTypes, N >::set_indexer_node_pointer(), and internal::successor_cache< T, M >::set_owner().

Here is the call graph for this function:

◆ indexer_node_base() [2/2]

template<typename InputTuple , typename OutputType , typename StructTypes >

internal::indexer_node_base< InputTuple, OutputType, StructTypes >::indexer_node_base ( const indexer_node_base< InputTuple, OutputType, StructTypes > & other )

inline

Definition at line 267 of file _flow_graph_indexer_impl.h.

                                                           : graph_node(other.my_graph), input_ports_type(), sender<output_type>() {
             indexer_helper<StructTypes,N>::set_indexer_node_pointer(this->my_inputs, this, other.my_graph);
             my_successors.set_owner(this);
             my_aggregator.initialize_handler(handler_type(this));
         }

References internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_aggregator, internal::indexer_node_FE< InputTuple, OutputType, StructTypes >::my_inputs, internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_successors, internal::indexer_helper< TupleTypes, N >::set_indexer_node_pointer(), and internal::successor_cache< T, M >::set_owner().

Here is the call graph for this function:

Member Function Documentation

◆ handle_operations()

template<typename InputTuple , typename OutputType , typename StructTypes >

void internal::indexer_node_base< InputTuple, OutputType, StructTypes >::handle_operations ( indexer_node_base_operation * op_list )

inlineprivate

Definition at line 217 of file _flow_graph_indexer_impl.h.

                                                                      {
             indexer_node_base_operation *current;
             while(op_list) {
                 current = op_list;
                 op_list = op_list->next;
                 switch(current->type) {
 
                 case reg_succ:
                     my_successors.register_successor(*(current->my_succ));
                     __TBB_store_with_release(current->status, SUCCEEDED);
                     break;
 
                 case rem_succ:
                     my_successors.remove_successor(*(current->my_succ));
                     __TBB_store_with_release(current->status, SUCCEEDED);
                     break;
                 case try__put_task: {
                         current->bypass_t = my_successors.try_put_task(*(current->my_arg));
                         __TBB_store_with_release(current->status, SUCCEEDED);  // return of try_put_task actual return value
                     }
                     break;
 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
                 case add_blt_succ:
                     my_successors.internal_add_built_successor(*(current->my_succ));
                     __TBB_store_with_release(current->status, SUCCEEDED);
                     break;
                 case del_blt_succ:
                     my_successors.internal_delete_built_successor(*(current->my_succ));
                     __TBB_store_with_release(current->status, SUCCEEDED);
                     break;
                 case blt_succ_cnt:
                     current->cnt_val = my_successors.successor_count();
                     __TBB_store_with_release(current->status, SUCCEEDED);
                     break;
                 case blt_succ_cpy:
                     my_successors.copy_successors(*(current->succv));
                     __TBB_store_with_release(current->status, SUCCEEDED);
                     break;
 #endif  /* TBB_DEPRECATED_FLOW_NODE_EXTRACTION */
                 }
             }
         }

Here is the call graph for this function:

◆ register_successor()

template<typename InputTuple , typename OutputType , typename StructTypes >

bool internal::indexer_node_base< InputTuple, OutputType, StructTypes >::register_successor ( successor_type & r )

inlinevirtual

Add a new successor to this node.

Implements tbb::flow::interface11::internal::untyped_sender.

Definition at line 273 of file _flow_graph_indexer_impl.h.

                                                                   {
             indexer_node_base_operation op_data(r, reg_succ);
             my_aggregator.execute(&op_data);
             return op_data.status == SUCCEEDED;
         }

References internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_aggregator, internal::indexer_node_base< InputTuple, OutputType, StructTypes >::reg_succ, tbb::interface6::internal::aggregated_operation< Derived >::status, and internal::SUCCEEDED.

◆ remove_successor()

template<typename InputTuple , typename OutputType , typename StructTypes >

bool internal::indexer_node_base< InputTuple, OutputType, StructTypes >::remove_successor ( successor_type & r )

inlinevirtual

Removes a successor from this node.

Implements tbb::flow::interface11::internal::untyped_sender.

Definition at line 279 of file _flow_graph_indexer_impl.h.

                                                                  {
             indexer_node_base_operation op_data(r, rem_succ);
             my_aggregator.execute(&op_data);
             return op_data.status == SUCCEEDED;
         }

References internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_aggregator, internal::indexer_node_base< InputTuple, OutputType, StructTypes >::rem_succ, tbb::interface6::internal::aggregated_operation< Derived >::status, and internal::SUCCEEDED.

◆ reset_node()

template<typename InputTuple , typename OutputType , typename StructTypes >

void internal::indexer_node_base< InputTuple, OutputType, StructTypes >::reset_node ( reset_flags f )

inlineprotected

Definition at line 322 of file _flow_graph_indexer_impl.h.

                                                       {
             if(f & rf_clear_edges) {
                 my_successors.clear();
                 indexer_helper<StructTypes,N>::reset_inputs(this->my_inputs,f);
             }
         }

References internal::successor_cache< T, M >::clear(), internal::indexer_node_FE< InputTuple, OutputType, StructTypes >::my_inputs, internal::indexer_node_base< InputTuple, OutputType, StructTypes >::my_successors, internal::indexer_helper< TupleTypes, N >::reset_inputs(), and tbb::flow::interface11::rf_clear_edges.

Here is the call graph for this function:

◆ try_put_task()

template<typename InputTuple , typename OutputType , typename StructTypes >

task* internal::indexer_node_base< InputTuple, OutputType, StructTypes >::try_put_task ( output_type const * v )

inline

Definition at line 285 of file _flow_graph_indexer_impl.h.

                                                   { // not a virtual method in this class
             indexer_node_base_operation op_data(v, try__put_task);
             my_aggregator.execute(&op_data);
             return op_data.bypass_t;
         }