X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/93f0ec84901a004b957e0967b2a7da62e40469eb..0424e24e1f270b3c65b20e994079679b18be3eb8:/examples/java/trace/pingpong/Sender.java?ds=sidebyside

diff --git a/examples/java/trace/pingpong/Sender.java b/examples/java/trace/pingpong/Sender.java
index f17cabd6ff..d3f107d2ab 100644
--- a/examples/java/trace/pingpong/Sender.java
+++ b/examples/java/trace/pingpong/Sender.java
@@ -5,41 +5,36 @@
  * under the terms of the license (GNU LGPL) which comes with this package. */
 
 package trace.pingpong;
-import org.simgrid.msg.Msg;
 import org.simgrid.msg.Host;
-import org.simgrid.msg.Task;
-import org.simgrid.msg.Process;
-import org.simgrid.msg.MsgException;
-import org.simgrid.msg.NativeException;
 import org.simgrid.msg.HostNotFoundException;
+import org.simgrid.msg.Msg;
+import org.simgrid.msg.MsgException;
+import org.simgrid.msg.Process;
+import org.simgrid.msg.Task;
 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 {
+  public Sender(String hostname, String name, String[] args) throws HostNotFoundException {
     super(hostname,name,args);
   }
 
   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]; 
+    String[] mailboxes = new String[hostCount]; 
     double time;
     double computeDuration = 0;
-    PingPongTask ping, pong;
+    PingPongTask ping;
 
     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++) { 
@@ -49,15 +44,15 @@ public class Sender extends Process {
       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");
+      Task.receive(getHost().getName());
       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);
-      time=timeSent;
+      time = timeSent;
 
       communicationTime=timeGot - time;
       Msg.info("Communication time : " + communicationTime);
@@ -65,11 +60,11 @@ public class Sender extends Process {
       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 */  
-    Trace.hostPopState (getHost().getName(), "PM_STATE");
+    Trace.hostPopState (getHost().getName(), PM_STATE);
     Msg.info("goodbye!");
   }
 }