c - MPI Isend 和 Ireceive 不起作用

Question

我在使用 Isend 和 Ireceive 时遇到问题。我试图向所有其他处理器发送消息，然后从其他处理器接收相同类型的消息，这些处理器执行相同的 Isend 方法。

void msgs(int my_rank, int num_procs){
    int arrive_count = 1;
    int leave_count = 0;
    int i;
    bool b_req = true;
    MPI_Request req, req2;
    //Send to all other procs
    for(i=0; i<num_procs; i++){
        if(i != my_rank){
            MPI_Isend(&b_req,sizeof(bool),MPI_BYTE,i,1,MPI_COMM_WORLD, &req);
        }
    }
    bool c_req;
    //Receive msgs from all other procs
    while(arrive_count != num_procs){              
        for(i=0; i<num_procs; i++){
            if(i != my_rank){     
                MPI_Irecv(&c_req,sizeof(bool),MPI_BYTE,i,1,MPI_COMM_WORLD, &req2);              
                if(c_req){
                    c_req = false;
                    arrive_count ++;                
                }
                MPI_Request_free(&req2);
            }
        }
    }
    printf("Done from rank: %d \n", my_rank);    
}

Answer 1

您的代码片段至少存在三个问题:

• 您不能将 MPI_BYTE 与 bool 一起使用。 MPI 标准允许您将 MPI_C_BOOL 与 _Bool 一起使用，另一个选项是在 bool 和 byte 之间手动转换> 传输MPI_BYTE
之前
• 您没有正确使用MPI_Isend() 和MPI_Recv()。您应该有一个请求数组，最后调用 MPI_Waitall()。
• 您可以在第一个循环中MPI_Irecv()所有远程对等点，然后MPI_Test()检查消息是否已到达另一个循环(请注意，您将需要一个 c_req 数组)，或者有一个循环，如果消息有，则紧接着 MPI_Iprobe() 和 MPI_Recv()到达(并且需要一个c_req。

顺便说一句，除非您在 while 循环中进行任何处理，否则您可能需要考虑集体操作，例如 MPI_Alltoall()。