17.2.421. MPI_Unpack_external
MPI_Unpack_external — 从可移植格式读取数据
17.2.421.1. 语法
17.2.421.1.1. C语法
#include <mpi.h>
int MPI_Unpack_external(const char datarep[], const void *inbuf,
MPI_Aint insize, MPI_Aint *position,
void *outbuf, int outcount,
MPI_Datatype datatype)
17.2.421.1.2. Fortran语法
USE MPI
! or the older form: INCLUDE 'mpif.h'
MPI_UNPACK_EXTERNAL(DATAREP, INBUF, INSIZE, POSITION,
OUTBUF, OUTCOUNT, DATATYPE, IERROR)
INTEGER OUTCOUNT, DATATYPE, IERROR
INTEGER(KIND=MPI_ADDRESS_KIND) INSIZE, POSITION
CHARACTER*(*) DATAREP
<type> INBUF(*), OUTBUF(*)
17.2.421.1.3. Fortran 2008 语法
USE mpi_f08
MPI_Unpack_external(datarep, inbuf, insize, position, outbuf, outcount,
datatype, ierror)
CHARACTER(LEN=*), INTENT(IN) :: datarep
TYPE(*), DIMENSION(..), INTENT(IN) :: inbuf
TYPE(*), DIMENSION(..) :: outbuf
INTEGER(KIND=MPI_ADDRESS_KIND), INTENT(IN) :: insize
INTEGER(KIND=MPI_ADDRESS_KIND), INTENT(INOUT) :: position
INTEGER, INTENT(IN) :: outcount
TYPE(MPI_Datatype), INTENT(IN) :: datatype
INTEGER, OPTIONAL, INTENT(OUT) :: ierror
17.2.421.2. 输入参数
datarep: 数据表示(字符串)。inbuf: 输入缓冲区起始位置(可选)。insize: 输入缓冲区的大小,以字节为单位(整数)。outcount: 待解包的项目数量(整数)。datatype: 每个输出数据项的数据类型(句柄)。
17.2.421.3. 输入/输出参数
position: 缓冲区中的当前位置,以字节为单位(整数)。
17.2.421.4. 输出参数
outbuf: 输出缓冲区起始位置(选项)。ierror: 仅限Fortran:错误状态(整数)。
17.2.421.5. 描述
MPI_Unpack_external 从external32格式解包数据,这是一种由MPI论坛定义的通用数据表示格式。该格式在MPI实现之间交换数据或将数据写入文件时非常有用。
输入缓冲区是一个由inbuf指向的连续存储区域,包含insize字节。输出缓冲区可以是MPI_Recv中允许的任何通信缓冲区,由outbuf、outcount和datatype指定。
position的输入值表示inbuf中开始读取解包数据的首个位置(以字节为单位计量,而非元素数量,相对于缓冲区起始位置)。函数返回时,position会增加已解包消息的大小,使其指向inbuf中刚解包消息之后的首个位置。这种方式使其可作为后续调用MPI_Unpack_external时的输入参数。
17.2.421.6. 注意事项
注意MPI_Recv和MPI_Unpack_external之间的区别:在MPI_Recv中,count参数指定了可接收的最大项目数。而在MPI_Unpack_external中,outcount参数指定了实际需要解包的项目数。对于常规接收操作,传入消息的大小决定了将被接收的组件数量。而对于MPI_Unpack_external,则由用户指定要解包多少组件,因为用户可能希望将接收到的消息多次解包到不同的缓冲区中。
为了理解pack和unpack的行为,可以方便地将消息的数据部分视为通过连接该消息中连续发送的值所获得的序列。pack操作将此序列存储在缓冲区空间中,就像将消息发送到该缓冲区一样。unpack操作从缓冲区空间检索此序列,就像从该缓冲区接收消息一样。(可以联想Fortran内部文件或C语言中的sscanf函数来理解类似功能。)
可以将多条消息连续打包到一个打包单元中。这是通过多次连续相关的MPI_Pack_external调用来实现的,其中第一次调用提供position=0,而每次后续调用都输入前一次调用输出的position值,同时保持outbuf和outcount的值不变。这个打包单元现在包含的信息等同于通过一次发送调用存储的消息,其发送缓冲区是各个发送缓冲区的"串联"。
打包单元可以使用MPI_BYTE类型发送。任何点对点或集体通信函数都可以用于将构成打包单元的字节序列从一个进程移动到另一个进程。现在可以使用任何接收操作接收此打包单元,使用任何数据类型:对于使用MPI_BYTE类型发送的消息,类型匹配规则会放宽。
一个打包单元可以被解包成多个连续的消息。这是通过多次连续相关的MPI_Unpack_external调用来实现的,其中第一次调用提供position=0,而每次后续调用都输入前一次调用输出的position值,以及相同的inbuf和insize值。
两个打包单元的连接不一定是打包单元;打包单元的子串也不一定是打包单元。 因此,不能将两个打包单元连接后作为一个打包单元解包;也不能将打包单元的子串作为单独的打包单元解包。 每个由一系列相关打包调用创建的打包单元,必须通过一系列相关的解包调用作为一个单元进行解包。
17.2.421.7. 错误
几乎所有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-3.1标准中的错误处理部分。
另请参阅
sscanf(3C)