From: cristianrosa Date: Tue, 15 Feb 2011 16:09:02 +0000 (+0000) Subject: Add another SMPI bugged example to test the MC. X-Git-Tag: v3.6_beta2~301 X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/af501088d2630992f48a552dc250273aa09fe10b?ds=sidebyside Add another SMPI bugged example to test the MC. git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@9632 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- diff --git a/examples/smpi/CMakeLists.txt b/examples/smpi/CMakeLists.txt index a3932a39bc..8300bfaa44 100644 --- a/examples/smpi/CMakeLists.txt +++ b/examples/smpi/CMakeLists.txt @@ -26,6 +26,7 @@ add_executable(smpi_sendrecv sendrecv.c) add_executable(smpi_traced smpi_traced.c) add_executable(ttest01 ttest01.c) add_executable(mc_bugged1 mc_bugged1.c) +add_executable(mc_bugged2 mc_bugged2.c) target_link_libraries(alltoall2 m simgrid smpi ) target_link_libraries(alltoall_basic m simgrid smpi ) @@ -45,5 +46,6 @@ target_link_libraries(smpi_sendrecv m simgrid smpi ) target_link_libraries(smpi_traced m simgrid smpi ) target_link_libraries(ttest01 m simgrid smpi ) target_link_libraries(mc_bugged1 m simgrid smpi ) +target_link_libraries(mc_bugged2 m simgrid smpi ) set_target_properties(smpi_sendrecv PROPERTIES RENAME sendrecv) diff --git a/examples/smpi/mc_bugged2.c b/examples/smpi/mc_bugged2.c new file mode 100644 index 0000000000..5297b3fa5f --- /dev/null +++ b/examples/smpi/mc_bugged2.c @@ -0,0 +1,47 @@ +/* A simple bugged MPI_ISend and MPI_IRecv test */ + +/* Copyright (c) 2009, 2011. The SimGrid Team. + * All rights reserved. */ + +/* This program is free software; you can redistribute it and/or modify it + * under the terms of the license (GNU LGPL) which comes with this package. */ + +#include +#include +#include + + +int main(int argc, char **argv) +{ + int recv_buff, err, size, rank; + MPI_Status status; + + /* Initialize MPI */ + err = MPI_Init(&argc, &argv); + if (err != MPI_SUCCESS) { + printf("MPI initialization failed!\n"); + exit(1); + } + + err = MPI_Comm_size(MPI_COMM_WORLD, &size); /* Get nr of tasks */ + err = MPI_Comm_rank(MPI_COMM_WORLD, &rank); /* Get id of this process */ + if (size % 3 != 0) { + printf("run this program with exactly 3*N processes \n"); + MPI_Finalize(); + exit(0); + } + + if (rank % 3 == 0) { + MPI_Recv(&recv_buff, 1, MPI_INT, MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &status); + printf("(%d) receive %d\n", rank, recv_buff); + MPI_Recv(&recv_buff, 1, MPI_INT, MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &status); + printf("(%d) receive %d\n", rank, recv_buff); + }else{ + MPI_Send(&rank, 1, MPI_INT, (rank / 3) * 3, 42, MPI_COMM_WORLD); + printf("Sent %d to rank %d\n", rank, (rank / 3) * 3); + } + + MPI_Finalize(); + + return 0; +}