| /external/compiler-rt/test/lsan/TestCases/ |
| high_allocator_contention.cc | 11 int num_threads; variable
24 for (int i = 0; i < total_num_alloc / num_threads; i++) {
34 num_threads = atoi(argv[1]);
35 assert(num_threads > 0);
36 assert(num_threads <= kMaxNumThreads);
39 printf("%d threads, %d allocations in each\n", num_threads,
40 total_num_alloc / num_threads);
41 for (int i = 0; i < num_threads; i++)
47 for (int i = 0; i < num_threads; i++) pthread_join(tid[i], 0);
|
| /external/google-breakpad/src/client/linux/minidump_writer/ |
| linux_dumper_unittest_helper.cc | 80 int num_threads = atoi(argv[2]); local
81 if (num_threads < 1) {
85 google_breakpad::scoped_array<pthread_t> threads(new pthread_t[num_threads]);
89 for (int i = 1; i < num_threads; i++) {
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| lp_screen.h | 52 unsigned num_threads; member in struct:llvmpipe_screen
|
| lp_query.c | 99 unsigned num_threads = MAX2(1, screen->num_threads); local
123 for (i = 0; i < num_threads; i++) {
128 for (i = 0; i < num_threads; i++) {
134 for (i = 0; i < num_threads; i++) {
171 for (i = 0; i < num_threads; i++) {
|
| /external/valgrind/drd/tests/ |
| omp_printf.c | 27 int num_threads = 2; local
36 case 't': num_threads = atoi(optarg); break;
47 assert(num_threads > 0);
49 omp_set_num_threads(num_threads);
|
| omp_prime.c | 42 int num_threads = 2; local
55 num_threads = atoi(optarg);
76 assert(num_threads >= 1);
81 omp_set_num_threads(num_threads);
|
| /external/libxml2/ |
| testThreads.c | 104 unsigned int num_threads = sizeof(testfiles) / sizeof(testfiles[0]); local
112 memset(results, 0, sizeof(*results)*num_threads);
113 memset(tid, 0xff, sizeof(*tid)*num_threads);
115 for (i = 0; i < num_threads; i++) {
123 for (i = 0; i < num_threads; i++) {
132 for (i = 0; i < num_threads; i++)
145 unsigned int num_threads = sizeof(testfiles) / sizeof(testfiles[0]); local
155 for (i = 0; i < num_threads; i++) {
160 for (i = 0; i < num_threads; i++) {
168 for (i = 0; i < num_threads; i++)
[all...] |
| testThreadsWin32.c | 89 unsigned int num_threads = sizeof(testfiles) / sizeof(testfiles[0]); local
98 for (i = 0; i < num_threads; i++)
104 for (i = 0; i < num_threads; i++)
116 if (WaitForMultipleObjects (num_threads, tid, TRUE, INFINITE) == WAIT_FAILED)
119 for (i = 0; i < num_threads; i++)
131 for (i = 0; i < num_threads; i++) {
|
| /external/tensorflow/tensorflow/contrib/tensor_forest/kernels/ |
| reinterpret_string_to_float_op.cc | 66 int num_threads = worker_threads->num_threads; variable
67 if (num_threads <= 1) {
76 Shard(num_threads, worker_threads->workers, num_data, 100, work);
|
| /external/tensorflow/tensorflow/core/kernels/ |
| concat_lib_cpu.h | 46 int num_threads = std::min(4, worker_threads->num_threads); local
50 num_threads =
51 static_cast<int>(std::min<int64>(num_threads, output->size() / 4096));
55 if (num_threads == 0) {
125 Shard(worker_threads->num_threads, worker_threads->workers, output->size(),
|
| bincount_op.cc | 57 const int64 num_threads = thread_pool->NumThreads() + 1; local
60 TensorShape({num_threads, size}),
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| threadpool_test.cc | 31 for (int num_threads = 1; num_threads < kNumThreads; num_threads++) {
32 fprintf(stderr, "Testing with %d threads\n", num_threads);
33 ThreadPool pool(Env::Default(), "test", num_threads); local
38 for (int num_threads = 1; num_threads < kNumThreads; num_threads++) {
39 fprintf(stderr, "Testing with %d threads\n", num_threads);
46 ThreadPool pool(Env::Default(), "test", num_threads); local
67 ThreadPool pool(Env::Default(), "test", num_threads); local
90 ThreadPool pool(Env::Default(), "test", num_threads); local
[all...] |
| /system/extras/memory_replay/ |
| Threads.h | 37 size_t num_threads() { return num_threads_; } function in class:Threads
|
| /art/runtime/ |
| barrier_test.cc | 55 static int32_t num_threads; member in class:art::BarrierTest
58 int32_t BarrierTest::num_threads = 4; member in class:art::BarrierTest
63 ThreadPool thread_pool("Barrier test thread pool", num_threads);
64 Barrier barrier(num_threads + 1); // One extra Wait() in main thread.
68 for (int32_t i = 0; i < num_threads; ++i) {
72 while (count1.LoadRelaxed() != num_threads) {
81 // Both counts should be equal to num_threads now.
82 EXPECT_EQ(count1.LoadRelaxed(), num_threads);
83 EXPECT_EQ(count2.LoadRelaxed(), num_threads);
114 ThreadPool thread_pool("Barrier test thread pool", num_threads);
[all...] |
| thread_pool_test.cc | 56 static int32_t num_threads; member in class:art::ThreadPoolTest
59 int32_t ThreadPoolTest::num_threads = 4; member in class:art::ThreadPoolTest
64 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
66 static const int32_t num_tasks = num_threads * 4;
79 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
81 static const int32_t num_tasks = num_threads * 4;
104 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
107 static const int32_t num_tasks = num_threads * 100;
154 ThreadPool thread_pool("Thread pool test thread pool", num_threads);
|
| /art/test/1944-sudden-exit/src/art/ |
| Test1944.java | 42 private static int num_threads = 10; field in class:Test1944
45 final Semaphore started = new Semaphore(-(num_threads - 1));
52 Thread[] threads = new Thread[num_threads];
53 for (int i = 0; i < num_threads; i++) {
|
| /external/autotest/client/tests/monotonic_time/src/ |
| threads.c | 27 static int num_threads; variable
61 if (num_threads >= MAX_THREADS)
64 thread = &threads[num_threads++];
73 --num_threads;
78 return num_threads;
95 thread = &threads[num_threads++];
103 --num_threads;
108 return num_threads;
117 while (num_threads > 0)
118 pthread_join(threads[--num_threads].thread, NULL)
[all...] |
| /external/compiler-rt/test/asan/TestCases/Linux/ |
| stress_dtls.c | 73 int num_threads = 1; local
76 num_threads = atoi(argv[1]);
100 for (i = 0; i < num_threads; i++) {
|
| /external/eigen/unsupported/test/ |
| cxx11_tensor_thread_pool.cpp | 274 const int num_threads = internal::random<int>(3, 11); local
275 ThreadPool thread_pool(num_threads);
276 Eigen::ThreadPoolDevice thread_pool_device(&thread_pool, num_threads);
298 const int num_threads = internal::random<int>(3, 11); local
299 Eigen::ThreadPool tp(num_threads);
300 Eigen::ThreadPoolDevice thread_pool_device(&tp, num_threads);
328 const int num_threads = internal::random<int>(2, 11); local
329 ThreadPool threads(num_threads);
330 Eigen::ThreadPoolDevice device(&threads, num_threads);
|
| /external/libvpx/libvpx/test/ |
| vp9_skip_loopfilter_test.cc | 36 void Init(int num_threads) {
45 if (num_threads > 0) cfg.threads = num_threads;
122 const int num_threads = 0; local
124 skip_loop_filter.Init(num_threads);
132 const int num_threads = 1; local
134 skip_loop_filter.Init(num_threads);
142 const int num_threads = 8; local
144 skip_loop_filter.Init(num_threads);
152 const int num_threads = 0 local
162 const int num_threads = 0; local
[all...] |
| /external/ltp/testcases/kernel/sched/pthreads/ |
| pth_str02.c | 46 #define USAGE "\nUsage: %s [-l | -n num_threads] [-d]\n\n" \
48 "\t-n num_threads Number of threads to create\n" \
68 int num_threads = DEFAULT_NUM_THREADS; variable
92 tst_resm(TINFO, "Creating %d threads", num_threads);
107 | Function: Recursively creates threads while num < num_threads |
119 * Create threads while num < num_threads...
121 if (test_limit || (num < num_threads)) {
184 num_threads = atoi(optarg);
|
| /external/mesa3d/src/gallium/auxiliary/util/ |
| u_queue.h | 65 unsigned num_threads; member in struct:util_queue
78 unsigned num_threads);
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| backend.cc | 54 int num_threads) {
55 intra_op_parallelism_threads_ = num_threads;
66 explicit EigenThreadPoolWrapper(const int num_threads)
68 "XLAEigen", num_threads)),
148 const int num_threads = intra_op_parallelism_threads > 0 local
152 new EigenThreadPoolWrapper(num_threads));
|
| /system/core/init/ |
| ueventd_test.cpp | 42 auto num_threads = files_and_parameters.size(); local
44 pthread_barrier_init(&barrier, nullptr, num_threads);
136 constexpr auto num_threads = 10; local
192 std::generate_n(back_inserter(threads), num_threads, local
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| TensorExecutor.h | 160 size_t num_threads = device.numThreads(); local
161 if (num_threads > 1) {
162 num_threads = TensorCostModel<ThreadPoolDevice>::numThreads(
163 size, evaluator.costPerCoeff(Vectorizable), num_threads);
165 if (num_threads == 1) {
169 Index blocksz = std::ceil<Index>(static_cast<float>(size)/num_threads) + PacketSize - 1;
|
