#include "main/impl/on_demand_ordering_init.hpp"#include <rxcpp/operators/rx-filter.hpp>#include <rxcpp/operators/rx-map.hpp>#include <rxcpp/operators/rx-skip.hpp>#include <rxcpp/operators/rx-start_with.hpp>#include <rxcpp/operators/rx-with_latest_from.hpp>#include <rxcpp/operators/rx-zip.hpp>#include "common/permutation_generator.hpp"#include "interfaces/iroha_internal/block.hpp"#include "logger/logger.hpp"#include "logger/logger_manager.hpp"#include "network/impl/client_factory_impl.hpp"#include "ordering/impl/on_demand_common.hpp"#include "ordering/impl/on_demand_connection_manager.hpp"#include "ordering/impl/on_demand_ordering_gate.hpp"#include "ordering/impl/on_demand_ordering_service_impl.hpp"#include "ordering/impl/on_demand_os_client_grpc.hpp"#include "ordering/impl/on_demand_os_server_grpc.hpp"#include "ordering/impl/ordering_gate_cache/on_demand_cache.hpp"#include "synchronizer/synchronizer_common.hpp"
Enumerations | |
| enum | RoundType |
| indexes to permutations for corresponding rounds More... | |
Functions | |
| auto | createNotificationFactory (std::shared_ptr< iroha::network::AsyncGrpcClient< google::protobuf::Empty >> async_call, std::shared_ptr< OnDemandOrderingInit::TransportFactoryType > proposal_transport_factory, std::chrono::milliseconds delay, const logger::LoggerManagerTreePtr &ordering_log_manager, std::shared_ptr< iroha::network::GenericClientFactory > client_factory) |
| enum RoundType |
indexes to permutations for corresponding rounds
| auto createNotificationFactory | ( | std::shared_ptr< iroha::network::AsyncGrpcClient< google::protobuf::Empty >> | async_call, |
| std::shared_ptr< OnDemandOrderingInit::TransportFactoryType > | proposal_transport_factory, | ||
| std::chrono::milliseconds | delay, | ||
| const logger::LoggerManagerTreePtr & | ordering_log_manager, | ||
| std::shared_ptr< iroha::network::GenericClientFactory > | client_factory | ||
| ) |
Creates notification factory for individual connections to peers with gRPC backend.
