MPI_Barrier上的父节点停滞

Question

我是MPI新手，在运行snow的Mac节点集群上实现mpirun时遇到了一些问题。我遇到的问题涉及到MPI_Barrier()。我有一个简单的函数，如下所示，运行良好。但是，当我在条件结尾处添加MPI_Barrier()命令时，父节点停止。其中一个处理器移过屏障命令，而另一个保持卡住。我希望有人能给我一个快速的解决办法，或者建议一些我的网络环境阻止命令正常工作的方法。

int main (int argc, char **argv)
{
    int me, np, q, sendto;
    double t0, t1;
    MPI_Status status;
    MPI_Init(&argc, &argv);
    t0 = MPI_Wtime();
    MPI_Comm_size(MPI_COMM_WORLD,&np);
    MPI_Commm_rank(MPI_COMM_WORLD,&me);
    if (np%2 == 1) return 0;
    if (me%2 == 1) {sendto = me - 1;}
    else {sendto = me + 1;}
    if (me%2 == 0) {
        MPI_Send(&me, 1, MPI_INT, sendto, me, MPI_COMM_WORLD);
        MPIRecv(&q, 1, MPI_INT, sendto, sendto, MPI_COMM_WORLD, &status);
    } else {
        MPI_Recv(&q, 1, MPI_INT, sendto, sendto, MPI_COMM_WORLD,&status);
        MPI_Send(&me,1,MPI_INT,sendto,me,MPI_COMM_WORLD);
    }
    printf("Send %d to proc %d, received %d from proc %d\n",me,sendto,q,sendto);
    t1 = MPI_Wtime();
    printf("Timing is %g",t1-10);
    MPI_Finalize();
    return 0;
}

Answer 1

除了修复几个打字错误之外，我还能让你的代码正常工作。我在IBM集群上使用openmpi和gnu c编译器。我不知道你把栅栏放在哪里了。我猜对了吗？

#include "mpi.h"
#include "stdio.h"

int main (int argc, char **argv)
{
int me, np, q, sendto;
double t0, t1;
MPI_Status status;
MPI_Init(&argc, &argv);
t0 = MPI_Wtime();
MPI_Comm_size(MPI_COMM_WORLD,&np);
MPI_Comm_rank(MPI_COMM_WORLD,&me);
if (np%2 == 1) {
  MPI_Finalize();
  return 0;
}
if (me%2 == 1) {sendto = me - 1;}
else {sendto = me + 1;}
if (me%2 == 0) {
  MPI_Send(&me, 1, MPI_INT, sendto, me, MPI_COMM_WORLD);
  MPI_Recv(&q, 1, MPI_INT, sendto, sendto, MPI_COMM_WORLD, &status);
} else {
  MPI_Recv(&q, 1, MPI_INT, sendto, sendto, MPI_COMM_WORLD,&status);
  MPI_Send(&me,1,MPI_INT,sendto,me,MPI_COMM_WORLD);
}
MPI_Barrier(MPI_COMM_WORLD);
printf("Send %d to proc %d, received %d from proc %d\n",
   me,sendto,q,sendto);
t1 = MPI_Wtime();
printf("Timing is %g\n",t1-t0);
MPI_Finalize();
return 0;
}