返回MPI数据类型为MPI收集

我有以下MPI_DataType代码返回MPI数据类型为MPI收集

typedef struct resultset { 
    int rank, totalProcessed, bracket1, bracket2, bracket3, bracket4; 
    float bracket1percent, bracket2percent, bracket3percent, bracket4percent; 
} resultset; 

MPI_Datatype createResultType() 
{ 
    // Set-up the arguments for the type constructor 
    MPI_Datatype new_type; 

    int count = 2; 

    int blocklens[] = { 6, 4 }; 

    MPI_Aint indices[2]; 
    indices[0] = 0; 
    MPI_Type_extent(MPI_FLOAT, &indices[1]); 
    indices[1] *= 4; // There are 4 float 

    MPI_Datatype old_types[] = { MPI_INT, MPI_FLOAT }; 

    // Call the data type constructor 
    MPI_Type_struct(count, blocklens, indices, old_types, &new_type); 
    MPI_Type_commit(&new_type); 

    return new_type; 
}

我尝试使用下面的代码从其他进程收到的数据。 rank是一个整数，它定义了进程的级别。

MPI_Datatype resType = createResultType(); 
if(rank != 0){ 
    MPI_Gather(&results, sizeof(resultset), resType, NULL, 1, resType, 0, MPI_COMM_WORLD); 
} 
else { 
    resultset* all_results = new resultset[numProcs]; 
    MPI_Gather(&results, sizeof(resultset), resType, all_results, sizeof(resultset), resType, 0, MPI_COMM_WORLD); 
}

的问题是，我可以通过all_results不循环，使用这种方法：

for(int i = 0; i < numProcs; ++i){ 
    std::cout << all_results[i].rank << " processed " << all_results[i].totalProcessed <<std::endl; 
}

我认为问题在于我的数据类型，但我不知道。任何意见，将不胜感激。

编辑︰我得到了循环它的问题，现在我越来越不完整的数据。我在收集功能中将sizeof(resultset)更改为1。现在我收到了正确的数据，除了最后两个浮点数是-431602080而不是0.0022234327654之外。

MPI_Datatype resType = createResultType(); 
if(rank != 0){ 
    MPI_Gather(&results, 1, resType, NULL, 1, resType, 0, MPI_COMM_WORLD); 
} 
else { 
    resultset* all_results = new resultset[numProcs]; 
    MPI_Gather(&results, 1, resType, all_results, 1, resType, 0, MPI_COMM_WORLD); 
}

来源

2013-11-27 S Grimminck

浮法需要是 “6”

int blocklens[] = { 6, 4 };

到

int blocklens[] = { 6, 6 };

来源

2013-11-27 13:37:24

返回MPI数据类型为MPI收集

回答

相关问题