1
1
This commit was SVN r5766.
Этот коммит содержится в:
Tim Woodall 2005-05-19 16:16:50 +00:00
родитель 95f4def89a
Коммит c77f24aa4b
2 изменённых файлов: 11 добавлений и 2 удалений

Просмотреть файл

@ -63,7 +63,7 @@ int orte_rmgr_base_pack_create_cmd(
return rc; 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) { if(ORTE_SUCCESS != rc) {
ORTE_ERROR_LOG(rc); ORTE_ERROR_LOG(rc);
return rc; return rc;

Просмотреть файл

@ -19,6 +19,7 @@
#include <string.h> #include <string.h>
#include "include/constants.h" #include "include/constants.h"
#include "util/output.h"
#include "dps/dps.h" #include "dps/dps.h"
#include "mca/rmgr/base/base.h" #include "mca/rmgr/base/base.h"
#include "mca/errmgr/errmgr.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; size_t i, cnt, num_context;
cnt = 1; 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); ORTE_ERROR_LOG(rc);
return rc; return rc;
} }
@ -181,20 +182,28 @@ int orte_rmgr_base_cmd_dispatch(orte_buffer_t* req, orte_buffer_t* rsp)
switch(cmd) { switch(cmd) {
case ORTE_RMGR_CMD_QUERY: case ORTE_RMGR_CMD_QUERY:
ompi_output(0, "RMGR: query");
return orte_rmgr_base_cmd_query(req,rsp); return orte_rmgr_base_cmd_query(req,rsp);
case ORTE_RMGR_CMD_CREATE: case ORTE_RMGR_CMD_CREATE:
ompi_output(0, "RMGR: create");
return orte_rmgr_base_cmd_create(req,rsp); return orte_rmgr_base_cmd_create(req,rsp);
case ORTE_RMGR_CMD_ALLOCATE: case ORTE_RMGR_CMD_ALLOCATE:
ompi_output(0, "RMGR: allocate");
return orte_rmgr_base_cmd_allocate(req,rsp); return orte_rmgr_base_cmd_allocate(req,rsp);
case ORTE_RMGR_CMD_DEALLOCATE: case ORTE_RMGR_CMD_DEALLOCATE:
ompi_output(0, "RMGR: deallocate");
return orte_rmgr_base_cmd_deallocate(req,rsp); return orte_rmgr_base_cmd_deallocate(req,rsp);
case ORTE_RMGR_CMD_MAP: case ORTE_RMGR_CMD_MAP:
ompi_output(0, "RMGR: map");
return orte_rmgr_base_cmd_map(req,rsp); return orte_rmgr_base_cmd_map(req,rsp);
case ORTE_RMGR_CMD_LAUNCH: case ORTE_RMGR_CMD_LAUNCH:
ompi_output(0, "RMGR: launch");
return orte_rmgr_base_cmd_launch(req,rsp); return orte_rmgr_base_cmd_launch(req,rsp);
case ORTE_RMGR_CMD_TERM_JOB: case ORTE_RMGR_CMD_TERM_JOB:
ompi_output(0, "RMGR: term job");
return orte_rmgr_base_cmd_term_job(req,rsp); return orte_rmgr_base_cmd_term_job(req,rsp);
case ORTE_RMGR_CMD_TERM_PROC: case ORTE_RMGR_CMD_TERM_PROC:
ompi_output(0, "RMGR: term proc");
return orte_rmgr_base_cmd_term_proc(req,rsp); return orte_rmgr_base_cmd_term_proc(req,rsp);
default: default:
ORTE_ERROR_LOG(ORTE_ERR_BAD_PARAM); ORTE_ERROR_LOG(ORTE_ERR_BAD_PARAM);