TimeSynchronizer.h

Go to the documentation of this file.

 
#pragma once
#include "constants.h"
#include "types.h"
#include "timesync/src/filters/AggregateSynchronizationFilter.h"
 
namespace catapult {
    namespace cache {
        class AccountStateCacheView;
        class ImportanceView;
    }
}
 
namespace catapult { namespace timesync {
 
    class TimeSynchronizer {
    public:
        explicit TimeSynchronizer(
                const filters::AggregateSynchronizationFilter& filter,
                Importance totalChainImportance,
                int64_t warningThresholdMillis = Warning_Threshold_Millis);
 
    public:
        TimeOffset calculateTimeOffset(
                const cache::AccountStateCacheView& accountStateCacheView,
                Height height,
                TimeSynchronizationSamples&& samples,
                NodeAge nodeAge);
 
    private:
        Importance::ValueType sumImportances(
                const cache::ImportanceView& importanceView,
                Height height,
                const TimeSynchronizationSamples& samples);
 
        double sumScaledOffsets(
                const cache::ImportanceView& importanceView,
                Height height,
                const TimeSynchronizationSamples& samples,
                double scaling);
    private:
        filters::AggregateSynchronizationFilter m_filter;
        Importance m_totalChainImportance;
        int64_t m_warningThresholdMillis;
    };
}}