Home
last modified time | relevance | path

Searched refs:b2 (Results 1 – 21 of 21) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_buffer_node.cpp202 tbb::flow::buffer_node<T> b2(g); in test_parallel() local
249 tbb::flow::make_edge( b, b2 ); in test_parallel()
250 tbb::flow::make_edge( b2, b3 ); in test_parallel()
320 tbb::flow::buffer_node<T> b2(g); in test_serial() local
353 tbb::flow::make_edge(b, b2); in test_serial()
363 spin_try_get( b2, j ); in test_serial()
374 tbb::flow::remove_edge(b, b2); in test_serial()
384 tbb::flow::make_edge( b, b2 ); in test_serial()
385 tbb::flow::make_edge( b2, b3 ); in test_serial()
408 tbb::flow::remove_edge(b, b2); in test_serial()
[all …]
H A Dtest_multifunction_node.cpp495 buffer_node<int> b2(g); in test_precedes() local
497 …multinode node(precedes(b1, b2), unlimited, [](const int& i, multinode::output_ports_type& op) -> … in test_precedes()
510 …CHECK_MESSAGE((b1.try_get(storage) && !b1.try_get(storage) && b2.try_get(storage) && !b2.try_get(s… in test_precedes()
566 buffer_node<int> b2(g);
568 …multinode node(precedes(b1, b2), unlimited, [](const int& i, multinode::output_ports_type& op) -> … in __anon0fcb77200802()
581 …CHECK_MESSAGE((b1.try_get(storage) && !b1.try_get(storage) && b2.try_get(storage) && !b2.try_get(s…
H A Dtest_join_node_key_matching.cpp39 broadcast_node<int> b1(g), b2(g); in test_deduction_guides() local
43 join_node j2(follows(b1, b2, b3), body_int, body_int, body_double); in test_deduction_guides()
H A Dtest_broadcast_node.cpp234 broadcast_node b2(precedes(buf)); in test_deduction_guides() local
235 static_assert(std::is_same_v<decltype(b2), broadcast_node<int>>); in test_deduction_guides()
H A Dtest_flow_graph_whitebox.cpp902 tbb::flow::graph::iterator b2 = g.begin(); variable
903 ++b2;
905 tbb::flow::graph::iterator* volatile b2_ptr = &b2;
906 b2 = *b2_ptr;
907 b = b2;
908 CHECK_MESSAGE((b == b2), "Assignment should make iterators equal");
H A Dtest_input_node.cpp144 function_body<T> b2( counters2 ); in test_single_dest() local
145 tbb::flow::function_node<T,bool,tbb::flow::rejecting> dest2(g, tbb::flow::serial, b2 ); in test_single_dest()
H A Dtest_split_node.cpp387 broadcast_node<tuple_type> b1(g), b2(g); in test_deduction_guides() local
390 split_node s2(follows(b1, b2)); in test_deduction_guides()
H A Dtest_task_arena.cpp229 MultipleMastersPart1( tbb::task_arena &a, utils::SpinBarrier &b1, utils::SpinBarrier &b2) in MultipleMastersPart1() argument
230 : my_a(a), my_b1(b1), my_b2(b2) {} in MultipleMastersPart1()
1004 TestEnqueueIsolateBody b2(executed, completed, arena); in TestEnqueue() local
1005 tbb::this_task_arena::isolate(b2); in TestEnqueue()
1038 TestDelegatedSpawnWaitBody( tbb::task_arena &a, utils::SpinBarrier &b1, utils::SpinBarrier &b2) in TestDelegatedSpawnWaitBody() argument
1039 : my_a(a), my_b1(b1), my_b2(b2) {} in TestDelegatedSpawnWaitBody()
H A Dtest_indexer_node.cpp650 broadcast_node<double> b2(g); in test_deduction_guides() local
654 indexer_node i1(follows(b1, b2)); in test_deduction_guides()
H A Dtest_async_node.cpp192 counting_async_serial_body b2 = tbb::flow::copy_body<counting_async_serial_body>(a); in test_reset() local
193 CHECK_MESSAGE( int(async_body_exec_count) == int(b2.my_async_body_exec_count), in test_reset()
H A Dtest_eh_flow_graph.cpp809 tbb::flow::broadcast_node<tbb::flow::continue_msg> b1(g), b2(g), b3(g); in run_one_continue_node_test() local
811 make_edge(b1,b2); in run_one_continue_node_test()
813 make_edge(b2,node_to_test); in run_one_continue_node_test()
H A Dtest_join_node.h355 unsigned char b2;
359 b2 = (unsigned char)((i>>8)&0xFF);
362 operator int() const { return (int)(b1+(b2<<8)+(b3<<16)); }
/oneTBB/doc/main/tbb_userguide/
H A DFlow_Graph_Single_Vs_Broadcast.rst46 std::atomic<size_t> b2; // for each function _node body
49 function_node<continue_msg> f2(g,serial,fn_body1(b2));
55 g_cnt = b1 = b2 = b3 = 0;
63 …rintf( "after single-push test, g_cnt == %d, b1==%d, b2==%d, b3==%d\n", (int)g_cnt, (int)b1, (int)…
71 g_cnt = b1 = b2 = b3 = 0;
79 …tf( "after broadcast-push test, g_cnt == %d, b1==%d, b2==%d, b3==%d\n", (int)g_cnt, (int)b1, (int)…
89 after single-push test, g_cnt == 3, b1==3, b2==0, b3==0
90 after broadcast-push test, g_cnt == 9, b1==3, b2==3, b3==3
/oneTBB/examples/parallel_for/polygon_overlay/
H A Dpolyover.cpp51 int r1, g1, b1, r2, g2, b2; in OverlayOnePolygonWithMap() local
62 p2->getColor(&r2, &g2, &b2); in OverlayOnePolygonWithMap()
65 myb = b1 + b2; in OverlayOnePolygonWithMap()
342 int r1, g1, b1, r2, g2, b2; in operator ()() local
368 p2->getColor(&r2, &g2, &b2); in operator ()()
371 myb = b1 + b2; in operator ()()
477 int r1, g1, b1, r2, g2, b2; in operator ()() local
503 p2->getColor(&r2, &g2, &b2); in operator ()()
506 myb = b1 + b2; in operator ()()
614 int r1, g1, b1, r2, g2, b2; in operator ()() local
[all …]
/oneTBB/test/common/
H A Dallocator_test_common.h300 AllocatorFooFloat b2(a2);
306 REQUIRE(!(a2 != b2));
311 TestAllocatorConcept<FooFloat>(b2);
318 TestBrokenAllocator<FooFloat>(b2);
325 TestAllocatorExceptions<FooFloat>(b2);
/oneTBB/test/conformance/
H A Dconformance_flowgraph.h441 Body b2 = copy_body<Body, Node>(testing_node); in test_copy_body_function() local
443 …CHECK_MESSAGE((base_body.copy_count + 1 < b2.copy_count), "copy_body and constructor should copy b… in test_copy_body_function()
566 …conformance::copy_counting_object<int> b2 = copy_body<conformance::copy_counting_object<int>, Node… in test_copy_ctor() local
568 CHECK_MESSAGE((fun2.copy_count + 1 < b2.copy_count), "constructor should copy bodies"); in test_copy_ctor()
725 CountingBody b2; in test_output_input_class() local
728 suc_node.try_get(b2); in test_output_input_class()
730 …DOCTEST_WARN_MESSAGE((b2.is_copy), "The type Output must meet the CopyConstructible requirements"); in test_output_input_class()
H A Dconformance_input_node.cpp104 …conformance::copy_counting_object<output_msg> b2 = copy_body<conformance::copy_counting_object<out… variable
106 CHECK_MESSAGE((fun2.copy_count + 1 < b2.copy_count), "constructor should copy bodies");
H A Dconformance_join_node.cpp45 broadcast_node<int> b1(g), b2(g), b3(g); in test_deduction_guides() local
50 join_node j1(follows(b1, b2, b3)); in test_deduction_guides()
53 join_node j2(follows(b1, b2, b3), reserving()); in test_deduction_guides()
H A Dconformance_continue_node.cpp195 counting_body b2 = copy_body<counting_body, continue_node<output_msg>>(node_copy); variable
197 CHECK_MESSAGE((fun2.copy_count + 1 < b2.copy_count), "constructor should copy bodies");
H A Dconformance_global_control.cpp49 StackSizeRun(int threads, utils::SpinBarrier *b1, utils::SpinBarrier *b2) : in StackSizeRun()
50 num_threads(threads), barr1(b1), barr2(b2) {} in StackSizeRun()
/oneTBB/include/oneapi/tbb/
H A Dflow_graph.h2234 …INE_SYM join_node(graph &g, __TBB_B0 b0, __TBB_B1 b1, __TBB_B2 b2) : unfolded_type(g, b0, b1, b2) { in __TBB_requires()
2240 …in_node(graph &g, __TBB_B0 b0, __TBB_B1 b1, __TBB_B2 b2, __TBB_B3 b3) : unfolded_type(g, b0, b1, b… in __TBB_requires()
2246 …__TBB_NOINLINE_SYM join_node(graph &g, __TBB_B0 b0, __TBB_B1 b1, __TBB_B2 b2, __TBB_B3 b3, __TBB_B… in __TBB_requires()
2247 unfolded_type(g, b0, b1, b2, b3, b4) { in __TBB_requires()
2255 …__TBB_NOINLINE_SYM join_node(graph &g, __TBB_B0 b0, __TBB_B1 b1, __TBB_B2 b2, __TBB_B3 b3, __TBB_B… in __TBB_requires()
2256 unfolded_type(g, b0, b1, b2, b3, b4, b5) { in __TBB_requires()
2266 unfolded_type(g, b0, b1, b2, b3, b4, b5, b6) { in __TBB_requires()
2275 …__TBB_NOINLINE_SYM join_node(graph &g, __TBB_B0 b0, __TBB_B1 b1, __TBB_B2 b2, __TBB_B3 b3, __TBB_B… in __TBB_requires()
2276 __TBB_B7 b7) : unfolded_type(g, b0, b1, b2, b3, b4, b5, b6, b7) { in __TBB_requires()
2286 __TBB_B7 b7, __TBB_B8 b8) : unfolded_type(g, b0, b1, b2, b3, b4, b5, b6, b7, b8) { in __TBB_requires()
[all …]