1
1

Update the checkpoint notification events that we throw out over the FTB with a payload embedded in {}

This commit was SVN r24057.
Этот коммит содержится в:
Abhishek Kulkarni 2010-11-16 17:55:57 +00:00
родитель 32be69eaef
Коммит 6e6ccae082
2 изменённых файлов: 16 добавлений и 14 удалений

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

@ -140,6 +140,7 @@ ORTE_DECLSPEC extern orte_snapc_coord_type_t orte_snapc_coord_type;
/** /**
* Some utility functions * Some utility functions
*/ */
ORTE_DECLSPEC void orte_snapc_ckpt_state_notify(int state);
ORTE_DECLSPEC int orte_snapc_ckpt_state_str(char ** state_str, int state); ORTE_DECLSPEC int orte_snapc_ckpt_state_str(char ** state_str, int state);
/******************************* /*******************************

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

@ -414,29 +414,33 @@ static void snapc_none_global_cmdline_request(int status,
return; return;
} }
/********************
* Utility functions
********************/
/* Report the checkpoint status over the notifier interface */ /* Report the checkpoint status over the notifier interface */
static void orte_snapc_ckpt_state_notify(int state) void orte_snapc_ckpt_state_notify(int state)
{ {
switch(state) { switch(state) {
case ORTE_SNAPC_CKPT_STATE_ESTABLISHED: case ORTE_SNAPC_CKPT_STATE_ESTABLISHED:
case ORTE_SNAPC_CKPT_STATE_RECOVERED: orte_notifier.log(ORTE_NOTIFIER_INFO, state,
orte_notifier.log(ORTE_NOTIFIER_INFO, state, "base:ckpt_state_notify: Checkpoint established for PID = %d {%s}.",
"base:ckpt_state_notify: Checkpoint established (PID = %d).", orte_process_info.pid, ORTE_JOBID_PRINT(ORTE_PROC_MY_NAME->jobid));
orte_process_info.pid);
break; break;
case ORTE_SNAPC_CKPT_STATE_NO_CKPT: case ORTE_SNAPC_CKPT_STATE_NO_CKPT:
orte_notifier.show_help(ORTE_NOTIFIER_WARN, state, orte_notifier.log(ORTE_NOTIFIER_WARN, state,
"help-orte-checkpoint.txt", "non-ckptable", true, "base:ckpt_state_notify: PID = %d is not checkpointable {%s}.",
orte_process_info.pid); orte_process_info.pid, ORTE_JOBID_PRINT(ORTE_PROC_MY_NAME->jobid));
break; break;
case ORTE_SNAPC_CKPT_STATE_ERROR: case ORTE_SNAPC_CKPT_STATE_ERROR:
orte_notifier.show_help(ORTE_NOTIFIER_WARN, state, orte_notifier.log(ORTE_NOTIFIER_WARN, state,
"help-orte-checkpoint.txt", "ckpt_failure", true, "base:ckpt_state_notify: Failed to checkpoint PID = %d {%s}.",
orte_process_info.pid, ORTE_ERROR); orte_process_info.pid, ORTE_JOBID_PRINT(ORTE_PROC_MY_NAME->jobid));
break; break;
/* ADK: We currently do not notify for these states, but good to /* ADK: We currently do not notify for these states, but good to
* have them around anyways. */ * have them around anyways. */
case ORTE_SNAPC_CKPT_STATE_RECOVERED:
case ORTE_SNAPC_CKPT_STATE_NONE: case ORTE_SNAPC_CKPT_STATE_NONE:
case ORTE_SNAPC_CKPT_STATE_REQUEST: case ORTE_SNAPC_CKPT_STATE_REQUEST:
case ORTE_SNAPC_CKPT_STATE_PENDING: case ORTE_SNAPC_CKPT_STATE_PENDING:
@ -449,9 +453,6 @@ static void orte_snapc_ckpt_state_notify(int state)
} }
} }
/********************
* Utility functions
********************/
int orte_snapc_base_global_coord_ckpt_init_cmd(orte_process_name_t* peer, int orte_snapc_base_global_coord_ckpt_init_cmd(orte_process_name_t* peer,
opal_buffer_t* buffer, opal_buffer_t* buffer,
opal_crs_base_ckpt_options_t *options, opal_crs_base_ckpt_options_t *options,