lib/phoenix/map_reduce.c

189     TASK_TYPE_T     task_type;          /* Assigned task type. */
513     switch (th_arg->task_type) {
532     tpool_t *tpool, TASK_TYPE_T task_type, thread_arg_t** th_arg_array, int num_workers)
536     switch (task_type) {
567     TASK_TYPE_T     task_type;
581     task_type = th_arg->task_type;
582     num_threads = getNumTaskThreads (env, task_type);
594         cpu = sched_thr_to_cpu (env->schedPolicies[task_type], thread_index + env->args->proc_offset);
604         env->tpool, task_type, &th_arg_array[1], num_threads - 1);
639     switch (task_type)
1703 getNumTaskThreads (mr_env_t* env, TASK_TYPE_T task_type)
1707     switch (task_type)
1734 getCurrThreadIndex (TASK_TYPE_T task_type)
1742     num_threads = getNumTaskThreads (env, task_type);
1832     th_arg.task_type = TASK_TYPE_MAP;
1848     th_arg.task_type = TASK_TYPE_REDUCE;
1868     th_arg.task_type = TASK_TYPE_MERGE;