Lines Matching refs:num_reduce_threads
137 int num_reduce_threads; /* # of threads for reduce tasks. */
400 env->num_reduce_threads = (args->num_reduce_threads > 0) ?
401 args->num_reduce_threads : num_procs;
404 args->num_merge_threads : env->num_reduce_threads;
407 env->num_merge_threads = env->num_reduce_threads / 2;
486 env->num_reduce_threads, sizeof (keyval_arr_t));
503 printf (OUT_PREFIX "num_reduce_threads = %u\n", env->num_reduce_threads);
1278 tq_reset (env->taskQueue, env->num_reduce_threads);
1280 tasks_per_thread = env->num_reduce_tasks / env->num_reduce_threads;
1285 for (tid = 0; tid < env->num_reduce_threads; ++tid) {
1711 num_threads = env->num_reduce_threads;
1870 th_arg.merge_len = env->num_reduce_threads;