X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1b4dc02411d79e4c367d331b85c1b295ec41edff..1ff90bc7103df77877d6860f1f117425afe1a516:/examples/java/trace/pingpong/Sender.java diff --git a/examples/java/trace/pingpong/Sender.java b/examples/java/trace/pingpong/Sender.java deleted file mode 100644 index 54673160e0..0000000000 --- a/examples/java/trace/pingpong/Sender.java +++ /dev/null @@ -1,70 +0,0 @@ -/* 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.Host; -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 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 { - super(hostname,name,args); - } - - public void main(String[] args) throws MsgException { - Msg.info("hello !"); - Trace.hostPushState (getHost().getName(), PM_STATE, "sendingPing"); - - int hostCount = args.length; - Msg.info("host count: " + hostCount); - String[] mailboxes = new String[hostCount]; - double time; - double computeDuration = 0; - PingPongTask ping; - - for(int pos = 0; pos < args.length ; pos++) { - mailboxes[pos] = Host.getByName(args[pos]).getName(); - } - - for (int pos = 0; pos < hostCount; pos++) { - time = Msg.getClock(); - Msg.info("sender time: " + time); - ping = new PingPongTask("no name",computeDuration,COMM_SIZE_LAT); - ping.setTime(time); - ping.send(mailboxes[pos]); - - Trace.hostPushState (getHost().getName(), PM_STATE, "waitingPong"); - Task.receive(getHost().getName()); - double timeGot = Msg.getClock(); - double timeSent = ping.getTime(); - double communicationTime; - - 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 "+ COMM_SIZE_BW/communicationTime + " ----"); - - /* Pop the last state (going back to sending ping) */ - Trace.hostPopState (getHost().getName(), PM_STATE); - } - - /* Pop the sendingPong state */ - Trace.hostPopState (getHost().getName(), PM_STATE); - Msg.info("goodbye!"); - } -}