Home
last modified time | relevance | path

Searched refs:counter (Results 1 – 25 of 41) sorted by relevance

12

/oneTBB/src/tbbmalloc/
H A DStatistics.h54 int counter[MaxCounters]; member
92 fprintf(outfile, ": allocNewBlocks %5d", ctrs.counter[allocBlockNew]); in STAT_print()
95 fprintf(outfile, ", privatizeCalled %10d", ctrs.counter[allocPrivatized]); in STAT_print()
96 fprintf(outfile, ", emptyEnough %10d", ctrs.counter[examineEmptyEnough]); in STAT_print()
97 fprintf(outfile, ", notEmptyEnough %10d", ctrs.counter[examineNotEmpty]); in STAT_print()
98 fprintf(outfile, ", freeBlocksPublic %5d", ctrs.counter[freeBlockPublic]); in STAT_print()
99 fprintf(outfile, ", freeBlocksBack %5d", ctrs.counter[freeBlockBack]); in STAT_print()
106 fprintf(outfile, ": allocBumpPtr %10d", ctrs.counter[allocBumpPtrUsed]); in STAT_print()
110 fprintf(outfile, ", freedByOther %10d", ctrs.counter[freeByOtherThread]); in STAT_print()
117 fprintf(outfile, ", cacheLargeObject %5d", ctrs.counter[cacheLargeObj]); in STAT_print()
[all …]
/oneTBB/test/conformance/
H A Dconformance_mutex.h32 Counter counter; variable
33 counter.value = 0;
40 counter.value = counter.value + 1;
46 counter.value = counter.value + 1;
150 counter.increment(); in TestReaderWriterLock_Impl()
160 okay = counter.value_is(counter.value[0]); in TestReaderWriterLock_Impl()
168 counter.increment(); in TestReaderWriterLock_Impl()
178 ArrayCounter<M, 8> counter; in TestReaderWriterLock() local
324 counter.value = counter.value + 1; in recurse_till()
345 C& counter; member
[all …]
H A Dconformance_parallel_for.cpp367 std::atomic<unsigned long> counter{}; variable
372 counter++; in __anondcc278fb0302()
376 counter++; in __anondcc278fb0402()
380 counter++; in __anondcc278fb0502()
384 counter++; in __anondcc278fb0602()
389 counter++; in __anondcc278fb0702()
392 CHECK_EQ(counter.load(std::memory_order_relaxed), iterations * number_of_partitioners);
H A Dconformance_flowgraph.h297 static int counter = 0; in operator() local
299 if(++counter > 500) { in operator()
300 counter = 0; in operator()
679 concurrency_peak_checker_body counter(expected_threads); in test_concurrency()
680 Node fnode(g, num_threads, counter); in test_concurrency()
775 std::atomic<int> counter{0}; in test_with_reserving_join_node_class()
780 ++counter; in test_with_reserving_join_node_class()
809 CHECK_MESSAGE((counter == put_count), "join_node with reserving policy \ in test_with_reserving_join_node_class()
H A Dconformance_sequencer_node.cpp150 std::atomic<std::size_t> counter{0}; variable
152 …CHECK_MESSAGE((msg.id == counter++), "The data is passed to the successor node in the exact same o… in __anona3025c380402()
H A Dconformance_input_node.cpp179 conformance::concurrency_peak_checker_body counter(1); variable
180 oneapi::tbb::flow::input_node<int> testing_node(g, counter);
H A Dconformance_enumerable_thread_specific.cpp1101 std::size_t counter = 0; in TestETSIterator() local
1104 ++counter % 2 == 0 ? ++iter : iter++; in TestETSIterator()
1106 REQUIRE(counter == expected_ets_size); in TestETSIterator()
1108 --counter % 2 == 0 ? --iter : iter--; in TestETSIterator()
1110 REQUIRE(counter == 0); in TestETSIterator()
1113 ++counter % 2 == 0 ? ++citer : citer++; in TestETSIterator()
1115 REQUIRE(counter == expected_ets_size); in TestETSIterator()
1117 --counter % 2 == 0 ? --citer : citer--; in TestETSIterator()
1119 REQUIRE(counter == 0); in TestETSIterator()
/oneTBB/test/tbb/
H A Dtest_mutex.cpp79 C& counter; member
85 typename C::mutex_type::scoped_lock lock(counter.mutex); in operator ()()
87 counter.value = counter.value + 1; in operator ()()
93 AddOne_CheckTransaction(C& counter_) : counter(counter_) {} in AddOne_CheckTransaction()
100 utils::Counter<M> counter; in TestTransaction() local
105 counter.value = 0; in TestTransaction()
106 …for(tbb::blocked_range<std::size_t>(0, n, 2), AddOne_CheckTransaction<utils::Counter<M>>(counter)); in TestTransaction()
107 REQUIRE(counter.value == n); in TestTransaction()
H A Dtest_parallel_pipeline.cpp402 std::atomic<int> counter; in run_function_spec() local
403 counter = max_counter; in run_function_spec()
504 std::atomic<int> counter; in run_lambdas_test() local
505 counter = max_counter; in run_lambdas_test()
510 if( --counter < 0 ) in run_lambdas_test()
523 counter = max_counter; in run_lambdas_test()
528 if( --counter < 0 ) { in run_lambdas_test()
547 counter = max_counter; in run_lambdas_test()
551 if( --counter < 0 ) { in run_lambdas_test()
569 counter = max_counter; in run_lambdas_test()
[all …]
H A Dtest_mutex.h172 Counter<M> counter; in test_basic() local
173 counter.value = 0; in test_basic()
175 utils::NativeParallelFor(nthread, Work<Counter<M>, TEST_SIZE>(counter)); in test_basic()
177 REQUIRE(counter.value == TEST_SIZE); in test_basic()
H A Dtest_semaphore.cpp136 Counter<tbb::detail::r1::binary_semaphore> counter; in test_binary_semaphore() local
137 AddOne<decltype(counter)> AddOneBody(counter); in test_binary_semaphore()
139 …REQUIRE_MESSAGE(n_threads * N_TIMES == counter.value, "Binary semaphore operations P()/V() have a … in test_binary_semaphore()
H A Dtest_parallel_invoke.cpp64 void test_from_2_to_10_arguments(const Body& body, const std::atomic<std::size_t>& counter) { in test_from_2_to_10_arguments() argument
75 REQUIRE_MESSAGE(counter == (2 + 10) * 9 / 2, in test_from_2_to_10_arguments()
H A Dtest_sequencer_node.cpp165 …std::atomic<int> &counter, touches<T> &t ) : my_s1(s1), my_s2(s2), my_num_threads(num_threads), my… in parallel_put_get()
220 std::atomic<int> counter; in test_parallel() local
221 counter = 0; in test_parallel()
222 … utils::NativeParallelFor( num_threads, parallel_put_get<T>(s1, s3, num_threads, counter, t) ); in test_parallel()
H A Dtest_resumable_tasks.cpp368 std::atomic<int> counter; member in ObserverTracker
371 counter = 0; in ObserverTracker()
378 ++counter; in on_scheduler_entry()
402 } while (tracker.counter < 100); in TestObservers()
H A Dtest_flow_graph.cpp199 int counter; member
200 input_body(tbb::task_arena* a) : midway_arena(a), counter(0) {} in input_body()
203 if (counter++ >= 1) { in operator ()()
H A Dtest_limiter_node.cpp449 std::atomic<int> counter{0}; in test_try_put_without_successors() local
452 counter += input; in test_try_put_without_successors()
460 CHECK((counter == i * try_put_num / 2)); in test_try_put_without_successors()
467 CHECK((counter == i * try_put_num / 2)); in test_try_put_without_successors()
H A Dtest_continue_node.cpp212 int* counter; member
213 add_to_counter(int& var):counter(&var){} in add_to_counter()
214 void operator()(continue_msg){*counter+=1;} in operator ()()
/oneTBB/include/oneapi/tbb/
H A Dparallel_for_each.h284 for (std::size_t counter = 1; counter < my_size; ++counter) {
286 spawn(*(task_pool.begin() + counter), my_execution_context);
303 for(std::size_t counter = 0; counter < max_block_size; ++counter) {
304 (task_pool.begin() + counter)->~iteration_task();
305 if (counter < my_size) {
306 (block_iteration_space.begin() + counter)->~Item();
349 for(std::size_t counter = 1; counter < my_size; ++counter) {
351 spawn(*(task_pool.begin() + counter), my_execution_context);
368 for(std::size_t counter = 0; counter < my_size; ++counter) {
369 (task_pool.begin() + counter)->~iteration_task();
/oneTBB/src/tbb/tools_api/
H A Dittnotify_config.h707 #define NEW_COUNTER_METADATA_NUM(gptr,h,h_tail,counter,type,value) { \ argument
710 h->counter = counter; \
725 #define NEW_COUNTER_METADATA_STR_A(gptr,h,h_tail,counter,type,str_valueA) { \ argument
728 h->counter = counter; \
745 #define NEW_COUNTER_METADATA_STR_W(gptr,h,h_tail,counter,type,str_valueW) { \ argument
748 h->counter = counter; \
/oneTBB/examples/graph/binpack/
H A Dbinpack.cpp203 size_type counter; member in item_generator
206 item_generator() : counter(0) {} in item_generator()
208 if (counter < elements_num) { in operator ()()
209 value_type result = input_array[counter]; in operator ()()
210 ++counter; in operator ()()
/oneTBB/src/tbbbind/
H A Dtbb_bind.cpp149 unsigned counter = 0; in numa_topology_parsing() local
156 numa_indexes_list[counter] = static_cast<int>(node_buffer->logical_index); in numa_topology_parsing()
158 if ( numa_indexes_list[counter] > max_numa_index ) { in numa_topology_parsing()
159 max_numa_index = numa_indexes_list[counter]; in numa_topology_parsing()
162 counter++; in numa_topology_parsing()
/oneTBB/examples/parallel_for/game_of_life/
H A DGame_of_life.cpp38 Board::Board(int width, int height, int squareSize, LabelPtr counter) in Board() argument
42 m_counter(counter) { in Board()
H A DBoard.hpp31 Board(int width, int height, int squareSize, LabelPtr counter);
/oneTBB/test/common/
H A Dconcurrent_priority_queue_common.h243 static std::atomic<std::size_t> counter; variable
283 ++counter; in operator()
288 ++counter; in operator()
321 counter = 0; in test_parallel_push_pop()
329 REQUIRE_MESSAGE(counter == qsize, "Failed pop size test"); in test_parallel_push_pop()
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DWavefront.rst48 counter with each item. Initialize each counter to the number of
51 decrement the counters of its successors. If a successor's counter
137 Each block has an associated atomic counter. Array ``Count``

12