mpi_cholesky_distributed.c 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2009-2011 Université de Bordeaux 1
  4. * Copyright (C) 2010 Mehdi Juhoor <mjuhoor@gmail.com>
  5. * Copyright (C) 2010, 2011, 2012, 2013 Centre National de la Recherche Scientifique
  6. *
  7. * StarPU is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU Lesser General Public License as published by
  9. * the Free Software Foundation; either version 2.1 of the License, or (at
  10. * your option) any later version.
  11. *
  12. * StarPU is distributed in the hope that it will be useful, but
  13. * WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  15. *
  16. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  17. */
  18. #include <starpu_mpi.h>
  19. #include "mpi_cholesky_models.h"
  20. #include "mpi_cholesky_codelets.h"
  21. #include "mpi_decomposition_matrix.h"
  22. #include "mpi_decomposition_params.h"
  23. #define FPRINTF(ofile, fmt, ...) do { if (!getenv("STARPU_SSILENT")) {fprintf(ofile, fmt, ## __VA_ARGS__); }} while(0)
  24. int main(int argc, char **argv)
  25. {
  26. /* create a simple definite positive symetric matrix example
  27. *
  28. * Hilbert matrix : h(i,j) = 1/(i+j+1)
  29. * */
  30. float ***bmat;
  31. int rank, nodes, ret;
  32. double timing, flops;
  33. ret = starpu_init(NULL);
  34. STARPU_CHECK_RETURN_VALUE(ret, "starpu_init");
  35. ret = starpu_mpi_init(&argc, &argv, 1);
  36. STARPU_CHECK_RETURN_VALUE(ret, "starpu_mpi_init");
  37. MPI_Comm_rank(MPI_COMM_WORLD, &rank);
  38. MPI_Comm_size(MPI_COMM_WORLD, &nodes);
  39. starpu_cublas_init();
  40. parse_args(argc, argv, nodes);
  41. matrix_init(&bmat, rank, nodes, 0);
  42. dw_cholesky(bmat, size/nblocks, rank, nodes, &timing, &flops);
  43. starpu_mpi_shutdown();
  44. matrix_free(&bmat, rank, nodes, 0);
  45. starpu_cublas_shutdown();
  46. starpu_shutdown();
  47. if (rank == 0)
  48. {
  49. FPRINTF(stdout, "Computation time (in ms): %2.2f\n", timing/1000);
  50. FPRINTF(stdout, "Synthetic GFlops : %2.2f\n", (flops/timing/1000.0f));
  51. }
  52. return 0;
  53. }