删除以下打印语句后来自 MPI_Bsend 的 MPI_ERR_BUFFER？

Question

我有以下有效的代码：

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

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

  int world_rank, world_size;
  MPI_Init(NULL, NULL);
  MPI_Comm_rank(MPI_COMM_WORLD, &world_rank);
  MPI_Comm_size(MPI_COMM_WORLD, &world_size);

  int n = 10000;
  int ni, i;

  double t[n];
  int x[n];

  int buf[n];
  int buf_size = n*sizeof(int);
  MPI_Buffer_attach(buf, buf_size);

  if (world_rank == 0) {
    for (ni = 0; ni < n; ++ni) {
      int msg_size = ni;
      int msg[msg_size];
      for (i = 0; i < msg_size; ++i) {
        msg[i] = rand();
      }

      double time0 = MPI_Wtime();
      MPI_Bsend(&msg, msg_size, MPI_INT, 1, 0, MPI_COMM_WORLD);
      t[ni] = MPI_Wtime() - time0;
      x[ni] = msg_size;
      MPI_Barrier(MPI_COMM_WORLD);
      printf("P0 sent msg with size %d\n", msg_size);
    }
  }

  else if (world_rank == 1) {
    for (ni = 0; ni < n; ++ni) {
      int msg_size = ni;
      int msg[msg_size];
      MPI_Request request;
      MPI_Barrier(MPI_COMM_WORLD);
      MPI_Irecv(&msg, msg_size, MPI_INT, 0, 0, MPI_COMM_WORLD, &request);
      MPI_Wait(&request, MPI_STATUS_IGNORE);
      printf("P1 received msg with size %d\n", msg_size);
    }
  }
  MPI_Buffer_detach(&buf, &buf_size);
  MPI_Finalize();
}

一旦我删除打印语句，程序就会崩溃，告诉我有一个MPI_ERR_BUFFER: invalid buffer pointer。如果我只删除一个打印语句，其他打印语句仍会执行，所以我相信它会在程序结束时崩溃。我不明白为什么它会崩溃，而且当我使用打印语句时它不会崩溃超出了我的逻辑......

有人知道这里发生了什么吗？

Answer 1

您根本没有为 MPI 提供足够的缓冲区空间。在缓冲模式下，所有正在进行的消息都存储在用作环形缓冲区的缓冲区空间中。在您的代码中，可能有多个消息需要缓冲，而不管printf。请注意，即使2*n*sizeof(int) 也没有足够的缓冲区空间 - 即使相应的接收完成，屏障也不能保证缓冲区在本地释放。您必须提供(n*(n-1)/2)*sizeof(int) 内存才能确定，或者介于两者之间并希望。

底线：不要使用缓冲模式。

通常，使用标准阻塞发送调用并编写应用程序以使其不会死锁。调整 MPI 实现，以便无论接收者如何都可以发送小消息 - 以避免延迟接收者的等待时间。

如果您想重叠通信和计算，请使用非阻塞消息 - 为每次通信提供适当的内存。