Ошибка при использовании MPI_SEND и MPI_RECV в Windows

Question

Я следую исходному коду в своих документах, но при попытке использовать и MPI_Recv() из библиотеки Open MPI я сталкиваюсь с ошибкой. У меня есть googled и читать некоторые темы на этом сайте, но я не могу найти решение для решения моей ошибки. Это моя ошибка:

mca_oob_tcp_msg_recv: readv faled : Unknown error (108) 

Здесь детали изображения:

И это код, который я следующее:

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

int main(int argc, char **argv) { 
int rank, size, mesg, tag = 123; 
MPI_Status status; 

MPI_Init(&argv, &argv); 
MPI_Comm_size(MPI_COMM_WORLD, &size); 
MPI_Comm_rank(MPI_COMM_WORLD, &rank); 
if (size < 2) { 
    printf("Need at least 2 processes!\n"); 
} else if (rank == 0) { 
    mesg = 11; 
    MPI_Send(&mesg,1,MPI_INT,1,tag,MPI_COMM_WORLD); 
    MPI_Recv(&mesg,1,MPI_INT,1,tag,MPI_COMM_WORLD,&status); 
    printf("Rank 0 received %d from rank 1\n",mesg); 
} else if (rank == 1) { 
    MPI_Recv(&mesg,1,MPI_INT,0,tag,MPI_COMM_WORLD,&status); 
    printf("Rank 1 received %d from rank 0/n",mesg); 
    mesg = 42; 
    MPI_Send(&mesg,1,MPI_INT,0,tag,MPI_COMM_WORLD); 
} 
MPI_Finalize(); 
return 0; 
} 

Я заметил все MPI_Send() , и MPI_Recv(), и моя программа сработала. В другой руке я прокомментировал либо MPI_Send(), либо MPI_Recv(), и у меня все еще есть эта ошибка. Поэтому я думаю, что проблема заключается в функциях MPI_Send() и MPI_Recv().

P.S .: Я использую Open MPI v1.6 для ОС Windows 8.1.

Answer 1

Комплект MPI_STATUS_IGNORED вместо &status в MPI_Recv в обоих местах.

Answer 2

Вы передаете неправильные аргументы MPI_Init (два раза argv, вместо argc и argv один раз). Похоже, что отправляет и получает на самом деле взгляд. Но есть одна опечатка в одной из ваших отпечатков с /n вместо \n.

Вот что работает для меня (на MacOSX, хотя):

int main(int argc, char **argv) { 
int rank, size, mesg, tag = 123; 
MPI_Status status; 

MPI_Init(&argc, &argv); 
MPI_Comm_size(MPI_COMM_WORLD, &size); 
MPI_Comm_rank(MPI_COMM_WORLD, &rank); 
if (size < 2) { 
    printf("Need at least 2 processes!\n"); 
} else if (rank == 0) { 
    mesg = 11; 
    MPI_Send(&mesg,1,MPI_INT,1,tag,MPI_COMM_WORLD); 
    MPI_Recv(&mesg,1,MPI_INT,1,tag,MPI_COMM_WORLD,&status); 
    printf("Rank 0 received %d from rank 1\n",mesg); 
} else if (rank == 1) { 
    MPI_Recv(&mesg,1,MPI_INT,0,tag,MPI_COMM_WORLD,&status); 
    printf("Rank 1 received %d from rank 0\n",mesg); 
    mesg = 42; 
    MPI_Send(&mesg,1,MPI_INT,0,tag,MPI_COMM_WORLD); 
} 
MPI_Finalize(); 
return 0; 
} 

Если это не работает, я предполагаю, что ваша операционная система не позволяет процессы взаимодействуют друг с другом с помощью метода, выбранного OpenMPI.