examples/java/cloud/migration/Test.java

   1 /* Copyright (c) 2014, 2016. The SimGrid Team.
   2  * All rights reserved.                                                     */
   3
   4 /* This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the license (GNU LGPL) which comes with this package. */
   6
   7 package cloud.migration;
   8 import java.util.ArrayList;
   9 import java.util.List;
  10
  11 import org.simgrid.msg.*;
  12 import org.simgrid.msg.Process;
  13
  14 public class Test extends Process{
  15
  16   Test(String hostname, String name) throws HostNotFoundException, NativeException  {
  17     super(hostname, name);
  18   }
  19
  20   public void doMigration(VM vm, Host src, Host dst) throws HostFailureException{
  21     Msg.info("     - Launch migration from "+ src.getName() +" to " + dst.getName());
  22     double startTime = Msg.getClock();
  23     vm.migrate(dst);
  24     double endTime = Msg.getClock();
  25     Msg.info("     - End of Migration from "+ src.getName() +" to " + dst.getName()+ " (duration:" +
  26              (endTime-startTime)+")");
  27   }
  28
  29   public void main(String[] strings) throws MsgException {
  30     Host host0 = null;
  31     Host host1 = null;
  32     try {
  33     /* get hosts 1 and 2*/
  34       host0 = Host.getByName("PM0");
  35       host1 = Host.getByName("PM1");
  36     }catch (HostNotFoundException e) {
  37       e.printStackTrace();
  38     }
  39
  40     List<VM> vms = new ArrayList<>();
  41
  42     /* Create VM1 */
  43     int dpRate = 70;
  44     int load1 = 90;
  45     int load2 = 80;
  46
  47     Msg.info("This example evaluates the migration time of a VM in presence of collocated VMs on the source and "
  48              + "the dest nodes");
  49     Msg.info("The migrated VM has a memory intensity rate of 70% of the network BW and a cpu load of 90% \" "
  50              +"(see cloudcom 2013 paper \"Adding a Live Migration Model Into SimGrid\" for further information) ");
  51
  52     Msg.info("Load of collocated VMs fluctuate between 0 and 90% in order to create a starvation issue and see "
  53              + "whether it impacts or not the migration time");
  54     XVM vm1 = new XVM(host0, "vm0",
  55         2048, // Ramsize,
  56         125, // Net bandwidth,
  57         dpRate // Memory intensity
  58         );
  59     vms.add(vm1);
  60     vm1.start();
  61
  62     /* Collocated VMs */
  63     int collocatedSrc = 6;
  64     int[] vmSrcLoad = {
  65         80,
  66         0,
  67         90,
  68         40,
  69         30,
  70         90,
  71     };
  72
  73     XVM tmp;
  74     for (int i=1 ; i<= collocatedSrc ; i++){
  75       tmp = new XVM(host0, "vm"+i,
  76           2048, // Ramsize,
  77           125, // Net bandwidth,
  78           dpRate // Memory intensity
  79           );
  80       vms.add(tmp);
  81       tmp.start();
  82       tmp.setLoad(vmSrcLoad[i-1]);
  83     }
  84
  85     int collocatedDst = 6;
  86     int[] vmDstLoad = {
  87         0,
  88         40,
  89         90,
  90         100,
  91         0,
  92         80,
  93     };
  94
  95     for (int i=1 ; i <= collocatedDst ; i++){
  96       tmp = new XVM(host1, "vm"+(i+collocatedSrc),
  97           2048, // Ramsize,
  98           125, // Net bandwidth,
  99           dpRate // Memory intensity
 100           );
 101       vms.add(tmp);
 102       tmp.start();
 103       tmp.setLoad(vmDstLoad[i-1]);
 104     }
 105
 106     Msg.info("Round trip of VM1 (load "+load1+"%)");
 107     vm1.setLoad(load1);
 108     doMigration(vm1, host0, host1);
 109     doMigration(vm1, host1, host0);
 110     Msg.info("");
 111     Msg.info("");
 112     Msg.info("Round trip of VM1 (load "+load2+"%)");
 113     vm1.setLoad(load2);
 114     doMigration(vm1, host0, host1);
 115     doMigration(vm1, host1, host0);
 116
 117     Main.setEndOfTest();
 118     Msg.info("Forcefully destroy VMs");
 119     for (VM vm: vms)
 120       vm.destroy();
 121   }
 122 }