Track process heartbeats with time_t, be a little less restrictive on who can retrieve an orte_job_t object
This commit was SVN r22921.
Этот коммит содержится в:
родитель
3111b2debf
Коммит
871a9e0df4
@ -457,8 +457,8 @@ orte_job_t* orte_get_job_data_object(orte_jobid_t job)
|
|||||||
{
|
{
|
||||||
int32_t ljob;
|
int32_t ljob;
|
||||||
|
|
||||||
/* if I am not an HNP, I cannot provide this object */
|
/* if the job data wasn't setup, we cannot provide the data */
|
||||||
if (!ORTE_PROC_IS_HNP && !ORTE_PROC_IS_CM) {
|
if (NULL == orte_job_data) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -602,9 +602,6 @@ static void orte_job_construct(orte_job_t* job)
|
|||||||
job->abort = false;
|
job->abort = false;
|
||||||
job->aborted_proc = NULL;
|
job->aborted_proc = NULL;
|
||||||
|
|
||||||
job->err_cbfunc = NULL;
|
|
||||||
job->err_cbstates = ORTE_PROC_STATE_UNDEF;
|
|
||||||
job->err_cbdata = NULL;
|
|
||||||
job->max_restarts = INT32_MAX;
|
job->max_restarts = INT32_MAX;
|
||||||
|
|
||||||
#if OPAL_ENABLE_FT_CR == 1
|
#if OPAL_ENABLE_FT_CR == 1
|
||||||
|
@ -381,12 +381,6 @@ typedef struct {
|
|||||||
bool abort;
|
bool abort;
|
||||||
/* proc that caused that to happen */
|
/* proc that caused that to happen */
|
||||||
struct orte_proc_t *aborted_proc;
|
struct orte_proc_t *aborted_proc;
|
||||||
/* errmgr callback function for this job, if any */
|
|
||||||
orte_err_cb_fn_t err_cbfunc;
|
|
||||||
/* states that will trigger callback */
|
|
||||||
orte_proc_state_t err_cbstates;
|
|
||||||
/* errmgr callback data */
|
|
||||||
void *err_cbdata;
|
|
||||||
/* max number of times a process can be restarted */
|
/* max number of times a process can be restarted */
|
||||||
int32_t max_restarts;
|
int32_t max_restarts;
|
||||||
#if OPAL_ENABLE_FT_CR == 1
|
#if OPAL_ENABLE_FT_CR == 1
|
||||||
@ -440,7 +434,7 @@ struct orte_proc_t {
|
|||||||
/* RML contact info */
|
/* RML contact info */
|
||||||
char *rml_uri;
|
char *rml_uri;
|
||||||
/* seconds when last heartbeat was detected */
|
/* seconds when last heartbeat was detected */
|
||||||
int beat;
|
time_t beat;
|
||||||
/* number of times this process has been restarted */
|
/* number of times this process has been restarted */
|
||||||
int32_t restarts;
|
int32_t restarts;
|
||||||
#if OPAL_ENABLE_FT_CR == 1
|
#if OPAL_ENABLE_FT_CR == 1
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user