src/at/ac/tuwien/lsdc/sched/SchedulerB.java

   1 package at.ac.tuwien.lsdc.sched;
   2
   3 import java.io.File;
   4 import java.io.IOException;
   5 import java.util.LinkedList;
   6
   7 import org.slf4j.Logger;
   8 import org.slf4j.LoggerFactory;
   9
  10 import at.ac.tuwien.lsdc.exception.OutOfPMsException;
  11 import at.ac.tuwien.lsdc.exception.VMResizeException;
  12 import at.ac.tuwien.lsdc.types.PhysicalMachine;
  13 import at.ac.tuwien.lsdc.types.ScenarioType;
  14 import at.ac.tuwien.lsdc.types.SchedulerEvent;
  15 import at.ac.tuwien.lsdc.types.SchedulerEvent.EventType;
  16 import at.ac.tuwien.lsdc.types.SchedulerType;
  17 import at.ac.tuwien.lsdc.types.VirtualMachine;
  18 import at.ac.tuwien.lsdc.types.VirtualMachine.VMType;
  19
  20 /**
  21  * Scheduler B.
  22  *
  23  * Initial State: All PMs switched off. If an application arrives, try to modify
  24  * size, CPU and RAM of an existing VM to run the application. If no VM is
  25  * running, create a new one (start a new PM if necessary). If the application
  26  * has finished decrease the size, CPU and RAM of the VM. If no applications are
  27  * running on a VM, shut down the VM. If no VM is running on a PM, shut down the
  28  * PM. Try to get a maximum of utilization on every PM. Migration: Try to move
  29  * applications from VMs to other VMs to get a better utilization and to use
  30  * less PMs.
  31  *
  32  * @author jan
  33  *
  34  */
  35 public class SchedulerB extends AbstractScheduler {
  36
  37         private static final Logger log = LoggerFactory.getLogger(SchedulerB.class);
  38
  39         public SchedulerB(int numPMs, int numCloudPartners, File schedulerLog, ScenarioType scenario) throws IOException {
  40                 super(numPMs, numCloudPartners, schedulerLog, scenario);
  41
  42                 vmType = VMType.Resizable;
  43         }
  44
  45         @Override
  46         protected void handleEvents(LinkedList<SchedulerEvent> events) {
  47                 log.debug("handleEvents():" + events);
  48                 for (SchedulerEvent evt : events) {
  49                         if (evt.getType() == EventType.endApplication) {
  50                                 VirtualMachine vm = evt.getApp().getRunningOn();
  51                                 evt.getApp().setRunningOn(null);
  52                                 vm.stopApplication(evt.getApp());
  53                                 try {
  54                                         vm.resizeVM(vm.getSize() - evt.getApp().getSize(), vm.getRAM() - evt.getApp().getRam(), vm.getCPU()
  55                                                         - evt.getApp().getCpu());
  56                                 } catch (VMResizeException e) {
  57                                         log.error("lol: " + e.getVm(), e);
  58                                 }
  59                                 if (vm.getApplications().size() == 0) {
  60                                         PhysicalMachine pm = vm.getRunningOn();
  61                                         pm.stopVirtualMachine(vm);
  62                                         manager.stopPhysicalMachine(pm.getId());
  63                                 }
  64                         }
  65                 }
  66
  67                 // TODO: migrate apps to get an empty VM and shut it down.
  68                 // TODO: run all delayed.
  69
  70                 for (SchedulerEvent evt : events) {
  71                         if (evt.getType() == EventType.startApplication) {
  72                                 VirtualMachine vm = null;
  73                                 for (PhysicalMachine pm : manager.getPMs()) {
  74                                         log.debug("PMs: " + pm);
  75                                         vm = pm.getVirtualMachines().get((pm.getVirtualMachines().keySet().toArray(new Integer[0]))[0]);
  76                                         try {
  77                                                 vm.resizeVM(vm.getSize() + evt.getApp().getSize(), vm.getRAM() + evt.getApp().getRam(), vm.getCPU()
  78                                                                 + evt.getApp().getCpu());
  79                                                 break;
  80                                         } catch (VMResizeException ex) {
  81                                                 vm = null;
  82                                         }
  83                                 }
  84                                 if (vm == null) {
  85                                         try {
  86                                                 vm = manager.startPhysicalMachine().startVirtualMachine(evt.getApp().getSize(), evt.getApp().getRam(),
  87                                                                 evt.getApp().getCpu(), vmType);
  88                                         } catch (OutOfPMsException e) {
  89                                                 log.error("OOP!", e);
  90                                                 // TODO: delay APP start.
  91                                                 return;
  92                                         }
  93                                 }
  94                                 vm.startApplication(evt.getApp());
  95                                 evt.getApp().setRunningOn(vm);
  96                                 insertStopEvent(currTime + evt.getApp().getDuration(), evt.getApp());
  97                         }
  98                 }
  99         }
 100
 101         @Override
 102         protected String getSchedulerType() {
 103                 return SchedulerType.B.toString();
 104         }
 105
 106 }