MPIでソケットプログラミングのselect（）と同等のものは何ですか？

Question

ソケットプログラミングでは、select()機能を使用して複数のソケットを同時にチェックできます。私は、MPIライブラリにもこのような機能がありますか？

次のコードの最初のforループでは、複数のノンブロッキング送受信リクエストを1つおきのノードに送信します。 2番目のforループでは、各ノードを順番に待つのではなく、最初にデータを送信するノードのデータの処理を開始する必要があります。私はそれを行う方法があることを知りたいですか？

for(id=0; id<numtasks; id++){ 
     if(id == taskid) continue; 
     if(sendCount[id] != 0) MPI_Isend(sendBuffer[id], N*sendCount[id], MPI_DOUBLE, id, tag, MPI_COMM_WORLD, &reqs[id]); 
     if(recvCount[id] != 0) MPI_Irecv(recvBuffer[id], N*recvCount[id], MPI_DOUBLE, id, tag, MPI_COMM_WORLD, &reqs[id]); 
} 

for(id=0; id<numtasks; id++){ 
     if(id == taskid) continue; 
     if(recvCount[id] != 0){ 
       MPI_Wait(&reqs[id], &status); 
       for(i=0; i<recvCount[id]; i++) 
         splitData(N, recvBuffer[id] + N*i, U[toRecv[id][i]]); 
     } 
}  

私のコードを修正しようとしましたが、実行時にまだセグメント化エラーが発生しています。エラーを理解するのを手伝ってください。

for(id=0; id<numtasks; id++){ 
     if(id == taskid) continue; 
     if(sendCount[id] != 0) MPI_Isend(sendBuffer[id], N*sendCount[id], MPI_DOUBLE, id, tag, MPI_COMM_WORLD, &reqs[id]); 
     if(recvCount[id] != 0) MPI_Irecv(recvBuffer[id], N*recvCount[id], MPI_DOUBLE, id, tag, MPI_COMM_WORLD, &reqs[id]); 
} 

reqs[taskid] = reqs[numtasks-1]; 
for(i=0; i<numtasks-1; i++){ 
     MPI_Waitany(numtasks-1, reqs, &id, &status); 
     if(id == taskid) id = numtasks-1; 
     for(i=0; i<recvCount[id]; i++) 
       splitData(N, recvBuffer[id] + N*i, U[toRecv[id][i]]); 
} 

Answer 1

最も近い同等のMPI_Waitsomeだろう、あなたは要求のリストを提供し、それはすぐに少なくとも一つの要求が完了すると戻ります。ただし、selectのようなタイムアウトはありません。また、MPI_Waitany,MPI_WaitallおよびMPI_Testany,MPI_Testall,MPI_Testsomeもある。

anyとsomeのバリエーションは、インターフェースが1つまたは複数の完了したリクエストについてあなたに知らせる方法が主に異なります。

編集：操作ごとに個別の要求、具体的には送信操作と受信操作を使用する必要があります。