X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/93f0ec84901a004b957e0967b2a7da62e40469eb..0424e24e1f270b3c65b20e994079679b18be3eb8:/examples/java/trace/pingpong/Receiver.java diff --git a/examples/java/trace/pingpong/Receiver.java b/examples/java/trace/pingpong/Receiver.java index 0a57d52496..4a1f26e55e 100644 --- a/examples/java/trace/pingpong/Receiver.java +++ b/examples/java/trace/pingpong/Receiver.java @@ -5,29 +5,24 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ package trace.pingpong; -import org.simgrid.msg.Host; +import org.simgrid.msg.HostNotFoundException; import org.simgrid.msg.Msg; import org.simgrid.msg.MsgException; -import org.simgrid.msg.NativeException; -import org.simgrid.msg.HostNotFoundException; -import org.simgrid.msg.Task; import org.simgrid.msg.Process; +import org.simgrid.msg.Task; import org.simgrid.trace.Trace; public class Receiver extends Process { - private final double commSizeLat = 1; - private final double commSizeBw = 100000000; + private static final double COMM_SIZE_LAT = 1; + private static final double COMM_SIZE_BW = 100000000; - public Receiver(String hostname, String name, String[]args) throws HostNotFoundException, NativeException{ + public Receiver(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", "waitingPing"); - double communicationTime=0; - - double time = Msg.getClock(); /* Wait for the ping */ Msg.info("try to get a task"); @@ -38,17 +33,17 @@ public class Receiver extends Process { Msg.info("Got at time "+ timeGot); Msg.info("Was sent at time "+timeSent); - time=timeSent; + double time=timeSent; - communicationTime=timeGot - time; + double communicationTime=timeGot - time; Msg.info("Communication time : " + communicationTime); - Msg.info(" --- bw "+ commSizeBw/communicationTime + " ----"); + Msg.info(" --- bw "+ COMM_SIZE_BW/communicationTime + " ----"); /* Send the pong */ Trace.hostPushState (getHost().getName(), "PM_STATE", "sendingPong"); double computeDuration = 0; - PingPongTask pong = new PingPongTask("no name",computeDuration,commSizeLat); + PingPongTask pong = new PingPongTask("no name",computeDuration,COMM_SIZE_LAT); pong.setTime(time); pong.send(ping.getSource().getName());