Commit 9d255236 authored by Matthieu Dorier's avatar Matthieu Dorier
Browse files

corrected callback to handle cancelled requests

parent 154d83bc
......@@ -452,7 +452,8 @@ static int mona_callback(const struct na_cb_info *info)
{
na_return_t na_ret = info->ret;
mona_request_t req = (mona_request_t)(info->arg);
if(info->type == NA_CB_RECV_UNEXPECTED) {
if(na_ret == NA_SUCCESS && info->type == NA_CB_RECV_UNEXPECTED) {
na_addr_t source = info->info.recv_unexpected.source;
na_tag_t tag = info->info.recv_unexpected.tag;
na_size_t size = info->info.recv_unexpected.actual_buf_size;
......@@ -466,6 +467,7 @@ static int mona_callback(const struct na_cb_info *info)
*(req->size) = size;
}
}
ABT_eventual_set(req->eventual, &na_ret, sizeof(na_ret));
return NA_SUCCESS;
}
......
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