mpi_cholesky_distributed.c 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. /* StarPU --- Runtime system for heterogeneous multicore architectures.
  2. *
  3. * Copyright (C) 2012 Inria
  4. * Copyright (C) 2009-2011,2014-2015,2017 Université de Bordeaux
  5. * Copyright (C) 2010-2013,2015,2017 CNRS
  6. * Copyright (C) 2010 Mehdi Juhoor
  7. *
  8. * StarPU is free software; you can redistribute it and/or modify
  9. * it under the terms of the GNU Lesser General Public License as published by
  10. * the Free Software Foundation; either version 2.1 of the License, or (at
  11. * your option) any later version.
  12. *
  13. * StarPU is distributed in the hope that it will be useful, but
  14. * WITHOUT ANY WARRANTY; without even the implied warranty of
  15. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  16. *
  17. * See the GNU Lesser General Public License in COPYING.LGPL for more details.
  18. */
  19. #include "mpi_cholesky.h"
  20. /* This is the same as matrix_decomposition, but the matrix is not allocated in
  21. * totality on all nodes, thus allowing much bigger matrices, but doesn't allow
  22. * trivial checks */
  23. int main(int argc, char **argv)
  24. {
  25. /* create a simple definite positive symetric matrix example
  26. *
  27. * Hilbert matrix : h(i,j) = 1/(i+j+1)
  28. * */
  29. float ***bmat;
  30. int rank, nodes, ret;
  31. double timing, flops;
  32. ret = starpu_init(NULL);
  33. STARPU_CHECK_RETURN_VALUE(ret, "starpu_init");
  34. ret = starpu_mpi_init(&argc, &argv, 1);
  35. STARPU_CHECK_RETURN_VALUE(ret, "starpu_mpi_init");
  36. starpu_mpi_comm_rank(MPI_COMM_WORLD, &rank);
  37. starpu_mpi_comm_size(MPI_COMM_WORLD, &nodes);
  38. starpu_cublas_init();
  39. parse_args(argc, argv, nodes);
  40. matrix_init(&bmat, rank, nodes, 0);
  41. dw_cholesky(bmat, size/nblocks, rank, nodes, &timing, &flops);
  42. starpu_mpi_shutdown();
  43. matrix_free(&bmat, rank, nodes, 0);
  44. starpu_cublas_shutdown();
  45. starpu_shutdown();
  46. if (rank == 0)
  47. {
  48. FPRINTF(stdout, "Computation time (in ms): %2.2f\n", timing/1000);
  49. FPRINTF(stdout, "Synthetic GFlops : %2.2f\n", (flops/timing/1000.0f));
  50. }
  51. return 0;
  52. }