Searched refs:num_reduce_threads (Results 1 - 3 of 3) sorted by path

/barrelfish-2018-10-04/lib/phoenix/
H A Dmap_reduce.c137 int num_reduce_threads; /* # of threads for reduce tasks. */ member in struct:__anon1376
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);
[all...]
H A Dmap_reduce.h157 int num_reduce_threads; /* # of threads to run reduce tasks on. member in struct:__anon1383
/barrelfish-2018-10-04/usr/tests/phoenix_tests/
H A Dkmeans.c411 map_reduce_args.num_reduce_threads = atoi(GETENV("MR_NUMTHREADS"));//16;

Completed in 69 milliseconds