X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/40d3634e5448cd560a6989d07d10ec30e85cf533..d4dfbe38abab90351c83a110a51a468b45eb53bc:/examples/java/trace/pingpong/Receiver.java diff --git a/examples/java/trace/pingpong/Receiver.java b/examples/java/trace/pingpong/Receiver.java index 27716559d1..6b90f7c8cb 100644 --- a/examples/java/trace/pingpong/Receiver.java +++ b/examples/java/trace/pingpong/Receiver.java @@ -1,30 +1,29 @@ -/* Copyright (c) 2006-2007, 2012-2014, 2016. The SimGrid Team. +/* Copyright (c) 2006-2018. 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.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; + private static final String PM_STATE = Main.PM_STATE; - 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"); + Trace.hostPushState (getHost().getName(), PM_STATE, "waitingPing"); /* Wait for the ping */ Msg.info("try to get a task"); @@ -40,18 +39,18 @@ public class Receiver extends Process { 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"); + 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()); /* Pop the two states */ - Trace.hostPopState (getHost().getName(), "PM_STATE"); - Trace.hostPopState (getHost().getName(), "PM_STATE"); + Trace.hostPopState (getHost().getName(), PM_STATE); + Trace.hostPopState (getHost().getName(), PM_STATE); Msg.info("goodbye!"); }