|
Packit |
0848f5 |
C -*- Mode: Fortran; -*-
|
|
Packit |
0848f5 |
C
|
|
Packit |
0848f5 |
C (C) 2003 by Argonne National Laboratory.
|
|
Packit |
0848f5 |
C See COPYRIGHT in top-level directory.
|
|
Packit |
0848f5 |
C
|
|
Packit |
0848f5 |
C This is a special test that requires an getarg/iargc routine
|
|
Packit |
0848f5 |
C
|
|
Packit |
0848f5 |
program main
|
|
Packit |
0848f5 |
C This implicit none is removed here because the iargc was not
|
|
Packit |
0848f5 |
C declared on the old sparc compilers
|
|
Packit |
0848f5 |
C implicit none
|
|
Packit |
0848f5 |
include 'mpif.h'
|
|
Packit |
0848f5 |
integer errs, err
|
|
Packit |
0848f5 |
integer rank, size, rsize, i
|
|
Packit |
0848f5 |
integer np
|
|
Packit |
0848f5 |
integer errcodes(2)
|
|
Packit |
0848f5 |
integer parentcomm, intercomm
|
|
Packit |
0848f5 |
integer status(MPI_STATUS_SIZE)
|
|
Packit |
0848f5 |
character*(10) inargv(6), outargv(6)
|
|
Packit |
0848f5 |
character*(80) argv(64)
|
|
Packit |
0848f5 |
integer argc
|
|
Packit |
0848f5 |
data inargv /"a", "b=c", "d e", "-pf", " Ss", " " /
|
|
Packit |
0848f5 |
data outargv /"a", "b=c", "d e", "-pf", " Ss", " " /
|
|
Packit |
0848f5 |
integer ierr
|
|
Packit |
0848f5 |
integer can_spawn
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
errs = 0
|
|
Packit |
0848f5 |
np = 2
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
call MTest_Init( ierr )
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
call MTestSpawnPossible( can_spawn, errs )
|
|
Packit |
0848f5 |
if ( can_spawn .eq. 0 ) then
|
|
Packit |
0848f5 |
call MTest_Finalize( errs )
|
|
Packit |
0848f5 |
goto 300
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
call MPI_Comm_get_parent( parentcomm, ierr )
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
if (parentcomm .eq. MPI_COMM_NULL) then
|
|
Packit |
0848f5 |
C Create 2 more processes
|
|
Packit |
0848f5 |
call MPI_Comm_spawn( "./spawnargvf", inargv, np,
|
|
Packit |
0848f5 |
$ MPI_INFO_NULL, 0, MPI_COMM_WORLD, intercomm, errcodes,
|
|
Packit |
0848f5 |
$ ierr )
|
|
Packit |
0848f5 |
else
|
|
Packit |
0848f5 |
intercomm = parentcomm
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
C We now have a valid intercomm
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
call MPI_Comm_remote_size( intercomm, rsize, ierr )
|
|
Packit |
0848f5 |
call MPI_Comm_size( intercomm, size, ierr )
|
|
Packit |
0848f5 |
call MPI_Comm_rank( intercomm, rank, ierr )
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
if (parentcomm .eq. MPI_COMM_NULL) then
|
|
Packit |
0848f5 |
C Master
|
|
Packit |
0848f5 |
if (rsize .ne. np) then
|
|
Packit |
0848f5 |
errs = errs + 1
|
|
Packit |
0848f5 |
print *, "Did not create ", np, " processes (got
|
|
Packit |
0848f5 |
$ ", rsize, ")"
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
do i=0, rsize-1
|
|
Packit |
0848f5 |
call MPI_Send( i, 1, MPI_INTEGER, i, 0, intercomm, ierr )
|
|
Packit |
0848f5 |
enddo
|
|
Packit |
0848f5 |
C We could use intercomm reduce to get the errors from the
|
|
Packit |
0848f5 |
C children, but we'll use a simpler loop to make sure that
|
|
Packit |
0848f5 |
C we get valid data
|
|
Packit |
0848f5 |
do i=0, rsize-1
|
|
Packit |
0848f5 |
call MPI_Recv( err, 1, MPI_INTEGER, i, 1, intercomm,
|
|
Packit |
0848f5 |
$ MPI_STATUS_IGNORE, ierr )
|
|
Packit |
0848f5 |
errs = errs + err
|
|
Packit |
0848f5 |
enddo
|
|
Packit |
0848f5 |
else
|
|
Packit |
0848f5 |
C Child
|
|
Packit |
0848f5 |
C FIXME: This assumes that stdout is handled for the children
|
|
Packit |
0848f5 |
C (the error count will still be reported to the parent)
|
|
Packit |
0848f5 |
argc = iargc()
|
|
Packit |
0848f5 |
do i=1, argc
|
|
Packit |
0848f5 |
call getarg( i, argv(i) )
|
|
Packit |
0848f5 |
enddo
|
|
Packit |
0848f5 |
if (size .ne. np) then
|
|
Packit |
0848f5 |
errs = errs + 1
|
|
Packit |
0848f5 |
print *, "(Child) Did not create ", np, " processes (got ",
|
|
Packit |
0848f5 |
$ size, ")"
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
call MPI_Recv( i, 1, MPI_INTEGER, 0, 0, intercomm, status, ierr
|
|
Packit |
0848f5 |
$ )
|
|
Packit |
0848f5 |
if (i .ne. rank) then
|
|
Packit |
0848f5 |
errs = errs + 1
|
|
Packit |
0848f5 |
print *, "Unexpected rank on child ", rank, "(",i,")"
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
C Check the command line
|
|
Packit |
0848f5 |
do i=1, argc
|
|
Packit |
0848f5 |
if (outargv(i) .eq. " ") then
|
|
Packit |
0848f5 |
errs = errs + 1
|
|
Packit |
0848f5 |
print *, "Wrong number of arguments (", argc, ")"
|
|
Packit |
0848f5 |
goto 200
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
if (argv(i) .ne. outargv(i)) then
|
|
Packit |
0848f5 |
errs = errs + 1
|
|
Packit |
0848f5 |
print *, "Found arg ", argv(i), " but expected ",
|
|
Packit |
0848f5 |
$ outargv(i)
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
enddo
|
|
Packit |
0848f5 |
200 continue
|
|
Packit |
0848f5 |
if (outargv(i) .ne. " ") then
|
|
Packit |
0848f5 |
C We had too few args in the spawned command
|
|
Packit |
0848f5 |
errs = errs + 1
|
|
Packit |
0848f5 |
print *, "Too few arguments to spawned command"
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
C Send the errs back to the master process
|
|
Packit |
0848f5 |
call MPI_Ssend( errs, 1, MPI_INTEGER, 0, 1, intercomm, ierr )
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
C It isn't necessary to free the intercomm, but it should not hurt
|
|
Packit |
0848f5 |
call MPI_Comm_free( intercomm, ierr )
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
C Note that the MTest_Finalize get errs only over COMM_WORLD
|
|
Packit |
0848f5 |
if (parentcomm .eq. MPI_COMM_NULL) then
|
|
Packit |
0848f5 |
call MTest_Finalize( errs )
|
|
Packit |
0848f5 |
endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
300 continue
|
|
Packit |
0848f5 |
call MPI_Finalize( ierr )
|
|
Packit |
0848f5 |
end
|