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

Set transfers as active before starting them.

Просмотр исходного кода 
cmr=v1.7.4:ticket=trac:3898

This commit was SVN r29654.

The following Trac tickets were found above:
  Ticket 3898 --> https://svn.open-mpi.org/trac/ompi/ticket/3898
Этот коммит содержится в:
Nathan Hjelm 2013-11-11 21:50:54 +00:00
родитель 3d3c29ae96
Коммит 6a331275d8
1 изменённых файлов: 2 добавлений и 2 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

4
ompi/mca/dpm/orte/dpm_orte.c
Просмотреть файл

@ -227,11 +227,11 @@ static int connect_accept(ompi_communicator_t *comm, int root,
ORTE_RML_TAG_COLL_ID_REQ, ORTE_RML_TAG_COLL_ID_REQ,
orte_rml_send_callback, NULL); orte_rml_send_callback, NULL);
/* wait for the id */ /* wait for the id */
xfer.active = true;
orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_COLL_ID, orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, ORTE_RML_TAG_COLL_ID,
ORTE_RML_NON_PERSISTENT, ORTE_RML_NON_PERSISTENT,
orte_rml_recv_callback, &xfer); orte_rml_recv_callback, &xfer);
/* wait for response */ /* wait for response */
xfer.active = true;
OMPI_WAIT_FOR_COMPLETION(xfer.active); OMPI_WAIT_FOR_COMPLETION(xfer.active);
i=1; i=1;
if (OPAL_SUCCESS != (rc = opal_dss.unpack(&xfer.data, &id, &i, ORTE_GRPCOMM_COLL_ID_T))) { if (OPAL_SUCCESS != (rc = opal_dss.unpack(&xfer.data, &id, &i, ORTE_GRPCOMM_COLL_ID_T))) {
@ -252,11 +252,11 @@ static int connect_accept(ompi_communicator_t *comm, int root,
rc = orte_rml.send_buffer_nb(&port, nbuf, tag, orte_rml_send_callback, NULL); rc = orte_rml.send_buffer_nb(&port, nbuf, tag, orte_rml_send_callback, NULL);
} else { } else {
/* wait to recv the collective id */ /* wait to recv the collective id */
xfer.active = true;
orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, tag, orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, tag,
ORTE_RML_NON_PERSISTENT, ORTE_RML_NON_PERSISTENT,
orte_rml_recv_callback, &xfer); orte_rml_recv_callback, &xfer);
/* wait for response */ /* wait for response */
xfer.active = true;
OMPI_WAIT_FOR_COMPLETION(xfer.active); OMPI_WAIT_FOR_COMPLETION(xfer.active);
i=1; i=1;
if (OPAL_SUCCESS != (rc = opal_dss.unpack(&xfer.data, &id, &i, ORTE_GRPCOMM_COLL_ID_T))) { if (OPAL_SUCCESS != (rc = opal_dss.unpack(&xfer.data, &id, &i, ORTE_GRPCOMM_COLL_ID_T))) {