Lines Matching refs:num_threads
100 int num_threads = 1;
994 int setup_shared_mem(int num_threads, int num_files, int depth,
1002 total_ram = num_files * depth * padded_reclen + num_threads;
1069 for (i = 0 ; i < num_threads ; i++) {
1106 if (num_threads > 1) {
1109 if (threads_starting == num_threads) {
1114 while (threads_starting != num_threads)
1178 if (num_threads > 1) {
1181 if (threads_ending == num_threads) {
1186 while(threads_ending != num_threads)
1213 int run_workers(struct thread_info *t, int num_threads)
1219 for(i = 0 ; i < num_threads ; i++) {
1226 for(i = 0 ; i < num_threads ; i++) {
1380 num_threads = atoi(optarg);
1414 if (num_threads > (num_files * num_contexts)) {
1415 num_threads = num_files * num_contexts;
1417 num_threads);
1420 t = malloc(num_threads * sizeof(*t));
1463 num_threads, num_files, num_contexts,
1469 thread_index = open_fds % num_threads;
1486 if (setup_shared_mem(num_threads, num_files * num_contexts,
1491 for (i = 0 ; i < num_threads ; i++) {
1495 if (num_threads > 1){
1496 printf("Running multi thread version num_threads:%d\n", num_threads);
1497 run_workers(t, num_threads);
