17.2.377. MPI_Testsome

MPI_Testsome — 测试列表中一个或多个先前发起的通信是否完成。

17.2.377.1. 语法

17.2.377.1.1. C语法

#include <mpi.h>

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

17.2.377.1.2. Fortran语法

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

17.2.377.1.3. Fortran 2008 语法

USE mpi_f08
MPI_Testsome(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.377.2. 输入参数

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

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

17.2.377.3. 输出参数

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

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

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

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

17.2.377.4. 描述

行为类似于MPI_Waitsome,不同之处在于它会立即返回。

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

如果没有操作完成,则返回outcount = 0。如果列表中没有活动句柄,则返回outcount = MPI_UNDEFINED。

MPI_Testsome 是一个本地操作,它会立即返回;而 MPI_Waitsome 则会阻塞直到通信完成(前提是传入的列表中至少包含一个活跃的句柄)。这两个调用都满足公平性要求:如果一个接收请求反复出现在传递给 MPI_WaitsomeMPI_Testsome 的请求列表中,并且已发布了匹配的发送操作,那么该接收最终会成功(除非发送操作被其他接收操作满足);发送请求同样满足此公平性要求。

MPI_Testsome执行期间发生的错误处理方式与MPI_Waitsome相同。

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

17.2.377.5. 备注

使用MPI_Testsome可能比使用MPI_Testany更高效。前者会返回所有已完成通信的信息;而后者需要为每个完成的通信发起新的调用。

一个拥有多个客户端的服务器可以使用MPI_Waitsome来避免任何客户端被饿死。客户端向服务器发送带有服务请求的消息。服务器为每个客户端调用MPI_Waitsome并设置一个接收请求,然后处理所有已完成的接收。如果改用MPI_Waitany调用,那么当一个客户端的请求总是抢先到达时,另一个客户端可能会被饿死。

17.2.377.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_Testsome,如果一个或多个请求产生MPI错误,只有第一个引发错误的MPI请求会被传递给其对应的错误处理程序。其他错误处理程序将不会被调用(即使有多个请求产生了错误)。然而,所有产生错误的请求都会在相应的status.MPI_ERROR字段中设置相关错误代码(除非使用了MPI_STATUSES_IGNORE)。

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