|
@@ -1311,7 +1311,7 @@ static void *_starpu_mpi_progress_thread_func(void *arg)
|
|
|
STARPU_ASSERT_MSG(_starpu_mpi_req_list_empty(new_requests), "List of new requests not empty");
|
|
STARPU_ASSERT_MSG(_starpu_mpi_req_list_empty(new_requests), "List of new requests not empty");
|
|
|
STARPU_ASSERT_MSG(posted_requests == 0, "Number of posted request is not zero");
|
|
STARPU_ASSERT_MSG(posted_requests == 0, "Number of posted request is not zero");
|
|
|
STARPU_ASSERT_MSG(HASH_COUNT(_starpu_mpi_req_hashmap) == 0, "Number of receive requests left is not zero");
|
|
STARPU_ASSERT_MSG(HASH_COUNT(_starpu_mpi_req_hashmap) == 0, "Number of receive requests left is not zero");
|
|
|
-
|
|
|
|
|
|
|
+ STARPU_ASSERT_MSG(HASH_COUNT(_starpu_mpi_copy_handle_hashmap) == 0, "Number of copy requests left is not zero");
|
|
|
if (argc_argv->initialize_mpi)
|
|
if (argc_argv->initialize_mpi)
|
|
|
{
|
|
{
|
|
|
_STARPU_MPI_DEBUG(3, "Calling MPI_Finalize()\n");
|
|
_STARPU_MPI_DEBUG(3, "Calling MPI_Finalize()\n");
|