diff --git a/src/mca/rmgr/base/rmgr_base_pack.c b/src/mca/rmgr/base/rmgr_base_pack.c index 0854cbdbcc..f4d2ca930e 100644 --- a/src/mca/rmgr/base/rmgr_base_pack.c +++ b/src/mca/rmgr/base/rmgr_base_pack.c @@ -63,7 +63,7 @@ int orte_rmgr_base_pack_create_cmd( return rc; } - rc = orte_dps.pack(buffer, &num_context, 1, ORTE_UINT32); + rc = orte_dps.pack(buffer, &num_context, 1, ORTE_SIZE); if(ORTE_SUCCESS != rc) { ORTE_ERROR_LOG(rc); return rc; diff --git a/src/mca/rmgr/base/rmgr_base_unpack.c b/src/mca/rmgr/base/rmgr_base_unpack.c index 02821a2851..3ce3cd9a17 100644 --- a/src/mca/rmgr/base/rmgr_base_unpack.c +++ b/src/mca/rmgr/base/rmgr_base_unpack.c @@ -19,6 +19,7 @@ #include #include "include/constants.h" +#include "util/output.h" #include "dps/dps.h" #include "mca/rmgr/base/base.h" #include "mca/errmgr/errmgr.h" @@ -43,7 +44,7 @@ static int orte_rmgr_base_cmd_create(orte_buffer_t* req, orte_buffer_t* rsp) size_t i, cnt, num_context; cnt = 1; - if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &num_context, &cnt, ORTE_UINT32))) { + if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &num_context, &cnt, ORTE_SIZE))) { ORTE_ERROR_LOG(rc); return rc; } @@ -181,20 +182,28 @@ int orte_rmgr_base_cmd_dispatch(orte_buffer_t* req, orte_buffer_t* rsp) switch(cmd) { case ORTE_RMGR_CMD_QUERY: + ompi_output(0, "RMGR: query"); return orte_rmgr_base_cmd_query(req,rsp); case ORTE_RMGR_CMD_CREATE: + ompi_output(0, "RMGR: create"); return orte_rmgr_base_cmd_create(req,rsp); case ORTE_RMGR_CMD_ALLOCATE: + ompi_output(0, "RMGR: allocate"); return orte_rmgr_base_cmd_allocate(req,rsp); case ORTE_RMGR_CMD_DEALLOCATE: + ompi_output(0, "RMGR: deallocate"); return orte_rmgr_base_cmd_deallocate(req,rsp); case ORTE_RMGR_CMD_MAP: + ompi_output(0, "RMGR: map"); return orte_rmgr_base_cmd_map(req,rsp); case ORTE_RMGR_CMD_LAUNCH: + ompi_output(0, "RMGR: launch"); return orte_rmgr_base_cmd_launch(req,rsp); case ORTE_RMGR_CMD_TERM_JOB: + ompi_output(0, "RMGR: term job"); return orte_rmgr_base_cmd_term_job(req,rsp); case ORTE_RMGR_CMD_TERM_PROC: + ompi_output(0, "RMGR: term proc"); return orte_rmgr_base_cmd_term_proc(req,rsp); default: ORTE_ERROR_LOG(ORTE_ERR_BAD_PARAM);