@@ -397,11 +397,12 @@ int ompi_errhandler_proc_failed_internal(ompi_proc_t* ompi_proc, int status, boo
397
397
pmix_info_t pmix_info [1 ];
398
398
pmix_status_t prc ;
399
399
400
+ assert (OPAL_ERR_PROC_ABORTED == status );
400
401
OPAL_PMIX_CONVERT_NAME (& pmix_source , OMPI_PROC_MY_NAME );
401
402
OPAL_PMIX_CONVERT_NAME (& pmix_proc , & ompi_proc -> super .proc_name );
402
403
PMIX_INFO_CONSTRUCT (& pmix_info [0 ]);
403
404
PMIX_INFO_LOAD (& pmix_info [0 ], PMIX_EVENT_AFFECTED_PROC , & pmix_proc , PMIX_PROC );
404
- prc = PMIx_Notify_event (status , & pmix_source , PMIX_RANGE_LOCAL ,
405
+ prc = PMIx_Notify_event (PMIX_ERR_PROC_ABORTED , & pmix_source , PMIX_RANGE_LOCAL ,
405
406
pmix_info , 1 , NULL , & active );
406
407
if ( PMIX_SUCCESS != prc &&
407
408
PMIX_OPERATION_SUCCEEDED != prc ) {
@@ -450,7 +451,7 @@ static void *ompi_errhandler_event_cb(int fd, int flags, void *context) {
450
451
continue ; /* we are not 'MPI connected' with this proc. */
451
452
}
452
453
assert ( !ompi_proc_is_sentinel (proc ) );
453
- ompi_errhandler_proc_failed_internal (proc , status , false);
454
+ ompi_errhandler_proc_failed_internal (proc , OPAL_ERR_PROC_ABORTED , false);
454
455
}
455
456
opal_event_del (& event -> super );
456
457
free (event );
0 commit comments