mpi_gather構造体

Question

私はqsortでキーと値のペアをソートしようとしています。すべてのprocは、procidとしてファイル名でファイルを読み込みます。 MPI_Gatherはすべての読み取り値をproc 0に送ります。proc 0はキーをソートし、「出力」というファイルにキーとバリューのペアを格納します。しかし、集まりは機能していないようです。どんな助けもありがとうございます。ありがとう！

私は

mpirun -np 3 ./a.out 

などのコードを実行して、私の入力ファイルは、次のとおりです。 ファイル "0"：

21 bbbb 
2119 iiii 
120 hhhh 

ファイル "1"：

40 dddd 
10 aaaa 
100 gggg 

ファイル「2 "：

32 cccc 
44 eeee 
99 ffff 

そして、コードは次のとおりです。

#include <stdio.h> 
#include <stdlib.h> 
#include <mpi.h> 

#define BUFSIZE 3 
#define BUFLEN 255 

struct keyval{ 
int key; 
char val[BUFLEN]; 
}; 

typedef struct keyval keyval_s; 

typedef int (*compareptr)(const void*, const void*); 

int compare (keyval_s * a, keyval_s * b) 
{ 
    return (a->key - b->key); 
} 

int main (int argc, char *argv[]) 
{  
    int values[BUFSIZE]; 
    keyval_s kv[BUFSIZE], *recv; 
    int n, i=0, temp; 
    FILE *in, *out; 

    int rank, size; 
    MPI_Init(&argc, &argv); 
    MPI_Comm_rank(MPI_COMM_WORLD, &rank); 
    MPI_Comm_size(MPI_COMM_WORLD, &size); 
    char filename[20]; 
    char data[20]; 

    if(rank ==0){ 
recv = (keyval_s *) malloc (size*BUFSIZE*sizeof(keyval_s)); 
    } 

    sprintf(filename, "%d", rank); 
    in=fopen(filename,"r"); 
    while(fscanf(in,"%d %s",&kv[i].key, kv[i].val) != EOF){ 
printf("Read key %d, data %s from file\n", kv[i].key, kv[i].val); 
i++; 
    } 
    MPI_Gather(kv,BUFSIZE,MPI_BYTE,recv,BUFSIZE,MPI_BYTE,0,MPI_COMM_WORLD); 
    if(rank==0){ 
qsort ((void*)&kv, BUFSIZE, sizeof(keyval_s),(compareptr) compare); 
out=fopen("Output","w"); 
for (n=0; n<BUFSIZE*size; n++) 
    fprintf (out,"%d %s\n",recv[n].key, recv[n].val); 
free(recv); 
fclose(out); 
    } 
fclose(in); 
return 0; 
} 

Answer 1

MPI_Gather内のデータのサイズが間違っています。これはMPI_Gatherでrecvcountパラメータがシングルランクからのメッセージではなく、収集されたデータの合計サイズ用であることを

MPI_Gather(kv, 
      sizeof(keyval_s)*BUFSIZE, 
      MPI_BYTE, 
      recv, 
      sizeof(keyval_s)*BUFSIZE, 
      MPI_BYTE, 
      0, 
      MPI_COMM_WORLD); 

注意すべきです。