Home
last modified time | relevance | path

Searched refs:num_threads (Results 1 – 25 of 31) sorted by relevance

12

/xnu-11215/tests/sched/sched_test_harness/
H A Dsched_runqueue_harness.c129 enqueue_threads(int num_threads, ...) in enqueue_threads() argument
132 va_start(args, num_threads); in enqueue_threads()
133 for (int i = 0; i < num_threads; i++) { in enqueue_threads()
142 for (int i = 0; i < num_threads; i++) { in enqueue_threads_arr()
152 va_start(args, num_threads); in enqueue_threads_rand_order()
153 for (int i = 0; i < num_threads; i++) { in enqueue_threads_rand_order()
165 for (int i = 0; i < num_threads; i++) { in enqueue_threads_arr_rand_order()
169 for (int i = 0; i < num_threads; i++) { in enqueue_threads_arr_rand_order()
209 va_start(args, num_threads); in dequeue_threads_expect_ordered()
211 for (int i = 0; i < num_threads; i++) { in dequeue_threads_expect_ordered()
[all …]
H A Dsched_runqueue_harness.h28 extern void enqueue_threads(int num_threads, ...);
29 extern void enqueue_threads_arr(int num_threads, test_thread_t *threads);
30 extern void enqueue_threads_rand_order(unsigned int random_seed, int num_threads, …
31 … enqueue_threads_arr_rand_order(unsigned int random_seed, int num_threads, test_thread_t …
33 extern int dequeue_threads_expect_ordered(int num_threads, ...);
34 extern int dequeue_threads_expect_ordered_arr(int num_threads, test_thread_t *thr…
/xnu-11215/tools/tests/perf_index/
H A Dtest_file_helper.h8 int test_file_create(char* path, int thread_id, int num_threads, long long length);
9 int test_file_read_setup(char* path, int num_threads, long long length, long long max_file_size);
10 int test_file_read(char* path, int thread_id, int num_threads, long long length, long long max_file…
11 int test_file_read_cleanup(char* path, int num_threads, long long length);
12 int test_file_write_setup(char* path, int num_threads, long long length);
13 int test_file_write(char* path, int thread_id, int num_threads, long long length, long long max_fil…
14 int test_file_write_cleanup(char* path, int num_threads, long long length);
H A Dtest_file_helper.c30 test_file_create(char* path, int thread_id, int num_threads, long long length) in test_file_create() argument
55 test_file_read_setup(char* path, int num_threads, long long length, long long max_file_size) in test_file_read_setup() argument
67 left = MIN(length, max_file_size / num_threads); in test_file_read_setup()
101 filesize = MIN(length, max_file_size / num_threads); in test_file_read()
127 test_file_read_cleanup(char* path, int num_threads, long long length) in test_file_read_cleanup() argument
140 test_file_write_setup(char* path, int num_threads, long long length) in test_file_write_setup() argument
146 fds = (int*)malloc(sizeof(int) * num_threads); in test_file_write_setup()
150 for (i = 0; i < num_threads; i++) { in test_file_write_setup()
185 if (file_offset > max_file_size / num_threads) { in test_file_write()
197 test_file_write_cleanup(char* path, int num_threads, long long length) in test_file_write_cleanup() argument
[all …]
H A Dperf_index.c17 int num_threads; member
46 parsed_args->num_threads = atoi(argv[2]); in parse_args()
139 long long work_size = args.length / args.num_threads; in thread_setup()
140 int work_remainder = args.length % args.num_threads; in thread_setup()
148 if (ready_thread_count == args.num_threads) { in thread_setup()
192 retval = test.setup(args.num_threads, args.length, 0, NULL); in main()
199 threads = (pthread_t*)malloc(sizeof(pthread_t) * args.num_threads); in main()
200 for (thread_index = 0; thread_index < args.num_threads; thread_index++) { in main()
206 if (ready_thread_count != args.num_threads) { in main()
213 for (thread_index = 0; thread_index < args.num_threads; thread_index++) { in main()
[all …]
H A Dperfindex-memory.c63 long long region_len = memsize / num_threads / 2;
64 long long region_start = memsize / num_threads * thread_id / 2;
67 if (thread_id < memsize / 2 % num_threads) {
71 region_start += memsize / 2 % num_threads;
H A Dperf_index.h4 #define DECL_SETUP int setup(int num_threads, long long length, int test_argc, const void** test_ar…
5 #define DECL_TEST int execute(int thread_id, int num_threads, long long length, int test_argc, cons…
6 #define DECL_CLEANUP int cleanup(int num_threads, long long length)
H A Dperfindex-file_write.c19 return test_file_write_setup(tempdir, num_threads, length);
23 return test_file_write(tempdir, thread_id, num_threads, length, 0L);
29 retval = test_file_write_cleanup(tempdir, num_threads, length);
H A Dperfindex-file_read.c18 return test_file_read_setup(tempdir, num_threads, length, 0L);
22 return test_file_read(tempdir, thread_id, num_threads, length, 0L);
28 retval = test_file_read_cleanup(tempdir, num_threads, length);
H A Dperfindex-ram_file_write.c19 return test_file_write_setup(ramdisk_path, num_threads, length);
23 return test_file_write(ramdisk_path, thread_id, num_threads, length, 0L);
29 retval = test_file_write_cleanup(ramdisk_path, num_threads, length);
H A Dtest_controller.py19 def main(num_clients, test_type, num_threads, job_size, args): argument
27 msg = "\0".join(["%s\0%d\0%d" % (test_type, num_threads, job_size)] + args) + "\0\0"
59 num_threads = int(sys.argv[3]) variable
65 print(main(num_clients, test_type, num_threads, job_size, args))
H A Dperfindex-ram_file_read.c19 return test_file_read_setup(ramdisk_path, num_threads, length, 0L);
23 return test_file_read(ramdisk_path, thread_id, num_threads, length, 0L);
29 retval = test_file_read_cleanup(ramdisk_path, num_threads, length);
H A Dtest_fault_helper.c43 test_fault_helper(int thread_id, int num_threads, long long length, testtype_t testtype) in test_fault_helper() argument
50 long long region_len = num_pages / num_threads; in test_fault_helper()
54 if (thread_id < num_pages % num_threads) { in test_fault_helper()
58 region_start += num_pages % num_threads; in test_fault_helper()
H A Dperfindex-fault.c9 return test_fault_helper(thread_id, num_threads, length, TESTFAULT);
H A Dperfindex-zfod.c9 return test_fault_helper(thread_id, num_threads, length, TESTZFOD);
H A Dtest_fault_helper.h10 int test_fault_helper(int thread_id, int num_threads, long long length, testtype_t testtype);
H A Dperfindex-file_create.c23 return test_file_create(tempdir, thread_id, num_threads, length);
H A Dperfindex-ram_file_create.c23 return test_file_create(ramdisk_path, thread_id, num_threads, length);
/xnu-11215/tests/
H A Dperf_vmfault.c61 static int num_threads; variable
159 for (i = 0; i < num_threads; i++) { in map_mem_regions_multiple()
162 region_len = num_pages / (size_t)num_threads; in map_mem_regions_multiple()
214 for (i = 0; i < num_threads; i++) { in setup_per_thread_regions()
240 for (i = 0; i < num_threads; i++) { in unmap_mem_regions()
277 if (ready_thread_count == num_threads) { in thread_setup()
288 if (finished_thread_count == num_threads) { in thread_setup()
321 while (ready_thread_count != num_threads) { in execute_threads()
364 T_LOG("No. of threads: %d", num_threads); in run_test()
392 num_threads = threads; in setup_and_run_test()
[all …]
H A Dmanual_wq_cooperative.c23 req_cooperative_wq_threads(qos_class_t qos, size_t num_threads) in req_cooperative_wq_threads() argument
27 for (size_t i = 0; i < num_threads; i++) { in req_cooperative_wq_threads()
37 req_wq_threads(qos_class_t qos, size_t num_threads, bool overcommit) in req_wq_threads() argument
41 for (size_t i = 0; i < num_threads; i++) { in req_wq_threads()
/xnu-11215/tests/sched/
H A Dthread_group_flags.c123 start_threads(void *(*func)(void *), struct thread_data *datas, int num_threads) in start_threads() argument
126 pthread_t *threads = (pthread_t *)malloc(sizeof(pthread_t) * num_threads); in start_threads()
130 for (int i = 0; i < num_threads; i++) { in start_threads()
141 start_test(ktrace_session_t session, pthread_t *threads, int num_threads) in start_test() argument
145 for (int i = 0; i < num_threads; i++) { in start_test()
335 search_for_pid_based_tg_flags_tracepoints(char *trace_path, int num_threads, struct thread_data *da… in search_for_pid_based_tg_flags_tracepoints() argument
394 int num_threads = 1; variable
401 …__block struct thread_data *datas = (struct thread_data *)calloc(num_threads, sizeof(struct thread…
403 search_for_pid_based_tg_flags_tracepoints(filepath, num_threads, datas);
409 __block pthread_t *threads = start_threads(join_leave_pid_based, datas, num_threads);
[all …]
H A Dyield_aggressor.c109 static unsigned int num_iterations, num_threads; variable
123 if (atomic_fetch_add(&done_threads, 1) == num_threads - 1) { in thread_fn()
142 for (unsigned int i = 0; i < num_threads; i++) { in start_threads()
185 pdwriter_record_variable_dbl(writer, "num_threads", num_threads); in write_independent_variables()
223 num_threads = thread_count; in run_yielding_test()
232 pthread_t threads[num_threads]; in run_yielding_test()
235 for (uint32_t i = 0; i < num_threads; i++) { in run_yielding_test()
260 T_LOG("All %u threads finished yielding %u times each", num_threads, num_iterations); in run_yielding_test()
H A Dclutch_runqueue.c83 int num_threads = TH_BUCKET_SCHED_MAX - 1; variable
84 test_thread_t threads[num_threads];
85 test_thread_t rev_threads[num_threads];
86 test_thread_t warper_threads[num_threads];
89 rev_threads[num_threads - bucket] = threads[bucket - 1];
261 int num_threads = TH_BUCKET_SCHED_MAX - 1; variable
262 test_thread_t threads[num_threads];
263 test_thread_t rev_threads[num_threads];
264 test_thread_t warper_threads[num_threads];
267 rev_threads[num_threads - bucket] = threads[bucket - 1];
[all …]
H A Dall_cores_running.c48 …threads(pthread_t *threads, void *(*start_routine)(void *), int priority, unsigned int num_threads) in start_threads() argument
56 for (unsigned int i = 0; i < num_threads; i++) { in start_threads()
168 unsigned int num_threads = (unsigned int)dt_ncpu() * 2;
169 T_LOG("Launching %u threads to spin for %lld seconds...", num_threads, spin_seconds);
171 pthread_t threads[num_threads];
172 start_threads(threads, &spin_thread_fn, DEFAULT_THREAD_PRI, num_threads);
/xnu-11215/tools/tests/affinity/
H A Dtags.c86 mach_msg_type_number_t num_threads; in main() local
122 ret = task_threads(port, &thread_array, &num_threads); in main()
127 for (i = 0; i < num_threads; i++) { in main()
134 for (i = 0; i < num_threads; i++) { in main()

12