X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/871107618b8c0e08361b84990c5c4a35ae4188e6..b8df87e176f27b25534f27d7e240defa32ca35bc:/examples/java/trace/pingpong/Sender.java diff --git a/examples/java/trace/pingpong/Sender.java b/examples/java/trace/pingpong/Sender.java index 256a4b896e..54673160e0 100644 --- a/examples/java/trace/pingpong/Sender.java +++ b/examples/java/trace/pingpong/Sender.java @@ -1,25 +1,24 @@ -/* Copyright (c) 2006-2014, 2016. The SimGrid Team. +/* Copyright (c) 2006-2019. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * 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 static final double commSizeLat = 1; - private static final double commSizeBw = 100000000; - private static final String PM_STATE = "PM_STATE"; + private static final double COMM_SIZE_LAT = 1; + private static final double COMM_SIZE_BW = 100000000; + private static final String PM_STATE = Main.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); } @@ -41,7 +40,7 @@ public class Sender extends Process { for (int pos = 0; pos < hostCount; pos++) { time = Msg.getClock(); Msg.info("sender time: " + time); - ping = new PingPongTask("no name",computeDuration,commSizeLat); + ping = new PingPongTask("no name",computeDuration,COMM_SIZE_LAT); ping.setTime(time); ping.send(mailboxes[pos]); @@ -58,7 +57,7 @@ public class Sender extends Process { communicationTime=timeGot - time; Msg.info("Communication time : " + communicationTime); - Msg.info(" --- bw "+ commSizeBw/communicationTime + " ----"); + Msg.info(" --- bw "+ COMM_SIZE_BW/communicationTime + " ----"); /* Pop the last state (going back to sending ping) */ Trace.hostPopState (getHost().getName(), PM_STATE);