|
@@ -244,52 +244,3 @@ void *_starpu_mpi_src_worker(void *arg)
|
|
|
|
|
|
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
-//void _starpu_mpi_source_send(const struct _starpu_mp_node *node, void *msg,
|
|
|
-// int len)
|
|
|
-//{
|
|
|
-// int dst = node->mp_connection.mpi_nodeid;
|
|
|
-// if (MPI_Send(msg, len, MPI_CHAR, dst, dst, MPI_COMM_WORLD))
|
|
|
-// STARPU_MP_COMMON_REPORT_ERROR(node, errno);
|
|
|
-//}
|
|
|
-//
|
|
|
-//void _starpu_mpi_source_recv(const struct _starpu_mp_node *node, void *msg,
|
|
|
-// int len)
|
|
|
-//{
|
|
|
-// int src = node->mp_connection.mpi_nodeid;
|
|
|
-// if (MPI_Recv(msg, len, MPI_CHAR, src, STARPU_MP_SRC_NODE,
|
|
|
-// MPI_COMM_WORLD, MPI_STATUS_IGNORE))
|
|
|
-// STARPU_MP_COMMON_REPORT_ERROR(node, errno);
|
|
|
-//}
|
|
|
-//
|
|
|
-//int _starpu_mpi_copy_src_to_sink(void *src,
|
|
|
-// unsigned src_node STARPU_ATTRIBUTE_UNUSED,
|
|
|
-// void *dst, unsigned dst_node, size_t size)
|
|
|
-//{
|
|
|
-// /* TODO */
|
|
|
-// return 0;
|
|
|
-//}
|
|
|
-//
|
|
|
-//int _starpu_mpi_copy_sink_to_src(void *src, unsigned src_node, void *dst,
|
|
|
-// unsigned dst_node STARPU_ATTRIBUTE_UNUSED,
|
|
|
-// size_t size)
|
|
|
-//{
|
|
|
-// /* TODO */
|
|
|
-// return 0;
|
|
|
-//}
|
|
|
-//
|
|
|
-//int _starpu_mpi_copy_sink_to_sink(void *src, unsigned src_node, void *dst,
|
|
|
-// unsigned dst_node, size_t size)
|
|
|
-//{
|
|
|
-// /* TODO */
|
|
|
-// return 0;
|
|
|
-//}
|
|
|
-//
|
|
|
-//void (*_starpu_mpi_get_kernel_from_job(const struct _starpu_mp_node *node,
|
|
|
-// struct _starpu_job *j))(void)
|
|
|
-//{
|
|
|
-// /* TODO */
|
|
|
-// return NULL;
|
|
|
-//}
|
|
|
-
|