Мне нужно было использовать функцию MPI_Gather в моей программе умножения матриц, но последние пару дней у меня с ней проблемы.
Поэтому я написал простую программу MPI, используя только функцию сбора, и пытался заставить ее работать... Для этого я сослался на книгу «Введение в параллельное программирование» Питера Пачеко.
Программа сразу завершает работу, не давая мне абсолютно никаких результатов или ошибок... Я до сих пор не смог понять ошибку.
/******************NOTE**********************
The program simply uses the MPI_Gather() function.
The program is exiting directly.
I have written it for only TWO processes.
(-np 2)
******************************************/
#include<stdio.h>
#include"mpi.h"
int main()
{
int i,j,proc,rank;
double d[4];
double local_a[2];
MPI_Init(NULL,NULL);
MPI_Comm_size(MPI_COMM_WORLD, &proc);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
if(rank==0)
{
local_a[0]=1.0;
local_a[1]=2.0;
}
else
{
local_a[0]=3.0;
local_a[1]=4.0;
}
int local=2;
if(rank==0)
{
MPI_Gather(local_a,local,MPI_DOUBLE,d,local,MPI_DOUBLE,0,MPI_COMM_WORLD);
//MPI_Gather(&local_a,local,MPI_DOUBLE,&d,local,MPI_DOUBLE,0,MPI_COMM_WORLD);
//also tried the above line just to be certain.
printf("\n");
for(j=0;j<4;j++)
printf("\t%f",d[j]);
}
else
{
MPI_Gather(local_a,local,MPI_DOUBLE,d,local,MPI_DOUBLE,0,MPI_COMM_WORLD);
//MPI_Gather(&local_a,local,MPI_DOUBLE,&d,local,MPI_DOUBLE,0,MPI_COMM_WORLD);
}
MPI_Finalize();
return 0;
}
Может кто-нибудь, пожалуйста, помогите мне.
Спасибо.
Анага Мадхусуданан