0

我正在尝试使用 MPI 实现逻辑环；其中每个进程从 id 小于当前进程的进程接收消息，并以循环方式转发到下一个进程。我的目标是传输缓冲区，使其丢失一些消息或者可能使它们无序。
当根节点发送的消息再次返回根节点时，一个通信周期就结束了。
这是我尝试过的代码：我只是包括它的相关部分。

if(procId!=root)
{
    sleep(100);
    while(1)
    {
        tm = MPI_Wtime();
        MPI_Irecv( &message, STR_LEN, MPI_CHAR,
                ((procId-1)>=0?(procId-1):(numProc-1)),RETURN_DATA_TAG,
                MPI_COMM_WORLD,&receiveRequest);

        MPI_Wait(&receiveRequest,&status);
        printf("%d: Received\n",procId);

        if(!strncmp(message,"STOP",4)&&(procId==(numProc-1)))
            break;

        MPI_Ssend( message, STR_LEN, MPI_CHAR,
                (procId+1)%numProc, SEND_DATA_TAG, MPI_COMM_WORLD);
        if(!strncmp(message,"STOP",4))
            break;
        printf("%d: Sent\n",procId);
    }
}
else
{
    for(iter=0;iter<benchmarkSize;iter++)
    {
        //Synthesize the message
        message[STR_LEN-1] = '\0';
        iErr = MPI_Bsend( message, STR_LEN, MPI_CHAR,
                (root+1)%numProc, SEND_DATA_TAG, MPI_COMM_WORLD);
        if (iErr != MPI_SUCCESS) {
            char error_string[BUFSIZ];
            int length_of_error_string;
            MPI_Error_string(iErr, error_string, &length_of_error_string);
            fprintf(stderr, "%3d: %s\n", procId, error_string);
        }

        tm = MPI_Wtime();
        while(((MPI_Wtime()-tm)*1000)<delay);
        printf("Root: Sending\n");
    }
    for(iter=0;iter<benchmarkSize;iter++)
    {
        MPI_Recv(message,STR_LEN,MPI_CHAR,
                (numProc-1),RETURN_DATA_TAG,MPI_COMM_WORLD,&status);

        //We should not wait for the messages to be received but wait for certain amount of time

        //Extract the fields in the message
        if(((prevRcvdSeqNum+1)!=atoi(seqNum))&&(prevRcvdSeqNum!=0))
            outOfOrderMsgs++;
        prevRcvdSeqNum = atoi(seqNum);
        printf("Seq Num: %d\n",atoi(seqNum));
        rcvdMsgs++;
        printf("Root: Receiving\n");
    }
    MPI_Isend( "STOP", 4, MPI_CHAR,
            (root+1)%numProc, SEND_DATA_TAG, MPI_COMM_WORLD,&sendRequest);
    MPI_Wait(&sendRequest,&status);

    /*This is to ask all other processes to terminate, when the work is done*/
}

现在，我有这些问题： 1）为什么当我在环的其他进程（我的意思是根以外的进程）中注入一些睡眠时；没有接收发生？
2）即使缓冲区大小只有1，根节点如何能够通过MPI_Bsend发送消息而不会出错？例如，当它需要以每秒 1000 条的速率发送总共 10 条消息并且缓冲区大小为 1 时。MPI_Bsend 能够发送所有消息而不会出现“缓冲区已满”的任何错误；不管环的其他进程中是否存在 sleep() ！万分感谢！

4

0 回答 0