[mpich-discuss] Problems with mpi spawn multiple

[Rajeev Thakur]

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\n
> 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
> 
> 
>