Line data    Source code

       1             : /**
       2             :  * Copyright Soramitsu Co., Ltd. All Rights Reserved.
       3             :  * SPDX-License-Identifier: Apache-2.0
       4             :  */
       5             : 
       6             : #include "multi_sig_transactions/mst_processor.hpp"
       7             : 
       8             : namespace iroha {
       9             : 
      10             :   MstProcessor::MstProcessor(logger::LoggerPtr log)
      11         263 :       : log_(std::move(log)) {}
      12             : 
      13             :   void MstProcessor::propagateBatch(const DataType &batch) {
      14          25 :     this->propagateBatchImpl(batch);
      15          25 :   }
      16             : 
      17             :   rxcpp::observable<std::shared_ptr<MstState>> MstProcessor::onStateUpdate()
      18             :       const {
      19         508 :     return this->onStateUpdateImpl();
      20           0 :   }
      21             : 
      22             :   rxcpp::observable<DataType> MstProcessor::onPreparedBatches() const {
      23         508 :     return this->onPreparedBatchesImpl();
      24           0 :   }
      25             : 
      26             :   rxcpp::observable<DataType> MstProcessor::onExpiredBatches() const {
      27         508 :     return this->onExpiredBatchesImpl();
      28           0 :   }
      29             : 
      30             :   bool MstProcessor::batchInStorage(const DataType &batch) const {
      31         738 :     return this->batchInStorageImpl(batch);
      32             :   }
      33             : 
      34             : }  // namespace iroha