BlockConsumers.h

Go to the documentation of this file.

 
#pragma once
#include "BlockChainProcessor.h"
#include "BlockChainSyncHandlers.h"
#include "HashCheckOptions.h"
#include "InputUtils.h"
#include "catapult/chain/ChainFunctions.h"
#include "catapult/disruptor/DisruptorConsumer.h"
#include "catapult/validators/ParallelValidationPolicy.h"
 
namespace catapult {
    namespace chain { struct CatapultState; }
    namespace io { class BlockStorageCache; }
    namespace model { class TransactionRegistry; }
    namespace utils { class TimeSpan; }
}
 
namespace catapult { namespace consumers {
 
    disruptor::BlockConsumer CreateBlockHashCalculatorConsumer(
            const GenerationHash& generationHash,
            const model::TransactionRegistry& transactionRegistry);
 
    disruptor::ConstBlockConsumer CreateBlockHashCheckConsumer(const chain::TimeSupplier& timeSupplier, const HashCheckOptions& options);
 
    disruptor::ConstBlockConsumer CreateBlockChainCheckConsumer(
            uint32_t maxChainSize,
            const utils::TimeSpan& maxBlockFutureTime,
            const chain::TimeSupplier& timeSupplier);
 
    using RequiresValidationPredicate = model::MatchingEntityPredicate;
 
    disruptor::ConstBlockConsumer CreateBlockStatelessValidationConsumer(
            const std::shared_ptr<const validators::stateless::AggregateEntityValidator>& pValidator,
            const std::shared_ptr<const validators::ParallelValidationPolicy>& pValidationPolicy,
            const RequiresValidationPredicate& requiresValidationPredicate);
 
    disruptor::DisruptorConsumer CreateBlockChainSyncConsumer(
            cache::CatapultCache& cache,
            state::CatapultState& state,
            io::BlockStorageCache& storage,
            uint32_t maxRollbackBlocks,
            const BlockChainSyncHandlers& handlers);
 
    disruptor::ConstDisruptorConsumer CreateBlockChainSyncCleanupConsumer(const std::string& dataDirectory);
 
    using NewBlockSink = consumer<const std::shared_ptr<const model::Block>&>;
 
    disruptor::DisruptorConsumer CreateNewBlockConsumer(const NewBlockSink& newBlockSink, disruptor::InputSource sinkSourceMask);
}}