|
@@ -17,14 +17,14 @@
|
|
|
|
|
|
#include <starpu_mpi_datatype.h>
|
|
|
|
|
|
-typedef int (*handle_to_datatype_func)(starpu_data_handle_t, MPI_Datatype *);
|
|
|
-typedef int (*handle_free_datatype_func)(MPI_Datatype *);
|
|
|
+typedef void (*handle_to_datatype_func)(starpu_data_handle_t, MPI_Datatype *);
|
|
|
+typedef void (*handle_free_datatype_func)(MPI_Datatype *);
|
|
|
|
|
|
/*
|
|
|
* Matrix
|
|
|
*/
|
|
|
|
|
|
-static int handle_to_datatype_matrix(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
+static void handle_to_datatype_matrix(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
{
|
|
|
int ret;
|
|
|
|
|
@@ -38,15 +38,13 @@ static int handle_to_datatype_matrix(starpu_data_handle_t data_handle, MPI_Datat
|
|
|
|
|
|
ret = MPI_Type_commit(datatype);
|
|
|
STARPU_ASSERT(ret == MPI_SUCCESS);
|
|
|
-
|
|
|
- return 0;
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
* Block
|
|
|
*/
|
|
|
|
|
|
-static int handle_to_datatype_block(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
+static void handle_to_datatype_block(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
{
|
|
|
int ret;
|
|
|
|
|
@@ -69,15 +67,13 @@ static int handle_to_datatype_block(starpu_data_handle_t data_handle, MPI_Dataty
|
|
|
|
|
|
ret = MPI_Type_commit(datatype);
|
|
|
STARPU_ASSERT(ret == MPI_SUCCESS);
|
|
|
-
|
|
|
- return 0;
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
* Vector
|
|
|
*/
|
|
|
|
|
|
-static int handle_to_datatype_vector(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
+static void handle_to_datatype_vector(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
{
|
|
|
int ret;
|
|
|
|
|
@@ -89,15 +85,13 @@ static int handle_to_datatype_vector(starpu_data_handle_t data_handle, MPI_Datat
|
|
|
|
|
|
ret = MPI_Type_commit(datatype);
|
|
|
STARPU_ASSERT(ret == MPI_SUCCESS);
|
|
|
-
|
|
|
- return 0;
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
* Variable
|
|
|
*/
|
|
|
|
|
|
-static int handle_to_datatype_variable(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
+static void handle_to_datatype_variable(starpu_data_handle_t data_handle, MPI_Datatype *datatype)
|
|
|
{
|
|
|
int ret;
|
|
|
|
|
@@ -108,8 +102,6 @@ static int handle_to_datatype_variable(starpu_data_handle_t data_handle, MPI_Dat
|
|
|
|
|
|
ret = MPI_Type_commit(datatype);
|
|
|
STARPU_ASSERT(ret == MPI_SUCCESS);
|
|
|
-
|
|
|
- return 0;
|
|
|
}
|
|
|
|
|
|
/*
|
|
@@ -147,13 +139,12 @@ void _starpu_mpi_handle_allocate_datatype(starpu_data_handle_t data_handle, MPI_
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-static int _starpu_mpi_handle_free_simple_datatype(MPI_Datatype *datatype)
|
|
|
+static void _starpu_mpi_handle_free_simple_datatype(MPI_Datatype *datatype)
|
|
|
{
|
|
|
MPI_Type_free(datatype);
|
|
|
- return 0;
|
|
|
}
|
|
|
|
|
|
-static int _starpu_mpi_handle_free_complex_datatype(MPI_Datatype *datatype)
|
|
|
+static void _starpu_mpi_handle_free_complex_datatype(MPI_Datatype *datatype)
|
|
|
{
|
|
|
int num_ints, num_adds, num_datatypes, combiner, i;
|
|
|
int *array_of_ints;
|
|
@@ -173,7 +164,6 @@ static int _starpu_mpi_handle_free_complex_datatype(MPI_Datatype *datatype)
|
|
|
}
|
|
|
MPI_Type_free(datatype);
|
|
|
}
|
|
|
- return 0;
|
|
|
}
|
|
|
|
|
|
static handle_free_datatype_func handle_free_datatype_funcs[STARPU_MAX_INTERFACE_ID] =
|