Commit 83b2816f authored by Jithin Jose's avatar Jithin Jose Committed by Charles J Archer
Browse files

Handle error-event for fi_cancel



Change-Id: I25d9c8e80329dc185ee89da9fa1d8d9f54ea493e
Signed-off-by: default avatarJithin Jose <jithin.jose@intel.com>
Signed-off-by: default avatarCharles J Archer <charles.j.archer@intel.com>
parent 7e2a47bb
......@@ -106,6 +106,13 @@ int MPID_nem_ofi_poll(int in_blocking_poll)
mpi_errno = MPI_ERR_OTHER;
}
}
else if (error.err == FI_ECANCELED) {
req = context_to_req(error.op_context);
MPIR_STATUS_SET_CANCEL_BIT(req->status, TRUE);
}
else {
mpi_errno = MPI_ERR_OTHER;
}
}
else {
MPIU_ERR_CHKANDJUMP4(1, mpi_errno, MPI_ERR_OTHER, "**ofi_poll",
......
......@@ -75,6 +75,13 @@ static inline int MPID_nem_ofi_send_callback(cq_tagged_entry_t * wc ATTRIBUTE((u
ret = fi_cancel((fid_t)gl_data.endpoint, \
&(REQ_OFI(req)->ofi_context)); \
if (ret == 0) { \
while (!MPIR_STATUS_GET_CANCEL_BIT(req->status)) { \
if ((mpi_errno = MPID_nem_ofi_poll(MPID_NONBLOCKING_POLL)) != \
MPI_SUCCESS) { \
MPIR_STATUS_SET_CANCEL_BIT(req->status, FALSE); \
return mpi_errno; \
} \
} \
MPIR_STATUS_SET_CANCEL_BIT(req->status, TRUE); \
} else { \
MPIR_STATUS_SET_CANCEL_BIT(req->status, FALSE); \
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment