Fortran implementation of the Actor Model using MPI - Revision history

Miranda ricardo at 18:54, 30 November 2014

2014-11-30T18:54:17Z

2014-11-30T18:52:44Z

2014-11-30T18:51:28Z

2014-11-30T18:46:15Z

2014-11-30T18:40:39Z

2014-11-30T18:40:06Z

2014-11-30T18:33:55Z

2014-11-30T18:33:32Z

2014-11-30T18:30:19Z

2014-11-30T18:23:26Z

@@ Line 52: / Line 52: @@
 In the recursive subroutine loop 2 messages are processed: getMsgPlayBall3Tag and getMsgEndGameTag. As promised by the actor model:
-*internal state is completely encapsulated;
+*internal state is encapsulated;
 *messages are processed one at a time; and
 *communication is asynchronous.

@@ Line 52: / Line 52: @@
 In the recursive subroutine loop 2 messages are processed: getMsgPlayBall3Tag and getMsgEndGameTag. As promised by the actor model:
-#internal state is completely encapsulated;
+*internal state is completely encapsulated;
-#messages are processed one at a time; and
+*messages are processed one at a time; and
-#communication is asynchronous.
+*communication is asynchronous.

← Older revision		Revision as of 18:51, 30 November 2014
Line 51:		Line 51:
	end subroutine loop		end subroutine loop

−	In the recursive subroutine loop 2 messages are processed: getMsgPlayBall3Tag and getMsgEndGameTag.	+	In the recursive subroutine loop 2 messages are processed: getMsgPlayBall3Tag and getMsgEndGameTag. As promised by the actor model:
		+	#internal state is completely encapsulated;
		+	#messages are processed one at a time; and
		+	#communication is asynchronous.

@@ Line 1: / Line 1: @@
 A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''[[moduleMPImanagement]]'' is necessary to compile both programs.
-If you examine the code there is no single MPI_BARRIER or any other explicit synchronization point. The main routine is:
+If you examine the code there is no single MPI_BARRIER or any other explicit synchronization point. The main subroutine is:
      subroutine main()
@@ Line 17: / Line 17: @@
      end subroutine main
-There is a call to an infinite loop. This routine reads the MPI message queue identifying messages to itself.
+There is a call to an infinite loop. This routine reads the MPI message queue identifying messages to itself (MPI_PROBE).
      recursive subroutine loop(pingPong)
@@ Line 50: / Line 50: @@
          if (pingPong%gameON) call loop(pingPong)
      end subroutine loop

@@ Line 23: / Line 23: @@
          integer                     :: STAT_CALL
          integer                     :: STATUS(MPI_STATUS_SIZE)
          STAT_CALL = UNDEFINED
          call MPI_PROBE(MPI_ANY_SOURCE,                                          &
                         MPI_ANY_TAG,                                             &
@@ Line 35: / Line 33: @@
              stop "subroutine loop, error calling MPI_PROBE, ERR01"
          end if
          if (STATUS(MPI_SOURCE) .EQ. getOtherMPI_id(pingPong)) then
              if (STATUS(MPI_TAG) .EQ. getMsgPlayBall3Tag()) then
@@ Line 43: / Line 40: @@
                      stop "subroutine loop, error calling receiveBall, ERR02"
                  end if
              else if (STATUS(MPI_TAG) .EQ. getMsgEndGameTag()) then
                  STAT_CALL = killPingPong(pingPong)
@@ Line 52: / Line 48: @@
              end if
          end if
          if (pingPong%gameON) call loop(pingPong)
      end subroutine loop

@@ Line 13: / Line 13: @@
              stop "subroutine main, error calling startGame, ERR01"
          end if
-         call loop(pingPong)
+         call loop(pingPong) !This loop reads MPI messages
          call EXIT(SUCCESS)
      end subroutine main

← Older revision		Revision as of 18:33, 30 November 2014
Line 1:		Line 1:
	A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''[[moduleMPImanagement]]'' is necessary to compile both programs.		A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''[[moduleMPImanagement]]'' is necessary to compile both programs.
−	If you examine the code there is no single MPI_BARRIER or any other explicit synchronization point.	+
		+	If you examine the code there is no single MPI_BARRIER or any other explicit synchronization point. The main routine is:
		+
		+	subroutine main()
		+	type(T_pingPong), pointer :: pingPong
		+	integer :: STAT_CALL
		+
		+	STAT_CALL = UNDEFINED
		+
		+	pingPong => constructPingPong()
		+
		+	STAT_CALL = startGame(pingPong)
		+	if (STAT_CALL .NE. SUCCESS) then
		+	print*, "STAT_CALL = ", STAT_CALL
		+	stop "subroutine main, error calling startGame, ERR01"
		+	end if
		+
		+	call loop(pingPong)
		+
		+	call EXIT(SUCCESS)
		+
		+	end subroutine main

← Older revision		Revision as of 18:30, 30 November 2014
Line 1:		Line 1:
	A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''[[moduleMPImanagement]]'' is necessary to compile both programs.		A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''[[moduleMPImanagement]]'' is necessary to compile both programs.
		+	If you examine the code there is no single MPI_BARRIER or any other explicit synchronization point.

← Older revision		Revision as of 18:23, 30 November 2014
Line 1:		Line 1:
−	A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''moduleMPImanagement'' is necessary to compile both programs.	+	A very simple ping-pong program is shown here. There are 2 programs, ''[[ping]]'' and ''[[pong]]'', that shoot messages among them, starting each with a random number of plays. The first program reaching 0 will send a message for the other program to stop and stops itself. File ''[[moduleMPImanagement]]'' is necessary to compile both programs.