| /external/libgav1/libgav1/src/ |
| D | threading_strategy.cc | 58 int ComputeFrameThreadCount(int thread_count, int tile_count, in ComputeFrameThreadCount() argument
60 assert(thread_count > 0); in ComputeFrameThreadCount()
61 if (thread_count == 1) return 0; in ComputeFrameThreadCount()
62 return (thread_count <= tile_count * kFrameParallelThresholdMultiplier) in ComputeFrameThreadCount()
64 : std::max(2, thread_count / (1 + tile_columns)); in ComputeFrameThreadCount()
70 int thread_count) { in Reset() argument
71 assert(thread_count > 0); in Reset()
74 if (thread_count == 1) { in Reset()
83 thread_count = std::min(thread_count, static_cast<int>(kMaxThreads)) - 1; in Reset()
85 if (thread_pool_ == nullptr || thread_pool_->num_threads() != thread_count) { in Reset()
[all …]
|
| D | threading_strategy.h | 53 int thread_count);
61 LIBGAV1_MUST_USE_RESULT bool Reset(int thread_count);
125 int thread_count, int tile_count, int tile_columns,
|
| /external/tensorflow/tensorflow/lite/kernels/internal/optimized/ |
| D | depthwiseconv_multithread.h | 89 int thread_count = std::max(1, num_muls / kMinMulPerThread); in HowManyConvThreads() local
90 return thread_count; in HowManyConvThreads()
93 inline bool MultithreadAlongBatches(int thread_count, int batches) { in MultithreadAlongBatches() argument
94 TFLITE_DCHECK_GE(thread_count, 2); in MultithreadAlongBatches()
97 if (batches < thread_count) { in MultithreadAlongBatches()
107 if (batches >= 2 * thread_count) { in MultithreadAlongBatches()
115 return ((batches % thread_count) == 0); in MultithreadAlongBatches()
132 int thread_count = HowManyConvThreads(output_shape, filter_shape); in DepthwiseConv() local
134 thread_count = std::max(1, std::min(thread_count, max_threads)); in DepthwiseConv()
139 thread_count = std::min(thread_count, 2); in DepthwiseConv()
[all …]
|
| /external/llvm-project/lldb/test/API/tools/lldb-server/ |
| D | TestGdbRemoteThreadsInStopReply.py | 20 def gather_stop_reply_fields(self, post_startup_log_lines, thread_count, argument
24 for i in range(thread_count - 1):
63 threads = self.wait_for_thread_count(thread_count)
65 self.assertEqual(len(threads), thread_count)
94 def gather_stop_reply_threads(self, post_startup_log_lines, thread_count): argument
97 post_startup_log_lines, thread_count, ["threads"])["threads"]
104 def gather_stop_reply_pcs(self, post_startup_log_lines, thread_count): argument
106 thread_count, ["threads", "thread-pcs"])
192 def stop_reply_reports_multiple_threads(self, thread_count): argument
196 self.ENABLE_THREADS_IN_STOP_REPLY_ENTRIES, thread_count)
[all …]
|
| D | TestGdbRemote_qThreadStopInfo.py | 18 def gather_stop_replies_via_qThreadStopInfo(self, thread_count): argument
21 for i in range(thread_count - 1):
54 threads = self.wait_for_thread_count(thread_count)
62 self.assertGreaterEqual(len(threads), thread_count)
64 self.assertEqual(len(threads), thread_count)
109 def qThreadStopInfo_works_for_multiple_threads(self, thread_count): argument
110 (stop_replies, _) = self.gather_stop_replies_via_qThreadStopInfo(thread_count)
114 self.assertGreaterEqual(len(stop_replies), thread_count)
116 self.assertEqual(len(stop_replies), thread_count)
134 self, thread_count): argument
[all …]
|
| /external/llvm-project/lldb/test/API/macosx/queues/ |
| D | main.c | 8 atomic_int thread_count = 0; variable
15 atomic_fetch_add(&thread_count, 1); in doing_the_work_1()
34 atomic_fetch_add(&thread_count, 1); in submit_work_1b()
42 atomic_fetch_add(&thread_count, 1); in doing_the_work_2()
65 atomic_fetch_add(&thread_count, 1); in doing_the_work_3()
111 atomic_fetch_add(&thread_count, 1); in main()
117 atomic_fetch_add(&thread_count, 1); in main()
123 atomic_fetch_add(&thread_count, 1); in main()
129 atomic_fetch_add(&thread_count, 1); in main()
135 atomic_fetch_add(&thread_count, 1); in main()
[all …]
|
| /external/llvm-project/libc/test/src/threads/ |
| D | thrd_test.cpp | 14 static constexpr int thread_count = 1000; variable
22 for (counter = 0; counter <= thread_count;) { in TEST()
27 int retval = thread_count + 1; // Start with a retval we dont expect. in TEST()
37 thrd_t thread_list[thread_count]; in TEST()
38 int args[thread_count]; in TEST()
40 for (int i = 0; i < thread_count; ++i) { in TEST()
46 for (int i = 0; i < thread_count; ++i) { in TEST()
47 int retval = thread_count + 1; // Start with a retval we dont expect. in TEST()
|
| D | call_once_test.cpp | 21 static atomic_uint thread_count; variable
30 ++thread_count; // This is a an atomic update. in func()
38 thread_count = 0; in TEST()
53 EXPECT_EQ(static_cast<unsigned int>(thread_count), 5U); in TEST()
|
| /external/tensorflow/tensorflow/core/platform/windows/ |
| D | subprocess.cc | 357 int thread_count = 0; in Communicate() local
369 thread_params[thread_count].iobuf = const_cast<string*>(stdin_input); in Communicate()
370 thread_params[thread_count].iohandle = parent_pipe_[CHAN_STDIN]; in Communicate()
372 thread_handles[thread_count] = in Communicate()
374 thread_params + thread_count, 0, NULL); in Communicate()
375 thread_count++; in Communicate()
384 thread_params[thread_count].iobuf = stdout_output; in Communicate()
385 thread_params[thread_count].iohandle = parent_pipe_[CHAN_STDOUT]; in Communicate()
387 thread_handles[thread_count] = in Communicate()
389 thread_params + thread_count, 0, NULL); in Communicate()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/timers/ |
| D | threadtest.c | 122 int thread_count, i; in main() local
131 thread_count = DEFAULT_THREAD_COUNT; in main()
141 thread_count = atoi(optarg); in main()
156 if (thread_count > MAX_THREADS) in main()
157 thread_count = MAX_THREADS; in main()
165 printf("Testing consistency with %i threads for %ld seconds: ", thread_count, runtime); in main()
169 for (i = 0; i < thread_count; i++) in main()
186 for (i = 0; i < thread_count; i++) in main()
|
| /external/grpc-grpc/test/core/gpr/ |
| D | spinlock_test.cc | 37 int thread_count; /* number of threads */ member
50 m->thread_count = threads; in test_new()
55 m->thread_count = 0; in test_new()
70 for (i = 0; i != m->thread_count; i++) { in test_create_threads()
79 for (i = 0; i != m->thread_count; i++) { in test_wait()
108 if (m->counter != m->thread_count * m->iterations * m->incr_step) { in test()
110 static_cast<long>(m->counter), m->thread_count, in test()
|
| /external/ruy/ruy/ |
| D | trmul.cc | 345 const int thread_count = block_map.thread_count; in TrMul() local
346 const bool need_atomics = thread_count > 1; in TrMul()
347 ctx->EnsureThreadSpecificResources(thread_count); in TrMul()
348 for (int i = 0; i < thread_count; i++) { in TrMul()
376 main_allocator->Allocate(thread_count, &tasks); in TrMul()
378 atomic_block_id->store(thread_count); in TrMul()
380 for (int i = 0; i < thread_count; i++) { in TrMul()
389 ctx->mutable_thread_pool()->Execute(thread_count, tasks); in TrMul()
392 for (int i = 0; i < thread_count; i++) { in TrMul()
|
| /external/python/cpython2/Lib/test/ |
| D | test_dummy_thread.py | 151 thread_count = 5
152 testing_queue = Queue.Queue(thread_count)
156 "(will take approx. %s to %s sec.) ***" % (DELAY, thread_count)
157 for count in xrange(thread_count):
167 self.assertEqual(testing_queue.qsize(), thread_count,
169 (thread_count, DELAY))
|
| /external/libiio/src/iiod/ |
| D | thread-pool.c | 41 unsigned int thread_count; member
54 pool->thread_count++; in thread_pool_thread_started()
61 pool->thread_count--; in thread_pool_thread_stopped()
144 pool->thread_count = 0; in thread_pool_new()
172 while (pool->thread_count) in thread_pool_stop_and_wait()
|
| /external/gemmlowp/internal/ |
| D | multi_thread_gemm.h | 601 int thread_count = std::min(max_count, CeilQuotient(rows, MinRowsPerThread)); in HowManyThreads() local
607 if (thread_count > 1) { in HowManyThreads()
615 thread_count = in HowManyThreads()
616 std::min(thread_count, int(cubic_size / min_cubic_size_per_thread)); in HowManyThreads()
618 if (thread_count < 1) { in HowManyThreads()
619 thread_count = 1; in HowManyThreads()
623 assert(thread_count > 0 && thread_count <= max_count); in HowManyThreads()
624 return thread_count; in HowManyThreads()
658 const int thread_count = HowManyThreads<KernelFormat::kRows>( in MultiThreadGemm() local
660 if (thread_count == 1) { in MultiThreadGemm()
[all …]
|
| /external/llvm-project/lldb/unittests/tools/lldb-server/inferior/ |
| D | thread_inferior.cpp | 16 int thread_count = 2; in main() local
18 thread_count = std::stoi(argv[1], nullptr, 10); in main()
23 for (int i = 0; i < thread_count; i++) { in main()
|
| /external/compiler-rt/test/tsan/ |
| D | debugging.cc | 16 int *mutex_count, int *thread_count,
57 int stack_count, mop_count, loc_count, mutex_count, thread_count, in __tsan_on_report() local
61 &loc_count, &mutex_count, &thread_count, in __tsan_on_report()
90 fprintf(stderr, "thread_count = %d\n", thread_count); in __tsan_on_report()
|
| /external/llvm-project/compiler-rt/test/tsan/ |
| D | debugging.cpp | 17 int *mutex_count, int *thread_count,
58 int stack_count, mop_count, loc_count, mutex_count, thread_count, in __tsan_on_report() local
62 &loc_count, &mutex_count, &thread_count, in __tsan_on_report()
91 fprintf(stderr, "thread_count = %d\n", thread_count); in __tsan_on_report()
|
| /external/tensorflow/tensorflow/lite/kernels/internal/optimized/sparse_ops/ |
| D | fully_connected.h | 177 const int thread_count = std::max(1, std::min(batches, max_threads)); in FullyConnectedSparseWeight1x4() local
178 if (thread_count == 1) { in FullyConnectedSparseWeight1x4()
185 tasks.reserve(thread_count); in FullyConnectedSparseWeight1x4()
187 for (int i = 0; i < thread_count; ++i) { in FullyConnectedSparseWeight1x4()
191 int thread_end = thread_start + batches / thread_count; in FullyConnectedSparseWeight1x4()
192 if (i < batches % thread_count) thread_end++; in FullyConnectedSparseWeight1x4()
|
| /external/llvm-project/compiler-rt/test/tsan/Darwin/ |
| D | external-swift-debugging.cpp | 12 int *mutex_count, int *thread_count,
52 int stack_count, mop_count, loc_count, mutex_count, thread_count, in __tsan_on_report() local
56 &loc_count, &mutex_count, &thread_count, in __tsan_on_report()
|
| /external/tensorflow/tensorflow/core/profiler/internal/cpu/ |
| D | traceme_recorder_test.cc | 78 std::atomic<int> thread_count = {0}; in TEST() local
80 pool.Schedule([&start, &stop, &thread_count] { in TEST()
89 thread_count.fetch_add(1, std::memory_order_relaxed); in TEST()
134 while (thread_count.load(std::memory_order_relaxed) < kNumThreads) { in TEST()
|
| /external/tensorflow/tensorflow/lite/kernels/internal/optimized/integer_ops/ |
| D | depthwise_conv_hybrid.h | 409 int thread_dim, thread_count, thread_dim_size; in DepthwiseConvHybridPerChannel() local
413 thread_count = thread_count_batch; in DepthwiseConvHybridPerChannel()
417 thread_count = thread_count_row; in DepthwiseConvHybridPerChannel()
421 thread_count = std::max(1, std::min(thread_count, max_threads)); in DepthwiseConvHybridPerChannel()
423 if (thread_count == 1) { in DepthwiseConvHybridPerChannel()
434 tasks.reserve(thread_count); in DepthwiseConvHybridPerChannel()
436 for (int i = 0; i < thread_count; ++i) { in DepthwiseConvHybridPerChannel()
438 thread_start + (thread_dim_size - thread_start) / (thread_count - i); in DepthwiseConvHybridPerChannel()
|
| /external/libaom/libaom/test/ |
| D | encode_perf_test.cc | 161 char thread_count[32]; in TEST_P() local
162 snprintf(thread_count, sizeof(thread_count), "_t-%d", threads); in TEST_P()
163 display_name += thread_count; in TEST_P()
|
| /external/libvpx/libvpx/test/ |
| D | encode_perf_test.cc | 164 char thread_count[32]; in TEST_P() local
165 snprintf(thread_count, sizeof(thread_count), "_t-%d", in TEST_P()
167 display_name += thread_count; in TEST_P()
|
| /external/libchrome/base/synchronization/ |
| D | condition_variable_unittest.cc | 71 explicit WorkQueue(int thread_count);
125 bool ThreadSafeCheckShutdown(int thread_count);
502 WorkQueue::WorkQueue(int thread_count) in WorkQueue() argument
507 thread_count_(thread_count), in WorkQueue()
509 thread_handles_(new PlatformThreadHandle[thread_count]), in WorkQueue()
510 assignment_history_(thread_count), in WorkQueue()
511 completion_history_(thread_count), in WorkQueue()
587 bool WorkQueue::ThreadSafeCheckShutdown(int thread_count) { in ThreadSafeCheckShutdown() argument
593 all_shutdown = (shutdown_task_count_ == thread_count); in ThreadSafeCheckShutdown()
|