Scatter/Gather

Introduction

The MPI_Scatter primitive is sends chunks of data stored in an array to several process ranks, where each rank receives different data elements. It is similar to MPI_Broadcast, except that MPI_Broadcast sends the same data to process ranks.

The syntax is as follows:

int MPI_Scatter(const void *sendbuf, 
		int sendcount,
		MPI_Datatype sendtype,
		void *recvbuf,
		int recvcount,
		MPI_Datatype recvtype,
		int root,
		MPI_Comm comm)

The MPI_Gather primitive receives data at the root from other processes. The syntax is as follows:

int MPI_Gather(const void *sendbuf, 
		int sendcount, 
		MPI_Datatype sendtype,
		void *recvbuf, 
		int recvcount, 
		MPI_Datatype recvtype,
		int root, 
		MPI_Comm comm)

Connection to Modules

  • This module may be useful for the distance matrix and K-means modules.

Files Required

Sum of an Array Part 1: Implementing Scatter and Gather using Send and Recv

In this exercise, rank 0 will generate an array of size $N$. There are $p$ process ranks. We assume $N~\mathrm{mod}~p=0$, i.e., $N/p$ divides evenly.

We will compute the total sum of the values in the array of size $N$ using the $p$ ranks. Using MPI_Send you will send chunks of size $N/p$ to each process rank from rank 0. Each rank will add the values in the array together ($N/p$ elements) and will send the data back to rank 0 using MPI_Send. At the end, rank 0 will add all of the values from each of the ranks together and output the total sum.

In this exercise, we will only use MPI_Send and MPI_Recv.

To get started, use the file scatter_starter.c.

Figure 1 shows an example of the sending the data, where $N=12$ and $p=4$. Each rank is sent $N/p=3$ elements to compute the local sums.

Figure 1: Example of sending chunks of size $N/p=3$ to $p=4$ ranks, where $N=12$.

Figure 2 shows an example of sending the data from each rank to rank 0.

Figure 2: Example of sending the local sums of the arrays at each rank to rank 0.

Sum of an Array Part 2: Using Scatter and Gather

Copy your code from Part 1. This time, implement the program using MPI_Scatter and MPI_Gather without using MPI_Send or MPI_Recv.

Previous
Next