Changeset 5630

Show
Ignore:
Timestamp:
10/29/09 23:03:39 (4 weeks ago)
Author:
balaji
Message:

Use consistent naming convention for the process-core binding
parameters in the upper layers as the binding library itself.

Location:
mpich2/trunk/src/pm/hydra
Files:
5 modified

Legend:

Unmodified
Added
Removed

  • mpich2/trunk/src/pm/hydra/include/hydra_tools.h

    r5472 r5630  
    1313HYD_status HYDT_bind_init(char *binding, char *bindlib); 
    1414void HYDT_bind_finalize(void); 
    15 HYD_status HYDT_bind_process(int core); 
    16 int HYDT_bind_get_core_id(int id); 
     15HYD_status HYDT_bind_process(int proc_unit_id); 
     16int HYDT_bind_get_proc_unit_id(int process_id); 
    1717 
    1818/* checkpointing */ 

  • mpich2/trunk/src/pm/hydra/include/hydra_utils.h

    r5527 r5630  
    161161 
    162162HYD_status HYDU_create_process(char **client_arg, HYD_env_t * env_list, 
    163                                int *in, int *out, int *err, int *pid, int core); 
    164 HYD_status HYDU_fork_and_exit(int core); 
     163                               int *in, int *out, int *err, int *pid, int proc_unit_id); 
     164HYD_status HYDU_fork_and_exit(int proc_unit_id); 
    165165#if defined HAVE_THREAD_SUPPORT 
    166166HYD_status HYDU_create_thread(void *(*func) (void *), void *args, 

  • mpich2/trunk/src/pm/hydra/pm/pmiserv/pmi_proxy_utils.c

    r5474 r5630  
    479479HYD_status HYD_pmcd_pmi_proxy_launch_procs(void) 
    480480{ 
    481     int i, j, arg, stdin_fd, process_id, core, pmi_id; 
     481    int i, j, arg, stdin_fd, process_id, proc_unit_id, pmi_id; 
    482482    char *str, *envstr, *list; 
    483483    char *client_args[HYD_NUM_TMP_STRINGS]; 
    … …  
    630630            client_args[arg++] = NULL; 
    631631 
    632             core = HYDT_bind_get_core_id(process_id); 
     632            proc_unit_id = HYDT_bind_get_proc_unit_id(process_id); 
    633633            if (pmi_id == 0) { 
    634634                status = HYDU_create_process(client_args, prop_env, 
    … …  
    636636                                             &HYD_pmcd_pmip.downstream.out[process_id], 
    637637                                             &HYD_pmcd_pmip.downstream.err[process_id], 
    638                                              &HYD_pmcd_pmip.downstream.pid[process_id], core); 
     638                                             &HYD_pmcd_pmip.downstream.pid[process_id], 
     639                                             proc_unit_id); 
    639640 
    640641                HYD_pmcd_pmip.local.stdin_buf_offset = 0; 
    … …  
    653654                                             &HYD_pmcd_pmip.downstream.out[process_id], 
    654655                                             &HYD_pmcd_pmip.downstream.err[process_id], 
    655                                              &HYD_pmcd_pmip.downstream.pid[process_id], core); 
     656                                             &HYD_pmcd_pmip.downstream.pid[process_id], 
     657                                             proc_unit_id); 
    656658            } 
    657659            HYDU_ERR_POP(status, "create process returned error\n"); 

  • mpich2/trunk/src/pm/hydra/tools/bind/bind.c

    r5629 r5630  
    188188 
    189189 
    190 int HYDT_bind_get_core_id(int id) 
     190int HYDT_bind_get_proc_unit_id(int id) 
    191191{ 
    192192    return HYDT_bind_info.bindmap[id % HYDT_bind_info.num_procs]; 

  • mpich2/trunk/src/pm/hydra/utils/launch/launch.c

    r5472 r5630  
    99 
    1010HYD_status HYDU_create_process(char **client_arg, HYD_env_t * env_list, 
    11                                int *in, int *out, int *err, int *pid, int core) 
     11                               int *in, int *out, int *err, int *pid, int proc_unit_id) 
    1212{ 
    1313    int inpipe[2], outpipe[2], errpipe[2], tpid; 
    … …  
    6060        } 
    6161 
    62         if (core >= 0) { 
    63             status = HYDT_bind_process(core); 
     62        if (proc_unit_id >= 0) { 
     63            status = HYDT_bind_process(proc_unit_id); 
    6464            HYDU_ERR_POP(status, "bind process failed\n"); 
    6565        } 
    … …  
    101101 
    102102 
    103 HYD_status HYDU_fork_and_exit(int core) 
     103HYD_status HYDU_fork_and_exit(int proc_unit_id) 
    104104{ 
    105105    pid_t tpid; 
    … …  
    115115        close(2); 
    116116 
    117         if (core >= 0) { 
    118             status = HYDT_bind_process(core); 
     117        if (proc_unit_id >= 0) { 
     118            status = HYDT_bind_process(proc_unit_id); 
    119119            HYDU_ERR_POP(status, "bind process failed\n"); 
    120120        }