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

Fixes to make the rdma osc component work again:

Просмотр исходного кода 
* Don't overwrite the des_flags field, removing the
    all important always callback field
  * Fix up return status of bml_base_send, since
    the rest of the code expects OMPI_SUCCESS or
    an error code

This commit was SVN r20178.
Этот коммит содержится в:
Brian Barrett 2009-01-01 23:48:29 +00:00
родитель a7586bdd90
Коммит e1f40c6a71
2 изменённых файлов: 4 добавлений и 5 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

1
ompi/mca/osc/rdma/osc_rdma_component.c
Просмотреть файл

@ -1064,7 +1064,6 @@ rdma_send_info_send(ompi_osc_rdma_module_t *module,
/* setup descriptor */
descriptor->des_cbfunc = rdma_send_info_send_complete;
descriptor->des_cbdata = peer_send_info;
descriptor->des_flags = MCA_BTL_DES_FLAGS_PRIORITY;
descriptor->des_src[0].seg_len = sizeof(ompi_osc_rdma_rdma_info_header_t);
/* pack header */

8
ompi/mca/osc/rdma/osc_rdma_data_move.c
Просмотреть файл

@ -462,7 +462,6 @@ ompi_osc_rdma_sendreq_send(ompi_osc_rdma_module_t *module,
/* setup descriptor */
descriptor->des_cbfunc = ompi_osc_rdma_sendreq_send_cb;
descriptor->des_flags = MCA_BTL_DES_FLAGS_PRIORITY;
module->m_pending_buffers[sendreq->req_target_rank].bml_btl = bml_btl;
module->m_pending_buffers[sendreq->req_target_rank].descriptor = descriptor;
@ -587,6 +586,7 @@ ompi_osc_rdma_sendreq_send(ompi_osc_rdma_module_t *module,
module->m_pending_buffers[sendreq->req_target_rank].remain_len = 0;
ret = mca_bml_base_send(bml_btl, descriptor, MCA_BTL_TAG_OSC_RDMA);
if (1 == ret) ret = OMPI_SUCCESS;
goto done;
}
@ -705,7 +705,6 @@ ompi_osc_rdma_replyreq_send(ompi_osc_rdma_module_t *module,
/* setup descriptor */
descriptor->des_cbfunc = ompi_osc_rdma_replyreq_send_cb;
descriptor->des_cbdata = (void*) replyreq;
descriptor->des_flags = MCA_BTL_DES_FLAGS_PRIORITY;
/* pack header */
header = (ompi_osc_rdma_reply_header_t*) descriptor->des_src[0].seg_addr.pval;
@ -762,6 +761,7 @@ ompi_osc_rdma_replyreq_send(ompi_osc_rdma_module_t *module,
/* send fragment */
ret = mca_bml_base_send(bml_btl, descriptor, MCA_BTL_TAG_OSC_RDMA);
if (1 == ret) ret = OMPI_SUCCESS;
goto done;
cleanup:
@ -1310,7 +1310,6 @@ ompi_osc_rdma_control_send(ompi_osc_rdma_module_t *module,
/* setup descriptor */
descriptor->des_cbfunc = ompi_osc_rdma_control_send_cb;
descriptor->des_cbdata = NULL;
descriptor->des_flags = MCA_BTL_DES_FLAGS_PRIORITY;
descriptor->des_src[0].seg_len = sizeof(ompi_osc_rdma_control_header_t);
/* pack header */
@ -1332,6 +1331,7 @@ ompi_osc_rdma_control_send(ompi_osc_rdma_module_t *module,
/* send fragment */
ret = mca_bml_base_send(bml_btl, descriptor, MCA_BTL_TAG_OSC_RDMA);
if (1 == ret) ret = OMPI_SUCCESS;
goto done;
cleanup:
@ -1372,7 +1372,6 @@ ompi_osc_rdma_rdma_ack_send(ompi_osc_rdma_module_t *module,
/* setup descriptor */
descriptor->des_cbfunc = ompi_osc_rdma_control_send_cb;
descriptor->des_cbdata = NULL;
descriptor->des_flags = MCA_BTL_DES_FLAGS_PRIORITY;
descriptor->des_src[0].seg_len = sizeof(ompi_osc_rdma_control_header_t);
/* pack header */
@ -1396,6 +1395,7 @@ ompi_osc_rdma_rdma_ack_send(ompi_osc_rdma_module_t *module,
/* send fragment */
ret = mca_bml_base_send(bml_btl, descriptor, MCA_BTL_TAG_OSC_RDMA);
if (1 == ret) ret = OMPI_SUCCESS;
goto done;
cleanup: