Skip to content

Commit ef29fb1

Browse files
npe9hppritcha
authored andcommitted
de-ORTEfy the ompi tree
The ompi tree should be runtime independent, but over time a few ORTE depedent definitions and functions have escaped into the ompi tree. I'm working on my own runtime so I've used this as an opportunity to get rid of ORTE dependencies in the ompi/ tree. I still need to go back and change orte to conform to the new world and these changes are untested, but I can now compile (but not link) without orte so I'm commiting this changeset. Signed-off-by: Noah Evans <[email protected]>
1 parent 88a4a16 commit ef29fb1

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

ompi/communicator/comm.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1768,8 +1768,8 @@ int ompi_comm_determine_first ( ompi_communicator_t *intercomm, int high )
17681768
theirproc = ompi_group_peer_lookup(intercomm->c_remote_group,0);
17691769

17701770
mask = OMPI_RTE_CMP_JOBID | OMPI_RTE_CMP_VPID;
1771-
rc = ompi_rte_compare_name_fields(mask, (const orte_process_name_t*)&(ourproc->super.proc_name),
1772-
(const orte_process_name_t*)&(theirproc->super.proc_name));
1771+
rc = ompi_rte_compare_name_fields(mask, (const ompi_process_name_t*)&(ourproc->super.proc_name),
1772+
(const ompi_process_name_t*)&(theirproc->super.proc_name));
17731773
if ( 0 > rc ) {
17741774
flag = true;
17751775
}

ompi/dpm/dpm.c

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -158,8 +158,8 @@ int ompi_dpm_connect_accept(ompi_communicator_t *comm, int root,
158158
sizeof(ompi_proc_t *));
159159
for (i=0 ; i<group->grp_proc_count ; i++) {
160160
if (NULL == (proc_list[i] = ompi_group_peer_lookup(group,i))) {
161-
ORTE_ERROR_LOG(ORTE_ERR_NOT_FOUND);
162-
rc = ORTE_ERR_NOT_FOUND;
161+
OMPI_ERROR_LOG(OMPI_ERR_NOT_FOUND);
162+
rc = OMPI_ERR_NOT_FOUND;
163163
free(proc_list);
164164
goto exit;
165165
}
@@ -665,10 +665,10 @@ int ompi_dpm_spawn(int count, const char *array_of_commands[],
665665
for (i = 0; i < count; ++i) {
666666
app = OBJ_NEW(opal_pmix_app_t);
667667
if (NULL == app) {
668-
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
668+
OMPI_ERROR_LOG(OMPI_ERR_OUT_OF_RESOURCE);
669669
OPAL_LIST_DESTRUCT(&apps);
670670
opal_progress_event_users_decrement();
671-
return ORTE_ERR_OUT_OF_RESOURCE;
671+
return OMPI_ERR_OUT_OF_RESOURCE;
672672
}
673673
/* add the app to the job data */
674674
opal_list_append(&apps, &app->super);
@@ -893,9 +893,9 @@ int ompi_dpm_spawn(int count, const char *array_of_commands[],
893893
ompi_info_get (array_of_info[i], "ompi_stdin_target", sizeof(stdin_target) - 1, stdin_target, &flag);
894894
if ( flag ) {
895895
if (0 == strcmp(stdin_target, "all")) {
896-
ui32 = ORTE_VPID_WILDCARD;
896+
ui32 = OPAL_VPID_WILDCARD;
897897
} else if (0 == strcmp(stdin_target, "none")) {
898-
ui32 = ORTE_VPID_INVALID;
898+
ui32 = OPAL_VPID_INVALID;
899899
} else {
900900
ui32 = strtoul(stdin_target, NULL, 10);
901901
}
@@ -911,7 +911,7 @@ int ompi_dpm_spawn(int count, const char *array_of_commands[],
911911
*/
912912
if ( !have_wdir ) {
913913
if (OMPI_SUCCESS != (rc = opal_getcwd(cwd, OPAL_PATH_MAX))) {
914-
ORTE_ERROR_LOG(rc);
914+
OMPI_ERROR_LOG(rc);
915915
OPAL_LIST_DESTRUCT(&apps);
916916
opal_progress_event_users_decrement();
917917
return rc;

ompi/mca/topo/treematch/topo_treematch_dist_graph_create.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -888,16 +888,16 @@ int mca_topo_treematch_dist_graph_create(mca_topo_base_module_t* topo_module,
888888
kv.type = OPAL_STRING;
889889
kv.data.string = strdup(set_as_string);
890890

891-
(void)opal_pmix.store_local((opal_process_name_t*)ORTE_PROC_MY_NAME, &kv);
891+
(void)opal_pmix.store_local((opal_process_name_t*)OMPI_PROC_MY_NAME, &kv);
892892
OBJ_DESTRUCT(&kv);
893893

894894
locality = opal_hwloc_base_get_relative_locality(opal_hwloc_topology,
895-
orte_process_info.cpuset,set_as_string);
895+
ompi_process_info.cpuset,set_as_string);
896896
OBJ_CONSTRUCT(&kv, opal_value_t);
897897
kv.key = strdup(OPAL_PMIX_LOCALITY);
898898
kv.type = OPAL_UINT16;
899899
kv.data.uint16 = locality;
900-
(void)opal_pmix.store_local((opal_process_name_t*)ORTE_PROC_MY_NAME, &kv);
900+
(void)opal_pmix.store_local((opal_process_name_t*)OMPI_PROC_MY_NAME, &kv);
901901
OBJ_DESTRUCT(&kv);
902902

903903
if( OMPI_SUCCESS != (err = ompi_comm_create(comm_old,

0 commit comments

Comments
 (0)