TimeSynchronizationUtils.h

Go to the documentation of this file.

 
#pragma once
#include "CommunicationTimestamps.h"
#include "TimeSynchronizationSample.h"
#include "catapult/extensions/ExtensionManager.h"
#include "catapult/ionet/Node.h"
#include "catapult/net/NodeRequestResult.h"
#include "catapult/thread/Task.h"
 
namespace catapult {
    namespace extensions { class ServiceState; }
    namespace timesync {
        struct TimeSynchronizationConfiguration;
        class TimeSynchronizationState;
        class TimeSynchronizer;
    }
}
 
namespace catapult { namespace timesync {
 
    using TimeSyncRequestResultPair = std::pair<net::NodeRequestResult, CommunicationTimestamps>;
 
    using TimeSyncResultSupplier = std::function<thread::future<TimeSyncRequestResultPair> (const ionet::Node&)>;
 
    thread::future<TimeSynchronizationSamples> RetrieveSamples(
            const ionet::NodeSet& nodes,
            const TimeSyncResultSupplier& resultSupplier,
            const extensions::ExtensionManager::NetworkTimeSupplier& networkTimeSupplier);
 
    thread::Task CreateTimeSyncTask(
            TimeSynchronizer& timeSynchronizer,
            const TimeSynchronizationConfiguration& timeSyncConfig,
            const TimeSyncResultSupplier& resultSupplier,
            const extensions::ServiceState& state,
            TimeSynchronizationState& timeSyncState,
            const extensions::ExtensionManager::NetworkTimeSupplier& networkTimeSupplier);
}}