Home
last modified time | relevance | path

Searched refs:receiver (Results 1 – 24 of 24) sorted by relevance

/oneTBB/include/oneapi/tbb/
H A Dflow_graph.h136 template< typename T > class receiver; variable
213 typedef receiver<T> successor_type;
234 bool remove_successor(sender<C>& s, receiver<C>& r) { in remove_successor()
240 class receiver {
243 virtual ~receiver() {} in ~receiver()
925 typedef receiver<TupleType> base_type;
1150 , public receiver<T>, public sender<T>
2002 … static_cast<receiver<input_type> *>(this), static_cast<receiver<DecrementType> *>(&decrement), in initialize()
2881 typedef receiver<input_type> receiver_type; in __TBB_requires()
2882 typedef receiver<output_type> successor_type; in __TBB_requires()
[all …]
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_cache_impl.h94 typedef receiver<output_type> successor_type;
152 typedef receiver<T> successor_type;
226 typedef receiver<T> successor_type;
227 typedef receiver<T>* pointer_type;
281 typedef receiver<continue_msg> successor_type;
282 typedef receiver<continue_msg>* pointer_type;
H A D_flow_graph_trace_impl.h30 template< typename T > class receiver; variable
73 void alias_input_port(void *node, receiver<InputType>* port, string_resource_index name_index) { in alias_input_port()
126 void register_input_port(void *node, receiver<InputType>* port, string_resource_index name_index) {
169 …void *addr = (void *)( static_cast< receiver< typename NodeType::input_type > * >(const_cast< Nod…
H A D_flow_graph_join_impl.h208 class reserving_port : public receiver<T> {
211 typedef typename receiver<input_type>::predecessor_type predecessor_type;
368 class queueing_port : public receiver<T>, public item_buffer<T> {
371 typedef typename receiver<input_type>::predecessor_type predecessor_type;
524 public receiver<typename TraitsType::T>,
533 typedef typename receiver<input_type>::predecessor_type predecessor_type;
614 key_matching_port() : receiver<input_type>(), buffer_type() {
H A D_flow_graph_node_set_impl.h98 struct is_receiver : std::is_base_of<receiver<typename T::input_type>, T> {};
H A D_flow_graph_node_impl.h50 class function_input_base : public receiver<Input>, no_assign {
59 typedef typename receiver<input_type>::predecessor_type predecessor_type;
H A D_flow_graph_body_impl.h334 : public receiver<DecrementType>, no_copy
H A D_flow_graph_indexer_impl.h61 class indexer_input_port : public receiver<T> {
/oneTBB/test/conformance/
H A Dconformance_indexer_node.cpp48 for(auto receiver: receiver_nodes) { variable
49 auto values = conformance::get_values(*receiver);
60 delete receiver;
H A Dconformance_split_node.cpp125 …CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::receiver<my_input_tuple>, my_split_type>::value)…
H A Dconformance_multifunction_node.cpp40 …CHECK_MESSAGE((std::is_base_of<receiver<I>, multifunction_node<I, O>>::value), "multifunction_node… in test_inheritance()
H A Dconformance_flowgraph.h493 for(auto& receiver : receiver_nodes) { in test_forwarding()
494 auto values = get_values(*receiver); in test_forwarding()
544 …CHECK_MESSAGE((std::is_base_of<receiver<InputType>, Node>::value), "Node should be derived from re… in test_inheritance()
H A Dconformance_input_node.cpp77 …CHECK_MESSAGE((!std::is_base_of<receiver<O>, input_node<O>>::value), "input_node cannot have prede… in test_inheritance()
/oneTBB/test/tbb/
H A Dtest_tbb_header.cpp202 …TestFuncDefinitionPresence( flow::make_edge, (tbb::flow::sender<Msg>&, tbb::flow::receiver<Msg>&),… in DefinitionPresence()
203 …TestFuncDefinitionPresence( flow::remove_edge, (tbb::flow::sender<Msg>&, tbb::flow::receiver<Msg>&… in DefinitionPresence()
H A Dtest_input_node.cpp39 class test_push_receiver : public tbb::flow::receiver<T>, utils::NoAssign {
56 typedef typename tbb::flow::receiver<T>::predecessor_type predecessor_type;
H A Dtest_continue_node.cpp48 tbb::flow::receiver< InputType > * const my_exe_node;
50 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts()
H A Dtest_limiter_node.cpp45 struct serial_receiver : public tbb::flow::receiver<T>, utils::NoAssign {
62 struct parallel_receiver : public tbb::flow::receiver<T>, utils::NoAssign {
H A Dtest_broadcast_node.cpp54 class counting_array_receiver : public tbb::flow::receiver<T> {
H A Dtest_function_node.cpp348 tbb::flow::receiver< InputType > * const my_exe_node;
350 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts()
H A Dtest_multifunction_node.cpp335 tbb::flow::receiver< InputType > * const my_exe_node;
337 parallel_puts( tbb::flow::receiver< InputType > &exe_node ) : my_exe_node(&exe_node) {} in parallel_puts()
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DFenced_Data_Transfer.rst68 order to the receiver (thus breaking condition a) or the receiver's
/oneTBB/doc/main/tbb_userguide/
H A DNodes.rst8 typically inherits from oneapi::tbb::flow::sender<T> , oneapi::tbb::flow::receiver<T> or
15 graph_node, sender and receiver, it is more typical that predefined node
H A DPredefined_Node_Types.rst8 class sender and class receiver but it is likely that you can create
/oneTBB/test/common/
H A Dgraph_utils.h258 struct harness_counting_receiver : public tbb::flow::receiver<T> {
293 struct harness_mapped_receiver : public tbb::flow::receiver<T> {