streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args > Class Template Reference

Inheritance diagram for streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >:

Collaboration diagram for streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >:

Classes
class	run_finalize_func
class	run_kernel_func
class	send_func

Public Member Functions
	args_storage (const kernel_type &kernel, StreamFactory &f, Args &&... args)
	args_storage (const args_storage &k)
	args_storage (const args_storage_base &k, Args &&... args)
void	enqueue (kernel_input_tuple &ip, output_ports_type &op, const streaming_node &n) __TBB_override
void	send (device_type d) __TBB_override
args_storage_base *	clone () const __TBB_override
Public Member Functions inherited from streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base
virtual	~args_storage_base ()

Private Types
typedef args_storage_base::output_ports_type	output_ports_type
typedef tbb::internal::stored_pack< Args... >	args_pack_type

Private Member Functions
template<int N>
bool	do_try_put (const kernel_input_tuple &ip, output_ports_type &op) const
template<int... S>
bool	do_try_put (const kernel_input_tuple &ip, output_ports_type &op, internal::sequence< S... >) const

Static Private Member Functions
template<typename FinalizeFn >
static run_finalize_func< FinalizeFn >	make_run_finalize_func (kernel_input_tuple &ip, StreamFactory &factory, FinalizeFn fn)

Private Attributes
args_pack_type	my_args_pack

Additional Inherited Members
Public Types inherited from streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base
typedef kernel_multifunction_node::output_ports_type	output_ports_type
Protected Member Functions inherited from streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base
	args_storage_base (const kernel_type &kernel, StreamFactory &f)
	args_storage_base (const args_storage_base &k)
Protected Attributes inherited from streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base
const kernel_type	my_kernel
StreamFactory &	my_factory

Detailed Description

template<typename... Ports, typename JP, typename StreamFactory>
template<typename... Args>
class streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >

Definition at line 490 of file _flow_graph_streaming_node.h.

Member Typedef Documentation

args_pack_type

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

typedef tbb::internal::stored_pack<Args...> streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::args_pack_type

private

Definition at line 629 of file _flow_graph_streaming_node.h.

output_ports_type

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

typedef args_storage_base::output_ports_type streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::output_ports_type

private

Definition at line 491 of file _flow_graph_streaming_node.h.

Constructor & Destructor Documentation

args_storage() [1/3]

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::args_storage ( const kernel_type &  kernel, StreamFactory &  f, Args &&...  args  )

inline

Definition at line 586 of file _flow_graph_streaming_node.h.

            : args_storage_base( kernel, f )
            , my_args_pack( std::forward<Args>(args)... )
        {}

args_storage() [2/3]

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::args_storage ( const args_storage &  k )

inline

Definition at line 591 of file _flow_graph_streaming_node.h.

: args_storage_base( k ), my_args_pack( k.my_args_pack ) {}

args_storage() [3/3]

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::args_storage ( const args_storage_base &  k, Args &&...  args  )

inline

Definition at line 593 of file _flow_graph_streaming_node.h.

: args_storage_base( k ), my_args_pack( std::forward<Args>(args)... ) {}

Member Function Documentation

clone()

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

args_storage_base* streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::clone ( ) const

inlinevirtual

Implements streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base.

Definition at line 623 of file _flow_graph_streaming_node.h.

                                                        {
            // Create new args_storage with copying constructor.
            return new args_storage<Args...>( *this );
        }

do_try_put() [1/2]

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

template<int N>

bool streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::do_try_put ( const kernel_input_tuple &  ip, output_ports_type &  op  ) const

inlineprivate

Definition at line 495 of file _flow_graph_streaming_node.h.

                                                                                     {
            const auto& t = get<N + 1>( ip );
            auto &port = get<N>( op );
            return port.try_put( t );
        }

do_try_put() [2/2]

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

template<int... S>

bool streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::do_try_put ( const kernel_input_tuple &  ip, output_ports_type &  op, internal::sequence< S... >    ) const

inlineprivate

Definition at line 502 of file _flow_graph_streaming_node.h.

                                                                                                             {
            return internal::or_return_values( do_try_put<S>( ip, op )... );
        }

References internal::or_return_values().

Here is the call graph for this function:

enqueue()

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

void streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::enqueue ( kernel_input_tuple &  ip, output_ports_type &  op, const streaming_node< tuple< Ports... >, JP, StreamFactory > &  n  )

inlinevirtual

Implements streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base.

Definition at line 595 of file _flow_graph_streaming_node.h.

                                                                                                              {
            // Make const qualified args_pack (from non-const)
            const args_pack_type& const_args_pack = my_args_pack;
            // factory.enqure_kernel() gets
            //  - 'ip' tuple elements by reference and updates it (and 'ip') with dependencies
            //  - arguments (from my_args_pack) by const-reference via const_args_pack
            tbb::internal::call( run_kernel_func( ip, n, *this ), const_args_pack );

            if (! do_try_put( ip, op, input_sequence() ) ) {
                graph& g = n.my_graph;
                // No one message was passed to successors so set a callback to extend the graph lifetime until the kernel completion.
                g.increment_wait_count();

                // factory.finalize() gets
                //  - 'ip' tuple elements by reference, so 'ip' might be changed
                //  - arguments (from my_args_pack) by const-reference via const_args_pack
                tbb::internal::call( make_run_finalize_func(ip, this->my_factory, [&g] {
                    g.decrement_wait_count();
                }), const_args_pack );
            }
        }

References tbb::internal::call(), and tbb::flow::interface11::internal::do_try_put().

Here is the call graph for this function:

make_run_finalize_func()

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

template<typename FinalizeFn >

static run_finalize_func<FinalizeFn> streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::make_run_finalize_func ( kernel_input_tuple &  ip, StreamFactory &  factory, FinalizeFn  fn  )

inlinestaticprivate

Definition at line 567 of file _flow_graph_streaming_node.h.

                                                                                                                                     {
            return run_finalize_func<FinalizeFn>( ip, factory, fn );
        }

References fn.

send()

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

void streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::send ( device_type  d )

inlinevirtual

Implements streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage_base.

Definition at line 617 of file _flow_graph_streaming_node.h.

                                                  {
            // factory.send() gets arguments by reference and updates these arguments with dependencies
            // (it gets but usually ignores port_ref-s)
            tbb::internal::call( send_func( this->my_factory, d ), my_args_pack );
        }

References tbb::internal::call(), and d.

Here is the call graph for this function:

Member Data Documentation

my_args_pack

template<typename... Ports, typename JP , typename StreamFactory >

template<typename... Args>

args_pack_type streaming_node< tuple< Ports... >, JP, StreamFactory >::args_storage< Args >::my_args_pack

private

Definition at line 630 of file _flow_graph_streaming_node.h.

---

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

• _flow_graph_streaming_node.h