Messages asynchrones bufferises avec MPI

Principe :

2 processus veulent echanger un message securise sans rendez-vous.
Le processus envoyeur se cree une zone tampon dans laquelle seront mis les messages (il faut qu'elle soit suffisante). Cette zone doit etre attachee au processus avant le premier envoie par la commande MPI_attach puis detachee avant la fin du programme par MPI_detach .
Le processus envoyeur envoie son message par la commande MPI_Bsend et continue son travail.
Le processus receptionneur recupere le message par la commande MPI_Recv quand il le souhaite. Cette attente bloque le travail du processus receptionneur.
L'echange est garanti et le syteme assure que le message ne peut etre perdu.

Programme :

#include "mpi.h"
#include <stdio.h>

#define SIZE 1000
int main(int argc, char* argv[])
{
    double startwtime, endwtime;
    int namelen, numprocs, myid, size ;
    char processor_name[MPI_MAX_PROCESSOR_NAME], buff[SIZE], msg[SIZE] ;
    MPI_status status ;

    MPI_Init(argc,argv);
    startwtime = MPI_Wtime();

    MPI_Comm_size(MPI_COMM_WORLD,&numprocs);
    MPI_Comm_rank(MPI_COMM_WORLD,&myid);
    MPI_Get_processor_name(processor_name,∓namelen);

    fprintf(stderr,"\nProcessus %d sur la machine %s parmi %d processus.\n",
            myid, processor_name, numprocs);
    if (numprocs != 3) fprintf(stderr,"Il me faut 3 processus !\n") ;

    if (myid==0)
    { strcpy(msg,"Message 1") ; size=sizeof(char)*strlen(msg) ;
      fprintf(stderr,"%d envoie <%s>\n",myid, msg) ;

      MPI_Buffer_attach( buff, SIZE) ;
      MPI_Bsend((void*) msg, size, MPI_CHAR, 1, 1, MPI_COMM_WORLD) ;

      strcpy(msg,"Message 2") ;
      fprintf(stderr,"%d envoie <%s>\n",myid,msg) ;
      MPI_Bsend(void*) msg, 15, MPI_CHAR, 2, 1, MPI_COMM_WORLD) ;

      MPI_Buffer_detach(buff, &size) ;

    } else
    { strcpy(msg,"") ;
      system("sleep 5") ;
      MPI_Recv(msg, 15, MPI_CHAR, 0, MPI_ANY_TAG, MPI_COMM_WORLD, &status) ;
      fprintf(stderr,"%d recoit <%s>\n",myid,msg) ;
    }

    endwtime = MPI_Wtime();
    printf("Temps ecoule sur %d = %f\n", myid, endwtime-startwtime);
    MPI_Finalize();

    return 0;
}

Resultat de l'execution :

Processus 0 sur la machine lil. parmi 3 processus.
0 envoie <Message 1>
0 envoie <Message 2>
Temps ecoule sur 0 : 0.003934

Processus 2 sur la machine lil. parmi 3 processus.

Processus 1 sur la machine lil. parmi 3 processus.
1 recoit <Message 1>
Temps ecoule sur 1 : 5.060591
2 recoit <Message 2>
Temps ecoule sur 2 : 5.066704

NB : L'implantation des procedures de messages bufferises n'est pas tres propre. L'utilisateur a besoin de definir une variable pour la zone tampon alors qu'il n'a jamais acces directement a cette zone.

Ph. RIS 1997