Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
cosmetics in java
authorFrederic Suter <frederic.suter@cc.in2p3.fr>
Thu, 9 Jun 2016 14:49:09 +0000 (16:49 +0200)
committerFrederic Suter <frederic.suter@cc.in2p3.fr>
Thu, 9 Jun 2016 14:49:09 +0000 (16:49 +0200)
examples/java/trace/pingpong/Main.java
examples/java/trace/pingpong/Sender.java
src/bindings/java/org/simgrid/msg/Semaphore.java

index 1e82ea8..bd43e17 100644 (file)
@@ -14,8 +14,8 @@ public class Main  {
   public static void main(String[] args) throws MsgException, NativeException {
     Msg.init(args);
     if(args.length < 1) {
   public static void main(String[] args) throws MsgException, NativeException {
     Msg.init(args);
     if(args.length < 1) {
-      Msg.info("Usage   : TracingTest platform_file");
-      Msg.info("example : TracingTest ../platforms/platform.xml");
+      Msg.info("Usage   : Main platform_file");
+      Msg.info("example : Main ../platforms/platform.xml");
       System.exit(1);
     }
 
       System.exit(1);
     }
 
index f17cabd..5fe2760 100644 (file)
@@ -15,8 +15,9 @@ import org.simgrid.msg.HostNotFoundException;
 import org.simgrid.trace.Trace;
 
 public class Sender extends Process {
 import org.simgrid.trace.Trace;
 
 public class Sender extends Process {
-  private final double commSizeLat = 1;
-  private final double commSizeBw = 100000000;
+  private static final double commSizeLat = 1;
+  private static final double commSizeBw = 100000000;
+  private static final String PM_STATE = "PM_STATE";
 
   public Sender(String hostname, String name, String[] args) throws HostNotFoundException, NativeException {
     super(hostname,name,args);
 
   public Sender(String hostname, String name, String[] args) throws HostNotFoundException, NativeException {
     super(hostname,name,args);
@@ -24,22 +25,17 @@ public class Sender extends Process {
 
   public void main(String[] args) throws MsgException {
     Msg.info("hello !"); 
 
   public void main(String[] args) throws MsgException {
     Msg.info("hello !"); 
-    Trace.hostPushState (getHost().getName(), "PM_STATE", "sendingPing");
+    Trace.hostPushState (getHost().getName(), PM_STATE, "sendingPing");
 
     int hostCount = args.length;
     Msg.info("host count: " + hostCount);
     String mailboxes[] = new String[hostCount]; 
     double time;
     double computeDuration = 0;
 
     int hostCount = args.length;
     Msg.info("host count: " + hostCount);
     String mailboxes[] = new String[hostCount]; 
     double time;
     double computeDuration = 0;
-    PingPongTask ping, pong;
+    PingPongTask ping;
 
     for(int pos = 0; pos < args.length ; pos++) {
 
     for(int pos = 0; pos < args.length ; pos++) {
-      try {
-        mailboxes[pos] = Host.getByName(args[pos]).getName();
-      } catch (HostNotFoundException e) {
-        Msg.info("Invalid deployment file: " + e.toString());
-        System.exit(1);
-      }
+      mailboxes[pos] = Host.getByName(args[pos]).getName();
     }
 
     for (int pos = 0; pos < hostCount; pos++) { 
     }
 
     for (int pos = 0; pos < hostCount; pos++) { 
@@ -49,15 +45,15 @@ public class Sender extends Process {
       ping.setTime(time);
       ping.send(mailboxes[pos]);
 
       ping.setTime(time);
       ping.send(mailboxes[pos]);
 
-      Trace.hostPushState (getHost().getName(), "PM_STATE", "waitingPong");
-      pong = (PingPongTask)Task.receive(getHost().getName());
+      Trace.hostPushState (getHost().getName(), PM_STATE, "waitingPong");
+      PingPongTask pong = (PingPongTask)Task.receive(getHost().getName());
       double timeGot = Msg.getClock();
       double timeSent = ping.getTime();
       double timeGot = Msg.getClock();
       double timeSent = ping.getTime();
-      double communicationTime=0;
+      double communicationTime;
 
       Msg.info("Got at time "+ timeGot);
       Msg.info("Was sent at time "+timeSent);
 
       Msg.info("Got at time "+ timeGot);
       Msg.info("Was sent at time "+timeSent);
-      time=timeSent;
+      time = timeSent;
 
       communicationTime=timeGot - time;
       Msg.info("Communication time : " + communicationTime);
 
       communicationTime=timeGot - time;
       Msg.info("Communication time : " + communicationTime);
@@ -65,11 +61,11 @@ public class Sender extends Process {
       Msg.info(" --- bw "+ commSizeBw/communicationTime + " ----");
 
       /* Pop the last state (going back to sending ping) */  
       Msg.info(" --- bw "+ commSizeBw/communicationTime + " ----");
 
       /* Pop the last state (going back to sending ping) */  
-      Trace.hostPopState (getHost().getName(), "PM_STATE");
+      Trace.hostPopState (getHost().getName(), PM_STATE);
     }
 
     /* Pop the sendingPong state */  
     }
 
     /* Pop the sendingPong state */  
-    Trace.hostPopState (getHost().getName(), "PM_STATE");
+    Trace.hostPopState (getHost().getName(), PM_STATE);
     Msg.info("goodbye!");
   }
 }
     Msg.info("goodbye!");
   }
 }
index 0172aa3..4952184 100644 (file)
@@ -34,6 +34,7 @@ public class Semaphore {
        /** Locks on the semaphore object until the provided timeout expires
         * @exception TimeoutException if the timeout expired before 
         *            the semaphore could be acquired.
        /** Locks on the semaphore object until the provided timeout expires
         * @exception TimeoutException if the timeout expired before 
         *            the semaphore could be acquired.
+        * @param timeout the duration of the lock
         */
        public native void acquire(double timeout) throws TimeoutException;
        /** Locks on the semaphore object with no timeout
         */
        public native void acquire(double timeout) throws TimeoutException;
        /** Locks on the semaphore object with no timeout
@@ -42,8 +43,8 @@ public class Semaphore {
                try {
                        acquire(-1);
                } catch (TimeoutException e) {
                try {
                        acquire(-1);
                } catch (TimeoutException e) {
-                       // This should not happen.
-                       assert(false);
+                       e.printStackTrace(); // This should not happen.
+                       assert false ;
                }
        }
        /** Releases the semaphore object
                }
        }
        /** Releases the semaphore object