Home
last modified time | relevance | path

Searched refs:threads (Results 1 – 25 of 644) sorted by relevance

12345678910>>...26

/external/v8/test/unittests/base/platform/
Dcondition-variable-unittest.cc61 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/
Dm_threadstate.c47 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/
Drefs.c64 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/
Dstereobp.cu168 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/
Dmicrodump_processor_unittest.cc102 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/
DCollationThreadTest.java227 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/
DCollationThreadTest.java223 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/
Dstress.py33 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/
Dordered_messages.cpp29 …#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/
Dkernbench.old3 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)
Dkernbench.py45 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/
Dpaste-httpserver-threadpool.txt14 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/
Dudp_socket_manager_unittest.cc28 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/
DThreadOnlyModifierDebuggee.java84 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/
Dmatch_template.cu113 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/
Dtsan_mutex_test.cc99 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/
Dsanitizer_mutex_test.cc107 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/
DThreadTest.java21 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/
DAllThreadsTest.java72 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/
Dbuild_warp_maps.cu167 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/
DThreadTest.java25 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/
Dtest-lockers.cc196 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/
Dscheduler.c242 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/
Dstats_poller.py20 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/
DTLSTest.cpp34 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()

12345678910>>...26