X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a54af5f04ecbfab678c59c04cd60acea403212d6..1ff90bc7103df77877d6860f1f117425afe1a516:/examples/java/app/masterworker/Worker.java diff --git a/examples/java/app/masterworker/Worker.java b/examples/java/app/masterworker/Worker.java deleted file mode 100644 index 20113dd7e6..0000000000 --- a/examples/java/app/masterworker/Worker.java +++ /dev/null @@ -1,47 +0,0 @@ -/* Copyright (c) 2006-2014. 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 app.masterworker; - -import org.simgrid.msg.Host; -import org.simgrid.msg.HostFailureException; -import org.simgrid.msg.Msg; -import org.simgrid.msg.Task; -import org.simgrid.msg.TaskCancelledException; -import org.simgrid.msg.TimeoutException; -import org.simgrid.msg.TransferFailureException; -import org.simgrid.msg.Process; - -public class Worker extends Process { - public Worker(Host host, String name, String[]args) { - super(host,name,args); - } - public void main(String[] args) throws TransferFailureException, HostFailureException, TimeoutException { - if (args.length < 1) { - Msg.info("Worker needs 1 argument (its number)"); - System.exit(1); - } - - int num = Integer.parseInt(args[0]); - Msg.debug("Receiving on 'worker_"+num+"'"); - - while(true) { - Task task = Task.receive("worker_"+num); - - if ("finalize".equals(task.getName())) { - break; - } - Msg.info("Received \"" + task.getName() + "\". Processing it (my pid is "+getPID()+")."); - try { - task.execute(); - } catch (TaskCancelledException e) { - e.printStackTrace(); - } - } - - Msg.info("Received Finalize. I'm done. See you!"); - } -}