From ae4d05993d7186ffcf4f789f7299c87c0de92c16 Mon Sep 17 00:00:00 2001 From: schnorr Date: Wed, 15 Sep 2010 15:58:25 +0000 Subject: [PATCH] increasing the message size for testing git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@8190 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- examples/smpi/smpi_traced.c | 60 +++++++++++++++++++------------------ 1 file changed, 31 insertions(+), 29 deletions(-) diff --git a/examples/smpi/smpi_traced.c b/examples/smpi/smpi_traced.c index 3fa968fbd6..a754e3bbd2 100644 --- a/examples/smpi/smpi_traced.c +++ b/examples/smpi/smpi_traced.c @@ -7,6 +7,8 @@ #include "mpi.h" #include +#define DATATOSENT 100000000 + int main(int argc, char *argv[]) { int rank, numprocs, i; @@ -50,21 +52,21 @@ int main(int argc, char *argv[]) MPI_Status status; MPI_Request req[2*N]; MPI_Status sta[2*N]; - int r; + int *r = (int*)malloc(sizeof(int)*DATATOSENT); if (A){ - MPI_Isend(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD, &request); + MPI_Isend(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD, &request); MPI_Wait (&request, &status); } MPI_Barrier (MPI_COMM_WORLD); if (B){ - MPI_Send(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD); } MPI_Barrier (MPI_COMM_WORLD); if (C){ for (i = 0; i < N; i++){ - MPI_Isend(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); + MPI_Isend(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ MPI_Wait (&req[i], &sta[i]); @@ -74,7 +76,7 @@ int main(int argc, char *argv[]) if (D){ for (i = 0; i < N; i++){ - MPI_Isend(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); + MPI_Isend(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ int completed; @@ -85,21 +87,21 @@ int main(int argc, char *argv[]) if (E){ for (i = 0; i < N; i++){ - MPI_Send(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD); } } MPI_Barrier (MPI_COMM_WORLD); if (F){ for (i = 0; i < N; i++){ - MPI_Send(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD); } } MPI_Barrier (MPI_COMM_WORLD); if (G){ for (i = 0; i < N; i++){ - MPI_Isend(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); + MPI_Isend(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); } MPI_Waitall (N, req, sta); } @@ -107,7 +109,7 @@ int main(int argc, char *argv[]) if (H){ for (i = 0; i < N; i++){ - MPI_Send(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD); } } MPI_Barrier (MPI_COMM_WORLD); @@ -115,17 +117,17 @@ int main(int argc, char *argv[]) if (I){ for (i = 0; i < 2*N; i++){ if (i < N){ - MPI_Send(&rank, 1, MPI_INT, 2, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 2, tag, MPI_COMM_WORLD); }else{ - MPI_Send(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD); } } MPI_Barrier (MPI_COMM_WORLD); for (i = 0; i < 2*N; i++){ if (i < N){ - MPI_Irecv(&r, 1, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); }else{ - MPI_Irecv(&r, 1, MPI_INT, 2, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 2, tag, MPI_COMM_WORLD, &req[i]); } } MPI_Waitall (2*N, req, sta); @@ -134,7 +136,7 @@ int main(int argc, char *argv[]) if (J){ for (i = 0; i < N; i++){ - MPI_Isend(&rank, 1, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); + MPI_Isend(r, DATATOSENT, MPI_INT, 1, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ int flag; @@ -153,36 +155,36 @@ int main(int argc, char *argv[]) MPI_Status status; MPI_Request req[N]; MPI_Status sta[N]; - int r; + int *r = (int*)malloc(sizeof(int)*DATATOSENT); if (A){ - MPI_Recv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &status); + MPI_Recv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &status); } MPI_Barrier (MPI_COMM_WORLD); if (B){ - MPI_Irecv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &request); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &request); MPI_Wait (&request, &status); } MPI_Barrier (MPI_COMM_WORLD); if (C){ for (i = 0; i < N; i++){ - MPI_Recv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &sta[i]); + MPI_Recv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &sta[i]); } } MPI_Barrier (MPI_COMM_WORLD); if (D){ for (i = 0; i < N; i++){ - MPI_Recv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &sta[i]); + MPI_Recv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &sta[i]); } } MPI_Barrier (MPI_COMM_WORLD); if (E){ for (i = 0; i < N; i++){ - MPI_Irecv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ MPI_Wait (&req[i], &sta[i]); @@ -192,7 +194,7 @@ int main(int argc, char *argv[]) if (F){ for (i = 0; i < N; i++){ - MPI_Irecv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ int completed; @@ -203,14 +205,14 @@ int main(int argc, char *argv[]) if (G){ for (i = 0; i < N; i++){ - MPI_Recv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &sta[i]); + MPI_Recv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &sta[i]); } } MPI_Barrier (MPI_COMM_WORLD); if (H){ for (i = 0; i < N; i++){ - MPI_Irecv(&rank, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } MPI_Waitall (N, req, sta); } @@ -218,13 +220,13 @@ int main(int argc, char *argv[]) if (I){ for (i = 0; i < N; i++){ - MPI_Irecv(&rank, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } MPI_Waitall (N, req, sta); MPI_Barrier (MPI_COMM_WORLD); for (i = 0; i < N; i++){ - MPI_Isend(&rank, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Isend(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } MPI_Waitall (N, req, sta); // for (i = 0; i < N; i++){ @@ -235,7 +237,7 @@ int main(int argc, char *argv[]) if (J){ for (i = 0; i < N; i++){ - MPI_Irecv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ int flag; @@ -254,7 +256,7 @@ int main(int argc, char *argv[]) // MPI_Status status; MPI_Request req[N]; MPI_Status sta[N]; - int r; + int *r = (int*)malloc(sizeof(int)*DATATOSENT); if (A) {} MPI_Barrier (MPI_COMM_WORLD); @@ -274,7 +276,7 @@ int main(int argc, char *argv[]) MPI_Barrier (MPI_COMM_WORLD); if (I){ for (i = 0; i < N; i++){ - MPI_Irecv(&r, 1, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); + MPI_Irecv(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD, &req[i]); } for (i = 0; i < N; i++){ int completed; @@ -283,7 +285,7 @@ int main(int argc, char *argv[]) MPI_Barrier (MPI_COMM_WORLD); for (i = 0; i < N; i++){ - MPI_Send(&rank, 1, MPI_INT, 0, tag, MPI_COMM_WORLD); + MPI_Send(r, DATATOSENT, MPI_INT, 0, tag, MPI_COMM_WORLD); } } MPI_Barrier (MPI_COMM_WORLD); -- 2.20.1