persistence_manager.hpp

Go to the documentation of this file.

#pragma once

#include <atomic>
#include <chrono>
#include <errno.h>
#include <queue>
#include <semaphore.h>
#include <thread>

#include "../replicated.hpp"
#include "derecho_internal.hpp"
#include "view_manager.hpp"
#include <derecho/persistent/Persistent.hpp>
#include <derecho/utils/logger.hpp>

namespace derecho {

using persistence_request_t = std::tuple<subgroup_id_t, persistent::version_t>;

class PersistenceManager {
private:
    std::thread persist_thread;
    std::atomic<bool> thread_shutdown;
    sem_t persistence_request_sem;
    std::queue<persistence_request_t> persistence_request_queue;
    std::atomic_flag prq_lock = ATOMIC_FLAG_INIT;

    persistence_callback_t persistence_callback;
    std::map<subgroup_id_t, std::reference_wrapper<ReplicatedObject>>& objects_by_subgroup_id;
    ViewManager* view_manager;

public:
    PersistenceManager(
            std::map<subgroup_id_t, std::reference_wrapper<ReplicatedObject>>& objects_map,
            const persistence_callback_t& _persistence_callback);


    virtual ~PersistenceManager();

    void set_view_manager(ViewManager& view_manager);

    void start();

    void post_persist_request(const subgroup_id_t& subgroup_id, const persistent::version_t& version);

    void make_version(const subgroup_id_t& subgroup_id,
                      const persistent::version_t& version, const HLC& mhlc);

    void shutdown(bool wait);

    persistence_manager_callbacks_t get_callbacks();
};
}  // namespace derecho