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 146 of file _flow_graph_impl.h.

146  {
147  rf_reset_protocol = 0,
148  rf_reset_bodies = 1 << 0, // delete the current node body, reset to a copy of the initial node body.
149  rf_clear_edges = 1 << 1 // delete edges
150 };

Function Documentation

◆ combine_tasks()

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

Definition at line 167 of file flow_graph.h.

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

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 3250 of file flow_graph.h.

3250  {
3251  return n.template copy_function_object<Body>();
3252 }

◆ device_info()

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

Definition at line 69 of file flow_graph_opencl_node.h.

69  {
70  T res;
71  enforce_cl_retcode(clGetDeviceInfo(d, i, sizeof(res), &res, NULL), "Failed to get OpenCL device information");
72  return res;
73 }
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 76 of file flow_graph_opencl_node.h.

76  {
77  size_t required;
78  enforce_cl_retcode(clGetDeviceInfo(d, i, 0, NULL, &required), "Failed to get OpenCL device information");
79 
80  char *buff = (char*)alloca(required);
81  enforce_cl_retcode(clGetDeviceInfo(d, i, required, buff, NULL), "Failed to get OpenCL device information");
82 
83  return buff;
84 }
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 54 of file flow_graph_opencl_node.h.

54  {
55  if (err != CL_SUCCESS) {
56  std::cerr << msg << "; error code: " << err << std::endl;
57  throw msg;
58  }
59 }

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 62 of file flow_graph_opencl_node.h.

62  {
63  T res;
64  enforce_cl_retcode(clGetEventInfo(e, i, sizeof(res), &res, NULL), "Failed to get OpenCL event information");
65  return res;
66 }
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 732 of file flow_graph_opencl_node.h.

732  {
733  return t.native_object();
734 }

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 737 of file flow_graph_opencl_node.h.

737  {
738  return t;
739 }

◆ internal_make_edge()

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

Definition at line 3104 of file flow_graph.h.

3104  {
3105 #else
3106 template< typename T >
3107 inline void internal_make_edge( sender<T> &p, receiver<T> &s ) {
3108 #endif
3109 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
3110  s.internal_add_built_predecessor(p);
3111  p.internal_add_built_successor(s);
3112 #endif
3113  p.register_successor( s );
3115 }
void const char const char int ITT_FORMAT __itt_group_sync s
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:3104
static void fgt_make_edge(void *, void *)

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 3167 of file flow_graph.h.

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

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 492 of file flow_graph_opencl_node.h.

492  {
494  const T &t = dmsg.data( false );
495  __TBB_STATIC_ASSERT( true, "" );
496  return key_from_message<K, T>( t );
497 }
K key_from_message(const T &t)
Definition: flow_graph.h:691
#define __TBB_STATIC_ASSERT(condition, msg)
Definition: tbb_stddef.h:532

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 3119 of file flow_graph.h.

3119  {
3120  internal_make_edge( p, s );
3121 }
void const char const char int ITT_FORMAT __itt_group_sync s
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:3104

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 3127 of file flow_graph.h.

3127  {
3128  internal_make_edge( p, s );
3129 }
void const char const char int ITT_FORMAT __itt_group_sync s
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:3104

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 3132 of file flow_graph.h.

3132  {
3133  internal_make_edge( p, s );
3134 }
void const char const char int ITT_FORMAT __itt_group_sync s
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:3104

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 3137 of file flow_graph.h.

3137  {
3138  internal_make_edge( p, s );
3139 }
void const char const char int ITT_FORMAT __itt_group_sync s
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:3104

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 3147 of file flow_graph.h.

3147  {
3148  make_edge(get<0>(output.output_ports()), get<0>(input.input_ports()));
3149 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3161

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 3154 of file flow_graph.h.

3154  {
3155  make_edge(get<0>(output.output_ports()), input);
3156 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3161

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 3161 of file flow_graph.h.

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

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 87 of file flow_graph_opencl_node.h.

87  {
88  T res;
89  enforce_cl_retcode(clGetPlatformInfo(p, i, sizeof(res), &res, NULL), "Failed to get OpenCL platform information");
90  return res;
91 }
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 94 of file flow_graph_opencl_node.h.

94  {
95  size_t required;
96  enforce_cl_retcode(clGetPlatformInfo(p, i, 0, NULL, &required), "Failed to get OpenCL platform information");
97 
98  char *buff = (char*)alloca(required);
99  enforce_cl_retcode(clGetPlatformInfo(p, i, required, buff, NULL), "Failed to get OpenCL platform information");
100 
101  return buff;
102 }
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 42 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 766 of file flow_graph_opencl_node.h.

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

777 {}

◆ 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 3183 of file flow_graph.h.

3183  {
3184  internal_remove_edge( p, s );
3185 }
void const char const char int ITT_FORMAT __itt_group_sync s
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3167
void const char const char int ITT_FORMAT __itt_group_sync p

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 3191 of file flow_graph.h.

3191  {
3192  internal_remove_edge( p, s );
3193 }
void const char const char int ITT_FORMAT __itt_group_sync s
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3167
void const char const char int ITT_FORMAT __itt_group_sync p

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 3196 of file flow_graph.h.

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

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 3201 of file flow_graph.h.

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

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 3210 of file flow_graph.h.

3210  {
3211  remove_edge(get<0>(output.output_ports()), get<0>(input.input_ports()));
3212 }
void remove_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3223

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 3217 of file flow_graph.h.

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

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 3223 of file flow_graph.h.

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

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 743 of file flow_graph_opencl_node.h.

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

754  {
755  typedef typename T::memory_object_type mem_obj_t;
756  mem_obj_t mem_obj = t.memory_object();
757  opencl_async_msg<mem_obj_t, typename mem_obj_t::opencl_factory_type> dmsg( mem_obj );
758  mem_obj.send( device, dmsg );
759 }

◆ 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 762 of file flow_graph_opencl_node.h.

762 {};

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.