1
1
Этот коммит содержится в:
Ralph Castain 2016-08-08 13:20:24 -07:00
родитель 2788083b98
Коммит ba77d9beff

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

@ -840,8 +840,6 @@ static int ompi_comm_allreduce_pmix_reduce_complete (ompi_comm_request_t *reques
opal_buffer_t sbuf;
int rc;
fprintf (stderr, "reduce complete\n");
OBJ_CONSTRUCT(&sbuf, opal_buffer_t);
if (OPAL_SUCCESS != (rc = opal_dss.pack(&sbuf, context->tmpbuf, (int32_t)context->count, OPAL_INT))) {
@ -871,8 +869,6 @@ static int ompi_comm_allreduce_pmix_reduce_complete (ompi_comm_request_t *reques
cid_context->iter);
}
fprintf (stderr, "%s, %s\n", info.key, pdat.value.key);
/* this macro is not actually non-blocking. if a non-blocking version becomes available this function
* needs to be reworked to take advantage of it. */
OPAL_PMIX_EXCHANGE(rc, &info, &pdat, 600); // give them 10 minutes