mpi: move raw_mpi specific functions from mpi/src/starpu_mpi.c to mpi/src/mpi/starpu_mpi_mpi.c

mpi/src/Makefile.am

@@ -86,14 +86,15 @@ libstarpumpi_@STARPU_EFFECTIVE_VERSION@_la_SOURCES =	\
 	starpu_mpi_cache.c				\
 	starpu_mpi_select_node.c			\
 	starpu_mpi_cache_stats.c			\
+	starpu_mpi_fortran.c				\
+	starpu_mpi_task_insert_fortran.c		\
+	starpu_mpi_init.c				\
+	mpi/starpu_mpi_mpi.c				\
 	mpi/starpu_mpi_early_data.c			\
 	mpi/starpu_mpi_early_request.c			\
 	mpi/starpu_mpi_sync_data.c			\
 	mpi/starpu_mpi_comm.c				\
 	mpi/starpu_mpi_tag.c				\
-	starpu_mpi_fortran.c				\
-	starpu_mpi_task_insert_fortran.c		\
-	starpu_mpi_init.c				\
 	load_balancer/policy/data_movements_interface.c	\
 	load_balancer/policy/load_data_interface.c	\
 	load_balancer/policy/load_heat_propagation.c	\

mpi/src/starpu_mpi_private.h

@@ -267,6 +267,24 @@ LIST_TYPE(_starpu_mpi_req,
 );
 PRIO_LIST_TYPE(_starpu_mpi_req, prio)
 
+struct _starpu_mpi_req *_starpu_mpi_isend_irecv_common(starpu_data_handle_t data_handle,
+						       int srcdst, int data_tag, MPI_Comm comm,
+						       unsigned detached, unsigned sync, int prio, void (*callback)(void *), void *arg,
+						       enum _starpu_mpi_request_type request_type, void (*func)(struct _starpu_mpi_req *),
+						       enum starpu_data_access_mode mode,
+						       int sequential_consistency,
+						       int is_internal_req,
+						       starpu_ssize_t count);
+
+void _starpu_mpi_submit_ready_request_inc(struct _starpu_mpi_req *req);
+void _starpu_mpi_request_init(struct _starpu_mpi_req **req);
+void _starpu_mpi_request_destroy(struct _starpu_mpi_req *req);
+void _starpu_mpi_isend_size_func(struct _starpu_mpi_req *req);
+void _starpu_mpi_irecv_data_func(struct _starpu_mpi_req *req);
+void _starpu_mpi_wait_func(struct _starpu_mpi_req *waiting_req);
+void _starpu_mpi_test_func(struct _starpu_mpi_req *testing_req);
+int _starpu_mpi_barrier(MPI_Comm comm);
+
 struct _starpu_mpi_argc_argv
 {
 	int initialize_mpi;