Scheduler.hpp

Go to the documentation of this file.

#pragma once
 
#include <mutable/mutable-config.hpp>
#include <mutable/parse/AST.hpp>
#include <mutable/util/Diagnostic.hpp>
#include <compare>
#include <future>
 
 
namespace m {
 
struct M_EXPORT Scheduler
{
    struct Transaction {
        private:
        uint64_t id_;
        int64_t start_time_ = -1;
 
        static std::atomic<uint64_t> next_id_;
 
        public:
        Transaction() : id_(next_id_.fetch_add(1, std::memory_order_relaxed)) { }
 
        void start_time(int64_t time) { M_insist(start_time_ == -1 and time >= 0); start_time_ = time; };
        int64_t start_time() const { return start_time_; };
 
        auto operator==(const Transaction &other) const { return id_ == other.id_; };
        auto operator<=>(const Transaction &other) const { return id_ <=> other.id_; };
    };
 
    protected:
    using queued_command = std::tuple<Transaction &, std::unique_ptr<ast::Command>, Diagnostic &, std::promise<bool>>;
 
    public:
    Scheduler() = default;
    virtual ~Scheduler() {}
 
    virtual std::future<bool> schedule_command(Transaction &t, std::unique_ptr<ast::Command> command, Diagnostic &diag) = 0;
 
    virtual std::unique_ptr<Transaction> begin_transaction() = 0;
 
    virtual bool commit(std::unique_ptr<Transaction> t) = 0;
 
    virtual bool abort(std::unique_ptr<Transaction> t) = 0;
 
    bool autocommit(std::unique_ptr<ast::Command> command, Diagnostic &diag);
};
 
}