From f7204e506b3c58dcb7dd4c2078f5934146a55022 Mon Sep 17 00:00:00 2001
From: cherierm <cherierm@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Date: Fri, 21 Sep 2007 15:43:04 +0000
Subject: [PATCH] schedule() and unschedule() methods implementation

git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@4657 48e7efb5-ca39-0410-a469-dd3cf9ba447f
---
 src/java/simgrid/msg/Process.java | 66 ++++++++++++++++++++++---------
 1 file changed, 47 insertions(+), 19 deletions(-)

diff --git a/src/java/simgrid/msg/Process.java b/src/java/simgrid/msg/Process.java
index ac30cf60b6..d390fd3d22 100644
--- a/src/java/simgrid/msg/Process.java
+++ b/src/java/simgrid/msg/Process.java
@@ -89,10 +89,10 @@ public abstract class Process extends Thread
     /*
      * The arguments of the method function of the process.	
      */
-    public Vector args;
+    public Vector<String> args;
     
-    /* Used to schedule the process */
-    protected Sem sem;
+   /* process synchronisation tools */
+	protected Sem schedBegin, schedEnd;
 	
     /**
      * Default constructor. (used in ApplicationHandler to initialize it)
@@ -102,8 +102,9 @@ public abstract class Process extends Thread
 	this.id = 0;
 	this.name = null;
 	this.bind = 0;
-	this.args = new Vector();
-	sem = new Sem(0); /* suspend the thread first */
+	this.args = new Vector<String>();
+	schedBegin = new Sem(0);
+	schedEnd = new Sem(0);
     }
 
 	
@@ -176,7 +177,7 @@ public abstract class Process extends Thread
 	    throw new NullPointerException("Process name cannot be NULL");
 	
 	
-	this.args = new Vector();
+	this.args = new Vector<String>();
 	
 	if(null != args)
 		this.args.addAll(Arrays.asList(args));
@@ -184,7 +185,8 @@ public abstract class Process extends Thread
 	this.name = name;
 	this.id = nextProcessId++;
 	
-	sem = new Sem(0); /* suspend the thread first */
+	schedBegin = new Sem(0);
+	schedEnd = new Sem(0);
 		
 	Msg.processCreate(this,host);
     }
@@ -372,7 +374,15 @@ public abstract class Process extends Thread
 	try {
 	    String[] args = null; /* do not fill it before the signal or this.args will be empty */
 	    
-	    waitSignal(); /* wait for other people to fill the process in */
+	    //waitSignal(); /* wait for other people to fill the process in */
+	    
+	    
+	    try {
+	    schedBegin.acquire();
+	} catch(InterruptedException e) {
+	}
+	
+			
 		
 		if(this.args.size() > 0)
 		{
@@ -383,6 +393,7 @@ public abstract class Process extends Thread
 
 	    this.main(args);
 	    Msg.processExit(this);
+	    schedEnd.release();
 	} catch (MsgException e) {
 	    e.printStackTrace();
 	    Msg.info("Unexpected behavior. Stopping now");
@@ -407,16 +418,33 @@ public abstract class Process extends Thread
     throws JniException, NativeException;
     
    
-    public void unschedule() {
-        try {        
-        		sem.acquire();
-    		} catch(InterruptedException e)
-    		{
-    			// todo
-    		}
-    }
+   public void unschedule() {
+   	
+   		try {
+			schedEnd.release();
+			schedBegin.acquire();
+		} catch(InterruptedException e){
+			
+		}
+	}
     
-     public void schedule() { 
-        sem.release(); 
-    }
+     public void schedule() {
+     	
+     	try { 
+			schedBegin.release();
+			schedEnd.acquire();
+		} catch(InterruptedException e) {
+			
+		}
+	}
+	
+	public void taskSend(Channel channel,Task task, Host host)  throws NativeException, JniException {
+		Msg.channelPut(channel,task,host);
+	}
+	
+	public Task taskReceive(Channel channel)  throws NativeException, JniException {
+		return Msg.channelGet(channel);
+	} 		     
 }
+
+
-- 
2.20.1