| /external/tensorflow/tensorflow/python/training/ |
| D | coordinator_test.py | 100 threads = [
105 for t in threads:
107 coord.join(threads)
108 for t in threads:
113 threads = [
118 for t in threads:
122 for t in threads:
127 threads = [
132 for t in threads:
136 coord.join(threads[1:1])
[all …]
|
| D | queue_runner_test.py | 54 threads = qr.create_threads(sess)
55 self.assertEqual(sorted(t.name for t in threads),
57 for t in threads:
59 for t in threads:
75 threads = qr.create_threads(sess)
76 self.assertEqual(sorted(t.name for t in threads),
80 for t in threads:
82 for t in threads:
93 threads = qr.create_threads(sess)
95 for t in threads:
[all …]
|
| /external/ltp/testcases/kernel/syscalls/tgkill/ |
| D | tgkill01.c | 25 static struct thread_state *threads; variable
66 if (threads[i].tid == -1) in stop_threads()
69 SAFE_PTHREAD_JOIN(threads[i].thread, NULL); in stop_threads()
70 threads[i].tid = -1; in stop_threads()
73 if (threads) in stop_threads()
74 free(threads); in stop_threads()
84 TEST(sys_tgkill(getpid(), threads[i].tid, SIGUSR1)); in run()
93 if (!pthread_equal(sigusr1_thread, threads[i].thread)) { in run()
109 threads = SAFE_MALLOC(sizeof(*threads) * n_threads); in setup()
117 threads[i].tid = -1; in setup()
[all …]
|
| /external/libvpx/libvpx/test/ |
| D | stress.sh | 80 local threads="$4"
94 "${YUV}" "-t ${threads} --limit=150 --test-decode=fatal --passes=1" \
104 "${YUV}" "-t ${threads} --limit=150 --test-decode=fatal --passes=2" \
114 "${YUV}" "-t ${threads} --limit=150 --test-decode=fatal " \
127 eval "${decoder}" "-t ${threads}" "${webm}" "--noblit" ${devnull} &
151 for threads in 2 4 8; do
153 stress vp8 "${VP8}" "${vp8_max_jobs}" ${threads} \
170 for threads in 4 8 64; do
171 vp9_stress "$threads" "--row-mt=0"
176 for threads in 4 8 64; do
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | unbounded_thread_pool_test.cc | 46 std::vector<std::unique_ptr<Thread>> threads; in TEST() local
50 threads.push_back(thread_factory->StartThread("", [&i]() { ++i; })); in TEST()
52 threads.clear(); in TEST()
64 std::vector<std::unique_ptr<Thread>> threads; in TEST() local
68 threads.push_back(thread_factory->StartThread("", [&i]() { in TEST()
73 threads.clear(); in TEST()
85 std::vector<std::unique_ptr<Thread>> threads; in TEST() local
89 threads.push_back(thread_factory->StartThread("", [&i, thread_factory]() { in TEST()
98 threads.clear(); in TEST()
108 std::vector<std::unique_ptr<Thread>> threads; in TEST() local
[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/tensorflow/tensorflow/contrib/boosted_trees/lib/models/ |
| D | multiple_additive_trees_test.cc | 62 tensorflow::thread::ThreadPool threads(tensorflow::Env::Default(), "test", in TEST_F() local
65 &threads, output_matrix, in TEST_F()
97 tensorflow::thread::ThreadPool threads(tensorflow::Env::Default(), "test", in TEST_F() local
103 batch_features_, &threads, output_matrix, in TEST_F()
115 batch_features_, &threads, output_matrix, in TEST_F()
133 MultipleAdditiveTrees::Predict(weighted, {0, 1}, batch_features_, &threads, in TEST_F()
143 &threads, output_matrix, nullptr); in TEST_F()
150 &threads, output_matrix, nullptr); in TEST_F()
157 &threads, output_matrix, nullptr); in TEST_F()
189 tensorflow::thread::ThreadPool threads(tensorflow::Env::Default(), "test", in TEST_F() local
[all …]
|
| /external/protobuf/objectivec/Tests/ |
| D | GPBConcurrencyTests.m | 68 - (void)startThreads:(NSArray *)threads {
69 for (NSThread *thread in threads) {
74 - (void)joinThreads:(NSArray *)threads {
75 for (NSThread *thread in threads) {
91 NSArray *threads =
94 [self startThreads:threads];
95 [self joinThreads:threads];
111 NSArray *threads =
114 [self startThreads:threads];
115 [self joinThreads:threads];
[all …]
|
| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| D | ShouldNotDeadlockAnswerExecutionTest.java | 25 ExecutorService threads = Executors.newCachedThreadPool(); in failIfMockIsSharedBetweenThreads() local
34 threads.execute(new ServiceRunner(service)); in failIfMockIsSharedBetweenThreads()
35 threads.execute(new ServiceRunner(service)); in failIfMockIsSharedBetweenThreads()
39 threads.shutdown(); in failIfMockIsSharedBetweenThreads()
41 if (!threads.awaitTermination(1000, TimeUnit.MILLISECONDS)) { in failIfMockIsSharedBetweenThreads()
51 ExecutorService threads = Executors.newCachedThreadPool(); in successIfEveryThreadHasItsOwnMock() local
61 threads.execute(new ServiceRunner(service1)); in successIfEveryThreadHasItsOwnMock()
62 threads.execute(new ServiceRunner(service2)); in successIfEveryThreadHasItsOwnMock()
66 threads.shutdown(); in successIfEveryThreadHasItsOwnMock()
68 if (!threads.awaitTermination(500, TimeUnit.MILLISECONDS)) { in successIfEveryThreadHasItsOwnMock()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/test/tools/llvm-cov/ |
| D | multithreaded-report.test | 1 # Test "report" command with and without multiple threads.
3 RUN: llvm-cov report -num-threads=1 \
8 RUN: llvm-cov report -num-threads=10 \
15 # Test "export" command with and without multiple threads.
16 RUN: llvm-cov export -num-threads=1 \
21 RUN: llvm-cov export -num-threads=10 \
28 # Test "show" command with and without multiple threads, single text file.
29 RUN: llvm-cov show -format=text -num-threads=1 \
34 RUN: llvm-cov show -format=text -num-threads=10 \
41 # Test "show" command with and without multiple threads, single HTML file.
[all …]
|
| /external/icu/icu4j/main/tests/collate/src/com/ibm/icu/dev/test/collator/ |
| D | CollationThreadTest.java | 226 private void runThreads(Thread[] threads, Control control) { in runThreads() argument
227 for (int i = 0; i < threads.length; ++i) { in runThreads()
228 threads[i].start(); in runThreads()
241 for (int i = 0; i < threads.length; ++i) { in runThreads()
242 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()
284 Thread[] threads = new Thread[10]; in testFrozen() local
[all …]
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/collator/ |
| D | CollationThreadTest.java | 229 private void runThreads(Thread[] threads, Control control) { in runThreads() argument
230 for (int i = 0; i < threads.length; ++i) { in runThreads()
231 threads[i].start(); in runThreads()
244 for (int i = 0; i < threads.length; ++i) { in runThreads()
245 threads[i].join(); in runThreads()
262 Thread[] threads = new Thread[10]; in testThreads() local
263 for (int i = 0; i < threads.length; ++i) { in testThreads()
274 threads[i] = new Thread(test); in testThreads()
277 runThreads(threads, control); in testThreads()
287 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/tensorflow/tensorflow/python/kernel_tests/ |
| D | dense_update_ops_no_tsan_test.py | 48 threads = [
52 for t in threads:
54 for t in threads:
75 threads = [
79 for t in threads:
81 for t in threads:
108 threads = [
112 for t in threads:
114 for t in threads:
136 threads = [
[all …]
|
| /external/tensorflow/tensorflow/core/util/ |
| D | work_sharder_test.cc | 32 thread::ThreadPool* threads) { in RunSharding() argument
37 Shard(num_workers, threads, total, cost_per_unit, in RunSharding()
54 threads->NumThreads()) { in RunSharding()
65 thread::ThreadPool threads(Env::Default(), "test", 16); in TEST() local
71 RunSharding(workers, total, cost_per_unit, maxp, &threads); in TEST()
79 thread::ThreadPool threads(Env::Default(), "test", 3); in TEST() local
84 Shard(workers, &threads, total_elements, cost_per_unit, in TEST()
93 thread::ThreadPool threads(Env::Default(), "test", 16); in BM_Sharding() local
98 Shard(arg - 1, &threads, total, 1, work); in BM_Sharding()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_atfork/ |
| D | 1-2.c | 89 pthread_t threads[3]; variable
96 threads[0] = pthread_self(); in prepare()
101 threads[1] = pthread_self(); in parent()
106 threads[2] = pthread_self(); in child()
137 if (!pthread_equal(ch, threads[0])) { in threaded()
142 if (!pthread_equal(pthread_self(), threads[2])) { in threaded()
151 if (!pthread_equal(ch, threads[0])) { in threaded()
156 if (!pthread_equal(pthread_self(), threads[1])) { in threaded()
|
| /external/grpc-grpc/test/core/gpr/ |
| D | spinlock_test.cc | 38 grpc_core::Thread* threads; member
48 static struct test* test_new(int threads, int64_t iterations, int incr_step) { in test_new() argument
50 m->thread_count = threads; in test_new()
51 m->threads = static_cast<grpc_core::Thread*>( in test_new()
52 gpr_malloc(sizeof(*m->threads) * static_cast<size_t>(threads))); in test_new()
63 gpr_free(m->threads); in test_destroy()
71 m->threads[i] = grpc_core::Thread("grpc_create_threads", body, m); in test_create_threads()
72 m->threads[i].Start(); in test_create_threads()
80 m->threads[i].Join(); in test_wait()
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| D | VMState.java | 52 List<ThreadReference> threads = null; // cached Threads field in VMState.Cache
192 List<ThreadReference> threads = null; in allThreads() local
198 threads = local.threads; in allThreads()
200 if (threads == null) { in allThreads()
201 threads = Arrays.asList((ThreadReference[])JDWP.VirtualMachine.AllThreads. in allThreads()
202 process(vm).threads); in allThreads()
204 local.threads = threads; in allThreads()
207 threads.size() + ") while VM suspended"); in allThreads()
214 return threads; in allThreads()
|
| /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 | 85 Thread[] threads = new Thread[10]; in run() local
86 for (int i = 0; i < threads.length; ++i) { in run()
87 threads[i] = new Thread(new TestThread(obj)); in run()
88 threads[i].setName("TestThread#" + i); in run()
92 THREAD_ONLY = threads[threads.length - 1]; in run()
102 for (int i = 0; i < threads.length; ++i) { in run()
103 runThread(threads[i]); in run()
|
| /external/mockito/src/test/java/org/mockitoutil/async/ |
| D | AsyncTesting.java | 20 private final LinkedList<Thread> threads = new LinkedList<Thread>(); field in AsyncTesting
32 if (threads.size() == MAX_THREADS) { in runAfter()
48 …at will execute the runnable after " + delayMillis + " millis. Threads so far: " + threads.size()); in runAfter()
49 threads.add(t); in runAfter()
59 …System.out.println("[AsyncTesting] Interrupting and waiting for " + threads.size() + " threads to … in cleanUp()
60 while(!threads.isEmpty()) { in cleanUp()
61 Thread t = threads.removeFirst(); in cleanUp()
|
| /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/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/VirtualMachine/ |
| D | AllThreadsTest.java | 73 int threads = reply.getNextValueAsInt(); in testAllThreads003() local
74 logWriter.println("Number of threads = " + threads); in testAllThreads003()
75 assertTrue("Number of threads must be > 0", threads > 0); in testAllThreads003()
77 for (int i = 0; i < threads; i++) { in testAllThreads003()
132 int threads = reply.getNextValueAsInt(); in testAllThreads002() local
133 logWriter.println("Number of threads = " + threads); in testAllThreads002()
134 assertTrue("Number of threads must be > 0", threads > 0); in testAllThreads002()
137 for (int i = 0; i < threads; i++) { in testAllThreads002()
203 int threads = reply.getNextValueAsInt(); in testAllThreads001() local
204 logWriter.println("Number of threads = " + threads); in testAllThreads001()
[all …]
|
| /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/clang/test/OpenMP/ |
| D | ordered_messages.cpp | 30 …#pragma omp ordered threads threads // expected-error {{directive '#pragma omp ordered' cannot con… in foo()
44 …#pragma omp ordered threads // expected-error {{'ordered' directive with 'threads' clause cannot b… in foo()
62 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo()
76 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo()
90 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo()
118 #pragma omp ordered depend(source) threads // expected-error {{'depend' clauses cannot be mixed wit… in foo()
159 …#pragma omp ordered threads threads // expected-error {{directive '#pragma omp ordered' cannot con… in foo()
173 …#pragma omp ordered threads // expected-error {{'ordered' directive with 'threads' clause cannot b… in foo()
191 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo()
205 …#pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd … in foo()
[all …]
|