dpm(数据保护管理器)
<p><strong>DPM</strong></p>
<p>数据保护管理器</p>
<p><strong>数据类型执行代码</strong>
<a href="https://github.com/qianyongjun895/HPIPS/tree/master/OpenMpi-Chain/ompi/dpm">https://github.com/qianyongjun895/HPIPS/tree/master/OpenMpi-Chain/ompi/dpm</a></p>
<p><strong>初始化DMP系统</strong>
int ompi_dpm_init(void);</p>
<p><strong>链接/接收通讯 </strong>
int ompi_dpm_connect_accept(ompi_communicator_t <em>comm, int root,const char </em>port, bool send_first,ompi_communicator_t **newcomm)</p>
<p><strong>在用户没有断开连接的情况下, 在所有动态通信者内部执行断开连接</strong>
int ompi_dpm_disconnect(ompi_communicator_t *comm)</p>
<p><strong>动态生成进程</strong>
int ompi_dpm_spawn(int count, char const *array_of_commands[], char *<em>array_of_argv[],】 const int array_of_maxprocs[],const MPI_Info array_of_info[],
const char </em>port_name)</p>
<p><strong>数据保护动态初始化</strong>
int ompi_dpm_dyn_init(void)</p>
<p><strong>接口的 mpi_finalize 调用, 以确保动态生成的触发集体敲定</strong>
int ompi_dpm_dyn_finalize(void);</p>
<p><strong>此例程计算特定通信器中给定进程的不同 jobids 的数量。如果有一个以上的 jobid, 我们将通信器标记为 "动态"。这是特别相关的 MPI_Comm_disconnect <em> 和 </em> 为 MPI_Finalize, 在那里我们必须等待所有仍然连接的进程</strong>
void ompi_dpm_mark_dyncomm(ompi_communicator_t *comm)</p>
<p><strong>为动态生成的作业定义会合点</strong>
int ompi_dpm_open_port(char *port_name)</p>
<p><strong>取消发布集合点</strong>
int ompi_dpm_close_port(const char *port_name)</p>
<p><strong>完成DMP</strong>
int ompi_dpm_finalize(void)</p>