asset_watcher.h

Go to the documentation of this file.

#pragma once
#include <context/context.hpp>
#include <filesystem/syncer.h>
#include <ospp/event.h>
 
#include <deque>
#include <mutex>
 
namespace unravel
{
class asset_watcher
{
public:
    asset_watcher();
    ~asset_watcher();
 
    auto init(rtti::context& ctx) -> bool;
    auto deinit(rtti::context& ctx) -> bool;
 
    void watch_assets(rtti::context& ctx, const std::string& protocol, bool wait = false);
    void unwatch_assets(rtti::context& ctx, const std::string& protocol);
 
private:
    void on_os_event(rtti::context& ctx, os::event& e);
 
    void setup_directory(rtti::context& ctx, fs::syncer& syncer);
    void setup_meta_syncer(rtti::context& ctx,
                           std::vector<uint64_t>& watchers,
                           fs::syncer& syncer,
                           const fs::path& data_dir,
                           const fs::path& meta_dir,
                           bool wait);
    void setup_cache_syncer(rtti::context& ctx,
                            std::vector<uint64_t>& watchers,
                            fs::syncer& syncer,
                            const fs::path& meta_dir,
                            const fs::path& cache_dir,
                            bool wait);
 
    struct watched
    {
        fs::syncer meta_syncer;
        fs::syncer cache_syncer;
        std::vector<std::uint64_t> watchers;
    };
 
    std::map<std::string, watched> watched_protocols_{};
    std::shared_ptr<int> sentinel_ = std::make_shared<int>(0);
 
};
} // namespace unravel