Skip to content

Commit aa78f90

Browse files
author
Ralph Castain
committed
Add some missing info to the job map so remote procs get their app_rank
1 parent 0e433ea commit aa78f90

File tree

2 files changed

+15
-0
lines changed

2 files changed

+15
-0
lines changed

orte/runtime/data_type_support/orte_dt_packing_fns.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -346,6 +346,13 @@ int orte_dt_pack_proc(opal_buffer_t *buffer, const void *src,
346346
return rc;
347347
}
348348

349+
/* pack the app rank */
350+
if (ORTE_SUCCESS != (rc = opal_dss_pack_buffer(buffer,
351+
(void*)(&(procs[i]->app_rank)), 1, OPAL_UINT32))) {
352+
ORTE_ERROR_LOG(rc);
353+
return rc;
354+
}
355+
349356
/* pack the attributes that will go */
350357
count = 0;
351358
OPAL_LIST_FOREACH(kv, &procs[i]->attributes, orte_attribute_t) {

orte/runtime/data_type_support/orte_dt_unpacking_fns.c

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -380,6 +380,14 @@ int orte_dt_unpack_proc(opal_buffer_t *buffer, void *dest,
380380
return rc;
381381
}
382382

383+
/* unpack the app_rank */
384+
n = 1;
385+
if (ORTE_SUCCESS != (rc = opal_dss_unpack_buffer(buffer,
386+
(&(procs[i]->app_rank)), &n, OPAL_UINT32))) {
387+
ORTE_ERROR_LOG(rc);
388+
return rc;
389+
}
390+
383391
/* unpack the attributes */
384392
n=1;
385393
if (ORTE_SUCCESS != (rc = opal_dss_unpack_buffer(buffer, &count,

0 commit comments

Comments
 (0)