X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6de03ecc4e630732984a0673512a5d15fd75e270..bdae0bd5341a0ed9faef3ef59a669abe91eedc45:/examples/java/tracing/Receiver.java diff --git a/examples/java/tracing/Receiver.java b/examples/java/tracing/Receiver.java index dab370f233..d3d0a1a466 100644 --- a/examples/java/tracing/Receiver.java +++ b/examples/java/tracing/Receiver.java @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2007, 2012-2014. The SimGrid Team. +/* Copyright (c) 2006-2007, 2012-2014, 2016. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -13,49 +13,47 @@ import org.simgrid.msg.Process; import org.simgrid.trace.Trace; public class Receiver extends Process { - - private final double commSizeLat = 1; + private final double commSizeLat = 1; private final double commSizeBw = 100000000; - - public Receiver(Host host, String name, String[]args) { - super(host,name,args); - } - - public void main(String[] args) throws MsgException { - - Msg.info("hello!"); - Trace.hostPushState (host.getName(), "PM_STATE", "waitingPing"); - double communicationTime=0; - - double time = Msg.getClock(); - - /* Wait for the ping */ - Msg.info("try to get a task"); - - PingPongTask ping = (PingPongTask)Task.receive(getHost().getName()); - double timeGot = Msg.getClock(); - double timeSent = ping.getTime(); - - Msg.info("Got at time "+ timeGot); - Msg.info("Was sent at time "+timeSent); - time=timeSent; - - communicationTime=timeGot - time; - Msg.info("Communication time : " + communicationTime); - - Msg.info(" --- bw "+ commSizeBw/communicationTime + " ----"); - - /* Send the pong */ - Trace.hostPushState (host.getName(), "PM_STATE", "sendingPong"); - double computeDuration = 0; - PingPongTask pong = new PingPongTask("no name",computeDuration,commSizeLat); - pong.setTime(time); - pong.send(ping.getSource().getName()); - - /* Pop the two states */ - Trace.hostPopState (host.getName(), "PM_STATE"); - Trace.hostPopState (host.getName(), "PM_STATE"); - - Msg.info("goodbye!"); - } + + public Receiver(Host host, String name, String[]args) { + super(host,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"); + + PingPongTask ping = (PingPongTask)Task.receive(getHost().getName()); + double timeGot = Msg.getClock(); + double timeSent = ping.getTime(); + + Msg.info("Got at time "+ timeGot); + Msg.info("Was sent at time "+timeSent); + time=timeSent; + + communicationTime=timeGot - time; + Msg.info("Communication time : " + communicationTime); + + Msg.info(" --- bw "+ commSizeBw/communicationTime + " ----"); + + /* Send the pong */ + Trace.hostPushState (getHost().getName(), "PM_STATE", "sendingPong"); + double computeDuration = 0; + PingPongTask pong = new PingPongTask("no name",computeDuration,commSizeLat); + pong.setTime(time); + pong.send(ping.getSource().getName()); + + /* Pop the two states */ + Trace.hostPopState (getHost().getName(), "PM_STATE"); + Trace.hostPopState (getHost().getName(), "PM_STATE"); + + Msg.info("goodbye!"); + } }