1
1

use persistent rml_recv in iof

This commit was SVN r25035.
Этот коммит содержится в:
Nathan Hjelm 2011-08-09 21:30:12 +00:00
родитель b144c8c343
Коммит aa3d302a05
4 изменённых файлов: 4 добавлений и 20 удалений

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

@ -97,7 +97,7 @@ static int init(void)
*/ */
if (ORTE_SUCCESS != (rc = orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, if (ORTE_SUCCESS != (rc = orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD,
ORTE_RML_TAG_IOF_HNP, ORTE_RML_TAG_IOF_HNP,
ORTE_RML_NON_PERSISTENT, ORTE_RML_PERSISTENT,
orte_iof_hnp_recv, orte_iof_hnp_recv,
NULL))) { NULL))) {
ORTE_ERROR_LOG(rc); ORTE_ERROR_LOG(rc);

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

@ -229,14 +229,6 @@ void orte_iof_hnp_recv(int status, orte_process_name_t* sender,
* to the message buffer for later processing * to the message buffer for later processing
*/ */
ORTE_MESSAGE_EVENT(sender, buffer, tag, process_msg); ORTE_MESSAGE_EVENT(sender, buffer, tag, process_msg);
/* reissue the recv */
if (ORTE_SUCCESS != (rc = orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD,
ORTE_RML_TAG_IOF_HNP,
ORTE_RML_NON_PERSISTENT,
orte_iof_hnp_recv,
NULL))) {
ORTE_ERROR_LOG(rc);
}
return; return;
} }

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

@ -96,7 +96,7 @@ static int init(void)
from the HNP IOF component */ from the HNP IOF component */
if (ORTE_SUCCESS != (rc = orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD, if (ORTE_SUCCESS != (rc = orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD,
ORTE_RML_TAG_IOF_PROXY, ORTE_RML_TAG_IOF_PROXY,
ORTE_RML_NON_PERSISTENT, ORTE_RML_PERSISTENT,
orte_iof_orted_recv, orte_iof_orted_recv,
NULL))) { NULL))) {
ORTE_ERROR_LOG(rc); ORTE_ERROR_LOG(rc);

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

@ -192,14 +192,6 @@ void orte_iof_orted_recv(int status, orte_process_name_t* sender,
* to the message buffer for later processing * to the message buffer for later processing
*/ */
ORTE_MESSAGE_EVENT(sender, buffer, tag, process_msg); ORTE_MESSAGE_EVENT(sender, buffer, tag, process_msg);
/* reissue the recv */
if (ORTE_SUCCESS != (rc = orte_rml.recv_buffer_nb(ORTE_NAME_WILDCARD,
ORTE_RML_TAG_IOF_PROXY,
ORTE_RML_NON_PERSISTENT,
orte_iof_orted_recv,
NULL))) {
ORTE_ERROR_LOG(rc);
}
return; return;
} }