iroha::consensus::yac::NetworkImpl Class Reference

#include "network_impl.hpp"

Inheritance diagram for iroha::consensus::yac::NetworkImpl:

Collaboration diagram for iroha::consensus::yac::NetworkImpl:

Public Types
using	Service = proto::Yac
using	ClientFactory = iroha::network::ClientFactory< Service >

Public Member Functions
	NetworkImpl (std::shared_ptr< network::AsyncGrpcClient< google::protobuf::Empty >> async_call, std::unique_ptr< iroha::network::ClientFactory< ::iroha::consensus::yac::proto::Yac >> client_factory, logger::LoggerPtr log)
void	subscribe (std::shared_ptr< YacNetworkNotifications > handler) override
void	sendState (const shared_model::interface::Peer &to, const std::vector< VoteMessage > &state) override
grpc::Status	SendState (::grpc::ServerContext *context, const ::iroha::consensus::yac::proto::State *request, ::google::protobuf::Empty *response) override
void	stop () override
	Prevent any new outgoing network activity. Be passive. More...
Public Member Functions inherited from iroha::consensus::yac::YacNetwork
virtual	~YacNetwork ()=default

Detailed Description

Class which provides implementation of transport for consensus based on grpc

Member Typedef Documentation

ClientFactory

using iroha::consensus::yac::NetworkImpl::ClientFactory = iroha::network::ClientFactory<Service>

Service

using iroha::consensus::yac::NetworkImpl::Service = proto::Yac

Constructor & Destructor Documentation

NetworkImpl()

iroha::consensus::yac::NetworkImpl::NetworkImpl ( std::shared_ptr< network::AsyncGrpcClient< google::protobuf::Empty >>  async_call, std::unique_ptr< iroha::network::ClientFactory< ::iroha::consensus::yac::proto::Yac >>  client_factory, logger::LoggerPtr  log  )

explicit

Member Function Documentation

sendState()

void iroha::consensus::yac::NetworkImpl::sendState ( const shared_model::interface::Peer &  to, const std::vector< VoteMessage > &  state  )

overridevirtual

Directly share collection of votes

Parameters

to	- peer recipient
state	- message for sending

Implements iroha::consensus::yac::YacNetwork.

Here is the call graph for this function:

SendState()

grpc::Status iroha::consensus::yac::NetworkImpl::SendState ( ::grpc::ServerContext *  context, const ::iroha::consensus::yac::proto::State *  request, ::google::protobuf::Empty *  response  )

override

Receive votes from another peer; Naming is confusing, because this is rpc call that perform on another machine;

Here is the call graph for this function:

stop()

void iroha::consensus::yac::NetworkImpl::stop ( )

overridevirtual

Prevent any new outgoing network activity. Be passive.

Implements iroha::consensus::yac::YacNetwork.

subscribe()

void iroha::consensus::yac::NetworkImpl::subscribe ( std::shared_ptr< YacNetworkNotifications >  handler )

overridevirtual

Implements iroha::consensus::yac::YacNetwork.

---

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

• irohad/consensus/yac/transport/impl/network_impl.hpp
• irohad/consensus/yac/transport/impl/network_impl.cpp