make progress on incomplete requests
This commit was SVN r3681.
Этот коммит содержится в:
родитель
96e0c767f3
Коммит
dfe145f297
@ -52,6 +52,9 @@ int ompi_request_test_any(
|
||||
/* Only fall through here if we found nothing */
|
||||
if(num_requests_null_inactive != count) {
|
||||
*completed = false;
|
||||
#if OMPI_HAVE_THREADS == 0
|
||||
ompi_progress();
|
||||
#endif
|
||||
} else {
|
||||
*index = MPI_UNDEFINED;
|
||||
*completed = true;
|
||||
@ -87,6 +90,9 @@ int ompi_request_test_all(
|
||||
|
||||
if (num_completed != count) {
|
||||
*completed = false;
|
||||
#if OMPI_HAVE_THREADS == 0
|
||||
ompi_progress();
|
||||
#endif
|
||||
return OMPI_SUCCESS;
|
||||
}
|
||||
|
||||
|
@ -24,6 +24,7 @@
|
||||
#include "class/ompi_list.h"
|
||||
#include "class/ompi_pointer_array.h"
|
||||
#include "errhandler/errhandler.h"
|
||||
#include "runtime/ompi_progress.h"
|
||||
#include "threads/mutex.h"
|
||||
#include "threads/condition.h"
|
||||
|
||||
@ -221,6 +222,9 @@ static inline int ompi_request_test(
|
||||
return request->req_fini(rptr);
|
||||
} else {
|
||||
*completed = false;
|
||||
#if OMPI_HAVE_THREADS == 0
|
||||
ompi_progress();
|
||||
#endif
|
||||
return OMPI_SUCCESS;
|
||||
}
|
||||
}
|
||||
|
Загрузка…
Ссылка в новой задаче
Block a user