#include "on_demand_connection_manager.hpp"

Inheritance diagram for iroha::ordering::OnDemandConnectionManager:

Collaboration diagram for iroha::ordering::OnDemandConnectionManager:

Classes
struct	CurrentPeers

Public Types
enum	PeerType { kRejectRejectConsumer = 0, kRejectCommitConsumer, kCommitRejectConsumer, kCommitCommitConsumer, kIssuer, kCount }

template<typename T >
using	PeerCollectionType = std::array< T, kCount >
	Collection with value types which represent peers. More...

Public Types inherited from iroha::ordering::transport::OdOsNotification
using	ProposalType = shared_model::interface::Proposal

using	TransactionBatchType = std::shared_ptr< shared_model::interface::TransactionBatch >

using	CollectionType = std::vector< TransactionBatchType >

Public Member Functions
	OnDemandConnectionManager (std::shared_ptr< transport::OdOsNotificationFactory > factory, rxcpp::observable< CurrentPeers > peers, logger::LoggerPtr log)

	OnDemandConnectionManager (std::shared_ptr< transport::OdOsNotificationFactory > factory, rxcpp::observable< CurrentPeers > peers, CurrentPeers initial_peers, logger::LoggerPtr log)

	~OnDemandConnectionManager () override

void	onBatches (CollectionType batches) override

boost::optional< std::shared_ptr< const ProposalType > >	onRequestProposal (consensus::Round round) override

Public Member Functions inherited from iroha::ordering::transport::OdOsNotification
virtual	~OdOsNotification ()=default

Detailed Description

Proxy class which redirects requests to appropriate peers

Member Typedef Documentation

◆ PeerCollectionType

template<typename T >

using iroha::ordering::OnDemandConnectionManager::PeerCollectionType = std::array<T, kCount>

Collection with value types which represent peers.

Member Enumeration Documentation

◆ PeerType

enum iroha::ordering::OnDemandConnectionManager::PeerType

Responsibilities of individual peers from the peers array Transactions are sent to three ordering services: reject round for current block, reject round for next block, and commit for subsequent next round Proposal is requested from the current ordering service: issuer

Enumerator
kRejectRejectConsumer
kRejectCommitConsumer
kCommitRejectConsumer
kCommitCommitConsumer
kIssuer
kCount

Constructor & Destructor Documentation

◆ OnDemandConnectionManager() [1/2]

OnDemandConnectionManager::OnDemandConnectionManager	(	std::shared_ptr< transport::OdOsNotificationFactory >	factory,
		rxcpp::observable< CurrentPeers >	peers,
		logger::LoggerPtr	log
	)

◆ OnDemandConnectionManager() [2/2]

OnDemandConnectionManager::OnDemandConnectionManager	(	std::shared_ptr< transport::OdOsNotificationFactory >	factory,
		rxcpp::observable< CurrentPeers >	peers,
		CurrentPeers	initial_peers,
		logger::LoggerPtr	log
	)

◆ ~OnDemandConnectionManager()

OnDemandConnectionManager::~OnDemandConnectionManager ( )

override

Member Function Documentation

◆ onBatches()

void OnDemandConnectionManager::onBatches ( CollectionType batches )

overridevirtual

Callback on receiving transactions

Parameters

batches - vector of passed transaction batches

Implements iroha::ordering::transport::OdOsNotification.

◆ onRequestProposal()

boost::optional< std::shared_ptr< const OnDemandConnectionManager::ProposalType > > OnDemandConnectionManager::onRequestProposal ( consensus::Round round )