MPI_Send and Receive - Wrapper

Question

아주 기본적인 MPI 코드를 작성하려고했지만 계속 전화를 끊습니다. 작업은 포인터 사용을 숨길 수 있도록 MPI_Send 및 Receive 루틴에 대한 래퍼를 작성하는 것입니다.

#include "mpi.h" 
#include<iostream> 
#include<cstdlib> 

#define _MAXSIZE_ 10 

using namespace std; 

/** Goal: Avoid pointers in MPI_Send and MPI_Recieve */ 

/* Wrapper for regular MPI_Send. */ 
void Send(int data, int destination, MPI_Comm mpicomm) { 
    MPI_Send(&data, 1, MPI_INT, destination, 0, mpicomm); 
    cout << "Data sent successfully" << data << endl; 
} 

/* Wrapper for regular MPI_Recieve */ 
int Recieve(MPI_Status stat, MPI_Comm mpicomm, int source_id = 0) { 
    int data; 
    MPI_Recv(&data, 1, MPI_INT, source_id, 0, mpicomm, &stat); 
    cout << "Data Recieved: " << data << endl; 
    return data; 
} 

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

    int myid, numprocs; 
    int arr[10]; 
    MPI_Init(&argc, &argv); 
    MPI_Comm_size(MPI_COMM_WORLD, &numprocs); 
    MPI_Comm_rank(MPI_COMM_WORLD, &myid); 
    MPI_Status status; 
    MPI_Comm mpicomm; 

    /** Trying to send an array of 10 integers without pointer usage */ 
    int data = 3; 
    int destination = rand() % numprocs; // choose a destination to send other than the master itself 
    cout << "Destination: " << destination << "\n" << endl; 
    if(myid == 0) { 
     if(destination != 0) { 
      Send(data, destination, mpicomm); 
     } 
    } 
    else if(myid == destination) { 
      int data = Recieve(status,mpicomm, 0); 
      cout << "Data Received Successfully" << data << endl; 
    } 

    MPI_Finalize(); 
    return 0; 
    } 

P.S.을 :

다음

내가 개발 한 것입니다 나는 내가 지금받는 답장을 추적하고있다. 감사.

산 제이

Answer 1

메시지 소스 또는받는 사람을 지정하려면, 당신은 계급과 의사 소통을 지정해야합니다; 쌍은 프로세스를 고유하게 지정합니다. 계급은 거리 이름이없는 거리 번호와 같습니다.

전달자를 전달 중입니다.하지만 값은 정의되지 않았습니다. 귀하의 코드

MPI_Comm mpicomm; 
// ... 
Send(data, destination, mpicomm); 

은 커뮤니케이터를 통과하지만 아무 값도 지정하지 않았습니다. 변수의 값과 MPI 구현이 어떻게 처리하는지에 따라 교착 상태가 발생하거나 openmpi에서 유용한 오류 메시지가 표시 될 수 있습니다. 그 중 하나가 작동합니다

Send(data, destination, MPI_COMM_WORLD); 
//... 
int data = Recieve(status, MPI_COMM_WORLD, 0); 

: 동등하게, 완전히 mpicomm 변수를 드롭,

MPI_Comm mpicomm = MPI_COMM_WORLD; 
//.. 
Send(data, destination, mpicomm); 
int data = Recieve(status, mpicomm, 0); 

나 :

은 당신이 아마 원하는 것은 이것이다.