Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface10 Namespace Reference

Namespaces

 internal
 
 opencl_info
 

Classes

class  async_msg
 
class  async_node
 Implements async node. More...
 
class  broadcast_node
 Forwards messages of type T to all successors. More...
 
class  buffer_node
 Forwards messages in arbitrary order. More...
 
class  callback
 
class  callback_base
 
class  composite_node
 
class  composite_node< tbb::flow::tuple< InputTypes... >, tbb::flow::tuple< OutputTypes... > >
 
class  composite_node< tbb::flow::tuple< InputTypes... >, tbb::flow::tuple<> >
 
class  composite_node< tbb::flow::tuple<>, tbb::flow::tuple< OutputTypes... > >
 
class  continue_msg
 An empty class used for messages that mean "I'm done". More...
 
class  continue_node
 Implements an executable node that supports continue_msg -> Output. More...
 
class  continue_receiver
 Base class for receivers of completion messages. More...
 
class  function_node
 Implements a function node that supports Input -> Output. More...
 
class  graph
 The graph class. More...
 
class  graph_iterator
 
class  graph_node
 The base of all graph nodes. More...
 
class  graph_proxy
 Pure virtual template classes that define interfaces for async communication. More...
 
struct  graph_task
 Base class for tasks generated by graph nodes. More...
 
class  indexer_node
 
class  indexer_node< T0 >
 
class  indexer_node< T0, T1 >
 
class  indexer_node< T0, T1, T2 >
 
class  indexer_node< T0, T1, T2, T3 >
 
class  indexer_node< T0, T1, T2, T3, T4 >
 
class  indexer_node< T0, T1, T2, T3, T4, T5 >
 
class  indexer_node< T0, T1, T2, T3, T4, T5, T6 >
 
class  indexer_node< T0, T1, T2, T3, T4, T5, T6, T7 >
 
class  indexer_node< T0, T1, T2, T3, T4, T5, T6, T7, T8 >
 
class  join_node
 
class  join_node< OutputTuple, key_matching< K, KHash > >
 
class  join_node< OutputTuple, queueing >
 
class  join_node< OutputTuple, reserving >
 
class  limiter_node
 Forwards messages only if the threshold has not been reached. More...
 
class  multifunction_node
 implements a function node that supports Input -> (set of outputs) More...
 
struct  null_type
 A generic null type. More...
 
class  opencl_async_msg
 
class  opencl_buffer
 
class  opencl_buffer_impl
 
class  opencl_device
 
class  opencl_device_list
 
class  opencl_factory
 
class  opencl_memory
 
class  opencl_node
 
class  opencl_node< tuple< Ports... > >
 
class  opencl_node< tuple< Ports... >, JP >
 
class  opencl_node< tuple< Ports... >, JP, Factory >
 
class  opencl_program
 
class  opencl_range
 
class  opencl_subbuffer
 
class  priority_queue_node
 Forwards messages in priority order. More...
 
class  queue_node
 Forwards messages in FIFO order. More...
 
class  receiver
 Pure virtual template class that defines a receiver of messages of type T. More...
 
class  receiver_gateway
 
class  run_and_put_task
 
class  sender
 Forward declaration section. More...
 
class  sequencer_node
 Forwards messages in sequence order. More...
 
class  source_node
 An executable node that acts as a source, i.e. it has no predecessors. More...
 
class  split_node
 split_node: accepts a tuple as input, forwards each element of the tuple to its More...
 
class  streaming_node
 
class  streaming_node< tuple< Ports... >, JP, StreamFactory >
 

Enumerations

enum  access_type { read_write, write_only, read_only }
 
enum  opencl_program_type { opencl_program_type::SOURCE, opencl_program_type::PRECOMPILED, opencl_program_type::SPIR }
 
enum  reset_flags { rf_reset_protocol = 0, rf_reset_bodies = 1 << 0, rf_clear_edges = 1 << 1 }
 

Functions

static tbb::taskcombine_tasks (graph &g, tbb::task *left, tbb::task *right)
 
void internal_make_edge (internal::untyped_sender &p, internal::untyped_receiver &s)
 
template<typename T >
void make_edge (sender< T > &p, receiver< T > &s)
 Makes an edge between a single predecessor and a single successor. More...
 
template<typename TS , typename TR , typename = typename tbb::internal::enable_if<tbb::internal::is_same_type<TS, internal::untyped_sender>::value || tbb::internal::is_same_type<TR, internal::untyped_receiver>::value>::type>
void make_edge (TS &p, TR &s)
 
template<typename T >
void make_edge (sender< T > &p, receiver< typename T::async_msg_data_type > &s)
 
template<typename T >
void make_edge (sender< typename T::async_msg_data_type > &p, receiver< T > &s)
 
template<typename T , typename V , typename = typename T::output_ports_type, typename = typename V::input_ports_type>
void make_edge (T &output, V &input)
 
template<typename T , typename R , typename = typename T::output_ports_type>
void make_edge (T &output, receiver< R > &input)
 
template<typename S , typename V , typename = typename V::input_ports_type>
void make_edge (sender< S > &output, V &input)
 
void internal_remove_edge (internal::untyped_sender &p, internal::untyped_receiver &s)
 
template<typename T >
void remove_edge (sender< T > &p, receiver< T > &s)
 Removes an edge between a single predecessor and a single successor. More...
 
template<typename TS , typename TR , typename = typename tbb::internal::enable_if<tbb::internal::is_same_type<TS, internal::untyped_sender>::value || tbb::internal::is_same_type<TR, internal::untyped_receiver>::value>::type>
void remove_edge (TS &p, TR &s)
 
template<typename T >
void remove_edge (sender< T > &p, receiver< typename T::async_msg_data_type > &s)
 
template<typename T >
void remove_edge (sender< typename T::async_msg_data_type > &p, receiver< T > &s)
 
template<typename T , typename V , typename = typename T::output_ports_type, typename = typename V::input_ports_type>
void remove_edge (T &output, V &input)
 
template<typename T , typename R , typename = typename T::output_ports_type>
void remove_edge (T &output, receiver< R > &input)
 
template<typename S , typename V , typename = typename V::input_ports_type>
void remove_edge (sender< S > &output, V &input)
 
template<typename Body , typename Node >
Body copy_body (Node &n)
 Returns a copy of the body from a function or continue node. More...
 
template<int N1, int N2 = N1>
internal::port_ref_impl< N1, N2 > port_ref ()
 
void enforce_cl_retcode (cl_int err, std::string msg)
 
template<typename T >
event_info (cl_event e, cl_event_info i)
 
template<typename T >
device_info (cl_device_id d, cl_device_info i)
 
template<>
std::string device_info< std::string > (cl_device_id d, cl_device_info i)
 
template<typename T >
platform_info (cl_platform_id p, cl_platform_info i)
 
template<>
std::string platform_info< std::string > (cl_platform_id p, cl_platform_info i)
 
template<typename K , typename T , typename Factory >
key_from_message (const opencl_async_msg< T, Factory > &dmsg)
 
 is_typedef (native_object_type)
 
 is_typedef (memory_object_type)
 
template<typename T >
std::enable_if< is_native_object_type< T >::value, typename T::native_object_type >::type get_native_object (const T &t)
 
template<typename T >
std::enable_if<!is_native_object_type< T >::value, T >::type get_native_object (T t)
 
template<typename T , typename Factory >
std::enable_if< is_memory_object_type< T >::value >::type send_if_memory_object (opencl_device device, opencl_async_msg< T, Factory > &dmsg)
 
template<typename T >
std::enable_if< is_memory_object_type< T >::value >::type send_if_memory_object (opencl_device device, T &t)
 
template<typename T >
std::enable_if<!is_memory_object_type< T >::value >::type send_if_memory_object (opencl_device, T &)
 
template<typename T , typename Factory >
std::enable_if< is_memory_object_type< T >::value >::type receive_if_memory_object (const opencl_async_msg< T, Factory > &dmsg)
 
template<typename T >
std::enable_if<!is_memory_object_type< T >::value >::type receive_if_memory_object (const T &)
 

Enumeration Type Documentation

◆ access_type

◆ opencl_program_type

◆ reset_flags

Enumerator
rf_reset_protocol 
rf_reset_bodies 
rf_clear_edges 

Definition at line 150 of file _flow_graph_impl.h.

150  {
151  rf_reset_protocol = 0,
152  rf_reset_bodies = 1 << 0, // delete the current node body, reset to a copy of the initial node body.
153  rf_clear_edges = 1 << 1 // delete edges
154 };

Function Documentation

◆ combine_tasks()

static tbb::task* tbb::flow::interface10::combine_tasks ( graph g,
tbb::task left,
tbb::task right 
)
inlinestatic

Definition at line 171 of file flow_graph.h.

171  {
172  // if no RHS task, don't change left.
173  if (right == NULL) return left;
174  // right != NULL
175  if (left == NULL) return right;
176  if (left == SUCCESSFULLY_ENQUEUED) return right;
177  // left contains a task
178  if (right != SUCCESSFULLY_ENQUEUED) {
179  // both are valid tasks
181  return right;
182  }
183  return left;
184 }
static tbb::task *const SUCCESSFULLY_ENQUEUED
void spawn_in_graph_arena(graph &g, tbb::task &arena_task)
Spawns a task inside graph arena.

Referenced by internal::function_input< Input, Output, Policy, A >::apply_body_impl_bypass(), internal::function_input_base< Input, Policy, A, multifunction_input< Input, OutputPortSet, Policy, A > >::forward_task(), internal::join_node_base< JP, InputTuple, OutputTuple >::handle_operations(), tbb::flow::interface10::queue_node< T, A >::try_put_and_add_task(), tbb::flow::interface10::priority_queue_node< T, Compare, A >::try_put_and_add_task(), and internal::broadcast_cache< output_type >::try_put_task().

Here is the caller graph for this function:

◆ copy_body()

template<typename Body , typename Node >
Body tbb::flow::interface10::copy_body ( Node &  n)

Returns a copy of the body from a function or continue node.

Definition at line 3254 of file flow_graph.h.

3254  {
3255  return n.template copy_function_object<Body>();
3256 }

◆ device_info()

template<typename T >
T tbb::flow::interface10::device_info ( cl_device_id  d,
cl_device_info  i 
)

Definition at line 73 of file flow_graph_opencl_node.h.

73  {
74  T res;
75  enforce_cl_retcode(clGetDeviceInfo(d, i, sizeof(res), &res, NULL), "Failed to get OpenCL device information");
76  return res;
77 }
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 enforce_cl_retcode(cl_int err, std::string msg)

References d, and enforce_cl_retcode().

Here is the call graph for this function:

◆ device_info< std::string >()

template<>
std::string tbb::flow::interface10::device_info< std::string > ( cl_device_id  d,
cl_device_info  i 
)
inline

Definition at line 80 of file flow_graph_opencl_node.h.

80  {
81  size_t required;
82  enforce_cl_retcode(clGetDeviceInfo(d, i, 0, NULL, &required), "Failed to get OpenCL device information");
83 
84  char *buff = (char*)alloca(required);
85  enforce_cl_retcode(clGetDeviceInfo(d, i, required, buff, NULL), "Failed to get OpenCL device information");
86 
87  return buff;
88 }
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 enforce_cl_retcode(cl_int err, std::string msg)

References d, and enforce_cl_retcode().

Here is the call graph for this function:

◆ enforce_cl_retcode()

void tbb::flow::interface10::enforce_cl_retcode ( cl_int  err,
std::string  msg 
)
inline

Definition at line 58 of file flow_graph_opencl_node.h.

58  {
59  if (err != CL_SUCCESS) {
60  std::cerr << msg << "; error code: " << err << std::endl;
61  throw msg;
62  }
63 }

Referenced by tbb::flow::interface10::opencl_async_msg< T, Factory >::clear_event(), tbb::flow::interface10::opencl_async_msg< T, Factory >::data(), device_info(), device_info< std::string >(), tbb::flow::interface10::opencl_factory< default_device_filter >::enqueue_map_buffer(), tbb::flow::interface10::opencl_factory< default_device_filter >::enqueue_unmap_buffer(), event_info(), tbb::flow::interface10::opencl_factory< default_device_filter >::finalize(), tbb::flow::interface10::internal::find_available_devices(), tbb::flow::interface10::opencl_program< Factory >::get_cl_kernel(), tbb::flow::interface10::opencl_program< Factory >::init(), tbb::flow::interface10::opencl_factory< default_device_filter >::init_once(), tbb::flow::interface10::opencl_factory< DeviceFilter >::kernel::kernel(), tbb::flow::interface10::opencl_async_msg< T, Factory >::opencl_async_msg(), tbb::flow::interface10::opencl_buffer_impl< Factory >::opencl_buffer_impl(), tbb::flow::interface10::opencl_program< Factory >::opencl_device_filter::opencl_device_filter(), tbb::flow::interface10::opencl_program< Factory >::opencl_program_builder::opencl_program_builder(), tbb::flow::interface10::opencl_async_msg< T, Factory >::operator=(), platform_info(), platform_info< std::string >(), tbb::flow::interface10::opencl_factory< default_device_filter >::process_one_arg(), tbb::flow::interface10::opencl_memory< Factory >::receive(), tbb::flow::interface10::opencl_async_msg< T, Factory >::register_callback(), tbb::flow::interface10::opencl_memory< Factory >::send(), tbb::flow::interface10::opencl_factory< default_device_filter >::send_kernel(), tbb::flow::interface10::opencl_factory< default_device_filter >::send_kernel_impl(), tbb::flow::interface10::opencl_async_msg< T, Factory >::set_event(), tbb::flow::interface10::opencl_factory< DeviceFilter >::kernel::~kernel(), tbb::flow::interface10::opencl_async_msg< T, Factory >::~opencl_async_msg(), tbb::flow::interface10::opencl_factory< default_device_filter >::~opencl_factory(), and tbb::flow::interface10::opencl_memory< Factory >::~opencl_memory().

Here is the caller graph for this function:

◆ event_info()

template<typename T >
T tbb::flow::interface10::event_info ( cl_event  e,
cl_event_info  i 
)

Definition at line 66 of file flow_graph_opencl_node.h.

66  {
67  T res;
68  enforce_cl_retcode(clGetEventInfo(e, i, sizeof(res), &res, NULL), "Failed to get OpenCL event information");
69  return res;
70 }
void enforce_cl_retcode(cl_int err, std::string msg)

References enforce_cl_retcode().

Here is the call graph for this function:

◆ get_native_object() [1/2]

template<typename T >
std::enable_if<is_native_object_type<T>::value, typename T::native_object_type>::type tbb::flow::interface10::get_native_object ( const T &  t)

Definition at line 736 of file flow_graph_opencl_node.h.

736  {
737  return t.native_object();
738 }

Referenced by tbb::flow::interface10::opencl_factory< default_device_filter >::process_one_arg().

Here is the caller graph for this function:

◆ get_native_object() [2/2]

template<typename T >
std::enable_if<!is_native_object_type<T>::value, T>::type tbb::flow::interface10::get_native_object ( t)

Definition at line 741 of file flow_graph_opencl_node.h.

741  {
742  return t;
743 }

◆ internal_make_edge()

void tbb::flow::interface10::internal_make_edge ( internal::untyped_sender p,
internal::untyped_receiver s 
)
inline

Definition at line 3108 of file flow_graph.h.

3108  {
3109 #else
3110 template< typename T >
3111 inline void internal_make_edge( sender<T> &p, receiver<T> &s ) {
3112 #endif
3113 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
3114  s.internal_add_built_predecessor(p);
3115  p.internal_add_built_successor(s);
3116 #endif
3117  p.register_successor( s );
3119 }
static void fgt_make_edge(void *, void *)
void const char const char int ITT_FORMAT __itt_group_sync p
void internal_make_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3108
void const char const char int ITT_FORMAT __itt_group_sync s

References tbb::internal::fgt_make_edge(), p, and s.

Referenced by make_edge().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ internal_remove_edge()

void tbb::flow::interface10::internal_remove_edge ( internal::untyped_sender p,
internal::untyped_receiver s 
)
inline

Definition at line 3171 of file flow_graph.h.

3171  {
3172 #else
3173 template< typename T >
3174 inline void internal_remove_edge( sender<T> &p, receiver<T> &s ) {
3175 #endif
3176  p.remove_successor( s );
3177 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
3178  // TODO: should we try to remove p from the predecessor list of s, in case the edge is reversed?
3179  p.internal_delete_built_successor(s);
3180  s.internal_delete_built_predecessor(p);
3181 #endif
3183 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3171
void const char const char int ITT_FORMAT __itt_group_sync p
static void fgt_remove_edge(void *, void *)
void const char const char int ITT_FORMAT __itt_group_sync s

References tbb::internal::fgt_remove_edge(), p, and s.

Referenced by remove_edge().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ is_typedef() [1/2]

tbb::flow::interface10::is_typedef ( native_object_type  )

◆ is_typedef() [2/2]

tbb::flow::interface10::is_typedef ( memory_object_type  )

◆ key_from_message()

template<typename K , typename T , typename Factory >
K tbb::flow::interface10::key_from_message ( const opencl_async_msg< T, Factory > &  dmsg)

Definition at line 496 of file flow_graph_opencl_node.h.

496  {
498  const T &t = dmsg.data( false );
499  __TBB_STATIC_ASSERT( true, "" );
500  return key_from_message<K, T>( t );
501 }
#define __TBB_STATIC_ASSERT(condition, msg)
Definition: tbb_stddef.h:536
K key_from_message(const T &t)
Definition: flow_graph.h:695

References __TBB_STATIC_ASSERT, tbb::flow::interface10::opencl_async_msg< T, Factory >::data(), and tbb::flow::key_from_message().

Here is the call graph for this function:

◆ make_edge() [1/7]

template<typename T >
void tbb::flow::interface10::make_edge ( sender< T > &  p,
receiver< T > &  s 
)
inline

Makes an edge between a single predecessor and a single successor.

Definition at line 3123 of file flow_graph.h.

3123  {
3124  internal_make_edge( p, s );
3125 }
void const char const char int ITT_FORMAT __itt_group_sync p
void internal_make_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3108
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_make_edge(), p, and s.

Referenced by make_edge(), streaming_node< tuple< Ports... >, JP, StreamFactory >::make_edges(), and streaming_node< tuple< Ports... >, JP, StreamFactory >::make_Nth_edge().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ make_edge() [2/7]

template<typename TS , typename TR , typename = typename tbb::internal::enable_if<tbb::internal::is_same_type<TS, internal::untyped_sender>::value || tbb::internal::is_same_type<TR, internal::untyped_receiver>::value>::type>
void tbb::flow::interface10::make_edge ( TS &  p,
TR &  s 
)
inline

Definition at line 3131 of file flow_graph.h.

3131  {
3132  internal_make_edge( p, s );
3133 }
void const char const char int ITT_FORMAT __itt_group_sync p
void internal_make_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3108
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_make_edge(), p, and s.

Here is the call graph for this function:

◆ make_edge() [3/7]

template<typename T >
void tbb::flow::interface10::make_edge ( sender< T > &  p,
receiver< typename T::async_msg_data_type > &  s 
)
inline

Definition at line 3136 of file flow_graph.h.

3136  {
3137  internal_make_edge( p, s );
3138 }
void const char const char int ITT_FORMAT __itt_group_sync p
void internal_make_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3108
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_make_edge(), p, and s.

Here is the call graph for this function:

◆ make_edge() [4/7]

template<typename T >
void tbb::flow::interface10::make_edge ( sender< typename T::async_msg_data_type > &  p,
receiver< T > &  s 
)
inline

Definition at line 3141 of file flow_graph.h.

3141  {
3142  internal_make_edge( p, s );
3143 }
void const char const char int ITT_FORMAT __itt_group_sync p
void internal_make_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3108
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_make_edge(), p, and s.

Here is the call graph for this function:

◆ make_edge() [5/7]

template<typename T , typename V , typename = typename T::output_ports_type, typename = typename V::input_ports_type>
void tbb::flow::interface10::make_edge ( T &  output,
V &  input 
)
inline

Definition at line 3151 of file flow_graph.h.

3151  {
3152  make_edge(get<0>(output.output_ports()), get<0>(input.input_ports()));
3153 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3165

References make_edge().

Here is the call graph for this function:

◆ make_edge() [6/7]

template<typename T , typename R , typename = typename T::output_ports_type>
void tbb::flow::interface10::make_edge ( T &  output,
receiver< R > &  input 
)
inline

Definition at line 3158 of file flow_graph.h.

3158  {
3159  make_edge(get<0>(output.output_ports()), input);
3160 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3165

References make_edge().

Here is the call graph for this function:

◆ make_edge() [7/7]

template<typename S , typename V , typename = typename V::input_ports_type>
void tbb::flow::interface10::make_edge ( sender< S > &  output,
V &  input 
)
inline

Definition at line 3165 of file flow_graph.h.

3165  {
3166  make_edge(output, get<0>(input.input_ports()));
3167 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3165

References make_edge().

Here is the call graph for this function:

◆ platform_info()

template<typename T >
T tbb::flow::interface10::platform_info ( cl_platform_id  p,
cl_platform_info  i 
)

Definition at line 91 of file flow_graph_opencl_node.h.

91  {
92  T res;
93  enforce_cl_retcode(clGetPlatformInfo(p, i, sizeof(res), &res, NULL), "Failed to get OpenCL platform information");
94  return res;
95 }
void const char const char int ITT_FORMAT __itt_group_sync p
void enforce_cl_retcode(cl_int err, std::string msg)

References enforce_cl_retcode(), and p.

Here is the call graph for this function:

◆ platform_info< std::string >()

template<>
std::string tbb::flow::interface10::platform_info< std::string > ( cl_platform_id  p,
cl_platform_info  i 
)
inline

Definition at line 98 of file flow_graph_opencl_node.h.

98  {
99  size_t required;
100  enforce_cl_retcode(clGetPlatformInfo(p, i, 0, NULL, &required), "Failed to get OpenCL platform information");
101 
102  char *buff = (char*)alloca(required);
103  enforce_cl_retcode(clGetPlatformInfo(p, i, required, buff, NULL), "Failed to get OpenCL platform information");
104 
105  return buff;
106 }
void const char const char int ITT_FORMAT __itt_group_sync p
void enforce_cl_retcode(cl_int err, std::string msg)

References enforce_cl_retcode(), and p.

Here is the call graph for this function:

◆ port_ref()

template<int N1, int N2 = N1>
internal::port_ref_impl<N1,N2> tbb::flow::interface10::port_ref ( )

Definition at line 46 of file flow_graph.h.

◆ receive_if_memory_object() [1/2]

template<typename T , typename Factory >
std::enable_if<is_memory_object_type<T>::value>::type tbb::flow::interface10::receive_if_memory_object ( const opencl_async_msg< T, Factory > &  dmsg)

Definition at line 770 of file flow_graph_opencl_node.h.

770  {
771  const T &t = dmsg.data( false );
772  typedef typename T::memory_object_type mem_obj_t;
773  mem_obj_t mem_obj = t.memory_object();
774  opencl_async_msg<mem_obj_t, Factory> d( mem_obj );
775  if ( dmsg.get_event() ) d.set_event( *dmsg.get_event() );
776  mem_obj.receive( d );
777  if ( d.get_event() ) dmsg.set_event( *d.get_event() );
778 }
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

References d, tbb::flow::interface10::opencl_async_msg< T, Factory >::data(), tbb::flow::interface10::opencl_async_msg< T, Factory >::get_event(), and tbb::flow::interface10::opencl_async_msg< T, Factory >::set_event().

Referenced by tbb::flow::interface10::opencl_async_msg< T, Factory >::finalize().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ receive_if_memory_object() [2/2]

template<typename T >
std::enable_if<!is_memory_object_type<T>::value>::type tbb::flow::interface10::receive_if_memory_object ( const T &  )

Definition at line 781 of file flow_graph_opencl_node.h.

781 {}

◆ remove_edge() [1/7]

template<typename T >
void tbb::flow::interface10::remove_edge ( sender< T > &  p,
receiver< T > &  s 
)
inline

Removes an edge between a single predecessor and a single successor.

Definition at line 3187 of file flow_graph.h.

3187  {
3188  internal_remove_edge( p, s );
3189 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3171
void const char const char int ITT_FORMAT __itt_group_sync p
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_remove_edge(), p, and s.

Referenced by remove_edge().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ remove_edge() [2/7]

template<typename TS , typename TR , typename = typename tbb::internal::enable_if<tbb::internal::is_same_type<TS, internal::untyped_sender>::value || tbb::internal::is_same_type<TR, internal::untyped_receiver>::value>::type>
void tbb::flow::interface10::remove_edge ( TS &  p,
TR &  s 
)
inline

Definition at line 3195 of file flow_graph.h.

3195  {
3196  internal_remove_edge( p, s );
3197 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3171
void const char const char int ITT_FORMAT __itt_group_sync p
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_remove_edge(), p, and s.

Here is the call graph for this function:

◆ remove_edge() [3/7]

template<typename T >
void tbb::flow::interface10::remove_edge ( sender< T > &  p,
receiver< typename T::async_msg_data_type > &  s 
)
inline

Definition at line 3200 of file flow_graph.h.

3200  {
3201  internal_remove_edge( p, s );
3202 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3171
void const char const char int ITT_FORMAT __itt_group_sync p
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_remove_edge(), p, and s.

Here is the call graph for this function:

◆ remove_edge() [4/7]

template<typename T >
void tbb::flow::interface10::remove_edge ( sender< typename T::async_msg_data_type > &  p,
receiver< T > &  s 
)
inline

Definition at line 3205 of file flow_graph.h.

3205  {
3206  internal_remove_edge( p, s );
3207 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3171
void const char const char int ITT_FORMAT __itt_group_sync p
void const char const char int ITT_FORMAT __itt_group_sync s

References internal_remove_edge(), p, and s.

Here is the call graph for this function:

◆ remove_edge() [5/7]

template<typename T , typename V , typename = typename T::output_ports_type, typename = typename V::input_ports_type>
void tbb::flow::interface10::remove_edge ( T &  output,
V &  input 
)
inline

Definition at line 3214 of file flow_graph.h.

3214  {
3215  remove_edge(get<0>(output.output_ports()), get<0>(input.input_ports()));
3216 }
void remove_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3227

References remove_edge().

Here is the call graph for this function:

◆ remove_edge() [6/7]

template<typename T , typename R , typename = typename T::output_ports_type>
void tbb::flow::interface10::remove_edge ( T &  output,
receiver< R > &  input 
)
inline

Definition at line 3221 of file flow_graph.h.

3221  {
3222  remove_edge(get<0>(output.output_ports()), input);
3223 }
void remove_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3227

References remove_edge().

Here is the call graph for this function:

◆ remove_edge() [7/7]

template<typename S , typename V , typename = typename V::input_ports_type>
void tbb::flow::interface10::remove_edge ( sender< S > &  output,
V &  input 
)
inline

Definition at line 3227 of file flow_graph.h.

3227  {
3228  remove_edge(output, get<0>(input.input_ports()));
3229 }
void remove_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3227

References remove_edge().

Here is the call graph for this function:

◆ send_if_memory_object() [1/3]

template<typename T , typename Factory >
std::enable_if<is_memory_object_type<T>::value>::type tbb::flow::interface10::send_if_memory_object ( opencl_device  device,
opencl_async_msg< T, Factory > &  dmsg 
)

Definition at line 747 of file flow_graph_opencl_node.h.

747  {
748  const T &t = dmsg.data( false );
749  typedef typename T::memory_object_type mem_obj_t;
750  mem_obj_t mem_obj = t.memory_object();
751  opencl_async_msg<mem_obj_t, Factory> d( mem_obj );
752  if ( dmsg.get_event() ) d.set_event( *dmsg.get_event() );
753  mem_obj.send( device, d );
754  if ( d.get_event() ) dmsg.set_event( *d.get_event() );
755 }
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

References d, tbb::flow::interface10::opencl_async_msg< T, Factory >::data(), tbb::flow::interface10::opencl_async_msg< T, Factory >::get_event(), and tbb::flow::interface10::opencl_async_msg< T, Factory >::set_event().

Referenced by tbb::flow::interface10::opencl_factory< default_device_filter >::send_data().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ send_if_memory_object() [2/3]

template<typename T >
std::enable_if<is_memory_object_type<T>::value>::type tbb::flow::interface10::send_if_memory_object ( opencl_device  device,
T &  t 
)

Definition at line 758 of file flow_graph_opencl_node.h.

758  {
759  typedef typename T::memory_object_type mem_obj_t;
760  mem_obj_t mem_obj = t.memory_object();
761  opencl_async_msg<mem_obj_t, typename mem_obj_t::opencl_factory_type> dmsg( mem_obj );
762  mem_obj.send( device, dmsg );
763 }

◆ send_if_memory_object() [3/3]

template<typename T >
std::enable_if<!is_memory_object_type<T>::value>::type tbb::flow::interface10::send_if_memory_object ( opencl_device  ,
T &   
)

Definition at line 766 of file flow_graph_opencl_node.h.

766 {};

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.