Yes, the code work locally on a single machine (either BIGBROTHER and LITTLESISTER):
runas /user:BIGBROTHER\cluster "cmd /K mpiexec -n 2 \\BIGBROTHER\MPI\mpi_comm.exe"
runas /user:LITTLESISTER\cluster "cmd /K mpiexec -n 2 \\BIGBROTHER\MPI\mpi_comm.exe"
But when I try to launch mpi_comm.exe on both machines, there is the error: Fatal error in PMPI_Recv: Internal MPI error!, error stack: ...
on BIGBROTHER machine (smpd works on either):
runas /user:BIGBROTHER\cluster "cmd /K mpiexec -hosts 2 BIGBROTHER 1 LITTLESISTER 1 \\BIGBROTHER\MPI\mpi_comm.exe"
-------------------------------------------------
mpi_hello works fine:
#include <stdio.h>
#include "mpi.h"
int main(int argc, char* argv[])
{
int procs_rank, procs_count;
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD, &procs_count);
MPI_Comm_rank(MPI_COMM_WORLD, &procs_rank);
printf ("\n Hello, World from process %d of %d", procs_rank, procs_count);
MPI_Finalize();
return 0;
}
but mpi_comm don't work (when I use MPI_Send and MPI_Recv):
int main(int argc, char *argv[])
{
int rank, nproc, name_len;
char processor_name[MPI_MAX_PROCESSOR_NAME];
double start_time, end_time;
char send_buf[64], recv_buf[64];
MPI_Status st;
MPI_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &nproc);
MPI_Get_processor_name(processor_name, &name_len);
start_time = MPI_Wtime();
switch (rank)
{
case 0:
sprintf(send_buf, "Hello from process 0");
MPI_Send(send_buf, 64, MPI_CHAR, 1, 0, MPI_COMM_WORLD);
break;
default:
MPI_Recv(send_buf, 64, MPI_CHAR, 0, 0, MPI_COMM_WORLD, &st);
printf("Process %d received %s\n", rank, send_buf);
}
end_time = MPI_Wtime();
printf("Work time %f sec\n", end_time - start_time);
MPI_Finalize();
return 0;
}
