FixedPriorityScheduler.hpp

#ifndef FIXEDPRIORITYSCHEDULER_H
#define FIXEDPRIORITYSCHEDULER_H

#include <iostream>
#include <list>
#include <string>
#include <cctype>
#include "SchedulerStep.hpp"
#include "Process.hpp"


class FixedPriorityScheduler{
private:
    double currentTime;
    std::list<Process> processes;

    static bool higherPriority( Process & a, Process & b){
        return a.getPriority() < b.getPriority();
    }
public:

    explicit FixedPriorityScheduler(std::list<Process> processes)
      : processes(processes) {
        currentTime = processes.front().getArrivalTime();
    }
    virtual ~FixedPriorityScheduler() {}

    std::list<SchedulerStep> getSteps(){
      std::list<SchedulerStep> steps = std::list<SchedulerStep>();
      std::list<Process> queue;

      Process currentProcess = processes.front();
      processes.pop_front();
      queue.push_back(currentProcess);
      Process next;

      double t, addedTime;
      while (!queue.empty()) {
        queue.sort(higherPriority);
        currentProcess = queue.front();
        queue.pop_front();

        if(!processes.empty()){
          next = processes.front();
          t = next.getArrivalTime()-currentTime;
          if(t>currentProcess.getDuration()){
            addedTime = currentTime + currentProcess.getDuration();
            steps.push_back(SchedulerStep(currentProcess.getName(), currentTime,addedTime,queue));
            currentTime = addedTime;
            currentProcess.reduceDuration(currentProcess.getDuration());
          }
          else{
            steps.push_back(SchedulerStep(currentProcess.getName(), currentTime, currentTime+t,queue));
            currentProcess.reduceDuration(t);
            currentTime = next.getArrivalTime();
            processes.pop_front();
            if(t!=currentProcess.getDuration()){
              queue.push_back(currentProcess);
            }
            queue.push_back(next);
          }
        }
        else{
          addedTime = currentTime + currentProcess.getDuration();
          steps.push_back(SchedulerStep(currentProcess.getName(), currentTime, addedTime,queue));
          next = queue.front();
          currentTime = currentTime + currentProcess.getDuration();
          currentProcess.reduceDuration(currentProcess.getDuration());
        }
      }
      return steps;
    }
};

#endif