Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface11 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_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  overwrite_node
 
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 >
 
class  write_once_node
 

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

158  {
159  rf_reset_protocol = 0,
160  rf_reset_bodies = 1 << 0, // delete the current node body, reset to a copy of the initial node body.
161  rf_clear_edges = 1 << 1 // delete edges
162 };

Function Documentation

◆ combine_tasks()

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

Definition at line 191 of file flow_graph.h.

191  {
192  // if no RHS task, don't change left.
193  if (right == NULL) return left;
194  // right != NULL
195  if (left == NULL) return right;
196  if (left == SUCCESSFULLY_ENQUEUED) return right;
197  // left contains a task
198  if (right != SUCCESSFULLY_ENQUEUED) {
199  // both are valid tasks
201  return right;
202  }
203  return left;
204 }
void spawn_in_graph_arena(tbb::flow::interface10::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::interface11::queue_node< T, A >::try_put_and_add_task(), tbb::flow::interface11::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::interface11::copy_body ( Node &  n)

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

Definition at line 3584 of file flow_graph.h.

3584  {
3585  return n.template copy_function_object<Body>();
3586 }

◆ device_info()

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

Definition at line 72 of file flow_graph_opencl_node.h.

72  {
73  T res;
74  enforce_cl_retcode(clGetDeviceInfo(d, i, sizeof(res), &res, NULL), "Failed to get OpenCL device information");
75  return res;
76 }
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::interface11::device_info< std::string > ( cl_device_id  d,
cl_device_info  i 
)
inline

Definition at line 79 of file flow_graph_opencl_node.h.

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

Definition at line 57 of file flow_graph_opencl_node.h.

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

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

Here is the caller graph for this function:

◆ event_info()

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

Definition at line 65 of file flow_graph_opencl_node.h.

65  {
66  T res;
67  enforce_cl_retcode(clGetEventInfo(e, i, sizeof(res), &res, NULL), "Failed to get OpenCL event information");
68  return res;
69 }
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::interface11::get_native_object ( const T &  t)

Definition at line 735 of file flow_graph_opencl_node.h.

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

Referenced by tbb::flow::interface11::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::interface11::get_native_object ( t)

Definition at line 740 of file flow_graph_opencl_node.h.

740  {
741  return t;
742 }

◆ internal_make_edge()

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

Definition at line 3438 of file flow_graph.h.

3438  {
3439 #else
3440 template< typename T >
3441 inline void internal_make_edge( sender<T> &p, receiver<T> &s ) {
3442 #endif
3443 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
3444  s.internal_add_built_predecessor(p);
3445  p.internal_add_built_successor(s);
3446 #endif
3447  p.register_successor( s );
3449 }
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:3438
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::interface11::internal_remove_edge ( internal::untyped_sender p,
internal::untyped_receiver s 
)
inline

Definition at line 3501 of file flow_graph.h.

3501  {
3502 #else
3503 template< typename T >
3504 inline void internal_remove_edge( sender<T> &p, receiver<T> &s ) {
3505 #endif
3506  p.remove_successor( s );
3507 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
3508  // TODO: should we try to remove p from the predecessor list of s, in case the edge is reversed?
3509  p.internal_delete_built_successor(s);
3510  s.internal_delete_built_predecessor(p);
3511 #endif
3513 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3501
static void fgt_remove_edge(void *, void *)
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 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::interface11::is_typedef ( native_object_type  )

◆ is_typedef() [2/2]

tbb::flow::interface11::is_typedef ( memory_object_type  )

◆ key_from_message()

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

Definition at line 495 of file flow_graph_opencl_node.h.

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

References __TBB_STATIC_ASSERT, tbb::flow::interface11::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::interface11::make_edge ( sender< T > &  p,
receiver< T > &  s 
)
inline

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

Definition at line 3453 of file flow_graph.h.

3453  {
3454  internal_make_edge( p, s );
3455 }
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:3438
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::interface11::make_edge ( TS &  p,
TR &  s 
)
inline

Definition at line 3461 of file flow_graph.h.

3461  {
3462  internal_make_edge( p, s );
3463 }
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:3438
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::interface11::make_edge ( sender< T > &  p,
receiver< typename T::async_msg_data_type > &  s 
)
inline

Definition at line 3466 of file flow_graph.h.

3466  {
3467  internal_make_edge( p, s );
3468 }
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:3438
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::interface11::make_edge ( sender< typename T::async_msg_data_type > &  p,
receiver< T > &  s 
)
inline

Definition at line 3471 of file flow_graph.h.

3471  {
3472  internal_make_edge( p, s );
3473 }
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:3438
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::interface11::make_edge ( T &  output,
V &  input 
)
inline

Definition at line 3481 of file flow_graph.h.

3481  {
3482  make_edge(get<0>(output.output_ports()), get<0>(input.input_ports()));
3483 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3495

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::interface11::make_edge ( T &  output,
receiver< R > &  input 
)
inline

Definition at line 3488 of file flow_graph.h.

3488  {
3489  make_edge(get<0>(output.output_ports()), input);
3490 }
void make_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3495

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::interface11::make_edge ( sender< S > &  output,
V &  input 
)
inline

Definition at line 3495 of file flow_graph.h.

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

References make_edge().

Here is the call graph for this function:

◆ platform_info()

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

Definition at line 90 of file flow_graph_opencl_node.h.

90  {
91  T res;
92  enforce_cl_retcode(clGetPlatformInfo(p, i, sizeof(res), &res, NULL), "Failed to get OpenCL platform information");
93  return res;
94 }
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::interface11::platform_info< std::string > ( cl_platform_id  p,
cl_platform_info  i 
)
inline

Definition at line 97 of file flow_graph_opencl_node.h.

97  {
98  size_t required;
99  enforce_cl_retcode(clGetPlatformInfo(p, i, 0, NULL, &required), "Failed to get OpenCL platform information");
100 
101  char *buff = (char*)alloca(required);
102  enforce_cl_retcode(clGetPlatformInfo(p, i, required, buff, NULL), "Failed to get OpenCL platform information");
103 
104  return buff;
105 }
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::interface11::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::interface11::receive_if_memory_object ( const opencl_async_msg< T, Factory > &  dmsg)

Definition at line 769 of file flow_graph_opencl_node.h.

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

Referenced by tbb::flow::interface11::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::interface11::receive_if_memory_object ( const T &  )

Definition at line 780 of file flow_graph_opencl_node.h.

780 {}

◆ remove_edge() [1/7]

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

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

Definition at line 3517 of file flow_graph.h.

3517  {
3518  internal_remove_edge( p, s );
3519 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3501
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::interface11::remove_edge ( TS &  p,
TR &  s 
)
inline

Definition at line 3525 of file flow_graph.h.

3525  {
3526  internal_remove_edge( p, s );
3527 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3501
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::interface11::remove_edge ( sender< T > &  p,
receiver< typename T::async_msg_data_type > &  s 
)
inline

Definition at line 3530 of file flow_graph.h.

3530  {
3531  internal_remove_edge( p, s );
3532 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3501
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::interface11::remove_edge ( sender< typename T::async_msg_data_type > &  p,
receiver< T > &  s 
)
inline

Definition at line 3535 of file flow_graph.h.

3535  {
3536  internal_remove_edge( p, s );
3537 }
void internal_remove_edge(internal::untyped_sender &p, internal::untyped_receiver &s)
Definition: flow_graph.h:3501
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::interface11::remove_edge ( T &  output,
V &  input 
)
inline

Definition at line 3544 of file flow_graph.h.

3544  {
3545  remove_edge(get<0>(output.output_ports()), get<0>(input.input_ports()));
3546 }
void remove_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3557

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::interface11::remove_edge ( T &  output,
receiver< R > &  input 
)
inline

Definition at line 3551 of file flow_graph.h.

3551  {
3552  remove_edge(get<0>(output.output_ports()), input);
3553 }
void remove_edge(sender< S > &output, V &input)
Definition: flow_graph.h:3557

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::interface11::remove_edge ( sender< S > &  output,
V &  input 
)
inline

Definition at line 3557 of file flow_graph.h.

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

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::interface11::send_if_memory_object ( opencl_device  device,
opencl_async_msg< T, Factory > &  dmsg 
)

Definition at line 746 of file flow_graph_opencl_node.h.

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

Referenced by tbb::flow::interface11::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::interface11::send_if_memory_object ( opencl_device  device,
T &  t 
)

Definition at line 757 of file flow_graph_opencl_node.h.

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

◆ send_if_memory_object() [3/3]

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

Definition at line 765 of file flow_graph_opencl_node.h.

765 {};

Copyright © 2005-2020 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.