[mpich-discuss] Problems with mpi spawn multiple

[Rajeev Thakur]

It is incorrect to use MPI::ROOT in Spawn_multiple. But you need it in the
Bcast since it is done on an intercommunicator. See the defintion of Bcast
for intercommunicators.

Rajeev

> -----Original Message-----
> From: mpich-discuss-bounces at mcs.anl.gov 
> [mailto:mpich-discuss-bounces at mcs.anl.gov] On Behalf Of fernando_luz
> Sent: Thursday, November 06, 2008 8:01 AM
> To: mpich-discuss at mcs.anl.gov
> Subject: Re: [mpich-discuss] Problems with mpi spawn multiple
> 
> Thanks Rajeev, 
> 
> It's works, but I need you MPI::ROOT in process parent, when 
> I call MPI::COMM_WORLD.Spawn_multiple.
> 
> Thanks again for the help
> 
> Fernando Luz
> 
> 
> "Rajeev Thakur" <thakur at mcs.anl.gov> escreveu:
> > The interface for MPI_Comm_spawn_multiple expects the 
> program names to 
> > be passed in an array of pointers, not a 2D array of chars. For 
> > example, if
> you
> > declare it as
> >  
> > char *program_name[2] = { "worker_02", "worker_02"};
> > 
> > it should work.
> > 
> > Rajeev
> > 
> >> -----Original Message-----
> >> From: mpich-discuss-bounces at mcs.anl.gov 
> >> [mailto:mpich-discuss-bounces at mcs.anl.gov] On Behalf Of 
> fernando_luz
> >> Sent: Tuesday, November 04, 2008 11:20 AM
> >> To: mpich-discuss at mcs.anl.gov
> >> Subject: Re: [mpich-discuss] Problems with mpi spawn multiple
> >> 
> >> Yes,
> >> 
> >> This code is based in a example code of MPI_Spawn in mpi forum 
> >> homepage (
> >> http://www.mpi-forum.org/docs/mpi-20-html/node98.htm#Node98 ). 
> >> 
> >> I adapted the code in C++ and to use mpi spawn multiple. This code 
> >> work's when I use with mpi spawn.
> >> 
> >> --------------------------------------------------------------
> >> -----------------
> >> manager_02 code:
> >> 
> >> #include <mpi.h>
> >> #include <iostream>
> >> #include <string>
> >> 
> >> #define MAX 128
> >> 
> >> MPI::Status status;
> >> MPI::Intercomm everyone;
> >> MPI::Info information[10];
> >> 
> >> int  size, rank, universe_size, *universe_sizep, n, n_proc[10], 
> >> size_machine;
> >> 
> >> bool flag;
> >>         
> >> char machine[MAX], program_name[4][MAX], buffer[MAX], s_wdir[MAX], 
> >> s_path[MAX], temp[MAX];
> >> 
> >> int main(int argc, char *argv[]){
> >>         
> >>   MPI::Init(argc, argv);
> >>   size = MPI::COMM_WORLD.Get_size();
> >>   rank = MPI::COMM_WORLD.Get_rank();
> >>   
> >>   MPI::Get_processor_name(machine,size_machine);
> >>   
> >>   if (size != 1)  std::cerr << "Top heavy with management" << 
> >> std::endl;
> >>   
> >>   flag = MPI::COMM_WORLD.Get_attr(MPI::UNIVERSE_SIZE,
> >> &universe_sizep);
> >>   
> >>   if (!flag) {
> >>     std::cout << "This MPI does not support UNIVERSE_SIZE. 
> How many 
> >> processes total?" << std::endl;
> >>     std::cin >> universe_size;
> >>   }
> >>   else universe_size = *universe_sizep;
> >>   
> >>   if (universe_size == 1) std::cerr << "Não tem como iniciar um 
> >> processo com universe_size igual a 1." << std::endl;
> >>   
> >>   universe_size = 3;
> >> 
> >>   for (int i = 0; i < universe_size-1; i++){
> >>     strcpy(program_name[i], "worker_02"); 
> >>     information[i] = information[i].Create();
> >>     information[i].Set("wdir","/home/fernando_luz/");
> >>    
> >> information[i].Set("path","/home/fernando_luz/SVN/TPN3/casos_t
> >> estes/02/worker_02/");
> >>     information[i].Set("host", "a54");
> >>     n_proc[i] = 1;
> >>   }
> >>   everyone = MPI::COMM_WORLD.Spawn_multiple(universe_size-1,
> >> (const char**)
> >> program_name, MPI::ARGVS_NULL, n_proc, information, rank);
> >> 
> >>   strcpy(buffer,"Who are you?");
> >>   everyone.Bcast(&buffer, MAX, MPI::CHAR, rank);
> >>   
> >>   for (int i=0; i < universe_size-1; i++){
> >>     everyone.Recv(&buffer, MAX, MPI::CHAR, i, 
> MPI::ANY_TAG, status);
> >>     std::cout << "I am " << buffer << " with rank " <<
> >> status.Get_source()
> >> << std::endl;
> >>   }
> >>   
> >>   for (int i = 0; i < universe_size-1; i++){
> >>     information[i].Free();
> >>   }
> >>   MPI::Finalize(); 
> >>   return 0;
> >> }
> >> 
> >> --------------------------------------------------------------
> >> ------------------------------
> >> 
> >> ==============================================================
> >> ==============================
> >> worker_02 code:
> >> 
> >> #include <mpi.h>
> >> #include <iostream>
> >> #include <string>
> >> 
> >> #define MAX 128
> >> 
> >> MPI::Status status;
> >> MPI::Intercomm parent;
> >> 
> >> int  rank, size, size_machine;
> >> 
> >> char machine[MAX], buffer[MAX];
> >> 
> >> int main(int argc, char *argv[]){
> >> 
> >>   MPI::Init(argc, argv);
> >>   parent = parent.Get_parent();
> >>   
> >>   MPI::Get_processor_name(machine,size_machine);
> >>     
> >>   if (parent == MPI::COMM_NULL) std::cerr << "No daddy!!" << 
> >> std::endl;
> >> 
> >>   size = parent.Get_remote_size();
> >> 
> >>   if (size != 1) std::cerr << "Problems with daddy..." << 
> std::endl;
> >> 
> >>   rank = parent.Get_rank();
> >> 
> >>   parent.Bcast(&buffer, MAX, MPI::CHAR, 0);
> >>         
> >>   std::cout << "Process " << rank << " received in broadcast: 
> >> " << buffer
> >> << std::endl;
> >> 
> >>   parent.Send(&machine, MAX, MPI::CHAR, 0, rank);
> >> 
> >>   MPI::Finalize(); 
> >>   return 0;
> >> }
> >> 
> >> ==============================================================
> >> ================================
> >> 
> >> and I start the program with "mpiexec -configfile executa.txt" 
> >> 
> >> ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
> >> ++++++++++++++++++++++++++++++++
> >> executa.txt file:
> >> 
> >> -host a53 -path
> >> /home/fernando_luz/SVN/TPN3/casos_testes/02/manager_02/
> >> -wdir /home/fernando_luz/ -l -exitinfo manager_02
> >> ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
> >> ++++++++++++++++++++++++++++++++
> >> 
> >> Thanks for help
> >> 
> >> Fernando Luz
> >> 
> >> 
> >> 
> > 
> > 
> 
> 
> 
>