X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f42642e426356bfe613de46681bdde3ac1b9d5fd..385be8f0b1e64c189591bb342a930824d8e9bb6a:/examples/java/app/centralizedmutex/Coordinator.java diff --git a/examples/java/app/centralizedmutex/Coordinator.java b/examples/java/app/centralizedmutex/Coordinator.java index f89fef94f4..22b3cfd0d4 100644 --- a/examples/java/app/centralizedmutex/Coordinator.java +++ b/examples/java/app/centralizedmutex/Coordinator.java @@ -1,5 +1,4 @@ -/* Copyright (c) 2012-2014, 2016. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2012-2017. 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. */ @@ -17,14 +16,13 @@ public class Coordinator extends Process { public Coordinator(Host host, String name, String[]args) { super(host,name,args); } - LinkedList waitingQueue=new LinkedList(); - int CsToServe; public void main(String[] args) throws MsgException { - CsToServe = Integer.parseInt(args[0]); - Task task; - while (CsToServe >0) { - task = Task.receive("coordinator"); + int csToServe = Integer.parseInt(args[0]); + LinkedList waitingQueue=new LinkedList<>(); + + while (csToServe >0) { + Task task = Task.receive("coordinator"); if (task instanceof RequestTask) { RequestTask t = (RequestTask) task; if (waitingQueue.isEmpty()) { @@ -40,8 +38,8 @@ public class Coordinator extends Process { GrantTask tosend = new GrantTask(); tosend.send(req.from); } - CsToServe--; - if (waitingQueue.isEmpty() && CsToServe==0) { + csToServe--; + if (waitingQueue.isEmpty() && csToServe==0) { Msg.info("we should shutdown the simulation now"); } }