#include "on_demand_ordering_gate.hpp"


Public Member Functions | |
| OnDemandOrderingGate (std::shared_ptr< OnDemandOrderingService > ordering_service, std::shared_ptr< transport::OdOsNotification > network_client, std::shared_ptr< shared_model::interface::UnsafeProposalFactory > factory, std::shared_ptr< ametsuchi::TxPresenceCache > tx_cache, size_t transaction_limit, logger::LoggerPtr log) | |
| ~OnDemandOrderingGate () override | |
| void | propagateBatch (std::shared_ptr< shared_model::interface::TransactionBatch > batch) override |
| void | processRoundSwitch (RoundSwitch const &event) |
| std::optional< network::OrderingEvent > | processProposalRequest (ProposalEvent const &event) const |
| void | stop () override |
| Prevent any new outgoing network activity. Be passive. More... | |
Public Member Functions inherited from iroha::network::OrderingGate | |
| virtual | ~OrderingGate ()=default |
Ordering gate which requests proposals from the ordering service votes for proposals, and passes committed proposals to the pipeline
| OnDemandOrderingGate::OnDemandOrderingGate | ( | std::shared_ptr< OnDemandOrderingService > | ordering_service, |
| std::shared_ptr< transport::OdOsNotification > | network_client, | ||
| std::shared_ptr< shared_model::interface::UnsafeProposalFactory > | factory, | ||
| std::shared_ptr< ametsuchi::TxPresenceCache > | tx_cache, | ||
| size_t | transaction_limit, | ||
| logger::LoggerPtr | log | ||
| ) |
|
override |

| std::optional< iroha::network::OrderingEvent > OnDemandOrderingGate::processProposalRequest | ( | ProposalEvent const & | event | ) | const |
Handle an incoming proposal from ordering service

| void OnDemandOrderingGate::processRoundSwitch | ( | RoundSwitch const & | event | ) |
|
overridevirtual |
Propagate a transaction batch for further processing
| batch |
Implements iroha::network::OrderingGate.
|
overridevirtual |
Prevent any new outgoing network activity. Be passive.
Implements iroha::network::OrderingGate.
