mxm: return the MXM_REQ_SEND_SYNC flag to mxm_req_send
This commit was SVN r25694.
Этот коммит содержится в:
родитель
3b97d609a8
Коммит
37dc53bbc9
@ -56,12 +56,11 @@ int ompi_mtl_mxm_send(struct mca_mtl_base_module_t* mtl,
|
||||
mxm_send_req.base.data.buffer.mkey = MXM_MKEY_NONE;
|
||||
mxm_send_req.base.context = NULL;
|
||||
mxm_send_req.base.completed_cb = NULL;
|
||||
|
||||
if (mode == MCA_PML_BASE_SEND_SYNCHRONOUS) {
|
||||
mxm_send_req.opcode = MXM_REQ_OP_SEND_SYNC;
|
||||
} else {
|
||||
mxm_send_req.opcode = MXM_REQ_OP_SEND;
|
||||
mxm_send_req.base.flags |= MXM_REQ_FLAG_SEND_SYNC;
|
||||
}
|
||||
|
||||
mxm_send_req.opcode = MXM_REQ_OP_SEND;
|
||||
mxm_send_req.op.send.tag = tag;
|
||||
mxm_send_req.op.send.imm_data = ompi_comm_rank(comm);
|
||||
|
||||
@ -114,16 +113,14 @@ int ompi_mtl_mxm_isend(struct mca_mtl_base_module_t* mtl,
|
||||
mxm_send_req->base.data.buffer.mkey = MXM_MKEY_NONE;
|
||||
mxm_send_req->base.context = mtl_mxm_request;
|
||||
mxm_send_req->base.completed_cb = ompi_mtl_mxm_send_completion_cb;
|
||||
|
||||
if (mode == MCA_PML_BASE_SEND_SYNCHRONOUS) {
|
||||
mxm_send_req->opcode = MXM_REQ_OP_SEND_SYNC;
|
||||
} else {
|
||||
mxm_send_req->opcode = MXM_REQ_OP_SEND;
|
||||
mxm_send_req->base.flags |= MXM_REQ_FLAG_SEND_SYNC;
|
||||
}
|
||||
|
||||
mxm_send_req->opcode = MXM_REQ_OP_SEND;
|
||||
mxm_send_req->op.send.tag = tag;
|
||||
mxm_send_req->op.send.imm_data = ompi_comm_rank(comm);
|
||||
|
||||
|
||||
/* post-send */
|
||||
err = mxm_req_send(mxm_send_req);
|
||||
if (MXM_OK != err) {
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user