#include "synchronizer_impl.hpp"


Public Member Functions | |
| SynchronizerImpl (std::unique_ptr< iroha::ametsuchi::CommandExecutor > command_executor, std::shared_ptr< network::ConsensusGate > consensus_gate, std::shared_ptr< validation::ChainValidator > validator, std::shared_ptr< ametsuchi::MutableFactory > mutable_factory, std::shared_ptr< ametsuchi::BlockQueryFactory > block_query_factory, std::shared_ptr< network::BlockLoader > block_loader, logger::LoggerPtr log) | |
| ~SynchronizerImpl () override | |
| void | processOutcome (consensus::GateObject object) override |
| rxcpp::observable< SynchronizationEvent > | on_commit_chain () override |
Public Member Functions inherited from iroha::synchronizer::Synchronizer | |
| virtual | ~Synchronizer ()=default |
| iroha::synchronizer::SynchronizerImpl::SynchronizerImpl | ( | std::unique_ptr< iroha::ametsuchi::CommandExecutor > | command_executor, |
| std::shared_ptr< network::ConsensusGate > | consensus_gate, | ||
| std::shared_ptr< validation::ChainValidator > | validator, | ||
| std::shared_ptr< ametsuchi::MutableFactory > | mutable_factory, | ||
| std::shared_ptr< ametsuchi::BlockQueryFactory > | block_query_factory, | ||
| std::shared_ptr< network::BlockLoader > | block_loader, | ||
| logger::LoggerPtr | log | ||
| ) |

|
override |
|
overridevirtual |
After synchronization this observable emits zero or more blocks plus outcome of synchronization
Implements iroha::synchronizer::Synchronizer.
|
overridevirtual |
Processing entry point for consensus outcome
Implements iroha::synchronizer::Synchronizer.
