Home
last modified time | relevance | path

Searched refs:fc (Results 1 – 25 of 29) sorted by relevance

12

/oneTBB/test/conformance/
H A Dconformance_parallel_pipeline.cpp126 [&flag](oneapi::tbb::flow_control& fc) -> I{ in RunPipeline() argument
128 fc.stop(); in RunPipeline()
151 [&first, &last](oneapi::tbb::flow_control& fc)-> ValueType{ in RootSequence() argument
157 fc.stop(); in RootSequence()
285 [&serial_checker](oneapi::tbb::flow_control&fc)
292 fc.stop(); in __anon5895f2ca0b02()
337 [&active_tokens](oneapi::tbb::flow_control&fc)
344 fc.stop(); in __anon5895f2ca0f02()
399 static_assert(std::is_same_v<decltype(fc), oneapi::tbb::filter<int, double>>);
414 auto first_body = [&](oneapi::tbb::flow_control& fc) -> middle_filter_type { in test_pipeline_invoke_basic() argument
[all …]
H A Dconformance_flowgraph.h201 OutputType operator()( oneapi::tbb::flow_control& fc ) { in operator()
204 fc.stop(); in operator()
244 OutputType operator()( oneapi::tbb::flow_control & fc ) { in operator()
248 fc.stop(); in operator()
296 int operator()( oneapi::tbb::flow_control & fc ) { in operator()
301 fc.stop(); in operator()
371 OutputType operator()( oneapi::tbb::flow_control & fc ) { in operator()
375 fc.stop(); in operator()
393 OutputType operator()( oneapi::tbb::flow_control & fc ) { in operator()
397 fc.stop(); in operator()
H A Dconformance_parallel_for.cpp159 const FooBody<Pad> fc = f; in Flog() local
168 invoke_for( rc, fc, p ); in Flog()
173 invoke_for( rc, fc, oneapi::tbb::simple_partitioner() ); in Flog()
178 invoke_for( rc, fc, oneapi::tbb::auto_partitioner() ); in Flog()
184 invoke_for( rc, fc, affinity ); in Flog()
H A Dconformance_input_node.cpp201 int operator()( oneapi::tbb::flow_control & fc ) { in operator ()()
204 fc.stop(); in operator ()()
/oneTBB/test/tbb/
H A Dtest_input_node.cpp80 T operator()( tbb::flow_control& fc ) { in operator ()() argument
86 fc.stop(); in operator ()()
273 [&](tbb::flow_control& fc) -> bool { in test_follows_and_precedes_api() argument
275 fc.stop(); in test_follows_and_precedes_api()
324 tbb::flow::input_node<int> in(g, [&](tbb::flow_control& fc) { fc.stop(); return 0;}); in __anone180743f0302() argument
H A Dtest_flow_graph_priorities.cpp291 data_type operator()(tbb::flow_control& fc) { in operator ()()
293 fc.stop(); in operator ()()
668 continue_msg operator()( tbb::flow_control& fc ){ in operator ()()
672 fc.stop(); in operator ()()
H A Dtest_flow_graph.cpp201 int operator()(tbb::flow_control &fc) { in operator ()()
204 fc.stop(); in operator ()()
H A Dtest_split_node.cpp110 TT operator()( tbb::flow_control &fc) { in operator ()() argument
112 fc.stop(); in operator ()()
H A Dtest_flow_graph_whitebox.cpp711 int operator()(tbb::flow_control& fc) { in operator ()()
713 fc.stop(); in operator ()()
847 tbb::flow::input_node<int> src(g, [&](tbb::flow_control& fc) { fc.stop(); return 0;}); in __anon8a33875c0a02() argument
H A Dtest_limiter_node.cpp514 tbb::flow::input_node<int> input{ graph, [&](tbb::flow_control & fc) -> int { in test_decrement_while_try_put_task()
516 if (i++ >= threshold) fc.stop(); in test_decrement_while_try_put_task()
H A Dtest_eh_flow_graph.cpp180 OutputType operator()(tbb::flow_control& fc) { in operator ()() argument
192 fc.stop(); in operator ()()
209 tbb::flow::continue_msg operator()( tbb::flow_control & fc) { in operator ()() argument
214 fc.stop(); in operator ()()
322 OutputTuple operator()(tbb::flow_control& fc) { in operator ()() argument
327 fc.stop(); in operator ()()
H A Dtest_indexer_node.cpp121 TT operator()( tbb::flow_control& fc) { in operator ()() argument
128 fc.stop(); in operator ()()
/oneTBB/examples/parallel_pipeline/square/
H A Dsquare.cpp99 TextSlice* operator()(oneapi::tbb::flow_control& fc) const;
109 TextSlice* MyInputFunc::operator()(oneapi::tbb::flow_control& fc) const { in operator ()()
117 fc.stop(); in operator ()()
/oneTBB/doc/main/tbb_userguide/
H A DData_Flow_Graph.rst124 Output Body::operator()( oneapi::tbb::flow_control &fc );
141 ``src_body`` until ``fc.stop()`` is invoked inside the body. You therefore
155 int operator()( oneapi::tbb::flow_control& fc ) {
159 fc.stop();
H A Davoiding_data_races.rst29 input_node< int > src( g, [&]( oneapi::tbb::flow_control& fc ) -> int {
33 fc.stop();
H A Duse_nested_algorithms.rst31 input_node< double * > matrix_source( g, [&]( oneapi::tbb::flow_control &fc ) -> double* {
36 fc.stop();
H A Duse_concurrency_limits.rst45 input_node< big_object * > s( g, [&]( oneapi::tbb::flow_control& fc ) -> big_object* {
51 fc.stop();
H A Duse_limiter_node.rst44 input_node< big_object * > s( g, [&]( oneapi::tbb::flow_control& fc ) -> big_object* {
50 fc.stop();
H A Duse_input_node.rst79 oneapi::tbb::flow::input_node<int> src( g, [&]( oneapi::tbb::flow_control &fc ) -> int {
83 fc.stop();
H A Dcreate_token_based_system.rst68 input_node< big_object * > s( g, [&]( oneapi::tbb::flow_control& fc ) -> big_object* {
74 fc.stop();
H A DWorking_on_the_Assembly_Line_pipeline.rst297 TextSlice* operator()( oneapi::tbb::flow_control& fc ) const;
311 TextSlice* MyInputFunc::operator()( oneapi::tbb::flow_control& fc ) const {
319 fc.stop();
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_body_impl.h80 virtual Output operator()(flow_control& fc) = 0;
89 Output operator()(flow_control& fc) override { return body(fc); }
/oneTBB/examples/graph/binpack/
H A Dbinpack.cpp207 value_type operator()(oneapi::tbb::flow_control& fc) { in operator ()() argument
214 fc.stop(); in operator ()()
/oneTBB/examples/graph/fgbzip2/
H A Dfgbzip2.cpp247 g, [&io](oneapi::tbb::flow_control& fc) -> BufferMsg { in fgCompression() argument
253 fc.stop(); in fgCompression()
/oneTBB/examples/test_all/fibonacci/
H A Dfibonacci.cpp277 queue_t *operator()(oneapi::tbb::flow_control &fc) const { in operator ()()
282 fc.stop(); in operator ()()

12