모든 프로세스가 종료 메시지를 보내도록 허용

Question

모든 프로세스에서 게임을 시뮬레이션하는 C/C++ MPI 프로그램에서 관련 문제가 있습니다. 마스터를 포함하여 어떤 프로세스가 승리하면 그 프로세스는 다른 모든 프로세스에게 게임 플레이를 종료하도록 알려야하므로 결과를 마스터에게 전송하고 마스터에 의해 합계 할 수 있습니다.

가끔은 내가이기는 과정에서 1 개 이상의 프로세스를 얻는 것이 문제입니다. 이렇게하면 작업이 끝나기 전에 긴 시간 (경우에 따라 1 분 이상 걸림)이됩니다. 모든 프로세스간에 메시지 종료 상황을 적절하게 처리하는지 확신 할 수 없습니다.

업데이트 :이 프로그램은 네트워크가 아닌 단일 컴퓨터에서 실행됩니다. 기계가 인터넷에 연결되어 있지 않습니다.

업데이트 2 : 너무 많은 작업을 유발하는 내부 게임 코드로 인해 지연 문제를 크게 줄일 수있었습니다. 나는 여전히 Irecv/Isend를 사용하여 프로세스를 종료하는 방법에 대한 해석을 찾고있다.

업데이트 3 : 내 대답이 내 대답에 표시됩니다.

여기 내 응용 프로그램의 일부 코드가 도움이됩니다.

int max_streak_length; // set in main from argv[], greater than 0 
bool should_quit = false; 

void checkMessages() 
{ 
    static int recvFlag 
    static bool msgBuff; 
    static MPI_Request request; 
    MPI_Status status; 

    // Are we already listening 
    if(request) 
    { 
     // Test for message 
     MPI_Test(&request, &recvFlag, &status); 

     if(recvFlag) 
     { 
      if(status.MPI_TAG == TAG_QUIT) 
       should_quit = true; 
     } 
    } 

    // Start listening if we aren't 
    if(!request) 
     MPI_Irecv(&msgBuff, 1, MPI_C_BOOL, MPI_ANY_SOURCE, TAG_QUIT, MPI_COMM_WORLD, &request); 
} 

void processMaster(int numProcs) { 
    double start = MPI_Wtime(); 
    Game game(max_streak_length); 

    do 
    { 
     if(numProcs > 1) 
      checkMessages(); 
     game.play(); 
    } while(!should_quit && !game.is_game_over()); 

    // Let other processes know they should stop, if I won 
    if(!should_quit && game.is_game_over()) 
    { 
     cout << "Master wins " << MPI_Wtime() << endl; 
     for(int pID = 1; numProcs > 1 && pID < numProcs; ++pID) 
     { 
      MPI_Request r; 
      MPI_Isend(&should_quit, 1, MPI_C_BOOL, pID, TAG_QUIT, MPI_COMM_WORLD, &r); 
     } 
    } 

    cout << "master quitting" << endl; 
} 

void processSlave(int numProcs, int rank) { 
    Game game(max_streak_length); 

    do 
    { 
     checkMessages(); 
     game.play(); 
    } while(!should_quit && !game.is_game_over()); 

    // Let other processes know they should stop, if I won 
    if(!should_quit && game.is_game_over()) 
    { 
     cout << rank << " wins " << MPI_Wtime() << endl; 
     for(int pID = 0; pID < numProcs; ++pID) 
     { 
      if(pID == rank) 
       continue; 
      MPI_Request r; 
      MPI_Isend(&should_quit, 1, MPI_C_BOOL, pID, TAG_QUIT, MPI_COMM_WORLD, &r); 
     } 
    } 

    cout << rank << " quitting" << endl; 
} 

Answer 1

문제가 해결되었습니다. 나는 더 이상 지연을 얻지 않으며, 문제는 게임 프로그램 로직 자체입니다. processSlave for 루프가 다른 조건 인 pID != rank을 수정하여 TAG_QUIT 메시지를 보낼 때 프로세스가 건너 뛴다는 논리를 위반했습니다.

Answer 2

'승리'패킷 Wireshark/ethereal 타이밍? '우승자'간에 얼마나 지연됩니까? 프로토콜을 사용하면 여러 클라이언트가 'win'이라고 말할 수는 있지만 클라이언트가 '이겼다고'가정하거나 확인을 기다리고 있습니까?

메시지 프로토콜은 무엇입니까? 몇 곳에서 'TAG_QUIT'을 (를) 표시합니다. 어떻게

• 아이는 '확인'
• '종료'(고소해) ​​
• 또는, 부모 신호를 다른 아이들과 다른 아이들을 자식 신호를이기는 '승리'
• 부모 신호 자녀와 부모를 신호에 대해 로 '승리'(경주 인해 실패, 지연) '실패'

'패'또는과

부모 신호지는/늦게 아이를 신호 수있는 자녀 (들)을 잃고

'종료'