Scheduler_8cpp_source.html

#include <mutable/catalog/Scheduler.hpp>


using namespace m;


std::atomic<uint64_t> Scheduler::Transaction::next_id_;


bool Scheduler::autocommit (std::unique_ptr<ast::Command> command, Diagnostic &diag) {

    auto t = begin_transaction();

    auto res_future = schedule_command(*t, std::move(command), diag);

    res_future.wait();

    if (res_future.get()) {

        bool res = commit(std::move(t));

        M_insist(res);

        return res;

    } else {

        bool aborted = abort(std::move(t));

        M_insist(aborted);

        return false;

    }

}

Scheduler.hpp

M_insist
#define M_insist(...)
Definition: macro.hpp:129

m
‍mutable namespace
Definition: Backend.hpp:10

m::Diagnostic
Definition: Diagnostic.hpp:12

m::Scheduler::Transaction::next_id_
static std::atomic< uint64_t > next_id_
‍Stores the next available Transaction ID, stored atomically to prevent race conditions
Definition: Scheduler.hpp:24

m::Scheduler::begin_transaction
virtual std::unique_ptr< Transaction > begin_transaction()=0
Returns a new Scheduler::Transaction object that is passed along when scheduling commands.

m::Scheduler::commit
virtual bool commit(std::unique_ptr< Transaction > t)=0
Closes the given Scheduler::Transaction and commits its changes.

m::Scheduler::autocommit
bool autocommit(std::unique_ptr< ast::Command > command, Diagnostic &diag)
Schedule a ast::Command for execution and automatically commits its changes.
Definition: Scheduler.cpp:9

m::Scheduler::abort
virtual bool abort(std::unique_ptr< Transaction > t)=0
Closes the given Scheduler::Transaction and discards its changes.

m::Scheduler::schedule_command
virtual std::future< bool > schedule_command(Transaction &t, std::unique_ptr< ast::Command > command, Diagnostic &diag)=0
Schedule a ast::Command for execution within the given Scheduler::Transaction.