/external/v8/test/unittests/base/platform/ |
D | condition-variable-unittest.cc | 61 ThreadWithMutexAndConditionVariable threads[kThreadCount]; in TEST() local 64 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST() 65 EXPECT_FALSE(threads[n].running_); in TEST() 66 EXPECT_FALSE(threads[n].finished_); in TEST() 67 threads[n].Start(); in TEST() 69 while (!threads[n].running_) { in TEST() 70 threads[n].cv_.Wait(&threads[n].mutex_); in TEST() 75 LockGuard<Mutex> lock_guard(&threads[n].mutex_); in TEST() 76 EXPECT_TRUE(threads[n].running_); in TEST() 77 EXPECT_FALSE(threads[n].finished_); in TEST() [all …]
|
/external/valgrind/coregrind/ |
D | m_threadstate.c | 47 ThreadState *VG_(threads); 58 VG_(threads) = VG_(arena_memalign) (VG_AR_CORE, "init_Threads", in VG_() 60 VG_N_THREADS * sizeof VG_(threads)[0]); in VG_() 64 ANNOTATE_BENIGN_RACE_SIZED(&VG_(threads)[tid].status, in VG_() 65 sizeof(VG_(threads)[tid].status), "")); in VG_() 67 ANNOTATE_BENIGN_RACE_SIZED(&VG_(threads)[tid].os_state.exitcode, in VG_() 68 sizeof(VG_(threads)[tid].os_state.exitcode), in VG_() 100 vg_assert(VG_(threads)[tid].tid == tid); in VG_() 101 return &VG_(threads)[tid]; in VG_() 109 if (VG_(threads)[tid].status == VgTs_Empty) return False; in VG_() local [all …]
|
/external/dbus/test/internals/ |
D | refs.c | 64 GThread *threads[N_THREADS]; member 181 g_thread_join (f->threads[i]); in wait_for_all_threads() 285 f->threads[i] = g_thread_new (NULL, ref_thread, &public_api); in test_connection() 287 f->threads[i] = g_thread_new (NULL, ref_thread, &internal_api); in test_connection() 289 g_assert (f->threads[i] != NULL); in test_connection() 297 f->threads[i] = g_thread_new (NULL, cycle_thread, &public_api); in test_connection() 299 f->threads[i] = g_thread_new (NULL, cycle_thread, &internal_api); in test_connection() 301 g_assert (f->threads[i] != NULL); in test_connection() 309 f->threads[i] = g_thread_new (NULL, unref_thread, &public_api); in test_connection() 311 f->threads[i] = g_thread_new (NULL, unref_thread, &internal_api); in test_connection() [all …]
|
/external/opencv3/modules/cudastereo/src/cuda/ |
D | stereobp.cu | 168 dim3 threads(32, 8, 1); in comp_data_gpu() local 171 grid.x = divUp(left.cols, threads.x); in comp_data_gpu() 172 grid.y = divUp(left.rows, threads.y); in comp_data_gpu() 174 comp_data<1, short><<<grid, threads, 0, stream>>>(left, right, (PtrStepSz<short>)data); in comp_data_gpu() 182 dim3 threads(32, 8, 1); in comp_data_gpu() local 185 grid.x = divUp(left.cols, threads.x); in comp_data_gpu() 186 grid.y = divUp(left.rows, threads.y); in comp_data_gpu() 188 comp_data<1, float><<<grid, threads, 0, stream>>>(left, right, (PtrStepSz<float>)data); in comp_data_gpu() 197 dim3 threads(32, 8, 1); in comp_data_gpu() local 200 grid.x = divUp(left.cols, threads.x); in comp_data_gpu() [all …]
|
/external/google-breakpad/src/processor/ |
D | microdump_processor_unittest.cc | 102 ASSERT_EQ(1U, state->threads()->size()); in AnalyzeDump() 133 ASSERT_EQ(1U, state.threads()->size()); in TEST_F() 134 ASSERT_EQ(12U, state.threads()->at(0)->frames()->size()); in TEST_F() 137 state.threads()->at(0)->frames()->at(0)->function_name); in TEST_F() 139 state.threads()->at(0)->frames()->at(3)->function_name); in TEST_F() 163 ASSERT_EQ(8U, state.threads()->at(0)->frames()->size()); in TEST_F() 165 state.threads()->at(0)->frames()->at(0)->function_name); in TEST_F() 167 state.threads()->at(0)->frames()->at(1)->function_name); in TEST_F() 169 state.threads()->at(0)->frames()->at(6)->function_name); in TEST_F() 171 state.threads()->at(0)->frames()->at(6)->module->code_file()); in TEST_F() [all …]
|
/external/icu/android_icu4j/src/main/tests/android/icu/dev/test/collator/ |
D | CollationThreadTest.java | 227 private void runThreads(Thread[] threads, Control control) { in runThreads() argument 228 for (int i = 0; i < threads.length; ++i) { in runThreads() 229 threads[i].start(); in runThreads() 242 for (int i = 0; i < threads.length; ++i) { in runThreads() 243 threads[i].join(); in runThreads() 259 Thread[] threads = new Thread[10]; in testThreads() local 260 for (int i = 0; i < threads.length; ++i) { in testThreads() 271 threads[i] = new Thread(test); in testThreads() 274 runThreads(threads, control); in testThreads() 283 Thread[] threads = new Thread[10]; in testFrozen() local [all …]
|
/external/icu/icu4j/main/tests/collate/src/com/ibm/icu/dev/test/collator/ |
D | CollationThreadTest.java | 223 private void runThreads(Thread[] threads, Control control) { in runThreads() argument 224 for (int i = 0; i < threads.length; ++i) { in runThreads() 225 threads[i].start(); in runThreads() 238 for (int i = 0; i < threads.length; ++i) { in runThreads() 239 threads[i].join(); in runThreads() 255 Thread[] threads = new Thread[10]; in testThreads() local 256 for (int i = 0; i < threads.length; ++i) { in testThreads() 267 threads[i] = new Thread(test); in testThreads() 270 runThreads(threads, control); in testThreads() 279 Thread[] threads = new Thread[10]; in testFrozen() local [all …]
|
/external/autotest/client/tests/stress/ |
D | stress.py | 33 threads = 2 * utils.count_cpus() 39 memory_per_thread = (mb * 1024) / threads 46 if (0.9 * free_disk) < file_size_per_thread * threads: 47 file_size_per_thread = (0.9 * free_disk) / threads 50 args = '--cpu %d ' % threads 52 args += '--io %d ' % threads 54 args += '--vm %d ' % threads 58 args += '--hdd %d ' % threads
|
/external/clang/test/OpenMP/ |
D | ordered_messages.cpp | 29 …#pragma omp ordered threads threads // expected-error {{directive '#pragma omp ordered' cannot con… in foo() 43 …#pragma omp ordered threads // expected-error {{'ordered' directive with 'threads' clause cannot b… in foo() 61 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo() 75 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo() 89 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo() 109 #pragma omp ordered depend(source) threads // expected-error {{'depend' clauses cannot be mixed wit… in foo() 142 …#pragma omp ordered threads threads // expected-error {{directive '#pragma omp ordered' cannot con… in foo() 156 …#pragma omp ordered threads // expected-error {{'ordered' directive with 'threads' clause cannot b… in foo() 174 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo() 188 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo() [all …]
|
/external/autotest/client/tests/kernbench/ |
D | kernbench.old | 3 threads = 2 * count_cpus() 9 print "kernbench [-j threads] [-i iterations] [-c config] [-k kernel]" 19 global threads,iterations,config,kernelver 23 threads = int(a) 24 if (threads == 0): 25 threads = "" 38 print "kernbench -j %d -i %d -c %s -k %s" % (threads, iterations, config, kernelver) 43 testkernel.build_timed(threads) # warmup run 45 testkernel.build_timed(threads, '../log/time.%d' % i)
|
D | kernbench.py | 45 def warmup(self, threads=None, version=None): argument 46 if threads: 47 self.threads = threads 49 self.threads = self.job.cpu_count()*2 55 self.kernel.build_timed(self.threads, output=logfile) # warmup run 63 " %d threads" % (self.iteration, self.threads)) 69 self.kernel.build_timed(self.threads, self.timefile)
|
/external/chromium-trace/catapult/third_party/Paste/docs/ |
D | paste-httpserver-threadpool.txt | 14 indefinitely. There's two basic ways you can manage threads: 18 * Start a pool of threads, and reuse those threads for subsequent 22 you will have an explosion of threads, and with it memory and a loss 26 If you are using a pool of threads, all the threads can simply be used 38 The pool tracks all workers threads. Threads can be in a few states: 56 When a request comes in, if there are no idle worker threads waiting 59 there are less than ``spawn_if_under`` busy threads. So if you have 60 10 workers, ``spawn_if_under`` is 5, and there are 6 hung threads and 61 4 busy threads, another thread will be opened (bringing the number of 62 busy threads back to 5). Later those threads may be collected again [all …]
|
/external/webrtc/webrtc/test/channel_transport/ |
D | udp_socket_manager_unittest.cc | 28 uint8_t threads = 1; in TEST() local 29 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads); in TEST() 31 EXPECT_FALSE(mgr->Init(id, threads)) in TEST() 40 uint8_t threads = 1; in TEST() local 41 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads); in TEST() 65 uint8_t threads = 1; in TEST() 66 UdpSocketManager* mgr = UdpSocketManager::Create(id, threads); in TEST()
|
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/EventModifiers/ |
D | ThreadOnlyModifierDebuggee.java | 84 Thread[] threads = new Thread[10]; in run() local 85 for (int i = 0; i < threads.length; ++i) { in run() 86 threads[i] = new Thread(new TestThread(obj)); in run() 87 threads[i].setName("TestThread#" + i); in run() 91 THREAD_ONLY = threads[threads.length - 1]; in run() 101 for (int i = 0; i < threads.length; ++i) { in run() 102 runThread(threads[i]); in run()
|
/external/opencv3/modules/cudaimgproc/src/cuda/ |
D | match_template.cu | 113 const dim3 threads(32, 8); in matchTemplateNaive_CCORR() local 114 const dim3 grid(divUp(result.cols, threads.x), divUp(result.rows, threads.y)); in matchTemplateNaive_CCORR() 116 …matchTemplateNaiveKernel_CCORR<T, cn><<<grid, threads, 0, stream>>>(templ.cols, templ.rows, image,… in matchTemplateNaive_CCORR() 183 const dim3 threads(32, 8); in matchTemplateNaive_SQDIFF() local 184 const dim3 grid(divUp(result.cols, threads.x), divUp(result.rows, threads.y)); in matchTemplateNaive_SQDIFF() 186 …matchTemplateNaiveKernel_SQDIFF<T, cn><<<grid, threads, 0, stream>>>(templ.cols, templ.rows, image… in matchTemplateNaive_SQDIFF() 239 const dim3 threads(32, 8); in matchTemplatePrepared_SQDIFF_8U() local 240 const dim3 grid(divUp(result.cols, threads.x), divUp(result.rows, threads.y)); in matchTemplatePrepared_SQDIFF_8U() 242 …matchTemplatePreparedKernel_SQDIFF_8U<cn><<<grid, threads, 0, stream>>>(w, h, image_sqsum, templ_s… in matchTemplatePrepared_SQDIFF_8U() 311 const dim3 threads(32, 8); in matchTemplatePrepared_SQDIFF_NORMED_8U() local [all …]
|
/external/compiler-rt/lib/tsan/tests/unit/ |
D | tsan_mutex_test.cc | 99 pthread_t threads[kThreads]; in TEST() local 101 pthread_create(&threads[i], 0, write_mutex_thread<Mutex>, &data); in TEST() 103 pthread_join(threads[i], 0); in TEST() 109 pthread_t threads[kThreads]; in TEST() local 111 pthread_create(&threads[i], 0, read_mutex_thread<Mutex>, &data); in TEST() 113 pthread_join(threads[i], 0); in TEST() 119 pthread_t threads[kThreads]; in TEST() local 121 pthread_create(&threads[i], 0, write_mutex_thread<SpinMutex>, &data); in TEST() 123 pthread_join(threads[i], 0); in TEST()
|
/external/compiler-rt/lib/sanitizer_common/tests/ |
D | sanitizer_mutex_test.cc | 107 pthread_t threads[kThreads]; in TEST() local 109 PTHREAD_CREATE(&threads[i], 0, lock_thread<SpinMutex>, &data); in TEST() 111 PTHREAD_JOIN(threads[i], 0); in TEST() 118 pthread_t threads[kThreads]; in TEST() local 120 PTHREAD_CREATE(&threads[i], 0, try_thread<SpinMutex>, &data); in TEST() 122 PTHREAD_JOIN(threads[i], 0); in TEST() 129 pthread_t threads[kThreads]; in TEST() local 131 PTHREAD_CREATE(&threads[i], 0, lock_thread<BlockingMutex>, &data); in TEST() 133 PTHREAD_JOIN(threads[i], 0); in TEST()
|
/external/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
D | ThreadTest.java | 21 private ArrayList<Worker> threads = new ArrayList<Worker>(); field in ThreadTest 32 threads.add(thread); in TestThreads() 36 for (Worker thread: threads) { in TestThreads() 73 ArrayList<Thread> threads = new ArrayList<Thread>(); in TestAnyTranslit() local 75 threads.add(new Thread() { in TestAnyTranslit() 81 for (Thread th:threads) { in TestAnyTranslit() 84 for (Thread th:threads) { in TestAnyTranslit()
|
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/VirtualMachine/ |
D | AllThreadsTest.java | 72 int threads = reply.getNextValueAsInt(); in testAllThreads003() local 73 logWriter.println("Number of threads = " + threads); in testAllThreads003() 74 assertTrue("Number of threads must be > 0", threads > 0); in testAllThreads003() 76 for (int i = 0; i < threads; i++) { in testAllThreads003() 131 int threads = reply.getNextValueAsInt(); in testAllThreads002() local 132 logWriter.println("Number of threads = " + threads); in testAllThreads002() 133 assertTrue("Number of threads must be > 0", threads > 0); in testAllThreads002() 136 for (int i = 0; i < threads; i++) { in testAllThreads002() 202 int threads = reply.getNextValueAsInt(); in testAllThreads001() local 203 logWriter.println("Number of threads = " + threads); in testAllThreads001() [all …]
|
/external/opencv3/modules/stitching/src/cuda/ |
D | build_warp_maps.cu | 167 dim3 threads(32, 8); in buildWarpPlaneMaps() local 168 dim3 grid(divUp(cols, threads.x), divUp(rows, threads.y)); in buildWarpPlaneMaps() 170 … buildWarpMapsKernel<PlaneMapper><<<grid,threads>>>(tl_u, tl_v, cols, rows, map_x, map_y); in buildWarpPlaneMaps() 188 dim3 threads(32, 8); in buildWarpCylindricalMaps() local 189 dim3 grid(divUp(cols, threads.x), divUp(rows, threads.y)); in buildWarpCylindricalMaps() 191 … buildWarpMapsKernel<CylindricalMapper><<<grid,threads>>>(tl_u, tl_v, cols, rows, map_x, map_y); in buildWarpCylindricalMaps() 209 dim3 threads(32, 8); in buildWarpSphericalMaps() local 210 dim3 grid(divUp(cols, threads.x), divUp(rows, threads.y)); in buildWarpSphericalMaps() 212 … buildWarpMapsKernel<SphericalMapper><<<grid,threads>>>(tl_u, tl_v, cols, rows, map_x, map_y); in buildWarpSphericalMaps()
|
/external/icu/android_icu4j/src/main/tests/android/icu/dev/test/translit/ |
D | ThreadTest.java | 25 private ArrayList<Worker> threads = new ArrayList<Worker>(); field in ThreadTest 36 threads.add(thread); in TestThreads() 40 for (Worker thread: threads) { in TestThreads() 77 ArrayList<Thread> threads = new ArrayList<Thread>(); in TestAnyTranslit() local 79 threads.add(new Thread() { in TestAnyTranslit() 85 for (Thread th:threads) { in TestAnyTranslit() 88 for (Thread th:threads) { in TestAnyTranslit()
|
/external/v8/test/cctest/ |
D | test-lockers.cc | 196 static void StartJoinAndDeleteThreads(const i::List<JoinableThread*>& threads) { in StartJoinAndDeleteThreads() argument 197 for (int i = 0; i < threads.length(); i++) { in StartJoinAndDeleteThreads() 198 threads[i]->Start(); in StartJoinAndDeleteThreads() 200 for (int i = 0; i < threads.length(); i++) { in StartJoinAndDeleteThreads() 201 threads[i]->Join(); in StartJoinAndDeleteThreads() 203 for (int i = 0; i < threads.length(); i++) { in StartJoinAndDeleteThreads() 204 delete threads[i]; in StartJoinAndDeleteThreads() 217 i::List<JoinableThread*> threads(kNThreads); in TEST() local 222 threads.Add(new IsolateLockingThreadWithLocalContext(isolate)); in TEST() 224 StartJoinAndDeleteThreads(threads); in TEST() [all …]
|
/external/valgrind/coregrind/m_scheduler/ |
D | scheduler.c | 242 if (VG_(threads)[i].status == VgTs_Empty) { in VG_() local 243 VG_(threads)[i].status = VgTs_Init; in VG_() local 244 VG_(threads)[i].exitreason = VgSrc_None; in VG_() local 245 if (VG_(threads)[i].thread_name) in VG_() local 246 VG_(free)(VG_(threads)[i].thread_name); in VG_() 247 VG_(threads)[i].thread_name = NULL; in VG_() local 368 == VG_(threads)[tid].os_state.lwpid); in VG_() 385 vg_assert(VG_(threads)[tid].exitreason != VgSrc_None); in VG_() 401 if (VG_(threads)[tid].status == VgTs_WaitSys) { in VG_() local 405 tid, VG_(threads)[tid].os_state.lwpid); in VG_() [all …]
|
/external/autotest/site_utils/ |
D | stats_poller.py | 20 threads = [] 25 threads.append(threading.Thread(target=f, args=(sam,))) 29 threads.append(threading.Thread(target=f, args=(drone,))) 33 threads.append(threading.Thread(target=f, args=(devserver,))) 36 threads.append(threading.Thread(target=f)) 38 for thread in threads:
|
/external/skia/tests/ |
D | TLSTest.cpp | 34 SkThread* threads[8]; in test_threads() local 35 int N = SK_ARRAY_COUNT(threads); in test_threads() 39 threads[i] = new SkThread(proc); in test_threads() 43 threads[i]->start(); in test_threads() 47 threads[i]->join(); in test_threads() 51 delete threads[i]; in test_threads()
|