X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b836accb70f6c40db457d70bfd57b010a142dc8e..886b7085ea26ae9500f57e065cd6c1cbc2b5a4ec:/examples/java/app/centralizedmutex/Node.java diff --git a/examples/java/app/centralizedmutex/Node.java b/examples/java/app/centralizedmutex/Node.java index b8fd1d1f95..511a95d96a 100644 --- a/examples/java/app/centralizedmutex/Node.java +++ b/examples/java/app/centralizedmutex/Node.java @@ -18,10 +18,11 @@ public class Node extends Process { } public void request(double CStime) throws MsgException { RequestTask req = new RequestTask(getName()); + GrantTask grant= new GrantTask();; 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 + grant.receive(getName()); Task compute = new Task("CS", CStime, 0); compute.execute(); ReleaseTask release = new ReleaseTask();