process.h

Go to the documentation of this file.

#ifndef PROCESS_H
#define PROCESS_H

#include <cmath>
#include <iterator>
#include <list>
#include <ostream>
#include <vector>
#include <memory>

namespace Utils
{
    class RandomGenerator;
    class BoundedRandomDistribution;
}

namespace Scheduler
{

class Event;

class Process
{
public:
    static std::shared_ptr<Process> createNextJob(const Process& task);
    static std::shared_ptr<Process> createProcess(double cpuLambda, double ioLambda);
    static std::shared_ptr<Process> createRealTimeTask(double wcet, double T,
        double dl, int pid, int priority = 0, double bcet = 0.0);
    static int getNewPid();
    static unsigned long int getMaxNumber();
    static void setRandomGenerator(Utils::RandomGenerator *gen);

    //static void init();

    static void end();
private:
    static const unsigned long int maxNumber = 4000000000;
    static unsigned long  int currentNumber;
    static Utils::RandomGenerator *randomGenerator;
public:
    /*FIXME: Why are those public?*/
    Process(int pid, int nbBursts, std::vector<double> cpuBursts, std::vector<double> ioBursts, int priority = 0);
    Process(const Process& task);
    ~Process();
    
    void setDurationDistribution(std::shared_ptr<Utils::BoundedRandomDistribution> randomDist);
    int getPid(void) const;
    int getPriority() const;
    void setPriority(int pri);
    void updateCurrentAow(double aow);
    bool advanceBurst();
    void decrementBurst();
    double getCurrentCpuAow() const;
    double getCurrentIoTime() const;
    void setRtParams(double dl, double T, double wcet, double bcet);
    void setDeadlineTimeFromStartTime(double startTime);//TODO: how does this work with AOW?
    bool isRealTime() const;
    double getPeriod() const;
    double getDeadline() const;
    double getDeadlineTime() const;
    void print(std::ostream& stream) const;
    void incrementJobNumber();//TODO: Why is this public?
    unsigned int getJobNumber() const;
    double getWcet() const;
    void setPowerCoeff(double);
    double powerCoeff{1.0}; /*FIXME make this private*/
private:
    /*Only for real-time jobs*/
    void setDuration();

    int pid;
    std::vector<double> cpuBurst;/*This is an array of aow. For RT jobs, this contains only one number*/
    std::vector<double> ioBurst;/*This is an array of times spent waiting*/
    int currentBurst{0};
    int nbBursts; /*This is the nb of cpu bursts. there are n-1 io bursts.*/
    int priority{0};

    /*Those are the real time parameters. Maybe would it be better to put them in an aggregated class*/
    bool RT{false};
    double deadline{0.0};
    double deadlineTime{0.0};
    double period{INFINITY};
    unsigned int jobNumber{0};
    double bcet{0.0}; /*best case execution time*/
    double wcet{0.0}; /*XXX: wcet and bcet are expressed as amount of work and not in time units.*/ 
    std::shared_ptr<Utils::BoundedRandomDistribution> randomDist{nullptr};
};




}


#endif