Need to set MPI_ERROR in the status before calling ompi_request_complete.
This commit was SVN r26757.
Этот коммит содержится в:
родитель
27d45ad550
Коммит
e0ceabd486
@ -234,9 +234,7 @@ libnbc_progress(void)
|
|||||||
item = opal_list_get_next(item)) {
|
item = opal_list_get_next(item)) {
|
||||||
ompi_coll_libnbc_request_t* request = (ompi_coll_libnbc_request_t*) item;
|
ompi_coll_libnbc_request_t* request = (ompi_coll_libnbc_request_t*) item;
|
||||||
if (NBC_OK == NBC_Progress(request)) {
|
if (NBC_OK == NBC_Progress(request)) {
|
||||||
request->super.req_status.MPI_ERROR = OMPI_SUCCESS;
|
|
||||||
/* done, remove */
|
/* done, remove */
|
||||||
fprintf(stderr, "why am i here?\n");
|
|
||||||
item = opal_list_remove_item(&mca_coll_libnbc_component.active_requests,
|
item = opal_list_remove_item(&mca_coll_libnbc_component.active_requests,
|
||||||
&request->super.super.super);
|
&request->super.super.super);
|
||||||
}
|
}
|
||||||
|
@ -274,6 +274,7 @@ static inline int NBC_Free(NBC_Handle* handle) {
|
|||||||
handle->tmpbuf = NULL;
|
handle->tmpbuf = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
handle->super.req_status.MPI_ERROR = OMPI_SUCCESS;
|
||||||
OPAL_THREAD_LOCK(&ompi_request_lock);
|
OPAL_THREAD_LOCK(&ompi_request_lock);
|
||||||
ompi_request_complete(&handle->super, true);
|
ompi_request_complete(&handle->super, true);
|
||||||
OPAL_THREAD_UNLOCK(&ompi_request_lock);
|
OPAL_THREAD_UNLOCK(&ompi_request_lock);
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user