Advertisement
Guest User

Untitled

a guest
Dec 12th, 2019
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
C 2.84 KB | None | 0 0
  1. #include <stdio.h>
  2. #include <unistd.h>
  3. #include <string.h>
  4. #include <math.h>
  5. #include <stdlib.h>
  6. #include <math.h>
  7. #include <time.h>
  8. #include <sys/time.h>
  9. #include "mpi.h"
  10.  
  11. static
  12. void init_array(int ni, int nj, int nk,
  13.                 float* alpha,
  14.                 float* beta,
  15.                 float C[ni][nj],
  16.                 float A[ni][nk],
  17.                 float B[nk][nj]) {
  18.     int i, j;
  19.  
  20.     *alpha = 1.5;
  21.     *beta = 1.2;
  22.     for (i = 0; i < ni; i++)
  23.         for (j = 0; j < nj; j++)
  24.             C[i][j] = (float) ((i * j + 1) % ni) / ni;
  25.     for (i = 0; i < ni; i++)
  26.         for (j = 0; j < nk; j++)
  27.             A[i][j] = (float) (i * (j + 1) % nk) / nk;
  28.     for (i = 0; i < nk; i++)
  29.         for (j = 0; j < nj; j++)
  30.             B[i][j] = (float) (i * (j + 2) % nj) / nj;
  31. }
  32.  
  33. static
  34. void kernel_gemm(int ni, int nj, int nk,
  35.                  float alpha,
  36.                  float beta,
  37.                  float C[ni][nj],
  38.                  float A[ni][nk],
  39.                  float B[nk][nj],
  40.                  int i_1,
  41.                  int i_2) {
  42.     int i, j, k;
  43.  
  44.     for (i = i_1; i < i_2; i++) {
  45.         for (j = 0; j < nj; j++) {
  46.             C[i][j] *= beta;
  47.             for (k = 0; k < nk; k++) {
  48.                 C[i][j] += alpha * A[i][k] * B[k][j];
  49.             }
  50.         }
  51.     }
  52. }
  53.  
  54. int main(int argc, char** argv) {
  55.         int proc_num, myrank;
  56.     MPI_Init(&argc, &argv);
  57.     MPI_Comm_size(MPI_COMM_WORLD, &proc_num);
  58.     MPI_Comm_rank(MPI_COMM_WORLD, &myrank);
  59.  
  60.     int ni = atoi(argv[1]);
  61.     int nj = atoi(argv[2]);
  62.     int nk = atoi(argv[3]);
  63.     if (myrank == 0) {
  64.         printf("%d processes, i = %d, j = %d, k = %d, ", proc_num, ni, nj, nk);
  65.     }
  66.     int i_min = ni / proc_num * myrank;
  67.     int i_max = ni / proc_num * (myrank + 1);
  68.     if (myrank < ni % proc_num) {
  69.         i_min += myrank;
  70.         i_max += myrank + 1;
  71.     } else {
  72.         i_min += ni % proc_num;
  73.         i_max += ni % proc_num;
  74.     }
  75.  
  76.     float alpha;
  77.     float beta;
  78.     float (* C)[ni][nj];
  79.     C = (float (*)[ni][nj]) malloc((ni) * (nj) * sizeof(float));
  80.     float (* A)[ni][nk];
  81.     A = (float (*)[ni][nk]) malloc((ni) * (nk) * sizeof(float));
  82.     float (* B)[nk][nj];
  83.     B = (float (*)[nk][nj]) malloc((nk) * (nj) * sizeof(float));
  84.  
  85.     init_array(ni, nj, nk, &alpha, &beta,
  86.                *C,
  87.                *A,
  88.                *B);
  89.  
  90.     MPI_Barrier(MPI_COMM_WORLD);
  91.     double time1 = MPI_Wtime();
  92.  
  93.     kernel_gemm(ni, nj, nk,
  94.                 alpha, beta,
  95.                 *C,
  96.                 *A,
  97.                 *B,
  98.                 i_min,
  99.                 i_max);
  100.  
  101.     MPI_Barrier(MPI_COMM_WORLD);
  102.     double time2 = MPI_Wtime();
  103.     if (myrank == 0) {
  104.         printf(" %lf sec\n", time2 - time1);
  105.     }
  106.  
  107.  
  108.     free((void*) C);
  109.     free((void*) A);
  110.     free((void*) B);
  111.  
  112.     MPI_Finalize();
  113.     return 0;
  114. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement