SerialScheduler.hpp

Go to the documentation of this file.

#pragma once
 
#include <mutable/catalog/Scheduler.hpp>
#include <condition_variable>
#include <list>
#include <future>
#include <thread>
 
 
namespace m {
 
struct SerialScheduler : Scheduler
{
    private:
    struct CommandQueue
    {
        private:
        std::list<queued_command> command_list_;
        Transaction *running_transaction_; 
        std::mutex mutex_;
        std::condition_variable has_element_;
        bool closed_ = false;
 
        public:
        CommandQueue() = default;
        ~CommandQueue() = default;
 
        std::optional<queued_command> pop();
        void push(Transaction &t, std::unique_ptr<ast::Command> command, Diagnostic &diag, std::promise<bool> promise);
        void close();    
        bool is_closed();  
        void stop_transaction(Transaction &t); 
    };
 
    static CommandQueue query_queue_; 
    std::thread schedule_thread_; 
 
    static std::atomic<int64_t> next_start_time; 
 
    public:
    SerialScheduler() = default;
    ~SerialScheduler();
 
    std::future<bool> schedule_command(Transaction &t, std::unique_ptr<ast::Command> command, Diagnostic &diag) override;
 
    std::unique_ptr<Transaction> begin_transaction() override;
 
    bool commit(std::unique_ptr<Transaction> t) override;
 
    bool abort(std::unique_ptr<Transaction> t) override;
 
    private:
    static void schedule_thread();
};
 
}