Blame test/mpi/f90/spawn/spawnargvf90.f90

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