X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/49e85177c669d793e84242983a1b1f430e47184e..6b0684975782916e6257c792879e1c0f3963411b:/examples/java/cloud/migration/Daemon.java diff --git a/examples/java/cloud/migration/Daemon.java b/examples/java/cloud/migration/Daemon.java index 80cf2a8b55..6b30faad73 100644 --- a/examples/java/cloud/migration/Daemon.java +++ b/examples/java/cloud/migration/Daemon.java @@ -1,4 +1,4 @@ -/* Copyright (c) 2014. The SimGrid Team. +/* Copyright (c) 2014-2018. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -10,29 +10,28 @@ import org.simgrid.msg.*; import org.simgrid.msg.Process; public class Daemon extends Process { - private Task currentTask; - public Daemon(VM vm, int load) { - super((Host)vm,"Daemon"); - currentTask = new Task(this.getHost().getName()+"-daemon-0", this.getHost().getSpeed()*100, 0); - } - public void main(String[] args) throws MsgException { - int i = 1; - while(!Main.isEndOfTest()) { - // TODO the binding is not yet available - try { - currentTask.execute(); - } catch (HostFailureException e) { - e.printStackTrace(); - } catch (TaskCancelledException e) { - System.out.println("task cancelled"); - suspend(); // Suspend the process - } - currentTask = new Task(this.getHost().getName()+"-daemon-"+(i++), this.getHost().getSpeed()*100, 0); -// Msg.info(currentTask.getName()); - } + private Task currentTask; + public Daemon(VM vm) { + super((Host)vm,"Daemon"); + currentTask = new Task(this.getHost().getName()+"-daemon-0", this.getHost().getSpeed()*100, 0); + } + public void main(String[] args) throws MsgException { + int i = 1; + while(!Main.isEndOfTest()) { + // TODO the binding is not yet available + try { + currentTask.execute(); + } catch (HostFailureException e) { + e.printStackTrace(); + } catch (TaskCancelledException e) { + Msg.info("task cancelled"); + suspend(); // Suspend the process } + currentTask = new Task(this.getHost().getName()+"-daemon-"+(i++), this.getHost().getSpeed()*100, 0); + } +} - public double getRemaining(){ - return this.currentTask.getRemainingDuration(); - } - } + public double getRemaining(){ + return this.currentTask.getFlopsAmount(); + } +}