Home
last modified time | relevance | path

Searched refs:gateway_type (Results 1 – 8 of 8) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_async_node.cpp107 typedef counting_async_node_type::gateway_type counting_gateway_type;
317 typedef typename async_node_type::gateway_type gateway_type; typedef in async_activity
321 gateway_type* gateway;
354 void submit( const input_type &input, gateway_type& gateway ) { in submit()
410 typedef typename async_node_type::gateway_type gateway_type; typedef
424 [&] (const input_type &input, gateway_type& gateway) { in run()
513 typedef typename async_node_type::gateway_type gateway_type; typedef
544 [&](const input_type &input, gateway_type& gateway) { in run()
613 typedef typename async_node_type::gateway_type gateway_type; typedef in enqueueing_on_inner_level
627 [&](const input_type &input, gateway_type& gateway) { in operator ()()
[all …]
H A Dtest_flow_graph_priorities.cpp256 typedef async_node_type::gateway_type gateway_type; typedef
258 struct work_type { data_type input; gateway_type* gateway; };
280 void submit(data_type input, gateway_type* gateway) { in submit()
339 void operator()(data_type input, async_node_type::gateway_type& gateway) noexcept { in operator ()()
/oneTBB/test/conformance/
H A Dconformance_async_node.cpp118 using gateway_type = async_node_type::gateway_type; typedef
125 [&](const int& input, gateway_type& gateway) { in __anon83a565ab0102()
150 …_invoke::SmartID<std::size_t>::template send_id_to_gateway<typename async_node_type::gateway_type>;
H A Dconformance_flowgraph.h42 typename oneapi::tbb::flow::async_node<Input, Output>::gateway_type;
/oneTBB/examples/graph/fgbzip2/
H A Dfgbzip2.cpp156 void submitRead(async_file_reader_node::gateway_type& gateway) { in submitRead()
167 void readingLoop(async_file_reader_node::gateway_type& gateway) { in readingLoop()
186 void sendLastMessage(async_file_reader_node::gateway_type& gateway) { in sendLastMessage()
209 async_file_reader_node::gateway_type& gateway) { in fgCompressionAsyncNode()
226 async_file_writer_node::gateway_type& gateway) { in fgCompressionAsyncNode()
/oneTBB/test/common/
H A Dgraph_utils.h704 template<typename gateway_type>
705 …void operator()(const std::thread::id& input, gateway_type&) noexcept { increase_and_check(input);…
788 template<typename gateway_type>
789 void operator()(const std::thread::id& input, gateway_type&) noexcept(NoExcept) {
839 template<typename input_type, typename gateway_type>
840 void operator()(const input_type&, gateway_type&) {
H A Dconcepts_common.h622 using gateway_type = typename tbb::flow::async_node<Input, Output>::gateway_type; variable
626 template <typename I, typename O> using Correct = PortsNodeBody<I, O, gateway_type<I, O>, /*CopyCto…
627 template <typename I, typename O> using NonCopyable = PortsNodeBody<I, O, gateway_type<I, O>, /*Cop…
628 template <typename I, typename O> using NonDestructible = PortsNodeBody<I, O, gateway_type<I, O>, /…
629 template <typename I, typename O> using NoOperatorRoundBrackets = PortsNodeBody<I, O, gateway_type<…
630 …e O> using WrongFirstInputOperatorRoundBrackets = PortsNodeBody<I, O, gateway_type<I, O>, /*CopyCt…
631 … O> using WrongSecondInputOperatorRoundBrackets = PortsNodeBody<I, O, gateway_type<I, O>, /*CopyCt…
/oneTBB/include/oneapi/tbb/
H A Dflow_graph.h2837 typedef Gateway gateway_type; typedef
2839 async_body_base(gateway_type *gateway): my_gateway(gateway) { } in async_body_base()
2840 void set_gateway(gateway_type *gateway) { in set_gateway()
2845 gateway_type *my_gateway;
2855 typedef Gateway gateway_type; typedef
2857 async_body(const Body &body, gateway_type *gateway) in async_body()
2884 typedef receiver_gateway<output_type> gateway_type; in __TBB_requires() typedef
2885 typedef async_body_base<gateway_type> async_body_base_type; in __TBB_requires()
2936 __TBB_requires(async_node_body<Body, input_type, gateway_type>) in __TBB_requires()
2952 __TBB_requires(async_node_body<Body, input_type, gateway_type>) in __TBB_requires()
[all …]