| /oneTBB/test/conformance/ |
| H A D | conformance_priority_queue_node.cpp | 67 int tmp = -1; variable 68 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed"); 69 CHECK_MESSAGE((tmp == 1), "Values should get sorted"); 70 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed"); 71 CHECK_MESSAGE((tmp == 2), "Values should get sorted"); 72 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed"); 73 CHECK_MESSAGE((tmp == 3), "Values should get sorted");
|
| H A D | conformance_overwrite_node.cpp | 36 int tmp = -1; variable 40 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message"); 41 CHECK_MESSAGE((tmp == 1), "Descendant needs to receive a correct value"); 46 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message"); 47 CHECK_MESSAGE((tmp == 2), "Descendant needs to receive a correct value"); 82 int tmp = -1; variable 84 …CHECK_MESSAGE((!testing_node.try_get(tmp)), "Gets from the node are non-destructive, but the first…
|
| H A D | conformance_sequencer_node.cpp | 122 int tmp = -1; variable 123 CHECK_MESSAGE((node.try_get(tmp) == true), "Getting from sequencer should succeed"); 124 CHECK_MESSAGE((tmp == 0), "Received value should be correct"); 126 tmp = -1; 127 CHECK_MESSAGE((node.try_get(tmp) == true), "Getting from sequencer should succeed"); 128 CHECK_MESSAGE((tmp == 1), "Received value should be correct"); 130 tmp = -1; 131 CHECK_MESSAGE((node.try_get(tmp) == false), "Getting from sequencer should not succeed");
|
| H A D | conformance_graph.cpp | 64 int tmp = -1; in test_input_node_rf_reset_protocol() local 65 CHECK_MESSAGE((node.try_get(tmp) == false), "Should be false"); in test_input_node_rf_reset_protocol() 91 int tmp = -1; in test_buffering_nodes_rf_reset_protocol() local 92 CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get should not succeed"); in test_buffering_nodes_rf_reset_protocol() 93 CHECK_MESSAGE((tmp == -1), "Value should not be updated"); in test_buffering_nodes_rf_reset_protocol() 99 tmp = -1; in test_buffering_nodes_rf_reset_protocol() 100 CHECK_MESSAGE((testing_node.try_get(tmp) == false), "try_get should not succeed"); in test_buffering_nodes_rf_reset_protocol() 101 CHECK_MESSAGE((tmp == -1), "Value should not be updated"); in test_buffering_nodes_rf_reset_protocol() 157 std::tuple<int> tmp(0); in test_join_node_rf_reset_protocol() local 158 CHECK_MESSAGE((!testing_node.try_get(tmp)), "All buffers must be emptied"); in test_join_node_rf_reset_protocol()
|
| H A D | conformance_join_node.cpp | 32 my_input_tuple tmp(0, 0.f, input_msg(0)); in get_values() local 33 while(rr.try_get(tmp)) { in get_values() 34 messages.push_back(tmp); in get_values() 187 my_input_tuple tmp(0, 0.f, input_msg(0)); variable 188 CHECK_MESSAGE((testing_node.try_get(tmp)), "If no one successor accepts the tuple the messages\ 190 …CHECK_MESSAGE((tmp == my_input_tuple(1, 1.f, input_msg(1))), "If no one successor accepts the tupl… 226 std::tuple<oneapi::tbb::flow::continue_msg, float> tmp; variable 227 CHECK_MESSAGE((testing_node.try_get(tmp)), "Mapped keys should match.\ 229 CHECK_MESSAGE((!testing_node.try_get(tmp)), "Message should not exist after item is consumed"); 247 std::tuple<oneapi::tbb::flow::continue_msg, float> tmp; variable [all …]
|
| H A D | conformance_flowgraph.h | 82 V tmp(0); in get_values() 84 while (rr.try_get(tmp)) { in get_values() 85 messages.push_back(tmp); in get_values() 93 V tmp; in get_values() local 95 while (rr.try_get(tmp)) { in get_values() 96 messages.push_back(tmp); in get_values() 455 int tmp = -1; in test_buffering() local 461 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "try_get after rejection should succeed"); in test_buffering() 462 CHECK_MESSAGE((tmp == 1), "try_get after rejection should set value"); in test_buffering() 469 CHECK_MESSAGE((tmp == -1), "try_get after rejection should not alter passed value"); in test_buffering() [all …]
|
| H A D | conformance_write_once_node.cpp | 61 int tmp = -1; variable 63 …CHECK_MESSAGE((!testing_node.try_get(tmp)), "Gets from the node are non-destructive, but the first…
|
| H A D | conformance_multifunction_node.cpp | 180 std::size_t tmp = 0; variable 181 while(buf.try_get(tmp)) { 183 CHECK(tmp == 1);
|
| /oneTBB/src/tbb/ |
| H A D | tls.h | 51 tls_key_t tmp = TlsAlloc(); 52 if( tmp==TLS_OUT_OF_INDEXES ) 54 my_key = tmp; 62 tls_key_t tmp = FlsAlloc(nullptr); 63 if( tmp== (DWORD)0xFFFFFFFF ) 65 my_key = tmp;
|
| H A D | queuing_rw_mutex.cpp | 324 unblock_or_wait_on_internal_lock(s, get_flag(tmp)); in release() 339 queuing_rw_mutex::scoped_lock *tmp = nullptr; in release() local 351 if( !(tricky_pointer(tmp) & FLAG) ) { in release() 358 tmp = nullptr; in release() 405 unblock_or_wait_on_internal_lock(s, get_flag(tmp)); in release() 464 queuing_rw_mutex::scoped_lock* tmp{}; in upgrade_to_writer() local 486 tmp = tricky_pointer::exchange(next->my_prev, &s, std::memory_order_release); in upgrade_to_writer() 487 unblock_or_wait_on_internal_lock(s, get_flag(tmp)); in upgrade_to_writer() 490 tmp = tricky_pointer(next)|FLAG; in upgrade_to_writer() 493 if( tricky_pointer::load(s.my_next, std::memory_order_acquire)==tmp ) in upgrade_to_writer() [all …]
|
| H A D | market.cpp | 100 int tmp = client.max_workers() * assigned_per_priority + carry; in update_allotment() local 101 allotted = tmp / my_priority_level_demand[list_idx]; in update_allotment() 102 carry = tmp % my_priority_level_demand[list_idx]; in update_allotment()
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | concurrent_priority_queue.h | 255 cpq_operation* tmp, *pop_list = nullptr; in handle_operations() local 271 tmp = op_list; in handle_operations() 273 if (tmp->type == POP_OP) { in handle_operations() 278 *(tmp->elem) = std::move(data.back()); in handle_operations() 286 pop_list = tmp; in handle_operations() 289 … __TBB_ASSERT(tmp->type == PUSH_OP || tmp->type == PUSH_RVALUE_OP, "Unknown operation"); in handle_operations() 294 if (tmp->type == PUSH_OP) { in handle_operations() 295 push_back_helper(*(tmp->elem)); in handle_operations() 312 tmp = pop_list; in handle_operations() 314 __TBB_ASSERT(tmp->type == POP_OP, nullptr); in handle_operations() [all …]
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _machine.h | 167 if( sizeof(x) > 4 && (uintptr_t tmp = x >> 32) ) { x = tmp; result += 32; } in machine_log2() 168 if( uintptr_t tmp = x >> 16 ) { x = tmp; result += 16; } in machine_log2() 169 if( uintptr_t tmp = x >> 8 ) { x = tmp; result += 8; } in machine_log2() 170 if( uintptr_t tmp = x >> 4 ) { x = tmp; result += 4; } in machine_log2() 171 if( uintptr_t tmp = x >> 2 ) { x = tmp; result += 2; } in machine_log2()
|
| H A D | _flow_graph_node_impl.h | 191 operation_type* tmp; in handle_operations() local 193 tmp = op_list; in handle_operations() 195 switch (tmp->type) { in handle_operations() 197 my_predecessors.add(*(tmp->r)); in handle_operations() 205 my_predecessors.remove(*(tmp->r)); in handle_operations() 209 tmp->bypass_t = nullptr; in handle_operations() 218 case try_fwd: internal_forward(tmp); break; in handle_operations() 436 function_body_type *tmp = my_init_body->clone(); in reset_function_input() local 438 my_body = tmp; in reset_function_input() 548 my_body = tmp; [all …]
|
| /oneTBB/examples/parallel_for/tachyon/src/ |
| H A D | apitrigeom.cpp | 66 vector x, y, z, tmp; in rt_tri_fcylinder() local 74 tmp.x = z.y - 2.1111111; in rt_tri_fcylinder() 75 tmp.y = -z.z + 3.14159267; in rt_tri_fcylinder() 76 tmp.z = z.x - 3.915292342341; in rt_tri_fcylinder() 78 MyVNorm(&tmp); in rt_tri_fcylinder() 79 MyVCross(&z, &tmp, &x); in rt_tri_fcylinder() 118 vector x, y, z, tmp; in rt_tri_ring() local 126 tmp.x = z.y - 2.1111111; in rt_tri_ring() 127 tmp.y = -z.z + 3.14159267; in rt_tri_ring() 130 MyVNorm(&tmp); in rt_tri_ring() [all …]
|
| H A D | parse.cpp | 136 apiflt tmp; in degtorad() local 138 return tmp; in degtorad() 142 vector tmp; in degvectoradvec() local 144 tmp.x = degtorad(degvec->x); in degvectoradvec() 147 *degvec = tmp; in degvectoradvec() 165 vector tmp; in Rotate3d() local 169 *vec = tmp; in Rotate3d() 406 char tmp[255]; in GetTexture() local 409 fscanf(dfile, "%s", tmp); in GetTexture() 420 char tmp[255]; in GetTexBody() local [all …]
|
| H A D | cylinder.cpp | 205 flt t, s, tin, tout, ln, d, tmp, tmp3; in fcylinder_intersect() local 243 VDOT(tmp, tmp2, ctmp4); in fcylinder_intersect() 246 if ((tmp > 0.0) && (tmp < sqrt(tmp3))) in fcylinder_intersect() 256 VDOT(tmp, tmp2, ctmp4); in fcylinder_intersect() 259 if ((tmp > 0.0) && (tmp < sqrt(tmp3))) in fcylinder_intersect()
|
| H A D | triangle.cpp | 208 vector P, tmp, norm; in stri_normal() local 215 CROSS(tmp, P, trn->edge2); in stri_normal() 216 U = DOT(tmp, norm) / lensqr; in stri_normal() 218 CROSS(tmp, trn->edge1, P); in stri_normal() 219 V = DOT(tmp, norm) / lensqr; in stri_normal()
|
| H A D | tgafile.cpp | 156 int imgsize, i, tmp; in readtga() local 216 tmp = (*imgdata)[i]; /* Blue */ in readtga() 218 (*imgdata)[i + 2] = tmp; /* Blue */ in readtga()
|
| /oneTBB/doc/main/tbb_userguide/design_patterns/ |
| H A D | Elementwise.rst | 78 float tmp = 0; 80 tmp += c[j]*x[i-j]; 81 y[i] = tmp; 100 float tmp = 0; 102 tmp += c[j]*x[i-j]; 103 y[i] = tmp; 122 float tmp = 0; 124 tmp += c[j]*x[i-j]; 125 y[i] = tmp;
|
| /oneTBB/examples/graph/fgbzip2/ |
| H A D | huffman.cpp | 81 Int32 zz, tmp; \ 83 tmp = heap[zz]; \ 84 while (weight[tmp] < weight[heap[zz >> 1]]) { \ 88 heap[zz] = tmp; \ 93 Int32 zz, yy, tmp; \ 95 tmp = heap[zz]; \ 102 if (weight[tmp] < weight[heap[yy]]) \ 107 heap[zz] = tmp; \
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_compliance.cpp | 639 void *tmp; in NULLReturn() local 680 tmp=Tmalloc(Size); in NULLReturn() 681 if (tmp != nullptr) in NULLReturn() 683 myMemset(tmp, 0, Size); in NULLReturn() 686 } while(tmp != nullptr); in NULLReturn() 699 tmp=Tmalloc(Size); in NULLReturn() 700 if (tmp == nullptr) in NULLReturn() 720 myMemset(tmp, 0, Size); in NULLReturn() 737 tmp=Tcalloc(COUNT_ELEM_CALLOC,Size); in NULLReturn() 738 if (tmp == nullptr) in NULLReturn() [all …]
|
| /oneTBB/src/tbbmalloc/ |
| H A D | frontend.cpp | 1325 block = tmp; in cleanPublicFreeLists() 2782 void *tmp; in pool_aligned_realloc() local 2792 return tmp; in pool_aligned_realloc() 2999 void *tmp; in scalable_realloc() local 3010 return tmp; in scalable_realloc() 3037 if (tmp) { in __TBB_malloc_safer_realloc() 3057 return tmp; in __TBB_malloc_safer_realloc() 3115 return tmp; in scalable_aligned_malloc() 3124 void *tmp; in scalable_aligned_realloc() local 3135 return tmp; in scalable_aligned_realloc() [all …]
|
| /oneTBB/ |
| H A D | INSTALL.md | 99 # Do our experiments in /tmp 100 cd /tmp 107 cmake -DCMAKE_INSTALL_PREFIX=/tmp/my_installed_onetbb -DTBB_TEST=OFF .. 112 # Well done! Your installed oneTBB is in /tmp/my_installed_onetbb
|
| /oneTBB/test/tbb/ |
| H A D | test_flow_graph_whitebox.cpp | 850 int tmp = -1; variable 851 CHECK_MESSAGE((src.try_get(tmp) == false), "try_get can not succeed"); 854 tmp = -1; 855 CHECK_MESSAGE((src.try_get(tmp) == false), "try_get can not succeed"); 891 int tmp = -1; variable 892 CHECK_MESSAGE((q.try_get(tmp) == false), "Message should not be passed on"); 941 int tmp = -1; variable 942 CHECK_MESSAGE((b.try_get(tmp) == false), "Message should not arrive"); 943 CHECK_MESSAGE((tmp == -1), "Value should not be altered"); 968 int tmp = -1; variable [all …]
|