iroha::network::PeerCommunicationServiceImpl Class Reference

#include "peer_communication_service_impl.hpp"

Inheritance diagram for iroha::network::PeerCommunicationServiceImpl:

Collaboration diagram for iroha::network::PeerCommunicationServiceImpl:

Public Member Functions
	PeerCommunicationServiceImpl (std::shared_ptr< OrderingGate > ordering_gate, std::shared_ptr< synchronizer::Synchronizer > synchronizer, std::shared_ptr< simulator::VerifiedProposalCreator > proposal_creator, logger::LoggerPtr log)
void	propagate_batch (std::shared_ptr< shared_model::interface::TransactionBatch > batch) const override
rxcpp::observable< OrderingEvent >	onProposal () const override
rxcpp::observable< simulator::VerifiedProposalCreatorEvent >	onVerifiedProposal () const override
rxcpp::observable< synchronizer::SynchronizationEvent >	onSynchronization () const override
Public Member Functions inherited from iroha::network::PeerCommunicationService
virtual	~PeerCommunicationService ()=default

Constructor & Destructor Documentation

PeerCommunicationServiceImpl()

iroha::network::PeerCommunicationServiceImpl::PeerCommunicationServiceImpl	(	std::shared_ptr< OrderingGate >	ordering_gate,
		std::shared_ptr< synchronizer::Synchronizer >	synchronizer,
		std::shared_ptr< simulator::VerifiedProposalCreator >	proposal_creator,
		logger::LoggerPtr	log
	)

Member Function Documentation

onProposal()

rxcpp::observable< OrderingEvent > iroha::network::PeerCommunicationServiceImpl::onProposal ( ) const

overridevirtual

Event is triggered when proposal arrives from network.

Returns

observable with Proposals. (List of Proposals)

Implements iroha::network::PeerCommunicationService.

onSynchronization()

rxcpp::observable< synchronizer::SynchronizationEvent > iroha::network::PeerCommunicationServiceImpl::onSynchronization ( ) const

overridevirtual

Event is triggered when commit block arrives.

Returns

observable with sequence of committed blocks. In common case observable<Block> will contain one element. But there are scenarios when consensus provide many blocks, e.g. on peer startup - peer will get all actual blocks. Also, it can provide no blocks at all, if commit was empty

Implements iroha::network::PeerCommunicationService.

onVerifiedProposal()

rxcpp::observable< simulator::VerifiedProposalCreatorEvent > iroha::network::PeerCommunicationServiceImpl::onVerifiedProposal ( ) const

overridevirtual

Event is triggered when verified proposal arrives

Returns

verified proposal and list of stateful validation errors

Implements iroha::network::PeerCommunicationService.

propagate_batch()

void iroha::network::PeerCommunicationServiceImpl::propagate_batch ( std::shared_ptr< shared_model::interface::TransactionBatch >  batch ) const

overridevirtual

Propagate batch to the network

Parameters

batch

- batch for propagation

Implements iroha::network::PeerCommunicationService.

---

The documentation for this class was generated from the following files:

• irohad/network/impl/peer_communication_service_impl.hpp
• irohad/network/impl/peer_communication_service_impl.cpp