2
* Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
3
* University Research and Technology
4
* Corporation. All rights reserved.
5
* Copyright (c) 2004-2005 The University of Tennessee and The University
6
* of Tennessee Research Foundation. All rights
8
* Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
9
* University of Stuttgart. All rights reserved.
12
* Additional copyrights may follow
16
#include "orte_config.h"
23
#include "opal/util/trace.h"
25
#include "orte/orte_constants.h"
26
#include "orte/dss/dss.h"
27
#include "orte/mca/rmgr/base/base.h"
28
#include "orte/mca/errmgr/errmgr.h"
35
int orte_rmgr_base_pack_cmd(orte_buffer_t* buffer, orte_rmgr_cmd_t cmd, orte_jobid_t jobid)
41
rc = orte_dss.pack(buffer, &cmd, 1, ORTE_RMGR_CMD);
42
if(ORTE_SUCCESS != rc) {
47
rc = orte_dss.pack(buffer, &jobid, 1, ORTE_JOBID);
48
if(ORTE_SUCCESS != rc) {
59
int orte_rmgr_base_pack_create_cmd(
60
orte_buffer_t* buffer,
61
orte_app_context_t** context,
66
orte_rmgr_cmd_t cmd = ORTE_RMGR_CMD_CREATE;
70
rc = orte_dss.pack(buffer, &cmd, 1, ORTE_RMGR_CMD);
71
if(ORTE_SUCCESS != rc) {
76
rc = orte_dss.pack(buffer, &num_context, 1, ORTE_SIZE);
77
if(ORTE_SUCCESS != rc) {
81
rc = orte_dss.pack(buffer, context, num_context, ORTE_APP_CONTEXT);
82
if(ORTE_SUCCESS != rc) {
90
int orte_rmgr_base_pack_terminate_proc_cmd(
91
orte_buffer_t* buffer,
92
const orte_process_name_t* name)
96
orte_rmgr_cmd_t cmd = ORTE_RMGR_CMD_CREATE;
100
rc = orte_dss.pack(buffer, &cmd, 1, ORTE_RMGR_CMD);
101
if(ORTE_SUCCESS != rc) {
106
rc = orte_dss.pack(buffer, (void*)name, 1, ORTE_NAME);
107
if(ORTE_SUCCESS != rc) {
115
int orte_rmgr_base_unpack_rsp(
116
orte_buffer_t* buffer)
123
if(ORTE_SUCCESS != (rc = orte_dss.unpack(buffer,&rc,&cnt,ORTE_INT32))) {
130
int orte_rmgr_base_unpack_create_rsp(
131
orte_buffer_t* buffer,
140
if(ORTE_SUCCESS != (rc = orte_dss.unpack(buffer,jobid,&cnt,ORTE_JOBID))) {
145
if(ORTE_SUCCESS != (rc = orte_dss.unpack(buffer,&rc,&cnt,ORTE_INT32))) {