|
@@ -1505,7 +1505,9 @@ static void *_starpu_mpi_progress_thread_func(void *arg)
|
|
|
}
|
|
|
}
|
|
|
#ifdef STARPU_USE_MPI_FT
|
|
|
+ STARPU_PTHREAD_MUTEX_UNLOCK(&progress_mutex);
|
|
|
starpu_mpi_ft_progress();
|
|
|
+ STARPU_PTHREAD_MUTEX_LOCK(&progress_mutex);
|
|
|
#endif // STARPU_USE_MPI_FT
|
|
|
#ifdef STARPU_SIMGRID
|
|
|
STARPU_PTHREAD_MUTEX_UNLOCK(&progress_mutex);
|