hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
on_demand_ordering_service_impl.cpp File Reference
#include "ordering/impl/on_demand_ordering_service_impl.hpp"
#include <unordered_set>
#include <boost/optional.hpp>
#include <boost/range/adaptor/filtered.hpp>
#include <boost/range/adaptor/indirected.hpp>
#include <boost/range/adaptor/transformed.hpp>
#include <boost/range/algorithm/for_each.hpp>
#include <boost/range/size.hpp>
#include "ametsuchi/tx_presence_cache.hpp"
#include "ametsuchi/tx_presence_cache_utils.hpp"
#include "common/visitor.hpp"
#include "datetime/time.hpp"
#include "interfaces/iroha_internal/proposal.hpp"
#include "interfaces/iroha_internal/transaction_batch.hpp"
#include "interfaces/transaction.hpp"
#include "logger/logger.hpp"
Include dependency graph for on_demand_ordering_service_impl.cpp:

Typedefs

using TransactionBatchType = transport::OdOsNotification::TransactionBatchType
 

Functions

static std::vector< std::shared_ptr< shared_model::interface::Transaction > > getTransactions (size_t requested_tx_amount, detail::BatchSetType &batch_collection, boost::optional< size_t &> discarded_txs_amount)
 

Typedef Documentation

◆ TransactionBatchType

Function Documentation

◆ getTransactions()

static std::vector<std::shared_ptr<shared_model::interface::Transaction> > getTransactions ( size_t  requested_tx_amount,
detail::BatchSetType batch_collection,
boost::optional< size_t &>  discarded_txs_amount 
)
static

Get transactions from the given batches queue. Does not break batches - continues getting all the transactions from the ongoing batch until the required amount is collected.

Parameters
requested_tx_amount- amount of transactions to get
batch_collection- the collection to get transactions from
discarded_txs_amount- the amount of discarded txs
Returns
transactions
Here is the call graph for this function:
Here is the caller graph for this function: