C++

Parallèlisation d'un programme avec MPICH

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : Parallèlisation d'un programme avec MPICH

nathan_g

Bonjour,

Je cherche à réaliser un programme parallèle avec MPICH-1.2.7pl sur un cluster de trois machines.
Pour cela, j'ai déja repris un programme de test classique trouvé dans un tutorial pour vérifier que les machines communiquent entre-elles.
Néanmoins, j'ai déja un souci. En effet, le programme suivant :

Code :

#include <stdio.h>
#include <string.h>
#include "mpi.h"
#include <iostream>
using namespace std;
int main(int argc, char** argv)
{
int my_rank; /* Rank of process */
int p; /* Number of processses */
int source; /* Rank of sender */
int dest; /* Rank of receiver */
int tag = 50; /* Tag of messages */
char message[100]; /* Storage of message */
MPI_Status status; /* Return status for receive */
MPI_Init(&argc,&argv);
MPI_Comm_rank(MPI_COMM_WORLD,&my_rank);
MPI_Comm_size(MPI_COMM_WORLD,&p);
if (my_rank != 0)
{
sprintf(message,"Greetings from process %d",my_rank);
dest = 0;
/* Use strlen(message)+1 to include '\0' */
MPI_Send(message,strlen(message)+1,MPI_CHAR,dest,tag,MPI_COMM_WORLD);
}
else
{
/* rank = 0 */
for(source = 1;source < p; source++)
{
MPI_Recv(message,100,MPI_CHAR,source,tag,MPI_COMM_WORLD,&status);
cout << "message" << endl;
}
}
MPI_Finalize();
}

ne me renvoie rien alors qu'il devrait donner le "message" à deux occasions, sur les 2 processeurs sur lesquels il est envoyé.
Ce qui m'inquiète en fait c'est que la variable " p " reste fixée à 1 dès le début du calcul, quand j'en demande la valeur, alors qu'elle devrait être égale à 3, le nombre de processeurs reliés entre eux.

Pourtant le fichier /usr/local/mpich-1.2.7pl/util/machines/machines.LINUX contient bien le nom des 3 machines visibles !

Sauriez-vous d'ou vient le problème ?

Merci d'avance de votre aide,

Nathan

Publicité

franceso

tu peux poster la ligne de commande que tu utilises pour lancer le programme ?

---------------
TriScale innov

nathan_g

Je compile le programme par les commandes :

g++ -c main.C -I/usr/local/mpich-1.2.7pl/include
g++ -o main main.o -lmpich -L/usr/local/mpich-1.2.7pl/lib

et je lance simplement par :

main

Est-ce que c'est cela qui me pose problème ?

franceso

oui, c'est sans doute là qu'est ton problème.

* Il vaut mieux que tu compiles avec mpiCC (qui est juste un alias pour g++ avec les bonnes options ; tu sembles l'avoir bien fait à la main, mais c'est plus simple d'utiliser les outils fournis )
* Il faut que tu exécutes ton binaire avec mpirun (dont les options en ligne de commande te permettent de déterminer le nombre de processeurs à utiliser, etc.)

---------------
TriScale innov

FORUM HardWare.fr

Programmation

C++

Parallèlisation d'un programme avec MPICH

Sujets relatifs
Programme en c++	Envoyer une interruption à partir d'un programme Java
Lancer un programme depuis une page en PHP	[C#.NET] Repertoire courant du programme, ya un raccourci ?
Win Api : L'utilisation du menu fait planter le programme	Programme VB + ombres WindowFX
gérer du hardware avec un programme en C	batch emplacement programme
lancer un programme externe	Mon premier programme c++... deja une erreur bisarre
Plus de sujets relatifs à : Parallèlisation d'un programme avec MPICH

Page générée en 0.057 secondes