tbb::flow::interface11::receiver< T > Class Template Reference

Pure virtual template class that defines a receiver of messages of type T. More...

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface11::receiver< T >:

Collaboration diagram for tbb::flow::interface11::receiver< T >:

Public Member Functions
bool	try_put (const typename internal::async_helpers< T >::filtered_type &t)
	Put an item to the receiver. More...
bool	try_put (const typename internal::async_helpers< T >::async_type &t)
Public Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
virtual	~untyped_receiver ()
	Destructor. More...
template<typename X >
bool	try_put (const X &t)
	Put an item to the receiver. More...
virtual bool	register_predecessor (predecessor_type &)
	Add a predecessor to the node. More...
virtual bool	remove_predecessor (predecessor_type &)
	Remove a predecessor from the node. More...

Public Attributes
__TBB_DEPRECATED typedef T	input_type
	The input type of this receiver. More...
__TBB_DEPRECATED typedef internal::async_helpers< T >::filtered_type	filtered_type

Protected Member Functions
virtual task *	try_put_task_wrapper (const void *p, bool is_async) __TBB_override
virtual task *	try_put_task (const T &t)=0
	Put item to successor; return task to run the successor if possible. More...
Protected Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
template<typename X >
task *	try_put_task (const X &t)
virtual graph &	graph_reference () const =0
virtual void	reset_receiver (reset_flags f=rf_reset_protocol)=0
	put receiver back in initial state More...
virtual bool	is_continue_receiver ()

Friends
template<typename >
class	internal::async_storage
template<typename , typename >
struct	internal::async_helpers

Additional Inherited Members
Public Types inherited from tbb::flow::interface11::internal::untyped_receiver
typedef untyped_sender	predecessor_type
	The predecessor type for this node. More...

Detailed Description

template<typename T>
class tbb::flow::interface11::receiver< T >

Pure virtual template class that defines a receiver of messages of type T.

Definition at line 118 of file flow_graph.h.

Member Function Documentation

try_put() [1/2]

template<typename T>

bool tbb::flow::interface11::receiver< T >::try_put ( const typename internal::async_helpers< T >::filtered_type &  t )

inline

Put an item to the receiver.

Definition at line 472 of file flow_graph.h.

                                                                            {
        return internal::untyped_receiver::try_put(t);
    }

try_put() [2/2]

template<typename T>

bool tbb::flow::interface11::receiver< T >::try_put ( const typename internal::async_helpers< T >::async_type &  t )

inline

Definition at line 476 of file flow_graph.h.

                                                                         {
        return internal::untyped_receiver::try_put(t);
    }

try_put_task()

template<typename T>

virtual task* tbb::flow::interface11::receiver< T >::try_put_task ( const T &  t )

protectedpure virtual

Put item to successor; return task to run the successor if possible.

Implemented in tbb::flow::interface11::write_once_node< T >, tbb::flow::interface11::overwrite_node< T >, tbb::flow::interface11::limiter_node< T, DecrementType >, tbb::flow::interface11::buffer_node< T, Allocator >, tbb::flow::interface11::broadcast_node< T >, tbb::flow::interface11::split_node< TupleType, Allocator >, tbb::flow::interface11::internal::key_matching_port< TraitsType >, internal::key_matching_port< TraitsType >, tbb::flow::interface11::internal::queueing_port< T >, tbb::flow::interface11::internal::decrementer< T, DecrementType, typename tbb::internal::enable_if< tbb::internal::is_integral< DecrementType >::value, void >::type >, internal::decrementer< T, DecrementType, typename tbb::internal::enable_if< tbb::internal::is_integral< DecrementType >::value, void >::type >, tbb::flow::interface11::internal::reserving_port< T >, tbb::flow::interface11::internal::indexer_input_port< T >, tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >, internal::function_input_base< Input, Policy, A, ImplType >, tbb::flow::interface11::internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, tbb::flow::interface11::internal::function_input_base< kernel_input_tuple, queueing, cache_aligned_allocator< kernel_input_tuple >, multifunction_input< kernel_input_tuple, internal::wrap_tuple_elements< tbb::flow::tuple_size< output_tuple >::value, internal::multifunction_output, output_tuple >::type, queueing, cache_aligned_allocator< kernel_input_tuple > > >, tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, Policy, cache_aligned_allocator< Input > > >, tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, function_input< Input, Output, Policy, cache_aligned_allocator< Input > > >, tbb::flow::interface11::internal::function_input_base< Input, Policy, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, cache_aligned_allocator< Input > > >, tbb::flow::interface11::internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, tbb::flow::interface11::internal::function_input_base< indexer_node_output_type, queueing, cache_aligned_allocator< indexer_node_output_type >, multifunction_input< indexer_node_output_type, internal::wrap_tuple_elements< tbb::flow::tuple_size< kernel_input_tuple >::value, internal::multifunction_output, kernel_input_tuple >::type, queueing, cache_aligned_allocator< indexer_node_output_type > > >, internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, and internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >.

Referenced by tbb::flow::interface11::internal::type_to_key_function_body< Input, Output & >::~type_to_key_function_body().

Here is the caller graph for this function:

try_put_task_wrapper()

template<typename T>

virtual task* tbb::flow::interface11::receiver< T >::try_put_task_wrapper ( const void *  p, bool  is_async  )

inlineprotectedvirtual

Implements tbb::flow::interface11::internal::untyped_receiver.

Definition at line 481 of file flow_graph.h.

                                                                                      {
        return internal::async_helpers<T>::try_put_task_wrapper_impl(this, p, is_async);
    }

Friends And Related Function Documentation

internal::async_helpers

template<typename T>

template<typename , typename >

friend struct internal::async_helpers

friend

Definition at line 464 of file flow_graph.h.

internal::async_storage

template<typename T>

template<typename >

friend class internal::async_storage

friend

Definition at line 463 of file flow_graph.h.

Member Data Documentation

filtered_type

template<typename T>

__TBB_DEPRECATED typedef internal::async_helpers<T>::filtered_type tbb::flow::interface11::receiver< T >::filtered_type

Definition at line 469 of file flow_graph.h.

input_type

template<typename T>

__TBB_DEPRECATED typedef T tbb::flow::interface11::receiver< T >::input_type

The input type of this receiver.

Definition at line 467 of file flow_graph.h.

---

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

• flow_graph.h