Neblokujici prijem zpravy v OpenMPI

Zdravim, ve svem programu vyuzivajim OpenMPI mam nasledujici blok kodu:

    if (myid == 0)
    {
        cout << myid << ": Zahajuju prenos" << endl;
        MPI_Send(&message, 1, MPI_INT, 1, TAG, MPI_COMM_WORLD);
        MPI_Send(&message, 1, MPI_INT, 1, TAG, MPI_COMM_WORLD);
        MPI_Send(&message, 1, MPI_INT, 2, TAG, MPI_COMM_WORLD);
    }
    else
    {
        while (1)
        {
            MPI_Irecv(&message, 1, MPI_INT, MPI_ANY_SOURCE, TAG, MPI_COMM_WORLD, &request);
            MPI_Test(&request, &flag, &stat);
            if (flag)
            {
                cout << myid << ": Dostal jsem zpravu od prvniho procesoru" << endl;                   
            }
        }
    }

Program spoustim se 3 procesy a vetsinou vypise pouze:

0: Zahajuju prenos
2: Dostal jsem zpravu od prvniho procesoru

Tzn, zpravu dostane jen treti proces, ale druhy ne. Nekdy se dokonce vypise jen prvni radek. Tipuju ze tam nekde dochazi k deadlocku, ale nemuzu na to prijit kde.

Pokud se divite, proc cyklicky kontroluju pritomnost dat pomoci neblokujiho receive+MPI_Test misto toho abych pouzil standardni MPI_Recv, tak je to z toho duvodu, ze obecne resim problem, aby proces kontrolovat zda mu dosla data, pokud ano, aby nejakym zpusobem odpovedel a pokud ne, tak at provadi jinou cinnost.

Mozna jdu na toto uplne spatne, muzete me prosim nejak nasmerovat?

Tak jsem zjistil, ze kdyz jako prvni prikaz do toho bloku while(1) dam sleep(1), tak to zacne fungovat mnohem spolehliveji (vypis probehne jak ma), ale i tak se to priblizne v jednom z peti pripadu zasekne.

Pritom tady: https://www.cac.cornell.edu/VW/MPIP2P/waittestfree.aspx jsem o MPI_Test vycetl:

"More practically, MPI_Test permits an event-driven style of programming, in which events are fired whenever a MPI_Test comes back true. This is particularly useful on the receiving side. A receiver can post a nonblocking receive early, then periodically check the status of the receive with MPI_Test."

A to je presne to, o co se neuspesne snazim...

Prikladam jeste kompletni zdrojak:

http://pastebin.com/X3aP6r2J

a skript, ktery pouzivam na preklad a spusteni programu:

http://pastebin.com/yPbNtcKY

Dotaz: Neblokujici prijem zpravy v OpenMPI

Odpovědi