[MPI] Solution 3 : Pass Data (non-blocking point-to-point communication)

This material is part of the course Practical Introduction to Parallel Programming and meant for educational purposes only.

Task

Implement an MPI program in which a single integer is passed around all processes using non-blocking point-to-point communication.

That is, the process with rank zero assigns the initial value to the integer. It then passes the integer to the process with rank one.

This process, in turn, passes the integer to the process with rank two.

This continues until the process with rank \((p - 1)\), with \(p\) the number of processes. This last process passes the integer back to the process with rank zero.

Finally, the process with rank zero prints the integer to the terminal and the program ends.

Test the program with one and more processes.

Hints

Use the functions MPI_Isend, MPI_Irecv, and MPI_Wait to pass the integer from one process to the next.

Use the function MPI_Comm_rank to determine from which process the integer is to be received, and to which process the integer is to be sent.

Use the function MPI_Comm_size to determine the total number of processes.

Dán dòng lệnh này vào terminal của bạn:

Mật khẩu để kết nối là

Câu hỏi 1: Pass Data

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

int main ( int argc, char** argv )
{
  const int    tag = 0;
  MPI_Request  req = MPI_REQUEST_NULL;

  int          proc_count;
  int          my_rank;
  int          value;

  MPI_Init      ( &argc, &argv );
  MPI_Comm_size ( MPI_COMM_WORLD, &proc_count );
  MPI_Comm_rank ( MPI_COMM_WORLD, &my_rank );

  if ( my_rank == 0 )
  {
    value = 13378; /* The magic value. */

    printf ( "Processor %d: value = %d.\n", my_rank, value );

    if ( proc_count > 1 )
    {
      MPI_Isend ( &value, 1, MPI_INT, my_rank + 1, tag,
                  MPI_COMM_WORLD, &req );
      MPI_Wait  ( &req, MPI_STATUS_IGNORE );
      MPI_Irecv ( &value, 1, MPI_INT, proc_count - 1, tag,
                  MPI_COMM_WORLD, &req );
      MPI_Wait  ( &req, MPI_STATUS_IGNORE );

      printf    ( "Processor %d: value = %d.\n", my_rank, value );
    }
  }
  else
  {
    MPI_Irecv ( &value, 1, MPI_INT, my_rank - 1, tag,
                MPI_COMM_WORLD, &req );
    MPI_Wait  ( &req, MPI_STATUS_IGNORE );

    printf    ( "Processor %d: value = %d.\n", my_rank, value );

    MPI_Isend ( &value, 1, MPI_INT, (my_rank + 1) % proc_count, tag,
                MPI_COMM_WORLD, &req );
    MPI_Wait  ( &req, MPI_STATUS_IGNORE );
  }

  MPI_Finalize ();

  return 0;
}

Câu hỏi 2: Number of MPI processes

Specify the number of MPI processes (1-64) that should be used for running your program (mpirun -np <nproc>)

Câu hỏi 3: Command Line Argument

Specify the command line arguments that should be passed to your program when it is run. Arguments must be given in quotes and separated by commas. Leave this filed empty if you do not want to specify command line arguments.

Example: "1","int","arg=2" is interpreted as three arguments 1, int, and arg=2.

Tác giả	Erik-Jan Lingen, Matthias Möller
Hạn chót	Không có hạn chót
Giới hạn nộp bài	Không có giới hạn

Thông tin

Đăng nhập