Home
last modified time | relevance | path

Searched refs:thread_count (Results 1 – 25 of 58) sorted by relevance

123

/external/valgrind/drd/tests/
Dpth_create_chain.c17 int thread_count = *(int*)(p); in thread_func() local
20 if (thread_count > 0) in thread_func()
22 thread_count--; in thread_func()
24 s_arg[thread_count] = thread_count; in thread_func()
27 pthread_create(&s_thread[thread_count], &attr, thread_func, in thread_func()
28 &s_arg[thread_count]); in thread_func()
31 std::cout << "created " << thread_count << "(" << s_thread[thread_count] in thread_func()
41 unsigned thread_count; in main() local
44 thread_count = argc > 1 ? atoi(argv[1]) : 50; in main()
45 assert(thread_count <= sizeof(s_thread) / sizeof(s_thread[0])); in main()
[all …]
Dpth_broadcast.c114 int thread_count; in main() local
134 thread_count = argc > optind + 1 ? atoi(argv[optind + 1]) : 10; in main()
148 thread_vec = malloc(sizeof(struct cthread) * thread_count); in main()
149 for (p = thread_vec; p != thread_vec + thread_count; p++) in main()
161 csema_p(&sema, thread_count); in main()
170 for (i = 0; i < thread_count; i++) in main()
Dpth_barrier_thr_cr.c30 int thread_count = barriers * barrier_participants; in main() local
37 tid = malloc(thread_count * sizeof(*tid)); in main()
39 for (i = 0; i < thread_count; i++) { in main()
43 for (i = 0; i < thread_count; i++) { in main()
Dannotate_rwlock.c143 const int thread_count = 10; in main() local
144 pthread_t tid[thread_count]; in main()
148 for (i = 0; i < thread_count; i++) in main()
153 for (i = 0; i < thread_count; i++) in main()
Dannotate_barrier.c30 unsigned thread_count; member
59 b->thread_count = count; in barrier_init()
79 if (__sync_add_and_fetch(&b->wait_count, 1) == b->thread_count) in barrier_wait()
81 __sync_sub_and_fetch(&b->wait_count, b->thread_count); in barrier_wait()
/external/chromium-trace/catapult/third_party/gsutil/gslib/tests/
Dtest_parallelism_framework.py133 thread_count = args[1]
137 thread_count=thread_count,
144 thread_count=thread_count,
166 thread_count = args[1]
170 thread_count=thread_count,
251 def _RunApply(self, func, args_iterator, process_count, thread_count, argument
258 thread_count=thread_count,
284 def _TestBasicApply(self, process_count, thread_count): argument
285 args = [()] * (17 * process_count * thread_count + 1)
287 results = self._RunApply(_ReturnOneValue, args, process_count, thread_count)
[all …]
/external/v8/test/unittests/base/platform/
Dcondition-variable-unittest.cc221 LoopIncrementThread(int rem, int* counter, int limit, int thread_count, in LoopIncrementThread() argument
227 thread_count_(thread_count), in LoopIncrementThread()
230 EXPECT_LT(rem, thread_count); in LoopIncrementThread()
231 EXPECT_EQ(0, limit % thread_count); in LoopIncrementThread()
271 for (int thread_count = 1; thread_count < kMaxThreadCount; ++thread_count) { in TEST() local
272 int limit = thread_count * 10; in TEST()
276 Thread** threads = new Thread* [thread_count]; in TEST()
277 for (int n = 0; n < thread_count; ++n) { in TEST()
278 threads[n] = new LoopIncrementThread(n, &counter, limit, thread_count, in TEST()
283 for (int n = thread_count - 1; n >= 0; --n) { in TEST()
[all …]
/external/gemmlowp/internal/
Dmulti_thread_gemm.h499 int thread_count = std::min(max_count, CeilQuotient(rows, MinRowsPerThread)); in HowManyThreads() local
505 if (thread_count > 1) { in HowManyThreads()
513 thread_count = in HowManyThreads()
514 std::min(thread_count, int(cubic_size / min_cubic_size_per_thread)); in HowManyThreads()
516 if (thread_count < 1) { in HowManyThreads()
517 thread_count = 1; in HowManyThreads()
521 assert(thread_count > 0 && thread_count <= max_count); in HowManyThreads()
522 return thread_count; in HowManyThreads()
552 const int thread_count = in MultiThreadGemm() local
554 if (thread_count == 1) { in MultiThreadGemm()
[all …]
/external/chromium-trace/catapult/third_party/gsutil/gslib/
Dcommand.py976 def _GetProcessAndThreadCount(self, process_count, thread_count, argument
1007 if not thread_count:
1008 thread_count = boto.config.getint(
1011 if thread_count < 1:
1013 thread_count)
1017 thread_count = 1
1026 self.logger.debug('thread count: %d', thread_count)
1028 return (process_count, thread_count)
1093 thread_count=None, should_return_results=False, argument
1130 (process_count, thread_count) = self._GetProcessAndThreadCount(
[all …]
/external/valgrind/helgrind/tests/
Dannotate_rwlock.c157 const int thread_count = 10; in main() local
158 pthread_t tid[thread_count]; in main()
162 for (i = 0; i < thread_count; i++) in main()
167 for (i = 0; i < thread_count; i++) in main()
/external/libvpx/libvpx/test/
Dencode_perf_test.cc178 char thread_count[32]; in TEST_P() local
179 snprintf(thread_count, sizeof(thread_count), "_t-%d", in TEST_P()
181 display_name += thread_count; in TEST_P()
/external/libchrome/base/synchronization/
Dcondition_variable_unittest.cc69 explicit WorkQueue(int thread_count);
123 bool ThreadSafeCheckShutdown(int thread_count);
494 WorkQueue::WorkQueue(int thread_count) in WorkQueue() argument
499 thread_count_(thread_count), in WorkQueue()
501 thread_handles_(new PlatformThreadHandle[thread_count]), in WorkQueue()
502 assignment_history_(thread_count), in WorkQueue()
503 completion_history_(thread_count), in WorkQueue()
579 bool WorkQueue::ThreadSafeCheckShutdown(int thread_count) { in ThreadSafeCheckShutdown() argument
585 all_shutdown = (shutdown_task_count_ == thread_count); in ThreadSafeCheckShutdown()
/external/webrtc/webrtc/examples/objc/AppRTCDemo/common/
DARDUtilities.m103 mach_msg_type_number_t thread_count;
104 if (task_threads(task, &thread_array, &thread_count) != KERN_SUCCESS) {
112 for (size_t i = 0; i < thread_count; ++i) {
126 sizeof(thread_act_t) * thread_count);
/external/google-breakpad/src/client/mac/handler/
Dexception_handler.cc821 mach_msg_type_number_t thread_count; in SuspendThreads() local
823 if (task_threads(mach_task_self(), &threads_for_task, &thread_count)) in SuspendThreads()
827 for (unsigned int i = 0; i < thread_count; ++i) { in SuspendThreads()
839 mach_msg_type_number_t thread_count; in ResumeThreads() local
841 if (task_threads(mach_task_self(), &threads_for_task, &thread_count)) in ResumeThreads()
845 for (unsigned int i = 0; i < thread_count; ++i) { in ResumeThreads()
/external/protobuf/gtest/src/
Dgtest-death-test.cc170 static String DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument
174 if (thread_count == 0) in DeathTestThreadWarning()
177 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning()
739 const size_t thread_count = GetThreadCount(); in AssumeRole() local
740 if (thread_count != 1) { in AssumeRole()
741 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()
Dgtest-port.cc84 mach_msg_type_number_t thread_count; in GetThreadCount() local
86 const kern_return_t status = task_threads(task, &thread_list, &thread_count); in GetThreadCount()
92 sizeof(thread_t) * thread_count); in GetThreadCount()
93 return static_cast<size_t>(thread_count); in GetThreadCount()
/external/google-breakpad/src/client/mac/tests/
Dminidump_generator_test.cc122 ASSERT_EQ((unsigned int)1, thread_list->thread_count()); in TEST_F()
213 ASSERT_EQ((unsigned int)1, thread_list->thread_count()); in TEST_F()
303 ASSERT_EQ((unsigned int)1, thread_list->thread_count()); in TEST_F()
/external/webrtc/webrtc/libjingle/xmllite/
Dxmlelement_unittest.cc243 int thread_count = 2; // Was 100, but that's too slow. in TEST() local
248 for (int i = 0; i < thread_count; i++) { in TEST()
254 for (int i = 0; i < thread_count; i++) { in TEST()
/external/google-breakpad/src/processor/
Dminidump.cc1561 uint32_t thread_count; in Read() local
1562 if (expected_size < sizeof(thread_count)) { in Read()
1564 expected_size << " < " << sizeof(thread_count); in Read()
1567 if (!minidump_->ReadBytes(&thread_count, sizeof(thread_count))) { in Read()
1573 Swap(&thread_count); in Read()
1575 if (thread_count > numeric_limits<uint32_t>::max() / sizeof(MDRawThread)) { in Read()
1576 BPLOG(ERROR) << "MinidumpThreadList thread count " << thread_count << in Read()
1581 if (expected_size != sizeof(thread_count) + in Read()
1582 thread_count * sizeof(MDRawThread)) { in Read()
1584 if (expected_size == sizeof(thread_count) + 4 + in Read()
[all …]
/external/llvm/utils/unittest/googletest/src/
Dgtest-death-test.cc179 static String DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument
183 if (thread_count == 0) in DeathTestThreadWarning()
186 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning()
789 const size_t thread_count = GetThreadCount(); in AssumeRole() local
790 if (thread_count != 1) { in AssumeRole()
791 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()
Dgtest-port.cc86 mach_msg_type_number_t thread_count; in GetThreadCount() local
88 const kern_return_t status = task_threads(task, &thread_list, &thread_count); in GetThreadCount()
94 sizeof(thread_t) * thread_count); in GetThreadCount()
95 return static_cast<size_t>(thread_count); in GetThreadCount()
/external/mesa3d/src/gtest/src/
Dgtest-death-test.cc179 static String DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument
183 if (thread_count == 0) in DeathTestThreadWarning()
186 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning()
787 const size_t thread_count = GetThreadCount(); in AssumeRole() local
788 if (thread_count != 1) { in AssumeRole()
789 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()
Dgtest-port.cc86 mach_msg_type_number_t thread_count; in GetThreadCount() local
88 const kern_return_t status = task_threads(task, &thread_list, &thread_count); in GetThreadCount()
94 sizeof(thread_t) * thread_count); in GetThreadCount()
95 return static_cast<size_t>(thread_count); in GetThreadCount()
/external/google-breakpad/src/testing/gtest/src/
Dgtest-port.cc91 mach_msg_type_number_t thread_count; in GetThreadCount() local
93 const kern_return_t status = task_threads(task, &thread_list, &thread_count); in GetThreadCount()
99 sizeof(thread_t) * thread_count); in GetThreadCount()
100 return static_cast<size_t>(thread_count); in GetThreadCount()
Dgtest-death-test.cc217 static String DeathTestThreadWarning(size_t thread_count) { in DeathTestThreadWarning() argument
221 if (thread_count == 0) in DeathTestThreadWarning()
224 msg << "detected " << thread_count << " threads."; in DeathTestThreadWarning()
825 const size_t thread_count = GetThreadCount(); in AssumeRole() local
826 if (thread_count != 1) { in AssumeRole()
827 GTEST_LOG_(WARNING) << DeathTestThreadWarning(thread_count); in AssumeRole()

123