X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/15d88ef3f0349e1182d81af28e7be16ac57e64ee..bdae0bd5341a0ed9faef3ef59a669abe91eedc45:/examples/java/mutualExclusion/Node.java diff --git a/examples/java/mutualExclusion/Node.java b/examples/java/mutualExclusion/Node.java index 55d91e3ffe..353dfd7947 100644 --- a/examples/java/mutualExclusion/Node.java +++ b/examples/java/mutualExclusion/Node.java @@ -1,4 +1,4 @@ -/* Copyright (c) 2012-2014. The SimGrid Team. +/* Copyright (c) 2012-2014, 2016. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -6,29 +6,29 @@ package mutualExclusion; -import org.simgrid.msg.Host; import org.simgrid.msg.Msg; -import org.simgrid.msg.MsgException; +import org.simgrid.msg.Host; import org.simgrid.msg.Task; import org.simgrid.msg.Process; +import org.simgrid.msg.MsgException; public class Node extends Process { - public Node(Host host, String name, String[]args) { - super(host,name,args); - } - public void request(double CStime) throws MsgException { - RequestTask req = new RequestTask(getName()); - Msg.info("Send a request to the coordinator"); - req.send("coordinator"); - Msg.info("Wait for a grant from the coordinator"); - Task.receive(getName()); // FIXME: ensure that this is a grant - Task compute = new Task("CS", CStime, 0); - compute.execute(); - ReleaseTask release = new ReleaseTask(); - release.send("coordinator"); - } - - public void main(String[] args) throws MsgException { - request(Double.parseDouble(args[1])); - } + public Node(Host host, String name, String[]args) { + super(host,name,args); + } + public void request(double CStime) throws MsgException { + RequestTask req = new RequestTask(getName()); + Msg.info("Send a request to the coordinator"); + req.send("coordinator"); + Msg.info("Wait for a grant from the coordinator"); + Task.receive(getName()); // FIXME: ensure that this is a grant + Task compute = new Task("CS", CStime, 0); + compute.execute(); + ReleaseTask release = new ReleaseTask(); + release.send("coordinator"); + } + + public void main(String[] args) throws MsgException { + request(Double.parseDouble(args[1])); + } } \ No newline at end of file