下面的代码尝试使用mpi查找数组的最大数目。但是我一直收到以下错误:



谁能告诉我怎么了?

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

int main(int argc , char * argv[])
{
    int myRank , numOfProcesses;
    int source , destination;
    int tag = 0;
    int i = 0, j = 0, k = 0;
    int masterArray[] = {5,6,8,10,12,3,9,-1,3,7};
    int max , globalMax = -100000;
    int flag = 0;

    MPI_Init(&argc, &argv);
    MPI_Status status;
    MPI_Comm_rank(MPI_COMM_WORLD , &myRank);
    MPI_Comm_size(MPI_COMM_WORLD , &numOfProcesses);
    printf("Process : %d \n" , myRank);

    int masterSize = sizeof(masterArray)/sizeof(int);
    //printf("%d \n" , masterSize);
    int slaveSize = masterSize/(numOfProcesses-1);
    //printf("%d \n" , slaveSize);
    int slaveArray[slaveSize];

     if (myRank == 0){

        for (i=1; i<numOfProcesses; i++){
            for (j=0; j<slaveSize; j++){
                slaveArray[j] = masterArray[k];
               // printf("%d \n" , masterArray[k]);
                k++;
            }

           MPI_Send(slaveArray, slaveSize, MPI_INT, i, tag, MPI_COMM_WORLD);
        }


       for (i=1; i<numOfProcesses; i++){
            MPI_Recv(max , 1, MPI_INT, i, tag, MPI_COMM_WORLD, &status);

            if (globalMax < max)
                max = globalMax;
        }
        printf("Global Maximum %d \n" , globalMax);

    }

    else{

        MPI_Recv(slaveArray , slaveSize, MPI_INT, 0, tag, MPI_COMM_WORLD, &status);
        max = slaveArray[0];

        for (i=0; i<slaveSize; i++){
                if (slaveArray[i] > max)
                    max = slaveArray[i];
        }
        printf("Max in %d %d \n" , myRank, max);

         MPI_Send(max , 1, MPI_INT, 0, tag, MPI_COMM_WORLD);

    }

 MPI_Finalize();

    return 0;
}

最佳答案

在MPI中发送和接收消息始终通过地址进行。在下面的:

MPI_Recv(max , 1, MPI_INT, i, tag, MPI_COMM_WORLD, &status);

...
MPI_Send(max , 1, MPI_INT, 0, tag, MPI_COMM_WORLD);

您使用该值。您必须添加&以获取地址。

您还应该学习使用适当的集体操作: MPI_Scatter MPI_Reduce

顺便说一句,这行的顺序也错误:
max = globalMax;

还请学习聆听您的编译器!任何处于合理设置的合理编译器都将警告您传递整数作为地址。

09-07 09:57