internal::join_node_FE< reserving, InputTuple, OutputTuple > Class Template Reference

#include <_flow_graph_join_impl.h>

Inheritance diagram for internal::join_node_FE< reserving, InputTuple, OutputTuple >:

Collaboration diagram for internal::join_node_FE< reserving, InputTuple, OutputTuple >:

Public Types
typedef OutputTuple	output_type
typedef InputTuple	input_type
typedef join_node_base< reserving, InputTuple, OutputTuple >	base_node_type

Public Member Functions
	join_node_FE (graph &g)
	join_node_FE (const join_node_FE &other)
void	set_my_node (base_node_type *new_my_node)
void	increment_port_count () __TBB_override
task *	decrement_port_count (bool handle_task) __TBB_override
input_type &	input_ports ()
Public Member Functions inherited from 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

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

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 Attributes
input_type	my_inputs
base_node_type *	my_node
atomic< size_t >	ports_with_no_inputs

Additional Inherited Members
Public Attributes inherited from internal::forwarding_base
graph &	graph_ref

Detailed Description

template<typename InputTuple, typename OutputTuple>
class internal::join_node_FE< reserving, InputTuple, OutputTuple >

Definition at line 875 of file _flow_graph_join_impl.h.

Member Typedef Documentation

base_node_type

template<typename InputTuple , typename OutputTuple >

typedef join_node_base<reserving, InputTuple, OutputTuple> internal::join_node_FE< reserving, InputTuple, OutputTuple >::base_node_type

Definition at line 880 of file _flow_graph_join_impl.h.

input_type

template<typename InputTuple , typename OutputTuple >

typedef InputTuple internal::join_node_FE< reserving, InputTuple, OutputTuple >::input_type

Definition at line 879 of file _flow_graph_join_impl.h.

output_type

template<typename InputTuple , typename OutputTuple >

typedef OutputTuple internal::join_node_FE< reserving, InputTuple, OutputTuple >::output_type

Definition at line 878 of file _flow_graph_join_impl.h.

Constructor & Destructor Documentation

join_node_FE() [1/2]

template<typename InputTuple , typename OutputTuple >

internal::join_node_FE< reserving, InputTuple, OutputTuple >::join_node_FE ( graph &  g )

inline

Definition at line 882 of file _flow_graph_join_impl.h.

                               : forwarding_base(g), my_node(NULL) {
            ports_with_no_inputs = N;
            join_helper<N>::set_join_node_pointer(my_inputs, this);
        }

References internal::join_helper< N >::set_join_node_pointer().

Here is the call graph for this function:

join_node_FE() [2/2]

template<typename InputTuple , typename OutputTuple >

internal::join_node_FE< reserving, InputTuple, OutputTuple >::join_node_FE ( const join_node_FE< reserving, InputTuple, OutputTuple > &  other )

inline

Definition at line 887 of file _flow_graph_join_impl.h.

                                                : forwarding_base((other.forwarding_base::graph_ref)), my_node(NULL) {
            ports_with_no_inputs = N;
            join_helper<N>::set_join_node_pointer(my_inputs, this);
        }

References internal::join_helper< N >::set_join_node_pointer().

Here is the call graph for this function:

Member Function Documentation

decrement_port_count()

template<typename InputTuple , typename OutputTuple >

task* internal::join_node_FE< reserving, InputTuple, OutputTuple >::decrement_port_count ( bool  handle_task )

inlinevirtual

Implements internal::forwarding_base.

Definition at line 899 of file _flow_graph_join_impl.h.

                                                                     {
            if(ports_with_no_inputs.fetch_and_decrement() == 1) {
                if(internal::is_graph_active(this->graph_ref)) {
                    task *rtask = new ( task::allocate_additional_child_of( *(this->graph_ref.root_task()) ) )
                        forward_task_bypass<base_node_type>(*my_node);
                    if(!handle_task) return rtask;
                    internal::spawn_in_graph_arena(this->graph_ref, *rtask);
                }
            }
            return NULL;
        }

References tbb::flow::interface11::internal::is_graph_active(), tbb::flow::interface11::internal::spawn_in_graph_arena(), and task.

Here is the call graph for this function:

increment_port_count()

template<typename InputTuple , typename OutputTuple >

void internal::join_node_FE< reserving, InputTuple, OutputTuple >::increment_port_count ( )

inlinevirtual

Implements internal::forwarding_base.

Definition at line 894 of file _flow_graph_join_impl.h.

                                                  {
            ++ports_with_no_inputs;
        }

input_ports()

template<typename InputTuple , typename OutputTuple >

input_type& internal::join_node_FE< reserving, InputTuple, OutputTuple >::input_ports ( )

inline

Definition at line 911 of file _flow_graph_join_impl.h.

{ return my_inputs; }

reset()

template<typename InputTuple , typename OutputTuple >

void internal::join_node_FE< reserving, InputTuple, OutputTuple >::reset ( reset_flags  f )

inlineprotected

Definition at line 915 of file _flow_graph_join_impl.h.

                                    {
            // called outside of parallel contexts
            ports_with_no_inputs = N;
            join_helper<N>::reset_inputs(my_inputs, f);
        }

References internal::join_helper< N >::reset_inputs().

Here is the call graph for this function:

set_my_node()

template<typename InputTuple , typename OutputTuple >

void internal::join_node_FE< reserving, InputTuple, OutputTuple >::set_my_node ( base_node_type *  new_my_node )

inline

Definition at line 892 of file _flow_graph_join_impl.h.

{ my_node = new_my_node; }

try_to_make_tuple()

template<typename InputTuple , typename OutputTuple >

bool internal::join_node_FE< reserving, InputTuple, OutputTuple >::try_to_make_tuple ( output_type &  out )

inlineprotected

Definition at line 935 of file _flow_graph_join_impl.h.

                                                 {
            if(ports_with_no_inputs) return false;
            return join_helper<N>::reserve(my_inputs, out);
        }

References internal::join_helper< N >::reserve().

Here is the call graph for this function:

tuple_accepted()

template<typename InputTuple , typename OutputTuple >

void internal::join_node_FE< reserving, InputTuple, OutputTuple >::tuple_accepted ( )

inlineprotected

Definition at line 940 of file _flow_graph_join_impl.h.

                              {
            join_helper<N>::consume_reservations(my_inputs);
        }

References internal::join_helper< N >::consume_reservations().

Here is the call graph for this function:

tuple_build_may_succeed()

template<typename InputTuple , typename OutputTuple >

bool internal::join_node_FE< reserving, InputTuple, OutputTuple >::tuple_build_may_succeed ( )

inlineprotected

Definition at line 931 of file _flow_graph_join_impl.h.

                                       {
            return !ports_with_no_inputs;
        }

tuple_rejected()

template<typename InputTuple , typename OutputTuple >

void internal::join_node_FE< reserving, InputTuple, OutputTuple >::tuple_rejected ( )

inlineprotected

Definition at line 943 of file _flow_graph_join_impl.h.

                              {
            join_helper<N>::release_reservations(my_inputs);
        }

References internal::join_helper< N >::release_reservations().

Here is the call graph for this function:

Member Data Documentation

my_inputs

template<typename InputTuple , typename OutputTuple >

input_type internal::join_node_FE< reserving, InputTuple, OutputTuple >::my_inputs

protected

Definition at line 947 of file _flow_graph_join_impl.h.

my_node

template<typename InputTuple , typename OutputTuple >

base_node_type* internal::join_node_FE< reserving, InputTuple, OutputTuple >::my_node

protected

Definition at line 948 of file _flow_graph_join_impl.h.

N

template<typename InputTuple , typename OutputTuple >

const int internal::join_node_FE< reserving, InputTuple, OutputTuple >::N = tbb::flow::tuple_size<OutputTuple>::value

static

Definition at line 877 of file _flow_graph_join_impl.h.

ports_with_no_inputs

template<typename InputTuple , typename OutputTuple >

atomic<size_t> internal::join_node_FE< reserving, InputTuple, OutputTuple >::ports_with_no_inputs

protected

Definition at line 949 of file _flow_graph_join_impl.h.

---

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

• _flow_graph_join_impl.h