#include "transaction_processor_impl.hpp"


Public Member Functions | |
| TransactionProcessorImpl (std::shared_ptr< network::PeerCommunicationService > pcs, std::shared_ptr< MstProcessor > mst_processor, std::shared_ptr< iroha::torii::StatusBus > status_bus, std::shared_ptr< shared_model::interface::TxStatusFactory > status_factory, rxcpp::observable< std::shared_ptr< const shared_model::interface::Block >> commits, logger::LoggerPtr log) | |
| void | batchHandle (std::shared_ptr< shared_model::interface::TransactionBatch > transaction_batch) const override |
Public Member Functions inherited from iroha::torii::TransactionProcessor | |
| virtual | ~TransactionProcessor ()=default |
| iroha::torii::TransactionProcessorImpl::TransactionProcessorImpl | ( | std::shared_ptr< network::PeerCommunicationService > | pcs, |
| std::shared_ptr< MstProcessor > | mst_processor, | ||
| std::shared_ptr< iroha::torii::StatusBus > | status_bus, | ||
| std::shared_ptr< shared_model::interface::TxStatusFactory > | status_factory, | ||
| rxcpp::observable< std::shared_ptr< const shared_model::interface::Block >> | commits, | ||
| logger::LoggerPtr | log | ||
| ) |
| pcs | - provide information proposals and commits |
| mst_processor | is a handler for multisignature transactions |
| status_bus | is a common notifier for tx statuses |
| status_factory | creates transaction statuses |
| commits | - an observable on committed blocks |
| log | to print the progress |

|
overridevirtual |
Process batch and propagate it to the MST or PCS
| transaction_batch | - transaction batch for processing |
Implements iroha::torii::TransactionProcessor.
