scheduler.h

Go to the documentation of this file.

#ifndef FPMAS_SCHEDULER_API_H
#define FPMAS_SCHEDULER_API_H
 
#include <list>
 
#include "fpmas/api/graph/distributed_node.h"
 
namespace fpmas { namespace api { namespace scheduler {
    typedef unsigned long Period;
    typedef float Date;
 
    typedef unsigned long TimeStep;
    typedef float SubTimeStep;
 
    typedef size_t JID;
 
    TimeStep time_step(Date date);
    SubTimeStep sub_time_step(Date date);
 
    api::scheduler::SubTimeStep sub_step_end(api::scheduler::TimeStep time_step);
 
    class Task {
        public:
            virtual void run() = 0;
 
            virtual void setJobPos(JID job_id, std::list<Task*>::iterator pos) = 0;
 
            virtual std::list<Task*>::iterator getJobPos(JID job_id) const = 0;
 
            virtual ~Task() {}
    };
 
    template<typename T>
        class NodeTask : public Task {
            public:
                virtual api::graph::DistributedNode<T>* node() = 0;
        };
 
    class Job {
        public:
            typedef std::list<Task*>::const_iterator TaskIterator;
 
            virtual JID id() const = 0;
            virtual void add(Task& task) = 0;
            virtual void remove(Task& task) = 0;
            virtual std::vector<Task*> tasks() const = 0;
            virtual TaskIterator begin() const = 0;
            virtual TaskIterator end() const = 0;
 
            virtual void setBeginTask(Task& task) = 0;
            virtual Task& getBeginTask() const = 0;
 
            virtual void setEndTask(Task& task) = 0;
            virtual Task& getEndTask() const = 0;
 
            virtual ~Job() {}
    };
 
    typedef std::vector<std::reference_wrapper<const Job>> JobList;
 
    class Epoch {
        public:
 
            typedef std::vector<const Job*>::const_iterator JobIterator;
 
            virtual void submit(const Job& job, SubTimeStep sub_time_step) = 0;
 
            virtual void submit(JobList job_list, SubTimeStep sub_time_step) = 0;
 
            virtual const std::vector<const Job*>& jobs() const = 0;
 
            virtual JobIterator begin() const = 0;
            virtual JobIterator end() const = 0;
            virtual size_t jobCount() = 0;
 
            virtual void clear() = 0;
            virtual ~Epoch() {};
    };
 
    class Scheduler {
        public:
            virtual void schedule(Date date, const Job& job) = 0;
            virtual void schedule(Date date, Period period, const Job& job) = 0;
 
            virtual void schedule(Date date, Date end, Period period, const Job& job) = 0;
 
            virtual void schedule(Date date, JobList job) = 0;
 
            virtual void schedule(Date date, Period period, JobList job) = 0;
            virtual void schedule(Date date, Date end, Period period, JobList job) = 0;
 
            virtual void build(TimeStep step, Epoch& epoch) const = 0;
 
            virtual ~Scheduler() {}
    };
}}}
#endif