From b6aaebb41faacd98894520d95f3cf18ab9fb0167 Mon Sep 17 00:00:00 2001 From: cristianrosa Date: Tue, 15 Feb 2011 16:08:48 +0000 Subject: [PATCH] Add SMPI bugged example to test the MC. git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@9629 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- examples/smpi/CMakeLists.txt | 4 ++- examples/smpi/mc_bugged1.c | 53 ++++++++++++++++++++++++++++++++++++ 2 files changed, 56 insertions(+), 1 deletion(-) create mode 100644 examples/smpi/mc_bugged1.c diff --git a/examples/smpi/CMakeLists.txt b/examples/smpi/CMakeLists.txt index acaef242ba..a3932a39bc 100644 --- a/examples/smpi/CMakeLists.txt +++ b/examples/smpi/CMakeLists.txt @@ -25,6 +25,7 @@ add_executable(mvmul mvmul.c) 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) target_link_libraries(alltoall2 m simgrid smpi ) target_link_libraries(alltoall_basic m simgrid smpi ) @@ -43,5 +44,6 @@ target_link_libraries(mvmul m simgrid smpi ) 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 ) -set_target_properties(smpi_sendrecv PROPERTIES RENAME sendrecv) \ No newline at end of file +set_target_properties(smpi_sendrecv PROPERTIES RENAME sendrecv) diff --git a/examples/smpi/mc_bugged1.c b/examples/smpi/mc_bugged1.c new file mode 100644 index 0000000000..b047f2d026 --- /dev/null +++ b/examples/smpi/mc_bugged1.c @@ -0,0 +1,53 @@ +/* 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, i; + 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 < 2) { + printf("run this program with exactly 2 processes (-np 2)\n"); + MPI_Finalize(); + exit(0); + } + + if (rank == 0) { + printf("MPI_ISend / MPI_IRecv Test \n"); + + for(i=0; i < size - 1; i++){ + MPI_Recv(&recv_buff, 1, MPI_INT, MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &status); + printf("Message received from %d\n", recv_buff); + } + + printf("recv_buff = %d\n", recv_buff); + MC_assert(recv_buff == size - 1); + + }else{ + MPI_Send(&rank, 1, MPI_INT, 0, 42, MPI_COMM_WORLD); + printf("Sent %d to rank 0\n", rank); + } + + MPI_Finalize(); + + return 0; +} -- 2.20.1