ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Continue to lace the trace functionality into orte...

Просмотр исходного кода 
This commit was SVN r7427.
Этот коммит содержится в:
Ralph Castain 2005-09-19 15:29:14 +00:00
родитель 09869daf8e
Коммит b589a93e29
53 изменённых файлов: 738 добавлений и 236 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

3
orte/mca/errmgr/base/errmgr_base_close.c
Просмотреть файл

@ -19,6 +19,7 @@
#include <stdio.h>
#include "include/orte_constants.h"
#include "opal/util/trace.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/errmgr/base/base.h"
@ -26,6 +27,8 @@
int orte_errmgr_base_close(void)
{
OPAL_TRACE(5);
/* If we have a selected component and module, then finalize it */
if (orte_errmgr_base_selected) {

15
orte/mca/errmgr/base/errmgr_base_fns.c
Просмотреть файл

@ -26,6 +26,7 @@
#include "runtime/runtime.h"
#include "runtime/orte_wait.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "util/proc_info.h"
#include "mca/ns/ns.h"
@ -36,6 +37,8 @@
void orte_errmgr_base_log(int error_code, char *filename, int line)
{
OPAL_TRACE(1);
if (NULL == orte_process_info.my_name) {
opal_output(0, "[NO-NAME] ORTE_ERROR_LOG: %s in file %s at line %d",
ORTE_ERROR_NAME(error_code), filename, line);
@ -52,6 +55,8 @@ void orte_errmgr_base_proc_aborted(orte_process_name_t *proc)
orte_jobid_t job;
int rc;
OPAL_TRACE(1);
if (ORTE_SUCCESS != (rc = orte_ns.get_jobid(&job, proc))) {
ORTE_ERROR_LOG(rc);
return;
@ -62,15 +67,21 @@ void orte_errmgr_base_proc_aborted(orte_process_name_t *proc)
void orte_errmgr_base_incomplete_start(orte_jobid_t job)
{
orte_rmgr.terminate_job(job);
OPAL_TRACE(1);
orte_rmgr.terminate_job(job);
}
void orte_errmgr_base_error_detected(int error_code)
{
OPAL_TRACE(1);
}
void orte_errmgr_base_abort()
{
OPAL_TRACE(1);
/* kill and reap all children */
orte_wait_kill(9);
@ -84,5 +95,7 @@ int orte_errmgr_base_register_job(orte_jobid_t job)
* changing to abnormal termination codes
*/
OPAL_TRACE(1);
return ORTE_SUCCESS;
}

3
orte/mca/errmgr/base/errmgr_base_open.c
Просмотреть файл

@ -22,6 +22,7 @@
#include "mca/base/base.h"
#include "mca/base/mca_base_param.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "mca/errmgr/base/base.h"
@ -63,6 +64,8 @@ int orte_errmgr_base_open(void)
{
int param, value;
OPAL_TRACE(5);
if (!orte_errmgr_initialized) { /* ensure we only do this once */
/* Debugging / verbose output */

28
orte/mca/gpr/base/data_type_support/gpr_data_type_packing_fns.c
Просмотреть файл

@ -21,6 +21,8 @@
#include <netinet/in.h>
#endif
#include "opal/util/trace.h"
#include "mca/errmgr/errmgr.h"
#include "dps/dps_internal.h"
@ -34,6 +36,8 @@ int orte_gpr_base_pack_cmd(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_CMD_T))) {
ORTE_ERROR_LOG(rc);
}
@ -49,6 +53,8 @@ int orte_gpr_base_pack_subscription_id(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_SUBSCRIPTION_ID_T))) {
ORTE_ERROR_LOG(rc);
}
@ -64,6 +70,8 @@ int orte_gpr_base_pack_trigger_id(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_TRIGGER_ID_T))) {
ORTE_ERROR_LOG(rc);
}
@ -79,6 +87,8 @@ int orte_gpr_base_pack_notify_action(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_NOTIFY_ACTION_T))) {
ORTE_ERROR_LOG(rc);
}
@ -94,6 +104,8 @@ int orte_gpr_base_pack_trigger_action(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_TRIGGER_ACTION_T))) {
ORTE_ERROR_LOG(rc);
}
@ -109,6 +121,8 @@ int orte_gpr_base_pack_addr_mode(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_ADDR_MODE_T))) {
ORTE_ERROR_LOG(rc);
}
@ -124,6 +138,8 @@ int orte_gpr_base_pack_notify_msg_type(orte_buffer_t *buffer, void *src,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_pack_buffer(buffer, src, num_vals, ORTE_GPR_NOTIFY_MSG_TYPE_T))) {
ORTE_ERROR_LOG(rc);
}
@ -142,6 +158,8 @@ int orte_gpr_base_pack_keyval(orte_buffer_t *buffer, void *src,
orte_gpr_keyval_t **keyval;
size_t i;
OPAL_TRACE(4);
/* array of pointers to keyval objects - need to pack the
objects */
keyval = (orte_gpr_keyval_t**) src;
@ -182,6 +200,8 @@ int orte_gpr_base_pack_value(orte_buffer_t *buffer, void *src,
orte_gpr_value_t **values;
size_t i;
OPAL_TRACE(4);
/* array of pointers to value objects - need to pack the objects */
values = (orte_gpr_value_t**) src;
for (i=0; i<num_vals; i++) {
@ -245,6 +265,8 @@ int orte_gpr_base_pack_subscription(orte_buffer_t *buffer, void *src,
orte_gpr_subscription_t **subs;
size_t i;
OPAL_TRACE(4);
/* array of pointers to subscription objects - need to pack the objects */
subs = (orte_gpr_subscription_t**) src;
for (i=0; i<num_vals; i++) {
@ -301,6 +323,8 @@ int orte_gpr_base_pack_trigger(orte_buffer_t *buffer, void *src,
orte_gpr_trigger_t **trigs;
size_t i;
OPAL_TRACE(4);
/* array of pointers to trigger objects - need to pack the objects */
trigs = (orte_gpr_trigger_t**) src;
for (i=0; i<num_vals; i++) {
@ -356,6 +380,8 @@ int orte_gpr_base_pack_notify_data(orte_buffer_t *buffer, void *src,
orte_gpr_value_t **values;
size_t i, j, k;
OPAL_TRACE(4);
/* array of pointers to notify data objects - need to pack the objects */
data = (orte_gpr_notify_data_t**) src;
@ -421,6 +447,8 @@ int orte_gpr_base_pack_notify_msg(orte_buffer_t *buffer, void *src,
orte_gpr_notify_data_t **data;
size_t i, j, k;
OPAL_TRACE(4);
/* array of messages */
msg = (orte_gpr_notify_message_t**) src;

28
orte/mca/gpr/base/data_type_support/gpr_data_type_unpacking_fns.c
Просмотреть файл

@ -21,6 +21,8 @@
#include <netinet/in.h>
#endif
#include "opal/util/trace.h"
#include "mca/errmgr/errmgr.h"
#include "dps/dps_internal.h"
@ -34,6 +36,8 @@ int orte_gpr_base_unpack_cmd(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_CMD_T))) {
ORTE_ERROR_LOG(rc);
}
@ -49,6 +53,8 @@ int orte_gpr_base_unpack_subscription_id(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_SUBSCRIPTION_ID_T))) {
ORTE_ERROR_LOG(rc);
}
@ -64,6 +70,8 @@ int orte_gpr_base_unpack_trigger_id(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_TRIGGER_ID_T))) {
ORTE_ERROR_LOG(rc);
}
@ -79,6 +87,8 @@ int orte_gpr_base_unpack_notify_action(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_NOTIFY_ACTION_T))) {
ORTE_ERROR_LOG(rc);
}
@ -94,6 +104,8 @@ int orte_gpr_base_unpack_trigger_action(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_TRIGGER_ACTION_T))) {
ORTE_ERROR_LOG(rc);
}
@ -109,6 +121,8 @@ int orte_gpr_base_unpack_notify_msg_type(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_NOTIFY_MSG_TYPE_T))) {
ORTE_ERROR_LOG(rc);
}
@ -124,6 +138,8 @@ int orte_gpr_base_unpack_addr_mode(orte_buffer_t *buffer, void *dest,
{
int rc;
OPAL_TRACE(4);
if (ORTE_SUCCESS != (rc = orte_dps_unpack_buffer(buffer, dest, num_vals, ORTE_GPR_ADDR_MODE_T))) {
ORTE_ERROR_LOG(rc);
}
@ -141,6 +157,8 @@ int orte_gpr_base_unpack_keyval(orte_buffer_t *buffer, void *dest,
orte_gpr_keyval_t **keyval;
size_t i, max_n=1;
OPAL_TRACE(4);
/* unpack into an array of keyval objects */
keyval = (orte_gpr_keyval_t**) dest;
for (i=0; i < *num_vals; i++) {
@ -186,6 +204,8 @@ int orte_gpr_base_unpack_value(orte_buffer_t *buffer, void *dest,
orte_gpr_value_t **values;
size_t i, max_n=1;
OPAL_TRACE(4);
/* unpack into array of value objects */
values = (orte_gpr_value_t**) dest;
for (i=0; i < *num_vals; i++) {
@ -270,6 +290,8 @@ int orte_gpr_base_unpack_subscription(orte_buffer_t *buffer, void *dest,
orte_gpr_subscription_t **subs;
size_t i, max_n=1;
OPAL_TRACE(4);
/* unpack into array of subscription objects */
subs = (orte_gpr_subscription_t**) dest;
for (i=0; i < *num_vals; i++) {
@ -342,6 +364,8 @@ int orte_gpr_base_unpack_trigger(orte_buffer_t *buffer, void *dest,
orte_gpr_trigger_t **trigs;
size_t i, max_n=1;
OPAL_TRACE(4);
/* unpack into array of trigger objects */
trigs = (orte_gpr_trigger_t**) dest;
for (i=0; i < *num_vals; i++) {
@ -411,6 +435,8 @@ int orte_gpr_base_unpack_notify_data(orte_buffer_t *buffer, void *dest,
orte_gpr_value_t **values;
size_t i, j, max_n=1;
OPAL_TRACE(4);
/* unpack into array of notify_data objects */
data = (orte_gpr_notify_data_t**) dest;
@ -483,6 +509,8 @@ int orte_gpr_base_unpack_notify_msg(orte_buffer_t *buffer, void *dest,
orte_gpr_notify_data_t **data;
size_t i, j, max_n=1;
OPAL_TRACE(4);
/* unpack into array of notify_data objects */
msg = (orte_gpr_notify_message_t**) dest;

9
orte/mca/gpr/base/gpr_base_close.c
Просмотреть файл

@ -15,13 +15,18 @@
*/
#include "orte_config.h"
#include "include/orte_constants.h"
#include "mca/gpr/base/base.h"
#include "opal/util/trace.h"
#include "orte/include/orte_constants.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_close(void)
{
OPAL_TRACE(5);
/* If we have a selected component and module, then finalize it */
if (orte_gpr_base_selected) {

14
orte/mca/gpr/base/gpr_base_open.c
Просмотреть файл

@ -15,15 +15,15 @@
*/
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/constants.h"
#include "orte/include/orte_constants.h"
\
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "mca/gpr/base/base.h"
#include "orte/mca/gpr/base/base.h"
@ -312,6 +312,8 @@ int orte_gpr_base_open(void)
int param, value, rc, id;
orte_data_type_t tmp;
OPAL_TRACE(5);
/* Debugging / verbose output */
param = mca_base_param_reg_int_name("gpr_base", "verbose",

8
orte/mca/gpr/base/gpr_base_select.c
Просмотреть файл

@ -16,9 +16,11 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/mca/gpr/base/base.h"
/**
@ -34,6 +36,8 @@ int orte_gpr_base_select(void)
bool multi, hidden;
int priority, best_priority = -1;
OPAL_TRACE(5);
/* Iterate through all the available components */
for (item = opal_list_get_first(&orte_gpr_base_components_available);

5
orte/mca/gpr/base/gpr_base_simplified_put.c
Просмотреть файл

@ -22,6 +22,7 @@
#include "orte/include/orte_constants.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
@ -45,6 +46,8 @@ int orte_gpr_base_put_1(orte_gpr_addr_mode_t addr_mode,
size_t i;
int rc;
OPAL_TRACE(1);
value.addr_mode = addr_mode;
value.segment = segment;
value.cnt = 1;
@ -89,6 +92,8 @@ int orte_gpr_base_put_N(orte_gpr_addr_mode_t addr_mode,
size_t i, j;
int rc;
OPAL_TRACE(1);
value.addr_mode = addr_mode;
value.segment = segment;
value.cnt = n;

9
orte/mca/gpr/base/gpr_base_simplified_subscribe.c
Просмотреть файл

@ -22,6 +22,7 @@
#include "orte/include/orte_constants.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
@ -55,6 +56,8 @@ int orte_gpr_base_subscribe_1(orte_gpr_subscription_id_t *id,
size_t i;
int rc;
OPAL_TRACE(1);
/* assemble the subscription object */
subs = &sub;
sub.name = sub_name;
@ -132,6 +135,8 @@ int orte_gpr_base_subscribe_N(orte_gpr_subscription_id_t *id,
size_t i, j;
int rc;
OPAL_TRACE(1);
/* assemble the subscription object */
subs = &sub;
sub.name = sub_name;
@ -223,6 +228,8 @@ int orte_gpr_base_define_trigger(orte_gpr_trigger_id_t *id,
size_t i, j;
int rc;
OPAL_TRACE(1);
/* check for error - this function can only be used to define triggers
* that compare their values to each other. It cannot be used to define
* triggers that fire when reaching a specified value as there is no
@ -314,6 +321,8 @@ int orte_gpr_base_define_trigger_level(orte_gpr_trigger_id_t *id,
size_t i, j;
int rc;
OPAL_TRACE(1);
/* check for error - this function can only be used to define triggers
* that fire at a specified level. It cannot be used to define
* triggers that compare their values to each other

3
orte/mca/gpr/base/gpr_base_xfer_payload.c
Просмотреть файл

@ -20,6 +20,7 @@
#include "opal/util/argv.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "mca/errmgr/errmgr.h"
@ -32,6 +33,8 @@ int orte_gpr_base_xfer_payload(orte_gpr_value_union_t *dest,
{
size_t i;
OPAL_TRACE(3);
switch(type) {
case ORTE_STRING:

16
orte/mca/gpr/base/pack_api_cmd/gpr_base_pack_arithmetic_ops.c
Просмотреть файл

@ -25,18 +25,22 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_pack_increment_value(orte_buffer_t *cmd, orte_gpr_value_t *value)
{
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_INCREMENT_VALUE_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -58,6 +62,8 @@ int orte_gpr_base_pack_decrement_value(orte_buffer_t *cmd, orte_gpr_value_t *val
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DECREMENT_VALUE_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {

10
orte/mca/gpr/base/pack_api_cmd/gpr_base_pack_cleanup.c
Просмотреть файл

@ -25,15 +25,19 @@
#include "orte_config.h"
#include "dps/dps.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/dps/dps.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_pack_cleanup_job(orte_buffer_t *buffer, orte_jobid_t jobid)
{
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_CLEANUP_JOB_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(buffer, &command, 1, ORTE_GPR_CMD))) {
@ -53,6 +57,8 @@ int orte_gpr_base_pack_cleanup_proc(orte_buffer_t *buffer, orte_process_name_t *
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_CLEANUP_PROC_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(buffer, &command, 1, ORTE_GPR_CMD))) {

16
orte/mca/gpr/base/pack_api_cmd/gpr_base_pack_del_index.c
Просмотреть файл

@ -19,18 +19,22 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "opal/util/trace.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "orte/include/orte_constants.h"
#include "mca/gpr/base/base.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_pack_delete_segment(orte_buffer_t *cmd, char *segment)
{
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DELETE_SEGMENT_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -54,6 +58,8 @@ int orte_gpr_base_pack_delete_entries(orte_buffer_t *cmd,
size_t n;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DELETE_ENTRIES_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -121,6 +127,8 @@ int orte_gpr_base_pack_index(orte_buffer_t *cmd, char *segment)
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_INDEX_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {

18
orte/mca/gpr/base/pack_api_cmd/gpr_base_pack_dump.c
Просмотреть файл

@ -25,16 +25,20 @@
#include "orte_config.h"
#include "opal/util/trace.h"
#include "orte/include/orte_constants.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "mca/gpr/base/base.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_pack_dump_all(orte_buffer_t *cmd)
{
orte_gpr_cmd_flag_t command;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_ALL_CMD;
return orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD);
@ -45,6 +49,8 @@ int orte_gpr_base_pack_dump_segments(orte_buffer_t *cmd, char *segment)
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_SEGMENTS_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -65,6 +71,8 @@ int orte_gpr_base_pack_dump_triggers(orte_buffer_t *cmd, orte_gpr_trigger_id_t s
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_TRIGGERS_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -84,6 +92,8 @@ int orte_gpr_base_pack_dump_subscriptions(orte_buffer_t *cmd, orte_gpr_subscript
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_SUBSCRIPTIONS_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -103,6 +113,8 @@ int orte_gpr_base_pack_dump_a_trigger(orte_buffer_t *cmd, char *name, orte_gpr_t
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_A_TRIGGER_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -128,6 +140,8 @@ int orte_gpr_base_pack_dump_a_subscription(orte_buffer_t *cmd, char *name,
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_A_SUBSCRIPTION_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -152,6 +166,8 @@ int orte_gpr_base_pack_dump_callbacks(orte_buffer_t *cmd)
{
orte_gpr_cmd_flag_t command;
OPAL_TRACE(3);
command = ORTE_GPR_DUMP_CALLBACKS_CMD;
return orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD);

16
orte/mca/gpr/base/pack_api_cmd/gpr_base_pack_put_get.c
Просмотреть файл

@ -25,13 +25,15 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "opal/util/trace.h"
#include "mca/errmgr/errmgr.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "mca/gpr/base/base.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_pack_put(orte_buffer_t *cmd,
size_t cnt, orte_gpr_value_t **values)
@ -39,6 +41,8 @@ int orte_gpr_base_pack_put(orte_buffer_t *cmd,
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_PUT_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -64,6 +68,8 @@ int orte_gpr_base_pack_get(orte_buffer_t *cmd,
int rc;
size_t n;
OPAL_TRACE(3);
command = ORTE_GPR_GET_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {

18
orte/mca/gpr/base/pack_api_cmd/gpr_base_pack_subscribe.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_pack_subscribe(orte_buffer_t *cmd,
size_t num_subs,
@ -42,6 +44,8 @@ int orte_gpr_base_pack_subscribe(orte_buffer_t *cmd,
int rc;
size_t zero=0;
OPAL_TRACE(3);
command = ORTE_GPR_SUBSCRIBE_CMD;
/* can't be both NULL */
@ -94,6 +98,8 @@ int orte_gpr_base_pack_unsubscribe(orte_buffer_t *cmd,
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_UNSUBSCRIBE_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {
@ -112,6 +118,8 @@ int orte_gpr_base_pack_cancel_trigger(orte_buffer_t *cmd, orte_gpr_trigger_id_t
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_CANCEL_TRIGGER_CMD;
if (ORTE_SUCCESS != (rc = orte_dps.pack(cmd, &command, 1, ORTE_GPR_CMD))) {

20
orte/mca/gpr/base/unpack_api_response/gpr_base_dump_notify.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "opal/util/trace.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "opal/util/output.h"
#include "mca/gpr/base/base.h"
#include "orte/mca/gpr/base/base.h"
static void orte_gpr_base_dump_data(orte_buffer_t *buffer, orte_gpr_notify_data_t *data);
@ -43,6 +45,8 @@ int orte_gpr_base_dump_notify_msg(orte_buffer_t *buffer,
orte_gpr_notify_data_t **data;
size_t i, j;
OPAL_TRACE(3);
asprintf(&tmp_out, "\nDUMP OF NOTIFY MESSAGE STRUCTURE");
orte_gpr_base_dump_load_string(buffer, &tmp_out);
@ -95,6 +99,8 @@ int orte_gpr_base_dump_notify_data(orte_buffer_t *buffer,
{
char *tmp_out;
OPAL_TRACE(3);
asprintf(&tmp_out, "\nDUMP OF NOTIFY DATA STRUCTURE");
orte_gpr_base_dump_load_string(buffer, &tmp_out);
@ -115,6 +121,8 @@ static void orte_gpr_base_dump_data(orte_buffer_t *buffer,
orte_gpr_value_t **values;
size_t i, j;
OPAL_TRACE(3);
if (NULL != data->target) {
asprintf(&tmp_out, "%lu values going to subscription target %s",
(unsigned long) data->cnt, data->target);
@ -144,6 +152,8 @@ int orte_gpr_base_dump_value(orte_buffer_t *buffer, orte_gpr_value_t *value)
orte_gpr_addr_mode_t addr;
size_t j;
OPAL_TRACE(3);
if (NULL == value->segment) {
asprintf(&tmp_out, "\tNULL segment name in value - %lu keyvals",
(unsigned long) value->cnt);
@ -242,6 +252,8 @@ void orte_gpr_base_dump_keyval_value(orte_buffer_t *buffer, orte_gpr_keyval_t *i
{
char *tmp_out;
OPAL_TRACE(3);
switch(iptr->type) {
case ORTE_BYTE:

16
orte/mca/gpr/base/unpack_api_response/gpr_base_unpack_arithmetic_ops.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_unpack_increment_value(orte_buffer_t *cmd, int *ret)
{
@ -38,6 +40,8 @@ int orte_gpr_base_unpack_increment_value(orte_buffer_t *cmd, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n=1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(cmd, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -65,6 +69,8 @@ int orte_gpr_base_unpack_decrement_value(orte_buffer_t *cmd, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n=1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(cmd, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);

16
orte/mca/gpr/base/unpack_api_response/gpr_base_unpack_cleanup.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_unpack_cleanup_job(orte_buffer_t *cmd, int *ret)
{
@ -38,6 +40,8 @@ int orte_gpr_base_unpack_cleanup_job(orte_buffer_t *cmd, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n=1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(cmd, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -64,6 +68,8 @@ int orte_gpr_base_unpack_cleanup_proc(orte_buffer_t *cmd, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n=1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(cmd, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);

18
orte/mca/gpr/base/unpack_api_response/gpr_base_unpack_del_index.c
Просмотреть файл

@ -19,12 +19,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_unpack_delete_segment(orte_buffer_t *buffer, int *ret)
@ -33,6 +35,8 @@ int orte_gpr_base_unpack_delete_segment(orte_buffer_t *buffer, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n = 1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -59,6 +63,8 @@ int orte_gpr_base_unpack_delete_entries(orte_buffer_t *buffer, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n = 1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -86,6 +92,8 @@ int orte_gpr_base_unpack_index(orte_buffer_t *buffer, int *ret, size_t *cnt, cha
orte_data_type_t type;
int rc;
OPAL_TRACE(3);
*cnt = 0;
*index = NULL;

16
orte/mca/gpr/base/unpack_api_response/gpr_base_unpack_put_get.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_unpack_put(orte_buffer_t *buffer, int *ret)
{
@ -38,6 +40,8 @@ int orte_gpr_base_unpack_put(orte_buffer_t *buffer, int *ret)
int rc;
size_t n;
OPAL_TRACE(3);
n=1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -66,6 +70,8 @@ int orte_gpr_base_unpack_get(orte_buffer_t *buffer, int *ret, size_t *cnt, orte_
int rc;
size_t n, num;
OPAL_TRACE(3);
n=1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);

18
orte/mca/gpr/base/unpack_api_response/gpr_base_unpack_subscribe.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "include/orte_types.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/base/base.h"
#include "orte/include/orte_constants.h"
#include "orte/include/orte_types.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/base/base.h"
int orte_gpr_base_unpack_subscribe(orte_buffer_t *buffer, int *ret)
@ -39,6 +41,8 @@ int orte_gpr_base_unpack_subscribe(orte_buffer_t *buffer, int *ret)
size_t n;
int rc;
OPAL_TRACE(3);
n = 1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -66,6 +70,8 @@ int orte_gpr_base_unpack_unsubscribe(orte_buffer_t *buffer, int *ret)
size_t n;
int rc;
OPAL_TRACE(3);
n = 1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
@ -92,6 +98,8 @@ int orte_gpr_base_unpack_cancel_trigger(orte_buffer_t *buffer, int *ret)
size_t n;
int rc;
OPAL_TRACE(3);
n = 1;
if (ORTE_SUCCESS != (rc = orte_dps.unpack(buffer, &command, &n, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);

12
orte/mca/gpr/replica/communications/gpr_replica_arithmetic_ops_cm.c
Просмотреть файл

@ -25,10 +25,12 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_increment_value_cmd(orte_buffer_t *cmd, orte_buffer_t *answer)
{
@ -39,6 +41,8 @@ int orte_gpr_replica_recv_increment_value_cmd(orte_buffer_t *cmd, orte_buffer_t
size_t n;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -105,6 +109,8 @@ int orte_gpr_replica_recv_decrement_value_cmd(orte_buffer_t *cmd, orte_buffer_t
size_t n;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;

12
orte/mca/gpr/replica/communications/gpr_replica_cleanup_cm.c
Просмотреть файл

@ -25,10 +25,12 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_cleanup_job_cmd(orte_buffer_t *input_buffer,
orte_buffer_t *output_buffer)
@ -38,6 +40,8 @@ int orte_gpr_replica_recv_cleanup_job_cmd(orte_buffer_t *input_buffer,
size_t n;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -73,6 +77,8 @@ int orte_gpr_replica_recv_cleanup_proc_cmd(orte_buffer_t *input_buffer,
size_t n;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;

10
orte/mca/gpr/replica/communications/gpr_replica_cmd_processor.c
Просмотреть файл

@ -25,10 +25,12 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "opal/util/output.h"
#include "gpr_replica_comm.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
/*
* handle message from proxies
@ -45,6 +47,8 @@ int orte_gpr_replica_process_command_buffer(orte_buffer_t *input_buffer,
bool compound_cmd=false;
orte_data_type_t type;
OPAL_TRACE(3);
*output_buffer = OBJ_NEW(orte_buffer_t);
if (NULL == *output_buffer) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);

10
orte/mca/gpr/replica/communications/gpr_replica_compound_cmd_cm.c
Просмотреть файл

@ -25,16 +25,20 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_compound_cmd(orte_buffer_t *output_buffer)
{
orte_gpr_cmd_flag_t command=ORTE_GPR_COMPOUND_CMD;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
}

14
orte/mca/gpr/replica/communications/gpr_replica_del_index_cm.c
Просмотреть файл

@ -25,10 +25,12 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_delete_segment_cmd(orte_buffer_t *buffer, orte_buffer_t *answer)
{
@ -38,6 +40,8 @@ int orte_gpr_replica_recv_delete_segment_cmd(orte_buffer_t *buffer, orte_buffer_
size_t n;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -79,6 +83,8 @@ int orte_gpr_replica_recv_delete_entries_cmd(orte_buffer_t *buffer, orte_buffer_
size_t num_tokens=0, num_keys=0, i, n;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -210,6 +216,8 @@ int orte_gpr_replica_recv_index_cmd(orte_buffer_t *buffer,
char *segment=NULL, **index=NULL;
int rc, ret;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;

22
orte/mca/gpr/replica/communications/gpr_replica_dump_cm.c
Просмотреть файл

@ -25,10 +25,12 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_dump_all_cmd(orte_buffer_t *answer)
@ -36,6 +38,8 @@ int orte_gpr_replica_recv_dump_all_cmd(orte_buffer_t *answer)
orte_gpr_cmd_flag_t command=ORTE_GPR_DUMP_ALL_CMD;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -56,6 +60,8 @@ int orte_gpr_replica_recv_dump_segments_cmd(orte_buffer_t *input_buffer, orte_bu
size_t n;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -82,6 +88,8 @@ int orte_gpr_replica_recv_dump_triggers_cmd(orte_buffer_t *input_buffer,
size_t n;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -109,6 +117,8 @@ int orte_gpr_replica_recv_dump_subscriptions_cmd(orte_buffer_t *input_buffer,
size_t n;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -138,6 +148,8 @@ int orte_gpr_replica_recv_dump_a_trigger_cmd(orte_buffer_t *input_buffer,
size_t n, i, j;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -202,6 +214,8 @@ int orte_gpr_replica_recv_dump_a_subscription_cmd(orte_buffer_t *input_buffer,
char *name;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -262,6 +276,8 @@ int orte_gpr_replica_recv_dump_callbacks_cmd(orte_buffer_t *answer)
orte_gpr_cmd_flag_t command=ORTE_GPR_DUMP_CALLBACKS_CMD;
int rc;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;

12
orte/mca/gpr/replica/communications/gpr_replica_put_get_cm.c
Просмотреть файл

@ -25,10 +25,12 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_put_cmd(orte_buffer_t *buffer, orte_buffer_t *answer)
{
@ -40,6 +42,8 @@ int orte_gpr_replica_recv_put_cmd(orte_buffer_t *buffer, orte_buffer_t *answer)
int rc, ret;
size_t i=0, cnt;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(answer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -145,6 +149,8 @@ int orte_gpr_replica_recv_get_cmd(orte_buffer_t *input_buffer,
size_t num_tokens=0, num_keys=0, n;
orte_gpr_value_t **values=NULL;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;

13
orte/mca/gpr/replica/communications/gpr_replica_recv_proxy_msgs.c
Просмотреть файл

@ -26,13 +26,14 @@
#include "orte_config.h"
#include "opal/util/output.h"
#include "util/proc_info.h"
#include "opal/util/trace.h"
#include "orte/util/proc_info.h"
#include "mca/errmgr/errmgr.h"
#include "mca/ns/ns_types.h"
#include "mca/rml/rml.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/ns/ns_types.h"
#include "orte/mca/rml/rml.h"
#include "gpr_replica_comm.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
/*
* handle message from proxies
@ -44,6 +45,8 @@ void orte_gpr_replica_recv(int status, orte_process_name_t* sender,
orte_buffer_t *answer;
int rc;
OPAL_TRACE(3);
if (orte_gpr_replica_globals.debug) {
opal_output(0, "[%lu,%lu,%lu] gpr replica: received message from [%lu,%lu,%lu]",
ORTE_NAME_ARGS(orte_process_info.my_name), ORTE_NAME_ARGS(sender));

16
orte/mca/gpr/replica/communications/gpr_replica_remote_msg.c
Просмотреть файл

@ -25,14 +25,16 @@
*/
#include "orte_config.h"
#include "include/orte_types.h"
#include "orte/include/orte_types.h"
#include "opal/util/output.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "mca/ns/ns_types.h"
#include "mca/rml/rml.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/ns/ns_types.h"
#include "orte/mca/rml/rml.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
static void orte_gpr_replica_remote_send_cb(
int status,
@ -52,6 +54,8 @@ int orte_gpr_replica_remote_notify(orte_process_name_t *recipient,
orte_gpr_cmd_flag_t command;
int rc;
OPAL_TRACE(3);
command = ORTE_GPR_NOTIFY_CMD;
OBJ_CONSTRUCT(&buffer, orte_buffer_t);

15
orte/mca/gpr/replica/communications/gpr_replica_subscribe_cm.c
Просмотреть файл

@ -25,12 +25,13 @@
*/
#include "orte_config.h"
#include "dps/dps.h"
#include "mca/errmgr/errmgr.h"
#include "util/proc_info.h"
#include "orte/dps/dps.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/util/proc_info.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "gpr_replica_comm.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
int orte_gpr_replica_recv_subscribe_cmd(orte_process_name_t* sender,
orte_buffer_t *input_buffer,
@ -43,6 +44,8 @@ int orte_gpr_replica_recv_subscribe_cmd(orte_process_name_t* sender,
orte_gpr_trigger_t **trigs=NULL;
orte_gpr_subscription_t **subscriptions=NULL;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -188,6 +191,8 @@ int orte_gpr_replica_recv_unsubscribe_cmd(orte_process_name_t *sender,
int rc, ret;
size_t n;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -225,6 +230,8 @@ int orte_gpr_replica_recv_cancel_trigger_cmd(orte_process_name_t *sender,
int rc, ret;
size_t n;
OPAL_TRACE(3);
if (ORTE_SUCCESS != (rc = orte_dps.pack(output_buffer, &command, 1, ORTE_GPR_CMD))) {
ORTE_ERROR_LOG(rc);
return rc;

14
orte/mca/gpr/replica/functional_layer/gpr_replica_arithmetic_ops_fn.c
Просмотреть файл

@ -25,12 +25,14 @@
*/
#include "orte_config.h"
#include "mca/ns/ns.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/ns/ns.h"
#include "orte/mca/errmgr/errmgr.h"
#include "gpr_replica_fn.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
int orte_gpr_replica_increment_value_fn(orte_gpr_addr_mode_t addr_mode,
@ -46,6 +48,8 @@ int orte_gpr_replica_increment_value_fn(orte_gpr_addr_mode_t addr_mode,
int rc;
size_t i, j, k, m, n;
OPAL_TRACE(2);
/* extract the token address mode */
tok_mode = 0x004f & addr_mode;
if (0x00 == tok_mode) { /* default tokens addressing mode to AND */
@ -144,6 +148,8 @@ int orte_gpr_replica_decrement_value_fn(orte_gpr_addr_mode_t addr_mode,
int rc;
size_t i, j, k, m, n;
OPAL_TRACE(2);
/* extract the token address mode */
tok_mode = 0x004f & addr_mode;
if (0x00 == tok_mode) { /* default tokens addressing mode to AND */

15
orte/mca/gpr/replica/functional_layer/gpr_replica_cleanup_fn.c
Просмотреть файл

@ -25,15 +25,16 @@
#include "orte_config.h"
#include "class/orte_pointer_array.h"
#include "orte/class/orte_pointer_array.h"
#include "opal/util/output.h"
#include "util/proc_info.h"
#include "opal/util/trace.h"
#include "orte/util/proc_info.h"
#include "mca/ns/ns.h"
#include "orte/mca/ns/ns.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "gpr_replica_fn.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
int orte_gpr_replica_cleanup_job_fn(orte_jobid_t jobid)
@ -42,6 +43,8 @@ int orte_gpr_replica_cleanup_job_fn(orte_jobid_t jobid)
char *jobidstring, *segment;
orte_gpr_replica_segment_t *seg;
OPAL_TRACE(2);
if (ORTE_SUCCESS != orte_ns.convert_jobid_to_string(&jobidstring, jobid)) {
return ORTE_ERR_BAD_PARAM;
}
@ -71,6 +74,8 @@ int orte_gpr_replica_cleanup_proc_fn(orte_process_name_t *proc)
int rc;
size_t i, j;
OPAL_TRACE(2);
if (orte_gpr_replica_globals.debug) {
opal_output(0, "[%lu,%lu,%lu] gpr_replica_cleanup_proc: function entered for process [%lu,%lu,%lu]",
ORTE_NAME_ARGS(orte_process_info.my_name), ORTE_NAME_ARGS(proc));

14
orte/mca/gpr/replica/functional_layer/gpr_replica_del_index_fn.c
Просмотреть файл

@ -25,13 +25,15 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "orte/include/orte_constants.h"
#include "opal/util/output.h"
#include "orte/util/proc_info.h"
#include "opal/util/trace.h"
#include "orte/mca/errmgr/errmgr.h"
#include "gpr_replica_fn.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
int orte_gpr_replica_delete_entries_fn(orte_gpr_addr_mode_t addr_mode,
@ -45,6 +47,8 @@ int orte_gpr_replica_delete_entries_fn(orte_gpr_addr_mode_t addr_mode,
size_t i, j, k, n, p;
int rc;
OPAL_TRACE(2);
/* if num_tokens == 0 and num_keys == 0, remove segment. We don't record
* any actions when doing this so that subscriptions don't fire like mad
*/
@ -142,6 +146,8 @@ int orte_gpr_replica_delete_entries_nb_fn(
orte_gpr_replica_itag_t *token_itags, size_t num_tokens,
orte_gpr_replica_itag_t *key_tags, size_t num_keys)
{
OPAL_TRACE(2);
return ORTE_ERR_NOT_IMPLEMENTED;
}
@ -155,6 +161,8 @@ int orte_gpr_replica_index_fn(orte_gpr_replica_segment_t *seg,
size_t i, j;
OPAL_TRACE(2);
/* set default responses */
*index = NULL;
*cnt = 0;
@ -217,6 +225,8 @@ int orte_gpr_replica_index_fn(orte_gpr_replica_segment_t *seg,
int orte_gpr_replica_index_nb_fn(orte_gpr_replica_segment_t *seg,
orte_gpr_notify_cb_fn_t cbfunc, void *user_tag)
{
OPAL_TRACE(2);
return ORTE_ERR_NOT_IMPLEMENTED;
}

12
orte/mca/gpr/replica/functional_layer/gpr_replica_dict_fn.c
Просмотреть файл

@ -25,10 +25,12 @@
#include "orte_config.h"
#include "class/orte_bitmap.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "gpr_replica_fn.h"
#include "orte/class/orte_bitmap.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
/*
*/
@ -42,6 +44,8 @@ bool orte_gpr_replica_check_itag_list(orte_gpr_replica_addr_mode_t addr_mode,
bool exclusive, match, found_one, not_set;
int rc, bit_is_set;
OPAL_TRACE(3);
/* check for trivial case */
if (NULL == itags || 0 == num_itags_search) { /* wildcard case - automatically true */
return true;
@ -138,6 +142,8 @@ int orte_gpr_replica_copy_itag_list(orte_gpr_replica_itag_t **dest,
return ORTE_ERR_BAD_PARAM;
}
OPAL_TRACE(3);
*dest = (orte_gpr_replica_itag_t*)malloc(num_itags * sizeof(orte_gpr_replica_itag_t));
if (NULL == *dest) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);

26
orte/mca/gpr/replica/functional_layer/gpr_replica_local_trig_ops_fn.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "mca/errmgr/errmgr.h"
#include "mca/ns/ns.h"
#include "util/output.h"
#include "mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "gpr_replica_fn.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/ns/ns.h"
#include "opal/util/output.h"
#include "opal/util/trace.h"
#include "orte/mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
/* FUNCTIONS REQUIRED FOR LOCAL SUBSCRIPTION AND TRIGGER
@ -42,6 +44,8 @@ orte_gpr_replica_enter_local_subscription(size_t cnt, orte_gpr_subscription_t **
orte_gpr_replica_local_subscriber_t *sub;
size_t i;
OPAL_TRACE(2);
for (i=0; i < cnt; i++) {
sub = OBJ_NEW(orte_gpr_replica_local_subscriber_t);
if (NULL == sub) {
@ -72,6 +76,8 @@ orte_gpr_replica_enter_local_trigger(size_t cnt, orte_gpr_trigger_t **trigs)
orte_gpr_replica_local_trigger_t *trig, **tptr;
size_t i, j, k;
OPAL_TRACE(2);
for (i=0; i < cnt; i++) {
/* If the provided trigger has a name, see if it already is on
* the local trigger list. If so, then check to see if we
@ -146,7 +152,9 @@ MOVEON:
int orte_gpr_replica_remove_local_subscription(orte_gpr_replica_local_subscriber_t *sub)
{
size_t index;
OPAL_TRACE(2);
if (NULL == sub) {
ORTE_ERROR_LOG(ORTE_ERR_BAD_PARAM);
return ORTE_ERR_BAD_PARAM;
@ -162,7 +170,9 @@ int orte_gpr_replica_remove_local_subscription(orte_gpr_replica_local_subscriber
int orte_gpr_replica_remove_local_trigger(orte_gpr_replica_local_trigger_t *trig)
{
size_t index;
OPAL_TRACE(2);
if (NULL == trig) {
ORTE_ERROR_LOG(ORTE_ERR_BAD_PARAM);
return ORTE_ERR_BAD_PARAM;

20
orte/mca/gpr/replica/functional_layer/gpr_replica_put_get_fn.c
Просмотреть файл

@ -26,14 +26,16 @@
#include "orte_config.h"
#include "opal/util/output.h"
#include "util/proc_info.h"
#include "opal/util/trace.h"
#include "mca/errmgr/errmgr.h"
#include "orte/util/proc_info.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "orte/mca/errmgr/errmgr.h"
#include "gpr_replica_fn.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
/*
* Local typedef for storing a list of itagvals
@ -134,6 +136,8 @@ int orte_gpr_replica_put_fn(orte_gpr_addr_mode_t addr_mode,
int rc;
size_t i, j, k, m, n, index;
OPAL_TRACE(2);
if (orte_gpr_replica_globals.debug) {
char *tmp;
@ -293,6 +297,8 @@ int orte_gpr_replica_put_nb_fn(orte_gpr_addr_mode_t addr_mode,
size_t cnt, orte_gpr_keyval_t **keyvals,
orte_gpr_notify_cb_fn_t cbfunc, void *user_tag)
{
OPAL_TRACE(2);
return ORTE_ERR_NOT_IMPLEMENTED;
}
@ -313,6 +319,8 @@ int orte_gpr_replica_get_fn(orte_gpr_addr_mode_t addr_mode,
int rc;
size_t i, j, k, m;
OPAL_TRACE(2);
if (orte_gpr_replica_globals.debug) {
char *token;
opal_output(0, "[%lu,%lu,%lu] gpr_replica_get: entered",
@ -501,6 +509,8 @@ int orte_gpr_replica_get_nb_fn(orte_gpr_addr_mode_t addr_mode,
orte_gpr_replica_itag_t *keytags, size_t num_keys,
orte_gpr_notify_cb_fn_t cbfunc, void *user_tag)
{
OPAL_TRACE(2);
return ORTE_ERR_NOT_IMPLEMENTED;
}

30
orte/mca/gpr/replica/functional_layer/gpr_replica_segment_fn.c
Просмотреть файл

@ -28,10 +28,12 @@
#include "opal/class/opal_object.h"
#include "opal/util/output.h"
#include "opal/util/argv.h"
#include "mca/errmgr/errmgr.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "opal/util/trace.h"
#include "gpr_replica_fn.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
int orte_gpr_replica_find_containers(orte_gpr_replica_segment_t *seg,
@ -41,6 +43,8 @@ int orte_gpr_replica_find_containers(orte_gpr_replica_segment_t *seg,
orte_gpr_replica_container_t **cptr;
size_t i, j, index;
OPAL_TRACE(3);
/* ensure the search array is clear */
orte_pointer_array_clear(orte_gpr_replica_globals.srch_cptr);
orte_gpr_replica_globals.num_srch_cptr = 0;
@ -74,6 +78,8 @@ int orte_gpr_replica_create_container(orte_gpr_replica_container_t **cptr,
int rc;
size_t index;
OPAL_TRACE(3);
*cptr = OBJ_NEW(orte_gpr_replica_container_t);
if (NULL == *cptr) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
@ -106,6 +112,8 @@ int orte_gpr_replica_release_container(orte_gpr_replica_segment_t *seg,
size_t i;
int rc;
OPAL_TRACE(3);
/* delete all the itagvals in the container */
iptr = (orte_gpr_replica_itagval_t**)((cptr->itagvals)->addr);
for (i=0; i < (cptr->itagvals)->size; i++) {
@ -143,6 +151,8 @@ int orte_gpr_replica_add_keyval(orte_gpr_replica_itagval_t **ivalptr,
orte_gpr_replica_itagval_t *iptr;
int rc;
OPAL_TRACE(3);
iptr = OBJ_NEW(orte_gpr_replica_itagval_t);
if (NULL == iptr) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
@ -190,6 +200,8 @@ int orte_gpr_replica_delete_itagval(orte_gpr_replica_segment_t *seg,
size_t i;
int rc;
OPAL_TRACE(3);
/* record that we are going to do this
* NOTE: it is important that we make the record BEFORE doing the release.
* The record_action function will do a RETAIN on the object so it
@ -239,6 +251,8 @@ int orte_gpr_replica_update_keyval(orte_gpr_replica_itagval_t **iptr2,
orte_pointer_array_t *ptr;
orte_gpr_replica_itagval_t *iptr;
OPAL_TRACE(3);
ptr = orte_gpr_replica_globals.srch_ival;
/* record the error value */
@ -307,6 +321,8 @@ int orte_gpr_replica_search_container(orte_gpr_replica_addr_mode_t addr_mode,
orte_gpr_replica_itagval_t **ptr;
size_t i, j, index;
OPAL_TRACE(3);
/* ensure the search array is clear */
orte_pointer_array_clear(orte_gpr_replica_globals.srch_ival);
orte_gpr_replica_globals.num_srch_ival = 0;
@ -346,6 +362,8 @@ int orte_gpr_replica_get_value(void *value, orte_gpr_replica_itagval_t *ival)
{
orte_gpr_value_union_t *src;
OPAL_TRACE(3);
src = &(ival->value);
switch(ival->type) {
@ -441,6 +459,8 @@ int orte_gpr_replica_get_value(void *value, orte_gpr_replica_itagval_t *ival)
int orte_gpr_replica_compare_values(int *cmp, orte_gpr_replica_itagval_t *ival1,
orte_gpr_replica_itagval_t *ival2)
{
OPAL_TRACE(3);
/* sanity check */
if (ival1->type != ival2->type) { /* can't compare mismatch */
ORTE_ERROR_LOG(ORTE_ERR_TYPE_MISMATCH);
@ -642,6 +662,8 @@ int orte_gpr_replica_release_segment(orte_gpr_replica_segment_t **seg)
int rc;
size_t i;
OPAL_TRACE(3);
i = (*seg)->itag;
OBJ_RELEASE(*seg);
@ -656,6 +678,8 @@ int orte_gpr_replica_release_segment(orte_gpr_replica_segment_t **seg)
int orte_gpr_replica_purge_itag(orte_gpr_replica_segment_t *seg,
orte_gpr_replica_itag_t itag)
{
OPAL_TRACE(3);
/*
* Begin by looping through the segment's containers and check
* their descriptions first - if removing this name leaves that

14
orte/mca/gpr/replica/functional_layer/gpr_replica_subscribe_fn.c
Просмотреть файл

@ -26,12 +26,14 @@
#include "orte_config.h"
#include "opal/util/output.h"
#include "util/proc_info.h"
#include "mca/ns/ns.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "gpr_replica_fn.h"
#include "orte/util/proc_info.h"
#include "orte/mca/ns/ns.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
int orte_gpr_replica_subscribe_fn(orte_process_name_t *requestor,
size_t num_subs,
@ -45,6 +47,8 @@ int orte_gpr_replica_subscribe_fn(orte_process_name_t *requestor,
bool ignore;
int rc=ORTE_SUCCESS;
OPAL_TRACE(2);
if (orte_gpr_replica_globals.debug) {
opal_output(0, "[%lu,%lu,%lu] gpr_replica_subscribe: entered with num_trigs:%d",
ORTE_NAME_ARGS(orte_process_info.my_name), num_trigs);

88
orte/mca/gpr/replica/functional_layer/gpr_replica_trig_ops_fn.c
Просмотреть файл

@ -25,12 +25,14 @@
#include "orte_config.h"
#include "mca/errmgr/errmgr.h"
#include "mca/ns/ns.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/ns/ns.h"
#include "opal/util/output.h"
#include "mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "gpr_replica_fn.h"
#include "opal/util/trace.h"
#include "orte/mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
/*
@ -49,6 +51,8 @@ orte_gpr_replica_register_subscription(orte_gpr_replica_subscription_t **subptr,
orte_gpr_replica_itag_t itag, *tokentags=NULL;
orte_gpr_replica_ivalue_t *ival;
OPAL_TRACE(3);
/* if this is a named subscription, see if that name has
* already been entered on the replica. If it has, then we
* simply attach this recipient to that subscription -
@ -285,6 +289,8 @@ orte_gpr_replica_register_trigger(orte_gpr_replica_trigger_t **trigptr,
orte_gpr_replica_trigger_requestor_t *req, **reqs;
bool found;
OPAL_TRACE(3);
/* set a default response value */
*trigptr = NULL;
@ -597,6 +603,8 @@ orte_gpr_replica_remove_subscription(orte_process_name_t *requestor,
size_t i, j, k, m;
bool found;
OPAL_TRACE(3);
/* find this subscription on the list */
subs = (orte_gpr_replica_subscription_t**)(orte_gpr_replica.subscriptions)->addr;
for (i=0, j=0; j < orte_gpr_replica.num_subs &&
@ -701,37 +709,39 @@ orte_gpr_replica_remove_trigger(orte_process_name_t *requestor,
orte_gpr_replica_trigger_t **trigs, *trig;
size_t i, j, k, m;
/* find this trigger on the list */
trigs = (orte_gpr_replica_trigger_t**)(orte_gpr_replica.triggers)->addr;
for (i=0, j=0; j < orte_gpr_replica.num_trigs &&
i < (orte_gpr_replica.triggers)->size; i++) {
if (NULL != trigs[i]) {
j++;
reqs = (orte_gpr_replica_trigger_requestor_t**)(trigs[i]->attached)->addr;
for (k=0, m=0; m < trigs[i]->num_attached &&
k < (trigs[i]->attached)->size; k++) {
if (NULL != reqs[k]) {
m++;
if (id == reqs[k]->idtag &&
((NULL == requestor && NULL == reqs[k]->requestor) ||
(NULL != requestor && NULL != reqs[k]->requestor &&
0 == orte_ns.compare(ORTE_NS_CMP_ALL,
reqs[k]->requestor, requestor)))) {
/* this is the trigger */
trig = trigs[i];
req = reqs[k];
goto PROCESS;
}
OPAL_TRACE(3);
/* find this trigger on the list */
trigs = (orte_gpr_replica_trigger_t**)(orte_gpr_replica.triggers)->addr;
for (i=0, j=0; j < orte_gpr_replica.num_trigs &&
i < (orte_gpr_replica.triggers)->size; i++) {
if (NULL != trigs[i]) {
j++;
reqs = (orte_gpr_replica_trigger_requestor_t**)(trigs[i]->attached)->addr;
for (k=0, m=0; m < trigs[i]->num_attached &&
k < (trigs[i]->attached)->size; k++) {
if (NULL != reqs[k]) {
m++;
if (id == reqs[k]->idtag &&
((NULL == requestor && NULL == reqs[k]->requestor) ||
(NULL != requestor && NULL != reqs[k]->requestor &&
0 == orte_ns.compare(ORTE_NS_CMP_ALL,
reqs[k]->requestor, requestor)))) {
/* this is the trigger */
trig = trigs[i];
req = reqs[k];
goto PROCESS;
}
}
}
}
/* if we arrive here, then we had a remote requestor but were
* unable to find a matching trigger. report that fact
* and exit
*/
ORTE_ERROR_LOG(ORTE_ERR_NOT_FOUND);
return ORTE_ERR_NOT_FOUND;
}
/* if we arrive here, then we had a remote requestor but were
* unable to find a matching trigger. report that fact
* and exit
*/
ORTE_ERROR_LOG(ORTE_ERR_NOT_FOUND);
return ORTE_ERR_NOT_FOUND;
PROCESS:
/* remove the specified requestor. if this was the last
@ -787,6 +797,8 @@ int orte_gpr_replica_record_action(orte_gpr_replica_segment_t *seg,
size_t index;
int rc;
OPAL_TRACE(3);
new_action = OBJ_NEW(orte_gpr_replica_action_taken_t);
if (NULL == new_action) {
ORTE_ERROR_LOG(ORTE_ERR_OUT_OF_RESOURCE);
@ -827,6 +839,8 @@ int orte_gpr_replica_update_storage_locations(orte_gpr_replica_itagval_t *new_ip
size_t i, j, k, m, n, p;
bool replaced;
OPAL_TRACE(3);
trig = (orte_gpr_replica_trigger_t**)((orte_gpr_replica.triggers)->addr);
for (i=0, m=0; m < orte_gpr_replica.num_trigs &&
i < (orte_gpr_replica.triggers)->size; i++) {
@ -870,6 +884,8 @@ int orte_gpr_replica_check_events(void)
size_t i, j;
int rc;
OPAL_TRACE(3);
/* we first check all the subscriptions to see if any are "active".
* this needs to be done BEFORE we check triggers to ensure that
* triggers that turn "on" a subscription don't cause duplicate
@ -943,6 +959,8 @@ int orte_gpr_replica_check_trig(orte_gpr_replica_trigger_t *trig)
int cmp;
int rc;
OPAL_TRACE(3);
if (ORTE_GPR_TRIG_CMP_LEVELS & trig->action) { /* compare the levels of the counters */
cntr = (orte_gpr_replica_counter_t**)((trig->counters)->addr);
first = true;
@ -1087,6 +1105,8 @@ int orte_gpr_replica_check_subscription(orte_gpr_replica_subscription_t *sub)
orte_gpr_addr_mode_t addr_mode;
int rc=ORTE_SUCCESS;
OPAL_TRACE(3);
/* When entering this function, we know that the specified
* subscription is active since that was tested above. What we now need
* to determine is whether or not any of the data
@ -1203,6 +1223,8 @@ bool orte_gpr_replica_check_notify_matches(orte_gpr_addr_mode_t *addr_mode,
size_t i, j;
orte_gpr_replica_ivalue_t **ivals;
OPAL_TRACE(3);
/* we need to run through all of this subscription's defined
* values to see if any of them match the acted upon one.
*/
@ -1252,6 +1274,8 @@ int orte_gpr_replica_purge_subscriptions(orte_process_name_t *proc)
size_t i;
int rc;
OPAL_TRACE(3);
/* locate any notification events that have proc as the requestor
* and remove them
*/

30
orte/mca/gpr/replica/gpr_replica_component.c
Просмотреть файл

@ -25,17 +25,19 @@
*/
#include "orte_config.h"
#include "class/orte_bitmap.h"
#include "orte/class/orte_bitmap.h"
#include "opal/class/opal_object.h"
#include "opal/util/output.h"
#include "util/proc_info.h"
#include "opal/util/trace.h"
#include "mca/rml/rml.h"
#include "orte/util/proc_info.h"
#include "gpr_replica.h"
#include "mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "mca/gpr/replica/communications/gpr_replica_comm.h"
#include "mca/errmgr/errmgr.h"
#include "orte/mca/rml/rml.h"
#include "orte/mca/gpr/replica/gpr_replica.h"
#include "orte/mca/gpr/replica/api_layer/gpr_replica_api.h"
#include "orte/mca/gpr/replica/communications/gpr_replica_comm.h"
#include "orte/mca/errmgr/errmgr.h"
/*
@ -130,12 +132,14 @@ orte_gpr_replica_t orte_gpr_replica;
orte_gpr_replica_globals_t orte_gpr_replica_globals;
/* instantiate the classes */
#include "mca/gpr/replica/gpr_replica_class_instances.h"
#include "orte/mca/gpr/replica/gpr_replica_class_instances.h"
int orte_gpr_replica_open(void)
{
int id, tmp;
OPAL_TRACE(5);
id = mca_base_param_register_int("gpr", "replica", "debug", NULL, 0);
mca_base_param_lookup_int(id, &tmp);
if (tmp) {
@ -160,6 +164,8 @@ int orte_gpr_replica_open(void)
*/
int orte_gpr_replica_close(void)
{
OPAL_TRACE(5);
return ORTE_SUCCESS;
}
@ -167,6 +173,8 @@ orte_gpr_base_module_t *orte_gpr_replica_init(bool *allow_multi_user_threads, bo
{
int rc;
OPAL_TRACE(5);
/* If we are to host a replica, then we want to be selected, so do all the
setup and return the module */
@ -293,6 +301,8 @@ orte_gpr_base_module_t *orte_gpr_replica_init(bool *allow_multi_user_threads, bo
int orte_gpr_replica_module_init(void)
{
OPAL_TRACE(5);
/* issue the non-blocking receive */
if (!orte_gpr_replica_globals.isolate) {
int rc = orte_rml.recv_buffer_nb(ORTE_RML_NAME_ANY, ORTE_RML_TAG_GPR, 0, orte_gpr_replica_recv, NULL);
@ -320,9 +330,7 @@ int orte_gpr_replica_finalize(void)
orte_gpr_replica_local_subscriber_t **lsubs;
orte_gpr_replica_local_trigger_t **ltrigs;
if (orte_gpr_replica_globals.debug) {
opal_output(0, "finalizing gpr replica");
}
OPAL_TRACE(5);
/* destruct the thread lock */
OBJ_DESTRUCT(&orte_gpr_replica_globals.mutex);

20
orte/mca/gpr/replica/transition_layer/gpr_replica_dict_tl.c
Просмотреть файл

@ -25,13 +25,15 @@
#include "orte_config.h"
#include "class/orte_pointer_array.h"
#include "orte/class/orte_pointer_array.h"
#include "opal/util/output.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "mca/gpr/replica/functional_layer/gpr_replica_fn.h"
#include "orte/mca/errmgr/errmgr.h"
#include "gpr_replica_tl.h"
#include "orte/mca/gpr/replica/functional_layer/gpr_replica_fn.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
int
orte_gpr_replica_create_itag(orte_gpr_replica_itag_t *itag,
@ -41,6 +43,8 @@ orte_gpr_replica_create_itag(orte_gpr_replica_itag_t *itag,
orte_gpr_replica_itag_t j;
size_t i, len, len2;
OPAL_TRACE(3);
/* default to illegal value */
*itag = ORTE_GPR_REPLICA_ITAG_MAX;
@ -104,6 +108,8 @@ int orte_gpr_replica_delete_itag(orte_gpr_replica_segment_t *seg, char *name)
size_t index;
int rc;
OPAL_TRACE(3);
/* check for errors */
if (NULL == name || NULL == seg) {
ORTE_ERROR_LOG(ORTE_ERR_BAD_PARAM);
@ -155,6 +161,8 @@ orte_gpr_replica_dict_lookup(orte_gpr_replica_itag_t *itag,
orte_gpr_replica_itag_t j;
size_t len, len2;
OPAL_TRACE(3);
/* initialize to illegal value */
*itag = ORTE_GPR_REPLICA_ITAG_MAX;
@ -198,6 +206,8 @@ int orte_gpr_replica_dict_reverse_lookup(char **name,
orte_gpr_replica_itag_t j;
OPAL_TRACE(3);
/* initialize to nothing */
*name = NULL;
@ -248,6 +258,8 @@ orte_gpr_replica_get_itag_list(orte_gpr_replica_itag_t **itaglist,
int rc;
size_t i;
OPAL_TRACE(3);
*itaglist = NULL;
/* check for errors */

6
orte/mca/gpr/replica/transition_layer/gpr_replica_segment_tl.c
Просмотреть файл

@ -25,7 +25,9 @@
#include "orte_config.h"
#include "gpr_replica_tl.h"
#include "opal/util/trace.h"
#include "orte/mca/gpr/replica/transition_layer/gpr_replica_tl.h"
int orte_gpr_replica_find_seg(orte_gpr_replica_segment_t **seg,
bool create, char *segment)
@ -35,6 +37,8 @@ int orte_gpr_replica_find_seg(orte_gpr_replica_segment_t **seg,
size_t i, cntri;
orte_gpr_replica_segment_t **ptr;
OPAL_TRACE(3);
/* initialize to nothing */
*seg = NULL;

12
orte/mca/rmgr/base/rmgr_base_close.c
Просмотреть файл

@ -18,15 +18,19 @@
#include <stdio.h>
#include "include/orte_constants.h"
#include "opal/util/trace.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/rmgr/base/base.h"
#include "orte/include/orte_constants.h"
#include "opal/mca/mca.h"
#include "opal/mca/base/base.h"
#include "orte/mca/rmgr/base/base.h"
int orte_rmgr_base_close(void)
{
OPAL_TRACE(5);
/* finalize the selected component */
if (NULL != orte_rmgr.finalize) {

32
orte/mca/rmgr/base/rmgr_base_context.c
Просмотреть файл

@ -13,22 +13,24 @@
*
* $HEADER$
*/
#include "ompi_config.h"
#include "orte_config.h"
#include <errno.h>
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif
#include <string.h>
#include "include/constants.h"
#include "mca/rmgr/base/base.h"
#include "mca/rds/base/base.h"
#include "mca/ras/base/base.h"
#include "mca/rmaps/base/base.h"
#include "mca/pls/base/base.h"
#include "mca/gpr/gpr.h"
#include "mca/ns/ns.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "orte/include/orte_constants.h"
#include "orte/mca/rmgr/base/base.h"
#include "orte/mca/rds/base/base.h"
#include "orte/mca/ras/base/base.h"
#include "orte/mca/rmaps/base/base.h"
#include "orte/mca/pls/base/base.h"
#include "orte/mca/gpr/gpr.h"
#include "orte/mca/ns/ns.h"
#include "orte/mca/errmgr/errmgr.h"
/*
@ -45,6 +47,8 @@ int orte_rmgr_base_put_app_context(
size_t job_slots;
int rc;
OPAL_TRACE(2);
rc = orte_rmgr_base_get_job_slots(jobid, &job_slots);
if(ORTE_SUCCESS != rc) {
return rc;
@ -115,6 +119,8 @@ static int orte_rmgr_base_cmp_app_context(
orte_app_context_t** app1,
orte_app_context_t** app2)
{
OPAL_TRACE(3);
if ((*app1)->idx < (*app2)->idx) {
return -1;
} else if((*app1)->idx > (*app2)->idx) {
@ -140,6 +146,8 @@ int orte_rmgr_base_get_app_context(
size_t i, num_values = 0, index = 0;
int rc;
OPAL_TRACE(2);
/* create the job segment on the registry */
if(ORTE_SUCCESS != (rc = orte_schema.get_job_segment_name(&segment, jobid)))
return rc;
@ -204,6 +212,8 @@ int orte_rmgr_base_get_job_slots(orte_jobid_t jobid, size_t* proc_slots)
size_t i, num_values = 0;
int rc;
OPAL_TRACE(2);
/* query the job segment on the registry */
if(ORTE_SUCCESS != (rc = orte_schema.get_job_segment_name(&segment, jobid)))
return rc;
@ -261,6 +271,8 @@ int orte_rmgr_base_set_job_slots(orte_jobid_t jobid, size_t proc_slots)
orte_gpr_keyval_t* keyvals[1];
int rc;
OPAL_TRACE(2);
/* query the job segment on the registry */
if(ORTE_SUCCESS != (rc = orte_schema.get_job_segment_name(&segment, jobid)))
return rc;

19
orte/mca/rmgr/base/rmgr_base_open.c
Просмотреть файл

@ -16,17 +16,20 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "orte/include/orte_constants.h"
#include "dps/dps.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/base/mca_base_param.h"
#include "mca/errmgr/errmgr.h"
#include "orte/dps/dps.h"
#include "opal/mca/mca.h"
#include "opal/mca/base/base.h"
#include "opal/mca/base/mca_base_param.h"
#include "orte/mca/errmgr/errmgr.h"
#include "opal/util/output.h"
#include "opal/util/argv.h"
#include "opal/util/trace.h"
#include "mca/rmgr/base/base.h"
#include "orte/mca/rmgr/base/base.h"
@ -153,6 +156,8 @@ int orte_rmgr_base_open(void)
int param, value, rc;
orte_data_type_t tmp;
OPAL_TRACE(5);
/* Debugging / verbose output */
orte_rmgr_base.rmgr_output = opal_output_open(NULL);

24
orte/mca/rmgr/base/rmgr_base_pack.c
Просмотреть файл

@ -18,10 +18,12 @@
#endif
#include <string.h>
#include "include/constants.h"
#include "dps/dps.h"
#include "mca/rmgr/base/base.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "orte/include/orte_constants.h"
#include "orte/dps/dps.h"
#include "orte/mca/rmgr/base/base.h"
#include "orte/mca/errmgr/errmgr.h"
/*
@ -31,6 +33,9 @@
int orte_rmgr_base_pack_cmd(orte_buffer_t* buffer, orte_rmgr_cmd_t cmd, orte_jobid_t jobid)
{
int rc;
OPAL_TRACE(4);
rc = orte_dps.pack(buffer, &cmd, 1, ORTE_RMGR_CMD);
if(ORTE_SUCCESS != rc) {
ORTE_ERROR_LOG(rc);
@ -55,8 +60,11 @@ int orte_rmgr_base_pack_create_cmd(
size_t num_context)
{
int rc;
orte_rmgr_cmd_t cmd = ORTE_RMGR_CMD_CREATE;
OPAL_TRACE(4);
rc = orte_dps.pack(buffer, &cmd, 1, ORTE_RMGR_CMD);
if(ORTE_SUCCESS != rc) {
ORTE_ERROR_LOG(rc);
@ -82,8 +90,11 @@ int orte_rmgr_base_pack_terminate_proc_cmd(
const orte_process_name_t* name)
{
int rc;
orte_rmgr_cmd_t cmd = ORTE_RMGR_CMD_CREATE;
OPAL_TRACE(4);
rc = orte_dps.pack(buffer, &cmd, 1, ORTE_RMGR_CMD);
if(ORTE_SUCCESS != rc) {
ORTE_ERROR_LOG(rc);
@ -104,6 +115,9 @@ int orte_rmgr_base_unpack_rsp(
{
int32_t rc;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(buffer,&rc,&cnt,ORTE_INT32))) {
ORTE_ERROR_LOG(rc);
return rc;
@ -118,6 +132,8 @@ int orte_rmgr_base_unpack_create_rsp(
int32_t rc;
size_t cnt;
OPAL_TRACE(4);
cnt = 1;
if(ORTE_SUCCESS != (rc = orte_dps.unpack(buffer,jobid,&cnt,ORTE_JOBID))) {
ORTE_ERROR_LOG(rc);

13
orte/mca/rmgr/base/rmgr_base_select.c
Просмотреть файл

@ -17,11 +17,14 @@
#include "orte_config.h"
#include "include/orte_constants.h"
#include "orte/include/orte_constants.h"
#include "opal/util/output.h"
#include "mca/mca.h"
#include "mca/base/base.h"
#include "mca/rmgr/base/base.h"
#include "opal/util/trace.h"
#include "opal/mca/mca.h"
#include "opal/mca/base/base.h"
#include "orte/mca/rmgr/base/base.h"
/**
@ -36,6 +39,8 @@ int orte_rmgr_base_select(void)
orte_rmgr_base_module_t *module, *best_module = NULL;
int priority, best_priority = -1;
OPAL_TRACE(5);
/* Iterate through all the available components */
for (item = opal_list_get_first(&orte_rmgr_base.rmgr_components);
item != opal_list_get_end(&orte_rmgr_base.rmgr_components);

31
orte/mca/rmgr/base/rmgr_base_unpack.c
Просмотреть файл

@ -11,18 +11,20 @@
*
* $HEADER$
*/
#include "ompi_config.h"
#include "orte_config.h"
#include <errno.h>
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif
#include <string.h>
#include "include/constants.h"
#include "orte/include/orte_constants.h"
#include "opal/util/output.h"
#include "dps/dps.h"
#include "mca/rmgr/base/base.h"
#include "mca/errmgr/errmgr.h"
#include "opal/util/trace.h"
#include "orte/dps/dps.h"
#include "orte/mca/rmgr/base/base.h"
#include "orte/mca/errmgr/errmgr.h"
/*
@ -32,6 +34,9 @@
static int orte_rmgr_base_cmd_query(orte_buffer_t* req, orte_buffer_t* rsp)
{
int32_t rc = orte_rmgr.query();
OPAL_TRACE(4);
return orte_dps.pack(rsp, &rc, 1, ORTE_INT32);
}
@ -43,6 +48,8 @@ static int orte_rmgr_base_cmd_create(orte_buffer_t* req, orte_buffer_t* rsp)
orte_jobid_t jobid;
size_t i, cnt, num_context;
OPAL_TRACE(4);
cnt = 1;
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &num_context, &cnt, ORTE_SIZE))) {
ORTE_ERROR_LOG(rc);
@ -86,6 +93,8 @@ static int orte_rmgr_base_cmd_allocate(orte_buffer_t* req, orte_buffer_t* rsp)
orte_jobid_t jobid;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &jobid, &cnt, ORTE_JOBID))) {
ORTE_ERROR_LOG(rc);
} else {
@ -100,6 +109,8 @@ static int orte_rmgr_base_cmd_deallocate(orte_buffer_t* req, orte_buffer_t* rsp)
orte_jobid_t jobid;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &jobid, &cnt, ORTE_JOBID))) {
ORTE_ERROR_LOG(rc);
} else {
@ -114,6 +125,8 @@ static int orte_rmgr_base_cmd_map(orte_buffer_t* req, orte_buffer_t* rsp)
orte_jobid_t jobid;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &jobid, &cnt, ORTE_JOBID))) {
ORTE_ERROR_LOG(rc);
} else {
@ -128,6 +141,8 @@ static int orte_rmgr_base_cmd_launch(orte_buffer_t* req, orte_buffer_t* rsp)
orte_jobid_t jobid;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &jobid, &cnt, ORTE_JOBID))) {
ORTE_ERROR_LOG(rc);
} else {
@ -143,6 +158,8 @@ static int orte_rmgr_base_cmd_term_job(orte_buffer_t* req, orte_buffer_t* rsp)
orte_jobid_t jobid;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &jobid, &cnt, ORTE_JOBID))) {
ORTE_ERROR_LOG(rc);
} else {
@ -158,6 +175,8 @@ static int orte_rmgr_base_cmd_term_proc(orte_buffer_t* req, orte_buffer_t* rsp)
orte_process_name_t name;
size_t cnt = 1;
OPAL_TRACE(4);
if(ORTE_SUCCESS != (rc = orte_dps.unpack(req, &name, &cnt, ORTE_NAME))) {
ORTE_ERROR_LOG(rc);
} else {
@ -174,6 +193,8 @@ int orte_rmgr_base_cmd_dispatch(orte_buffer_t* req, orte_buffer_t* rsp)
size_t cnt = 1;
int rc;
OPAL_TRACE(4);
rc = orte_dps.unpack(req, &cmd, &cnt, ORTE_RMGR_CMD);
if(ORTE_SUCCESS != rc) {
ORTE_ERROR_LOG(rc);

39
orte/mca/rmgr/proxy/rmgr_proxy.c
Просмотреть файл

@ -11,18 +11,21 @@
*
* $HEADER$
*/
#include "ompi_config.h"
#include "orte_config.h"
#include <errno.h>
#include <unistd.h>
#include <string.h>
#include "include/constants.h"
#include "orte/include/orte_constants.h"
#include "opal/util/output.h"
#include "mca/errmgr/errmgr.h"
#include "mca/rmgr/base/base.h"
#include "mca/rml/rml.h"
#include "mca/iof/iof.h"
#include "rmgr_proxy.h"
#include "opal/util/trace.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/rmgr/base/base.h"
#include "orte/mca/rml/rml.h"
#include "orte/mca/iof/iof.h"
#include "orte/mca/rmgr/proxy/rmgr_proxy.h"
static int orte_rmgr_proxy_query(void);
@ -87,6 +90,8 @@ static int orte_rmgr_proxy_create(
orte_buffer_t rsp;
int rc;
OPAL_TRACE(1);
/* construct command */
OBJ_CONSTRUCT(&cmd, orte_buffer_t);
rc = orte_rmgr_base_pack_create_cmd(&cmd, app_context, num_context);
@ -127,6 +132,8 @@ static int orte_rmgr_proxy_cmd(orte_rmgr_cmd_t cmd_id, orte_jobid_t jobid)
orte_buffer_t rsp;
int rc;
OPAL_TRACE(2);
/* construct command */
OBJ_CONSTRUCT(&cmd, orte_buffer_t);
rc = orte_rmgr_base_pack_cmd(&cmd, cmd_id, jobid);
@ -164,31 +171,43 @@ static int orte_rmgr_proxy_cmd(orte_rmgr_cmd_t cmd_id, orte_jobid_t jobid)
static int orte_rmgr_proxy_query(void)
{
OPAL_TRACE(1);
return orte_rmgr_proxy_cmd(ORTE_RMGR_CMD_QUERY, 0);
}
static int orte_rmgr_proxy_allocate(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return orte_rmgr_proxy_cmd(ORTE_RMGR_CMD_ALLOCATE, jobid);
}
static int orte_rmgr_proxy_deallocate(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return orte_rmgr_proxy_cmd(ORTE_RMGR_CMD_DEALLOCATE, jobid);
}
static int orte_rmgr_proxy_map(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return orte_rmgr_proxy_cmd(ORTE_RMGR_CMD_MAP, jobid);
}
static int orte_rmgr_proxy_launch(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return orte_rmgr_proxy_cmd(ORTE_RMGR_CMD_LAUNCH, jobid);
}
static int orte_rmgr_proxy_terminate_job(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return orte_rmgr_proxy_cmd(ORTE_RMGR_CMD_TERM_JOB, jobid);
}
@ -198,6 +217,8 @@ static int orte_rmgr_proxy_terminate_proc(const orte_process_name_t* proc_name)
orte_buffer_t rsp;
int rc;
OPAL_TRACE(1);
/* construct command */
OBJ_CONSTRUCT(&cmd, orte_buffer_t);
rc = orte_rmgr_base_pack_terminate_proc_cmd(&cmd, proc_name);
@ -241,6 +262,8 @@ static void orte_rmgr_proxy_callback(orte_gpr_notify_data_t *data, void *cbdata)
size_t i, j, k;
int rc;
OPAL_TRACE(1);
/* we made sure in the subscriptions that at least one
* value is always returned
* get the jobid from the segment name in the first value
@ -306,6 +329,8 @@ static int orte_rmgr_proxy_spawn(
int rc;
orte_process_name_t* name;
OPAL_TRACE(1);
/*
* Perform resource discovery.
*/

56
orte/mca/rmgr/urm/rmgr_urm.c
Просмотреть файл

@ -13,23 +13,26 @@
*
* $HEADER$
*/
#include "ompi_config.h"
#include "orte_config.h"
#include <errno.h>
#include <unistd.h>
#include <string.h>
#include "include/constants.h"
#include "mca/errmgr/errmgr.h"
#include "mca/rds/base/base.h"
#include "mca/ras/base/base.h"
#include "mca/rmaps/base/base.h"
#include "mca/rmgr/base/base.h"
#include "mca/pls/base/base.h"
#include "mca/gpr/gpr.h"
#include "mca/iof/iof.h"
#include "mca/ns/ns.h"
#include "mca/rml/rml.h"
#include "rmgr_urm.h"
#include "opal/util/trace.h"
#include "orte/include/orte_constants.h"
#include "orte/mca/errmgr/errmgr.h"
#include "orte/mca/rds/base/base.h"
#include "orte/mca/ras/base/base.h"
#include "orte/mca/rmaps/base/base.h"
#include "orte/mca/rmgr/base/base.h"
#include "orte/mca/pls/base/base.h"
#include "orte/mca/gpr/gpr.h"
#include "orte/mca/iof/iof.h"
#include "orte/mca/ns/ns.h"
#include "orte/mca/rml/rml.h"
#include "orte/mca/rmgr/urm/rmgr_urm.h"
static int orte_rmgr_urm_query(void);
@ -89,6 +92,9 @@ orte_rmgr_base_module_t orte_rmgr_urm_module = {
static int orte_rmgr_urm_query(void)
{
int rc;
OPAL_TRACE(1);
if(ORTE_SUCCESS != (rc = orte_rds_base_query())) {
ORTE_ERROR_LOG(rc);
return rc;
@ -108,6 +114,8 @@ static int orte_rmgr_urm_create(
{
int rc;
OPAL_TRACE(1);
/* allocate a jobid */
if (ORTE_SUCCESS != (rc = orte_ns.create_jobid(jobid))) {
ORTE_ERROR_LOG(rc);
@ -135,31 +143,43 @@ static int orte_rmgr_urm_create(
static int orte_rmgr_urm_allocate(orte_jobid_t jobid)
{
return mca_rmgr_urm_component.urm_ras->allocate(jobid);
OPAL_TRACE(1);
return mca_rmgr_urm_component.urm_ras->allocate(jobid);
}
static int orte_rmgr_urm_deallocate(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return mca_rmgr_urm_component.urm_ras->deallocate(jobid);
}
static int orte_rmgr_urm_map(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return mca_rmgr_urm_component.urm_rmaps->map(jobid);
}
static int orte_rmgr_urm_launch(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return mca_rmgr_urm_component.urm_pls->launch(jobid);
}
static int orte_rmgr_urm_terminate_job(orte_jobid_t jobid)
{
OPAL_TRACE(1);
return mca_rmgr_urm_component.urm_pls->terminate_job(jobid);
}
static int orte_rmgr_urm_terminate_proc(const orte_process_name_t* proc_name)
{
OPAL_TRACE(1);
return mca_rmgr_urm_component.urm_pls->terminate_proc(proc_name);
}
@ -169,6 +189,8 @@ static void orte_rmgr_urm_wireup_stdin(orte_jobid_t jobid)
int rc;
orte_process_name_t* name;
OPAL_TRACE(1);
if (ORTE_SUCCESS != (rc = orte_ns.create_process_name(&name, 0, jobid, 0))) {
ORTE_ERROR_LOG(rc);
return;
@ -188,6 +210,8 @@ static void orte_rmgr_urm_callback(orte_gpr_notify_data_t *data, void *cbdata)
size_t i, j, k;
int rc;
OPAL_TRACE(1);
/* we made sure in the subscriptions that at least one
* value is always returned
* get the jobid from the segment name in the first value
@ -256,6 +280,8 @@ static int orte_rmgr_urm_spawn(
int rc;
orte_process_name_t* name;
OPAL_TRACE(1);
/*
* Perform resource discovery.
*/
@ -330,6 +356,8 @@ static int orte_rmgr_urm_finalize(void)
{
int rc;
OPAL_TRACE(1);
/**
* Finalize Process Launch Subsystem (PLS)
*/