Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface10::internal::untyped_receiver Class Referenceabstract

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface10::internal::untyped_receiver:
Collaboration diagram for tbb::flow::interface10::internal::untyped_receiver:

Public Types

typedef untyped_sender predecessor_type
 The predecessor type for this node. More...
 

Public Member Functions

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

Protected Member Functions

template<typename X >
tasktry_put_task (const X &t)
 
virtual tasktry_put_task_wrapper (const void *p, bool is_async)=0
 
virtual graphgraph_reference ()=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 , typename >
class run_and_put_task
 
template<typename >
class limiter_node
 
template<typename , typename >
class internal::broadcast_cache
 
template<typename , typename >
class internal::round_robin_cache
 
template<typename , typename >
class internal::successor_cache
 
template<typename , typename >
class proxy_dependency_receiver
 

Detailed Description

Definition at line 330 of file flow_graph.h.

Member Typedef Documentation

◆ predecessor_type

The predecessor type for this node.

Definition at line 343 of file flow_graph.h.

Constructor & Destructor Documentation

◆ ~untyped_receiver()

virtual tbb::flow::interface10::internal::untyped_receiver::~untyped_receiver ( )
inlinevirtual

Destructor.

Definition at line 346 of file flow_graph.h.

346 {}

Member Function Documentation

◆ graph_reference()

virtual graph& tbb::flow::interface10::internal::untyped_receiver::graph_reference ( )
protectedpure virtual

Implemented in tbb::flow::interface10a::overwrite_node< T >, tbb::flow::interface10::limiter_node< T >, tbb::flow::interface10::buffer_node< T, A >, tbb::flow::interface10::broadcast_node< T >, tbb::flow::interface10::split_node< TupleType, Allocator >, tbb::flow::interface10::internal::continue_input< Output, Policy >, tbb::flow::interface10::internal::key_matching_port< TraitsType >, internal::key_matching_port< TraitsType >, tbb::flow::interface10::internal::queueing_port< T >, tbb::flow::interface10::internal::decrementer< T >, tbb::flow::interface10::internal::decrementer< tbb::flow::interface10::limiter_node< T > >, tbb::flow::interface10::internal::reserving_port< T >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, ImplType >, internal::function_input_base< Input, Policy, A, ImplType >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, tbb::flow::interface10::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::interface10::internal::function_input_base< Input, Policy, Allocator, function_input< Input, Output, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, tbb::flow::interface10::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 > > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, Allocator > >, internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, and tbb::flow::interface10::internal::indexer_input_port< T >.

◆ is_continue_receiver()

virtual bool tbb::flow::interface10::internal::untyped_receiver::is_continue_receiver ( )
inlineprotectedvirtual

Reimplemented in tbb::flow::interface10::continue_receiver.

Definition at line 391 of file flow_graph.h.

391 { return false; }

◆ register_predecessor()

virtual bool tbb::flow::interface10::internal::untyped_receiver::register_predecessor ( predecessor_type )
inlinevirtual

Add a predecessor to the node.

Reimplemented in tbb::flow::interface10::limiter_node< T >, tbb::flow::interface10::continue_receiver, tbb::flow::interface10::internal::reserving_port< T >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, ImplType >, internal::function_input_base< Input, Policy, A, ImplType >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, tbb::flow::interface10::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::interface10::internal::function_input_base< Input, Policy, Allocator, function_input< Input, Output, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, tbb::flow::interface10::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 > > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, Allocator > >, 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 > >.

Definition at line 362 of file flow_graph.h.

362 { return false; }

◆ remove_predecessor()

virtual bool tbb::flow::interface10::internal::untyped_receiver::remove_predecessor ( predecessor_type )
inlinevirtual

Remove a predecessor from the node.

Reimplemented in tbb::flow::interface10::limiter_node< T >, tbb::flow::interface10::continue_receiver, tbb::flow::interface10::internal::reserving_port< T >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, ImplType >, internal::function_input_base< Input, Policy, A, ImplType >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, tbb::flow::interface10::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::interface10::internal::function_input_base< Input, Policy, Allocator, function_input< Input, Output, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, tbb::flow::interface10::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 > > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, Allocator > >, 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 > >.

Definition at line 365 of file flow_graph.h.

365 { return false; }

◆ reset_receiver()

virtual void tbb::flow::interface10::internal::untyped_receiver::reset_receiver ( reset_flags  f = rf_reset_protocol)
protectedpure virtual

put receiver back in initial state

Implemented in tbb::flow::interface10a::overwrite_node< T >, tbb::flow::interface10::limiter_node< T >, tbb::flow::interface10::buffer_node< T, A >, tbb::flow::interface10::broadcast_node< T >, tbb::flow::interface10::split_node< TupleType, Allocator >, tbb::flow::interface10::internal::key_matching_port< TraitsType >, tbb::flow::interface10::internal::continue_input< Output, Policy >, tbb::flow::interface10::continue_receiver, tbb::flow::interface10::internal::queueing_port< T >, tbb::flow::interface10::internal::reserving_port< T >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, ImplType >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, tbb::flow::interface10::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::interface10::internal::function_input_base< Input, Policy, Allocator, function_input< Input, Output, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, Policy, Allocator > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, tbb::flow::interface10::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 > > >, tbb::flow::interface10::internal::function_input_base< Input, Policy, Allocator, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< Output >::value, internal::multifunction_output, Output >::type, Policy, Allocator > >, internal::function_input_base< Input, Policy, A, function_input< Input, Output, Policy, A > >, internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >, and tbb::flow::interface10::internal::indexer_input_port< T >.

◆ try_put()

template<typename X >
bool tbb::flow::interface10::internal::untyped_receiver::try_put ( const X &  t)
inline

Put an item to the receiver.

Definition at line 350 of file flow_graph.h.

350  {
351  task *res = try_put_task(t);
352  if (!res) return false;
354  return true;
355  }
static tbb::task *const SUCCESSFULLY_ENQUEUED
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task * task
void spawn_in_graph_arena(graph &g, tbb::task &arena_task)
Spawns a task inside graph arena.

◆ try_put_task()

template<typename X >
task* tbb::flow::interface10::internal::untyped_receiver::try_put_task ( const X &  t)
inlineprotected

Definition at line 378 of file flow_graph.h.

◆ try_put_task_wrapper()

Friends And Related Function Documentation

◆ internal::broadcast_cache

template<typename , typename >
friend class internal::broadcast_cache
friend

Definition at line 334 of file flow_graph.h.

◆ internal::round_robin_cache

template<typename , typename >
friend class internal::round_robin_cache
friend

Definition at line 335 of file flow_graph.h.

◆ internal::successor_cache

template<typename , typename >
friend class internal::successor_cache
friend

Definition at line 336 of file flow_graph.h.

◆ limiter_node

template<typename >
friend class limiter_node
friend

Definition at line 332 of file flow_graph.h.

◆ proxy_dependency_receiver

template<typename , typename >
friend class proxy_dependency_receiver
friend

Definition at line 339 of file flow_graph.h.

◆ run_and_put_task

template<typename , typename >
friend class run_and_put_task
friend

Definition at line 331 of file flow_graph.h.


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

Copyright © 2005-2019 Intel Corporation. All Rights Reserved.

Intel, Pentium, Intel Xeon, Itanium, Intel XScale and VTune are registered trademarks or trademarks of Intel Corporation or its subsidiaries in the United States and other countries.

* Other names and brands may be claimed as the property of others.