在 Windows 上使用 MPI_SEND 和 MPI_RECV 时出错

Question

我正在关注我的文档中的源代码，但是当我尝试使用 Open MPI 库中的 MPI_Send() 和 MPI_Recv() 时遇到错误。 我已经在这个网站上搜索并阅读了一些主题，但我找不到解决我的错误的解决方案。 这是我的错误：

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.：我在 Windows 8.1 操作系统上使用 Open MPI v1.6。

Answer 1

您将错误的参数传递给 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 选择的方法相互通信。

Answer 2

在两个地方的 MPI_Recv 中设置 MPI_STATUS_IGNORED 而不是 &status。