ChainSynchronizer.h

Go to the documentation of this file.

 
#pragma once
#include "RemoteNodeSynchronizer.h"
#include "catapult/disruptor/DisruptorTypes.h"
#include "catapult/model/AnnotatedEntityRange.h"
#include "catapult/model/RangeTypes.h"
 
namespace catapult {
    namespace api {
        class ChainApi;
        class RemoteChainApi;
    }
    namespace model { struct BlockChainConfiguration; }
}
 
namespace catapult { namespace chain {
 
    using BlockRangeConsumerFunc = consumer<model::BlockRange&&>;
 
    using CompletionAwareBlockRangeConsumerFunc = std::function<disruptor::DisruptorElementId (
            model::AnnotatedBlockRange&&,
            const disruptor::ProcessingCompleteFunc&)>;
 
    struct ChainSynchronizerConfiguration {
        uint32_t MaxBlocksPerSyncAttempt;
 
        uint32_t MaxChainBytesPerSyncAttempt;
 
        uint32_t MaxRollbackBlocks;
    };
 
    RemoteNodeSynchronizer<api::RemoteChainApi> CreateChainSynchronizer(
            const std::shared_ptr<const api::ChainApi>& pLocalChainApi,
            const ChainSynchronizerConfiguration& config,
            const CompletionAwareBlockRangeConsumerFunc& blockRangeConsumer);
}}