calendar.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_6110ca70156c39f06bccb0b02bb98b63bef265d6284d970e13ddddb69c4a633b
#define USGOV_6110ca70156c39f06bccb0b02bb98b63bef265d6284d970e13ddddb69c4a633b
 
#include <set>
#include <mutex>
#include <chrono>
#include <atomic>
#include <condition_variable>
#include "evidence.h"
 
namespace us{ namespace gov {
namespace engine {
    using namespace std;
 
    //struct evidence;
    struct app;
    struct calndx final {
        calndx(evidence*e);
        bool operator < (const calndx& other) const;
        evidence* e;
    };
 
    struct calendar_t:set<calndx> {
        static constexpr chrono::seconds cycle_period {60};
        static constexpr chrono::seconds idle_wakeup {1};
        static constexpr chrono::seconds relay_interval {15}; //Tx execution is delayed this many seconds to account for propagation.
        calendar_t();
        ~calendar_t();
        calendar_t(const calendar_t&)=delete;
        calendar_t& operator =(const calendar_t&)=delete;
        void clear_until(uint64_t);
        //void on_finish();
        int schedule(evidence* e); //0-accepted; 1-invalid-expired; 2-invalid-late; 3-dup
        mutable mutex mx;
        //mutable condition_variable cv;
        uint64_t block_opening;
        uint64_t block_closure;
        uint64_t last_processed;
        //mutable atomic<short> resume{0};
    };
 
}
}}
 
#endif