Простая программа MPI - PullRequest
Новая
       8

Простая программа MPI

2 голосов
/ 10 мая 2011

Я пытаюсь сделать несколько MPI, и вот простая программа, использующая MPI_Send, MPI_Recv (да, блокировка). Ранг 0 отправляет сообщения всем другим процессам, а остальные получают его. Тем не менее, мой MPI_Send никогда не возвращается. Я что-то здесь упускаю? Спасибо! 

#include<stdio.h>
#include<string.h>
#include<unistd.h>
#include"mpi.h"

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

int rank, size, i;
MPI_Status status;
char message[20];
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
strcpy(message, "Hello, world");
if (rank==0){
   for(i=1;i<size;i++){

         printf("I am sending %s\n", message);
         MPI_Send(message, 23, MPI_BYTE, 0, 7, MPI_COMM_WORLD);
         printf("Sending node=%d, message=%s\n", rank, message);
 }
}
else{
                     MPI_Recv(message, 23, MPI_BYTE, MPI_ANY_SOURCE, 7, MPI_COMM_WORLD,&status);
                     printf("Receiving node=%d, message=%s\n", rank, message);
 }
MPI_Finalize();
return 0;
}

Ответы [ 2 ]

11 голосов
/ 10 мая 2011

Вы отправляете сообщение себе: 

MPI_Send(message, 23, MPI_BYTE, 0, 7, MPI_COMM_WORLD);

Я считаю, что это должно быть 

MPI_Send(message, 23, MPI_BYTE, i, 7, MPI_COMM_WORLD);
4 голосов
/ 07 декабря 2012

Как указывает @cnicutar, процесс 0 отправляет сообщения самому себе. Однако мне кажется, что MPI_Bcast будет лучшим выбором здесь. Это, безусловно, будет намного проще, поскольку он действует как метод «отправить» и «получить».

...