X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f77a123e30950899367a432165bd2e56123dffb8..8ab9fbef9cd17e59a43126cd5ea214f4190db39e:/examples/java/reservationSurfPlugin/Sender.java diff --git a/examples/java/reservationSurfPlugin/Sender.java b/examples/java/reservationSurfPlugin/Sender.java index 6f5ccf4c00..5f6ca385a0 100644 --- a/examples/java/reservationSurfPlugin/Sender.java +++ b/examples/java/reservationSurfPlugin/Sender.java @@ -23,33 +23,31 @@ public class Sender extends Process { Msg.info("helloo!"); - int hostCount = args.length; - - Msg.info("host count: " + hostCount); - String mailboxes[] = new String[hostCount]; - double time; + String receiverName = args[0]; + double oldTime, curTime; double computeDuration = 10000; Task task; - for(int pos = 0; pos < args.length ; pos++) { - try { - mailboxes[pos] = Host.getByName(args[pos]).getName(); - } catch (HostNotFoundException e) { - Msg.info("Invalid deployment file: " + e.toString()); - System.exit(1); - } - } - - for (int pos = 0; pos < hostCount; pos++) { - time = Msg.getClock(); - - Msg.info("sender time: " + time); - - task = new Task("no name",computeDuration,commSizeLat); - - task.send(mailboxes[pos]); - } - - Msg.info("goodbye!"); + oldTime = Msg.getClock(); + task = new Task("no name",computeDuration,commSizeLat); + task.send(receiverName); + curTime = Msg.getClock(); + Msg.info("Send duration: " + (curTime - oldTime)); + + TestPlugin.tp.updateBandwidthRoute("Jacquelin", "Boivin", 10E2); + oldTime = curTime; + task = new Task("no name",computeDuration,commSizeLat); + task.send(receiverName); + curTime = Msg.getClock(); + Msg.info("Send duration with update bandwidth: " + (curTime - oldTime)); + + TestPlugin.tp.limitBandwidthActions("Jacquelin", "Boivin", 10E1); + oldTime = curTime; + task = new Task("no name",computeDuration,commSizeLat); + task.send(receiverName); + curTime = Msg.getClock(); + Msg.info("Send normal duration with limited bandwidth: " + (curTime - oldTime)); + + Msg.info("goodbye!"); } }