hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
iroha::network::PeerCommunicationServiceImpl Class Reference

#include "peer_communication_service_impl.hpp"

Inheritance diagram for iroha::network::PeerCommunicationServiceImpl:
Inheritance graph
Collaboration diagram for iroha::network::PeerCommunicationServiceImpl:
Collaboration graph

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< OrderingEventonProposal () const override
 
rxcpp::observable< simulator::VerifiedProposalCreatorEventonVerifiedProposal () const override
 
rxcpp::observable< synchronizer::SynchronizationEventonSynchronization () const override
 
- Public Member Functions inherited from iroha::network::PeerCommunicationService
virtual ~PeerCommunicationService ()=default
 

Constructor & Destructor Documentation

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

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.

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.

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.

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: