syncd.h

Go to the documentation of this file.

/*
-------------------------------------------------------------------------------
                            PLEBBLE
-------------------------------------------------------------------------------
 Copyright (C) 2019-2020 KATLAS Technology. (http://katlastechnology.com)
 Copyright (C) 2017-2020 Marcos Mayorga. (mm@mm-studios.com)
 
 This file is part of our Plebble(R) Platform.
 
 The code below cannot be copied, used for any purpose other than the one
 agreed and/or distributed without the express permission of
 KATLAS Technology.
-------------------------------------------------------------------------------
 
 
*/
#ifndef USGOV_77adc1ef338434dcbe2fd89f5a86d54ba6fe219dcb84f80d6903a1ee04fc73ea
#define USGOV_77adc1ef338434dcbe2fd89f5a86d54ba6fe219dcb84f80d6903a1ee04fc73ea
 
#include <condition_variable>
#include <mutex>
#include <chrono>
#include <atomic>
#include "diff.h"
#include <us/gov/config.h>
#include <us/gov/bgtask.h>
 
namespace us{ namespace gov {
namespace engine {
    using namespace std;
 
    struct syncd_t: bgtask {
        typedef bgtask t;
        typedef diff::hash_t hash_t;
 
        struct actuator {
            virtual ~actuator() {}
            virtual bool get_prev(const hash_t& h, hash_t& prev) const=0;
            virtual int query_block(const hash_t& hash)=0;
            virtual void clear()=0;
            virtual bool patch_db(vector<hash_t>& patches)=0;
            virtual void on_sync()=0;
        };
 
        syncd_t(actuator* d);
        ~syncd_t() override;
        syncd_t(const syncd_t&)=delete;
        syncd_t& operator = (const syncd_t&)=delete;
        //void on_finish() override;
        void dump(ostream& os) const;
        void run();
        void update(const hash_t& head, const hash_t& tail);
        void update(const hash_t& tail);
        void wait();
        void onwakeup();
        void wait(const chrono::steady_clock::duration& d);
        const hash_t& tip() const;
        bool in_sync() const;
        bool in_sync_() const;
        void signal_file_arrived();
        void logline(ostream&os) const;
        actuator* d;
        condition_variable cv;
        mutable mutex mx;
 
        hash_t head;
        hash_t cur;
        hash_t tail;
        //atomic<short> resume{0};
        condition_variable cv_wait4file;
        mutex mx_wait4file;
        atomic<bool> file_arrived{false};
        hash_t last_snapshot{0};
 
        #if CFG_COUNTERS==1
            struct counters_t {
                uint32_t trigger_sync_event{0};
                uint32_t db_reset_countdowns{0};
                uint32_t db_reset{0};
                void dump(ostream&os) const;
            };
            static counters_t counters;
        #endif
        #if CFG_LOGS==1
            string logdir;
        #endif
    };
 
}}
}
 
#endif