X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5a2381818ef1eec814d276bbe5d9452e3e092661..cf108868b4eeed4d0d9d343bc68557d7814e18c0:/examples/java/cloud/migration/Test.java

diff --git a/examples/java/cloud/migration/Test.java b/examples/java/cloud/migration/Test.java
index 50e9271170..e67b32c4e6 100644
--- a/examples/java/cloud/migration/Test.java
+++ b/examples/java/cloud/migration/Test.java
@@ -1,141 +1,148 @@
-/* Copyright (c) 2014. The SimGrid Team.
+/* Copyright (c) 2014, 2016. 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 cloud.migration;
+import java.util.ArrayList;
+import java.util.List;
+
 
 import org.simgrid.msg.*;
 import org.simgrid.msg.Process;
 
 public class Test extends Process{
 
-    Test(Host host, String name, String[] args) throws HostNotFoundException, NativeException  {
-        super(host, name, args);
+  Test(Host host, String name, String[] args) throws HostNotFoundException, NativeException  {
+    super(host, name, args);
+  }
+
+  public void main(String[] strings) throws MsgException {
+    double startTime = 0;
+    double endTime = 0;
+
+    /* get hosts 1 and 2*/
+    Host host0 = null;
+    Host host1 = null;
+
+    try {
+      host0 = Host.getByName("host0");
+      host1 = Host.getByName("host1");
+    }catch (HostNotFoundException e) {
+      e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
     }
 
-    public void main(String[] strings) throws MsgException {
-
-       double startTime = 0;
-       double endTime = 0;
-
-       /* get hosts 1 and 2*/
-        Host host0 = null;
-        Host host1 = null;
-
-        try {
-            host0 = Host.getByName("host0");
-            host1 = Host.getByName("host1");
-        }catch (HostNotFoundException e) {
-            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
-        }
-
-      /* Create VM1 */
-        int dpRate = 70;
-        int load1 = 90;
-        int load2 = 80;
-
-        XVM vm1 = null;
-        vm1 = new XVM(
-                host0,
-                "vm0",
-                1, // Nb of vcpu
-                2048, // Ramsize,
-                125, // Net Bandwidth
-                null, //VM disk image
-                -1,   //size of disk image,
-                125, // Net bandwidth,
-                dpRate // Memory intensity
+    List<VM> vms = new ArrayList<VM>();
+
+    /* Create VM1 */
+    int dpRate = 70;
+    int load1 = 90;
+    int load2 = 80;
+
+    Msg.info("This example evaluates the migration time of a VM in presence of collocated VMs on the source and "
+             + "the dest nodes");
+    Msg.info("The migrated VM has a memory intensity rate of 70% of the network BW and a cpu load of 90% \" "
+             +"(see cloudcom 2013 paper \"Adding a Live Migration Model Into SimGrid\" for further information) ");
+
+    Msg.info("Load of collocated VMs fluctuate between 0 and 90% in order to create a starvation issue and see "
+             + "whether it impacts or not the migration time");
+    XVM vm1 = null;
+    vm1 = new XVM(host0, "vm0",
+        1, // Nb of vcpu
+        2048, // Ramsize,
+        125, // Net Bandwidth
+        null, //VM disk image
+        -1,   //size of disk image,
+        125, // Net bandwidth,
+        dpRate // Memory intensity
         );
+    vms.add(vm1);
+    vm1.start();
+
+    /* Collocated VMs */
+    int collocatedSrc = 6;
+    int vmSrcLoad[] = {
+        80,
+        0,
+        90,
+        40,
+        30,
+        90,
+    };
+
+    XVM tmp = null;
+    for (int i=1 ; i<= collocatedSrc ; i++){
+      tmp = new XVM(host0, "vm"+i,
+          1, // Nb of vcpu
+          2048, // Ramsize,
+          125, // Net Bandwidth
+          null, //VM disk image
+          -1,   //size of disk image,
+          125, // Net bandwidth,
+          dpRate // Memory intensity
+          );
+      vms.add(tmp);
+      tmp.start();
+      tmp.setLoad(vmSrcLoad[i-1]);
+    }
 
-
-        vm1.start();
-
-        /* Collocated VMs */
-        int collocatedSrc = 6;
-        int vmSrcLoad[] = {
-                80,
-                0,
-                90,
-                40,
-                30,
-                90,
-        };
-
-        XVM tmp = null;
-        for (int i=1 ; i<= collocatedSrc ; i++){
-            tmp = new XVM(
-                    host0,
-                    "vm"+i,
-                    1, // Nb of vcpu
-                    2048, // Ramsize,
-                    125, // Net Bandwidth
-                    null, //VM disk image
-                    -1,   //size of disk image,
-                    125, // Net bandwidth,
-                    dpRate // Memory intensity
-            );
-            tmp.start();
-            tmp.setLoad(vmSrcLoad[i-1]);
-        }
-
-        int collocatedDst = 6;
-        int vmDstLoad[] = {
-                0,
-                40,
-                90,
-                100,
-                0,
-                80,
-        };
-
-        for (int i=1 ; i <= collocatedDst ; i++){
-            tmp = new XVM(
-                    host1,
-                    "vm"+i+collocatedSrc,
-                    1, // Nb of vcpu
-                    2048, // Ramsize,
-                    125, // Net Bandwidth
-                    null, //VM disk image
-                    -1,   //size of disk image,
-                    125, // Net bandwidth,
-                    dpRate // Memory intensity
-            );
-            tmp.start();
-            tmp.setLoad(vmDstLoad[i-1]);
-        }
-
-
-
-
-
-        Msg.info("Round trip of VM1 (load "+load1+"%)");
-        vm1.setLoad(load1);
-        Msg.info("     - Launch migration from host 0 to host 1");
-        startTime = Msg.getClock();
-        vm1.migrate(host1);
-        endTime = Msg.getClock();
-        Msg.info("     - End of Migration from host 0 to host 1 (duration:"+(endTime-startTime)+")");
-        Msg.info("     - Launch migration from host 1 to host 0");
-        startTime = Msg.getClock();
-        vm1.migrate(host0);
-        endTime = Msg.getClock();
-        Msg.info("     - End of Migration from host 1 to host 0 (duration:"+(endTime-startTime)+")");
-
-        Msg.info("\n \n \nRound trip of VM1 (load "+load2+"%)");
-        vm1.setLoad(load2);
-        Msg.info("     - Launch migration from host 0 to host 1");
-        startTime = Msg.getClock();
-        vm1.migrate(host1);
-        endTime = Msg.getClock();
-        Msg.info("     - End of Migration from host 0 to host 1 (duration:"+(endTime-startTime)+")");
-        Msg.info("     - Launch migration from host 1 to host 0");
-        startTime = Msg.getClock();
-        vm1.migrate(host0);
-        endTime = Msg.getClock();
-        Msg.info("     - End of Migration from host 1 to host 0 (duration:"+(endTime-startTime)+")");
-
-        waitFor(100000);
-        Main.setEndOfTest();
+    int collocatedDst = 6;
+    int vmDstLoad[] = {
+        0,
+        40,
+        90,
+        100,
+        0,
+        80,
+    };
+
+    for (int i=1 ; i <= collocatedDst ; i++){
+      tmp = new XVM(host1, "vm"+(i+collocatedSrc),
+          1, // Nb of vcpu
+          2048, // Ramsize,
+          125, // Net Bandwidth
+          null, //VM disk image
+          -1,   //size of disk image,
+          125, // Net bandwidth,
+          dpRate // Memory intensity
+          );
+      vms.add(tmp);
+      tmp.start();
+      tmp.setLoad(vmDstLoad[i-1]);
     }
+
+    Msg.info("Round trip of VM1 (load "+load1+"%)");
+    vm1.setLoad(load1);
+    Msg.info("     - Launch migration from host 0 to host 1");
+    startTime = Msg.getClock();
+    vm1.migrate(host1);
+    endTime = Msg.getClock();
+    Msg.info("     - End of Migration from host 0 to host 1 (duration:"+(endTime-startTime)+")");
+    Msg.info("     - Launch migration from host 1 to host 0");
+    startTime = Msg.getClock();
+    vm1.migrate(host0);
+    endTime = Msg.getClock();
+    Msg.info("     - End of Migration from host 1 to host 0 (duration:"+(endTime-startTime)+")");
+
+    Msg.info("");
+    Msg.info("");
+    Msg.info("Round trip of VM1 (load "+load2+"%)");
+    vm1.setLoad(load2);
+    Msg.info("     - Launch migration from host 0 to host 1");
+    startTime = Msg.getClock();
+    vm1.migrate(host1);
+    endTime = Msg.getClock();
+    Msg.info("     - End of Migration from host 0 to host 1 (duration:"+(endTime-startTime)+")");
+    Msg.info("     - Launch migration from host 1 to host 0");
+    startTime = Msg.getClock();
+    vm1.migrate(host0);
+    endTime = Msg.getClock();
+    Msg.info("     - End of Migration from host 1 to host 0 (duration:"+(endTime-startTime)+")");
+
+    Main.setEndOfTest();
+    Msg.info("Forcefully destroy VMs");
+    for (VM vm: vms)
+      vm.finalize();
+  }
 }