2017-10-07 77 views
0

我正嘗試將數組發送到超立方體系結構中的不同處理器。問題是它要麼不發送給所有的處理器,要麼發送給錯誤的處理器。當我嘗試發送一個整數時,它可以正常工作。無法將數組發送到MPI中的正確目標處理器

下面是代碼:

void hypercube(int d,int my_id,int X[]){ 
    mask = (int)pow((double)2,d)-1; 
for(i = d-1;i>=0;i--){ 
     //printf("before xor mask is %d and power is %d\n",mask,(int)pow((double)2,i)); 
     mask = xor(mask,(int)pow((double)2,i)); 
     //printf("After xor rank is %d and mask is %d\n",rank,mask); 
     if(and(my_id, mask) == 0){ 
       if(and(my_id,(int) pow((double)2,i)) == 0){ 
         dest = xor(my_id,(int) pow((double)2,i)); 
         printf("rank %d destination %d\n",rank,dest); 
         MPI_Send(&X,8,MPI_INT,dest,tag,MPI_COMM_WORLD);; 
         //MPI_Send(&X,1,MPI_INT,dest,tag,MPI_COMM_WORLD); 
         //printf("After sending from rank %d and destination is %d\n",my_id,dest); 
       } 
       else{ 
         //printf("going to receive in a sec...\n"); 
         source = xor(my_id,(int)pow((double)2,i)); 
         MPI_Recv(&X,8,MPI_INT,source,tag,MPI_COMM_WORLD,&status); 
         //MPI_Recv(&X,1,MPI_INT,source,tag,MPI_COMM_WORLD,&status); 
         //printf("in rank %d with data %d\n",rank,X); 

       } 
     } 
    } 
} 

int main(int argc, char **argv){ 


    MPI_Init(&argc,&argv); 
    MPI_Comm_size(MPI_COMM_WORLD,&world_size);; 
    MPI_Comm_rank(MPI_COMM_WORLD,&rank); 


    if(rank == master){ 
    //a[ARR_SIZE] = {1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16}; 
    // q = 4; 
    } 

    hypercube(3,rank,a); 


    return 0; 
} 

有什麼,我沒有服用的保健?

回答

1

你的數組被聲明爲int X[],所以你必須在緩衝區傳遞到MPI_Send()MPI_Recv()X而不是&X

傳球&X[0]也是正確的,但我寧願建議X,因爲它更簡單。

+0

我試着用X發送它。我遇到了同樣的問題。 我得到了解決這個問題的方法,但它不是代碼應該如何。我沒有創建一個單獨的函數「超立方體」,而是將所有內容都放在主體中。我不知道它爲什麼現在起作用。 –

+1

請使用[最小,完整和可驗證示例]編輯您的問題(https://stackoverflow.com/help/mcve),我會看看。 –