17.2.426. MPI_Waitsome

MPI_Waitsome — 等待部分指定的通信操作完成。

17.2.426.1. 语法

17.2.426.1.1. C语法

#include <mpi.h>

int MPI_Waitsome(int incount, MPI_Request array_of_requests[],
     int *outcount, int array_of_indices[],
     MPI_Status array_of_statuses[])

17.2.426.1.2. Fortran语法

USE MPI
! or the older form: INCLUDE 'mpif.h'
MPI_WAITSOME(INCOUNT, ARRAY_OF_REQUESTS, OUTCOUNT,
             ARRAY_OF_INDICES, ARRAY_OF_STATUSES, IERROR)
     INTEGER INCOUNT, ARRAY_OF_REQUESTS(*), OUTCOUNT
     INTEGER ARRAY_OF_INDICES(*)
     INTEGER ARRAY_OF_STATUSES(MPI_STATUS_SIZE*)
     INTEGER IERROR

17.2.426.1.3. Fortran 2008 语法

USE mpi_f08
MPI_Waitsome(incount, array_of_requests, outcount, array_of_indices,
             array_of_statuses, ierror)
     INTEGER, INTENT(IN) :: incount
     TYPE(MPI_Request), INTENT(INOUT) :: array_of_requests(incount)
     INTEGER, INTENT(OUT) :: outcount, array_of_indices(*)
     TYPE(MPI_Status) :: array_of_statuses(*)
     INTEGER, OPTIONAL, INTENT(OUT) :: ierror

17.2.426.2. 输入参数

  • incount: 数组array_of_requests的长度(整数)。

  • array_of_requests: 请求数组(句柄数组)。

17.2.426.3. 输出参数

  • outcount: 已完成请求的数量(整数)。

  • array_of_indices: 已完成操作的索引数组(整数数组)。

  • array_of_statuses: 已完成操作的状态对象数组(状态数组)。

  • ierror: 仅限Fortran:错误状态(整数)。

17.2.426.4. 描述

等待直到列表中活动句柄关联的至少一个操作完成。在outcount中返回已完成操作的请求数量(来自array_of_requests数组)。在array_of_indices数组的前outcount个位置中返回这些操作的索引(在array_of_requests数组中的索引;C语言中数组从0开始索引,Fortran中从1开始)。在array_of_status数组的前outcount个位置中返回这些已完成操作的状态。如果完成的请求是由非阻塞通信调用分配的,则该请求会被释放,并且关联的句柄会被设置为MPI_REQUEST_NULL。

如果列表中没有活动的句柄,则调用会立即返回,且outcount = MPI_UNDEFINED。

当一个或多个由MPI_Waitsome完成的通信操作失败时,通常需要返回每个通信的具体信息。参数outcount、array_of_indices和array_of_statuses将被调整,以指示所有已成功或失败的通信完成情况。该调用将返回错误码MPI_ERR_IN_STATUS,且每个返回状态的错误字段将被设置为指示成功或发生的特定错误。如果没有请求导致错误,调用将返回MPI_SUCCESS;如果由于其他原因(如无效参数)失败,则将返回另一个错误码。在这种情况下,它不会更新状态的错误字段。

如果您的应用程序不需要检查array_of_statuses字段,可以通过使用预定义常量MPI_STATUSES_IGNORE作为array_of_statuses参数的特殊值来节省资源。

示例:MPI_Waitany手册页中的示例代码相同,但 使用MPI_Waitsome

CALL MPI_COMM_SIZE(comm, size, ierr)
CALL MPI_COMM_RANK(comm, rank, ierr)
IF(rank > 0) THEN         ! client code
    DO
       CALL MPI_ISEND(a, n, MPI_REAL, 0, tag, comm, request, ierr)
       CALL MPI_WAIT(request, status, ierr)
    END DO
ELSE         ! rank=0: server code
    DO i=1, size-1
       CALL MPI_IRECV(a(1,i), n, MPI_REAL, i, tag, &
                      comm, requests(i), ierr)
    END DO
    DO
       CALL MPI_WAITSOME(size, request_list, numdone, &
                        indices, statuses, ierr)
       DO i=1, numdone
          CALL DO_SERVICE(a(1, indices(i)))
          CALL MPI_IRECV(a(1, indices(i)), n, MPI_REAL, i, tag, &
                       comm, requests(indices(i)), ierr)
       END DO
    END DO
END IF

17.2.426.5. 注意事项

索引数组的范围在C语言中为0到incount-1,在Fortran中为1到incount。

17.2.426.6. 错误

几乎所有MPI例程都会返回一个错误值;C语言例程通过函数返回值返回,Fortran例程则通过最后一个参数返回。

在返回错误值之前,会调用与通信对象(如通信器、窗口、文件)关联的当前MPI错误处理程序。如果MPI调用未关联任何通信对象,则该调用被视为附加到MPI_COMM_SELF,并将调用关联的MPI错误处理程序。当MPI_COMM_SELF未初始化时(即在MPI_Init/MPI_Init_thread之前、MPI_Finalize之后,或仅使用会话模型时),错误会触发初始错误处理程序。初始错误处理程序可通过在使用世界模型时调用MPI_Comm_set_errhandler来修改MPI_COMM_SELF,或通过mpiexec的mpi_initial_errhandler命令行参数,或MPI_Comm_spawn/MPI_Comm_spawn_multiple的info键来设置。如果未设置其他适当的错误处理程序,则MPI I/O函数将调用MPI_ERRORS_RETURN错误处理程序,而其他所有MPI函数将调用MPI_ERRORS_ABORT错误处理程序。

Open MPI 包含三个可使用的预定义错误处理器:

  • MPI_ERRORS_ARE_FATAL 导致程序中止所有连接的MPI进程。

  • MPI_ERRORS_ABORT 一个可在通信器、窗口、文件或会话上调用的错误处理程序。当在通信器上调用时,其行为类似于在该通信器上调用MPI_Abort。如果在窗口或文件上调用,则行为类似于在包含对应窗口或文件中进程组的通信器上调用MPI_Abort。如果在会话上调用,则仅中止本地进程。

  • MPI_ERRORS_RETURN 向应用程序返回一个错误代码。

MPI应用程序也可以通过调用以下方式实现自己的错误处理程序:

请注意,MPI不保证MPI程序在出现错误后能够继续运行。

查看MPI手册页获取完整的MPI错误代码列表。

有关更多信息,请参阅MPI-3.1标准中的错误处理部分。

对于每次调用MPI_Waitsome,如果一个或多个请求产生MPI错误,只有第一个导致错误的MPI请求会被传递给其对应的错误处理程序。其他错误处理程序将不会被调用(即使多个请求产生了错误)。然而,所有产生错误的请求都会在相应的status.MPI_ERROR字段中设置相关错误代码(除非使用了MPI_STATUSES_IGNORE)。

如果调用的错误处理程序允许MPI_Waitsome返回调用者,在C和Fortran绑定中将返回MPI_ERR_IN_STATUS值。