From 29bae2bcc4ae6d59eb3cc6c1e034daec79436b27 Mon Sep 17 00:00:00 2001
From: amad206 <amad206@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Date: Sat, 20 May 2006 08:06:44 +0000
Subject: [PATCH] example of parallel matrix multiplication : I modified the
 pmm.c by adding messages of Ack (from sensor to maestro)  to indicate the end
 of each step

git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@2259 48e7efb5-ca39-0410-a469-dd3cf9ba447f
---
 examples/gras/pmm/pmm.c | 31 +++++++++++++++++++++----------
 1 file changed, 21 insertions(+), 10 deletions(-)

diff --git a/examples/gras/pmm/pmm.c b/examples/gras/pmm/pmm.c
index 379cbb5705..14c3a4d56b 100755
--- a/examples/gras/pmm/pmm.c
+++ b/examples/gras/pmm/pmm.c
@@ -172,6 +172,8 @@ xbt_ex_t e;
 int i,ask_result,step;
 result_t result;
 matrix_t A,B,C;
+gras_socket_t from;
+result_t result;
 
   gras_socket_t socket[MATRIX_SIZE*MATRIX_SIZE]; /* sockets for brodcast to other sensor */
 	
@@ -230,15 +232,20 @@ matrix_t A,B,C;
 		RETHROW0("Unable to send the msg : %s");
 		}
 	}
-	
+	INFO0("send to sensor to begin a next step");
 	/* wait for computing and sensor messages exchange */
-	for (i=0; i< nbr_sensor; i++){
+	i=0;
+	while  ( i< nbr_sensor){
 		TRY {
-		gras_msg_wait(600,gras_msgtype_by_name(""),&from,&mydata);
+		gras_msg_wait(600,gras_msgtype_by_name("step_ack"),&from,&mydata);
 		} CATCH(e) {
 		RETHROW0("I Can't get a init Data message from Maestro : %s");
 		}
+		
+		i++;
+		INFO1("Recive step ack from %s",gras_socket_peer_name(from));
 	}
+
 	}
 	/*********************************  gather ***************************************/
 	
@@ -269,7 +276,7 @@ int sensor(int argc,char *argv[]) {
   static int myrow,mycol;
   static double mydataA,mydataB;
   int bA,bB;
-  int step,l,result=0;
+  int step,l,result_ack=0;
 
   gras_socket_t from;  /* to recive from server for steps */
 
@@ -369,18 +376,22 @@ int sensor(int argc,char *argv[]) {
 
   } while (step < MATRIX_SIZE);
     /*  wait Message from maestro to send the result */
-	    /*after finished the bC computing */
+ 
+	result.value=bC;
+	result.i=myrow;
+	result.j=mycol;
+ 
 	  TRY {
-		  gras_msg_wait(600,gras_msgtype_by_name("result"),
-				&from,&result);
+		  gras_msg_wait(600,gras_msgtype_by_name("ask_result"),
+				&from,&result_ack);
 	  } CATCH(e) {
 		  RETHROW0("I Can't get a data message from row : %s");
 	  }
-	  /* 5. send Result to the Maestro */
+	  /* 5. send Result to Maestro */
 	  TRY {
-		  gras_msg_send(from, gras_msgtype_by_name("result"),&bC);
+		  gras_msg_send(from, gras_msgtype_by_name("result"),&result);
 	  } CATCH(e) {
-		  gras_socket_close(from);
+		 // gras_socket_close(from);
 		  RETHROW0("Failed to send PING to server: %s");
 	  }
 	  INFO3(">>>>>>>> Result: %d sent to %s:%d <<<<<<<<",
-- 
2.20.1