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

using TransactionBatchType = transport::OdOsNotification::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: