Home
last modified time | relevance | path

Searched refs:gateway (Results 1 – 6 of 6) sorted by relevance

/oneTBB/examples/graph/fgbzip2/
H A Dfgbzip2.cpp156 void submitRead(async_file_reader_node::gateway_type& gateway) { in submitRead() argument
157 gateway.reserve_wait(); in submitRead()
158 std::thread(&AsyncNodeActivity::readingLoop, this, std::ref(gateway)) in submitRead()
167 void readingLoop(async_file_reader_node::gateway_type& gateway) { in readingLoop() argument
171 gateway.try_put(bufferMsg); in readingLoop()
173 sendLastMessage(gateway); in readingLoop()
174 gateway.release_wait(); in readingLoop()
186 void sendLastMessage(async_file_reader_node::gateway_type& gateway) { in sendLastMessage() argument
189 gateway.try_put(lastMsg); in sendLastMessage()
209 async_file_reader_node::gateway_type& gateway) { in fgCompressionAsyncNode() argument
[all …]
/oneTBB/test/tbb/
H A Dtest_async_node.cpp125 gateway.try_put(input); in operator ()()
321 gateway_type* gateway; member
355 work_type work = {input, &gateway}; in submit()
427 gateway.reserve_wait(); in run()
547 gateway.reserve_wait(); in run()
628 gateway.reserve_wait(); in operator ()()
679 gateway_t* gateway; member
687 w.gateway->try_put(res); in __anon62ab872d0a02()
688 w.gateway->release_wait(); in __anon62ab872d0a02()
695 work_type w = {i, gateway}; in submit()
[all …]
H A Dtest_flow_graph_priorities.cpp258 struct work_type { data_type input; gateway_type* gateway; }; member
271 work.gateway->try_put(work.input); in operator ()()
272 work.gateway->release_wait(); in operator ()()
280 void submit(data_type input, gateway_type* gateway) { in submit()
281 work_type work = { input, gateway }; in submit()
282 gateway->reserve_wait(); in submit()
339 void operator()(data_type input, async_node_type::gateway_type& gateway) noexcept { in operator ()()
340 my_activity->submit(input, &gateway); in operator ()()
/oneTBB/test/common/
H A Dtest_invoke.h97 void send_id_to_gateway(GatewayType& gateway) const { in send_id_to_gateway() argument
98 gateway.reserve_wait(); in send_id_to_gateway()
99 gateway.try_put(id); in send_id_to_gateway()
100 gateway.release_wait(); in send_id_to_gateway()
/oneTBB/test/conformance/
H A Dconformance_async_node.cpp125 [&](const int& input, gateway_type& gateway) { in __anon83a565ab0102()
126 gateway.reserve_wait(); in __anon83a565ab0102()
129 gateway.try_put(input); in __anon83a565ab0102()
130 gateway.release_wait(); in __anon83a565ab0102()
/oneTBB/include/oneapi/tbb/
H A Dflow_graph.h2839 async_body_base(gateway_type *gateway): my_gateway(gateway) { } in async_body_base() argument
2840 void set_gateway(gateway_type *gateway) { in set_gateway() argument
2841 my_gateway = gateway; in set_gateway()
2857 async_body(const Body &body, gateway_type *gateway) in async_body() argument
2858 : base_type(gateway), my_body(body) { } in async_body()
2981 gateway_type& gateway() { in __TBB_requires()