ping MPI

gistfile1.c

#include <stdio.h>
#include <mpi.h>

int main( int argc, char **argv) {

  int size, rank;
  int msg = 0;
  MPI_Status status;
  MPI_Init(&argc, &argv);

  // ilosc procesow
  MPI_Comm_size(MPI_COMM_WORLD,&size);
  // numer procesu
  MPI_Comm_rank(MPI_COMM_WORLD,&rank);
  

  // wysylam do nastepnego procesu
  if(!MPI_Send(&msg, 1, MPI_INT, (rank+1)%size, 666, MPI_COMM_WORLD)) {
    printf("rank%i wyslal do %d wartosc %d\n",rank,(rank+1)%size, msg);
    msg++; // zwiekszam przed wyslaniem, nie dziala
  }

  // odbieram z poprzedniego
  if(!MPI_Recv(&msg, 1, MPI_INT, (rank-1)%size, 666, MPI_COMM_WORLD, &status)) {
    printf("rank%i received %d\n",rank,msg);
    msg++; // zwiekszam po odebraniu, nie dziala
  }
  
  MPI_Finalize();

  return 0;
}