#include "storage_impl.hpp"

Inheritance diagram for iroha::ametsuchi::StorageImpl:

Collaboration diagram for iroha::ametsuchi::StorageImpl:

Public Member Functions
expected::Result< std::unique_ptr< CommandExecutor >, std::string >	createCommandExecutor () override

std::unique_ptr< TemporaryWsv >	createTemporaryWsv (std::shared_ptr< CommandExecutor > command_executor) override

std::unique_ptr< MutableStorage >	createMutableStorage (std::shared_ptr< CommandExecutor > command_executor) override

boost::optional< std::shared_ptr< PeerQuery > >	createPeerQuery () const override

boost::optional< std::shared_ptr< BlockQuery > >	createBlockQuery () const override

boost::optional< std::unique_ptr< SettingQuery > >	createSettingQuery () const override

iroha::expected::Result< std::unique_ptr< QueryExecutor >, std::string >	createQueryExecutor (std::shared_ptr< PendingTransactionStorage > pending_txs_storage, std::shared_ptr< shared_model::interface::QueryResponseFactory > response_factory) const override

bool	insertBlock (std::shared_ptr< const shared_model::interface::Block > block) override

expected::Result< void, std::string >	insertPeer (const shared_model::interface::Peer &peer) override

std::unique_ptr< MutableStorage >	createMutableStorage (std::shared_ptr< CommandExecutor > command_executor, BlockStorageFactory &storage_factory) override

void	resetPeers () override

expected::Result< void, std::string >	dropBlockStorage () override

boost::optional< std::shared_ptr< const iroha::LedgerState > >	getLedgerState () const override

void	freeConnections () override

CommitResult	commit (std::unique_ptr< MutableStorage > mutable_storage) override

bool	preparedCommitEnabled () const override
	Check if prepared commits are enabled. More...

CommitResult	commitPrepared (std::shared_ptr< const shared_model::interface::Block > block) override

std::shared_ptr< WsvQuery >	getWsvQuery () const override

std::shared_ptr< BlockQuery >	getBlockQuery () const override

rxcpp::observable< std::shared_ptr< const shared_model::interface::Block > >	on_commit () override

void	prepareBlock (std::unique_ptr< TemporaryWsv > wsv) override

	~StorageImpl () override

Public Member Functions inherited from iroha::ametsuchi::Storage
virtual	~Storage ()=default

Public Member Functions inherited from iroha::ametsuchi::TemporaryFactory
virtual	~TemporaryFactory ()=default

Public Member Functions inherited from iroha::ametsuchi::MutableFactory
virtual	~MutableFactory ()=default

Public Member Functions inherited from iroha::ametsuchi::PeerQueryFactory
virtual	~PeerQueryFactory ()=default

Public Member Functions inherited from iroha::ametsuchi::BlockQueryFactory
virtual	~BlockQueryFactory ()=default

Public Member Functions inherited from iroha::ametsuchi::QueryExecutorFactory
virtual	~QueryExecutorFactory ()=default

Public Member Functions inherited from iroha::ametsuchi::SettingQueryFactory
virtual	~SettingQueryFactory ()=default

Static Public Member Functions
static expected::Result< std::shared_ptr< StorageImpl >, std::string >	create (const PostgresOptions &postgres_options, std::shared_ptr< PoolWrapper > pool_wrapper, std::shared_ptr< shared_model::interface::PermissionToString > perm_converter, std::shared_ptr< PendingTransactionStorage > pending_txs_storage, std::shared_ptr< shared_model::interface::QueryResponseFactory > query_response_factory, std::unique_ptr< BlockStorageFactory > temporary_block_storage_factory, std::shared_ptr< BlockStorage > persistent_block_storage, std::optional< std::reference_wrapper< const VmCaller >> vm_caller_ref, logger::LoggerManagerTreePtr log_manager, size_t pool_size=10)

Protected Member Functions
	StorageImpl (boost::optional< std::shared_ptr< const iroha::LedgerState >> ledger_state, const PostgresOptions &postgres_options, std::shared_ptr< BlockStorage > block_store, std::shared_ptr< PoolWrapper > pool_wrapper, std::shared_ptr< shared_model::interface::PermissionToString > perm_converter, std::shared_ptr< PendingTransactionStorage > pending_txs_storage, std::shared_ptr< shared_model::interface::QueryResponseFactory > query_response_factory, std::unique_ptr< BlockStorageFactory > temporary_block_storage_factory, size_t pool_size, std::optional< std::reference_wrapper< const VmCaller >> vm_caller, logger::LoggerManagerTreePtr log_manager)

Friends
class	::iroha::ametsuchi::AmetsuchiTest

Constructor & Destructor Documentation

◆ ~StorageImpl()

iroha::ametsuchi::StorageImpl::~StorageImpl ( )

override

Here is the call graph for this function:

◆ StorageImpl()

iroha::ametsuchi::StorageImpl::StorageImpl	(	boost::optional< std::shared_ptr< const iroha::LedgerState >>	ledger_state,
		const PostgresOptions &	postgres_options,
		std::shared_ptr< BlockStorage >	block_store,
		std::shared_ptr< PoolWrapper >	pool_wrapper,
		std::shared_ptr< shared_model::interface::PermissionToString >	perm_converter,
		std::shared_ptr< PendingTransactionStorage >	pending_txs_storage,
		std::shared_ptr< shared_model::interface::QueryResponseFactory >	query_response_factory,
		std::unique_ptr< BlockStorageFactory >	temporary_block_storage_factory,
		size_t	pool_size,
		std::optional< std::reference_wrapper< const VmCaller >>	vm_caller,
		logger::LoggerManagerTreePtr	log_manager
	)

protected

Here is the caller graph for this function:

Member Function Documentation

◆ commit()

CommitResult iroha::ametsuchi::StorageImpl::commit ( std::unique_ptr< MutableStorage > mutableStorage )

overridevirtual

Commit mutable storage to Ametsuchi. This transforms Ametsuchi to the new state consistent with MutableStorage.

Parameters

mutableStorage

Returns: the status of commit

Implements iroha::ametsuchi::MutableFactory.

Here is the caller graph for this function:

◆ commitPrepared()

CommitResult iroha::ametsuchi::StorageImpl::commitPrepared ( std::shared_ptr< const shared_model::interface::Block > block )

overridevirtual

Try to apply prepared block to Ametsuchi.

Parameters

block The previously prepared block that will be committed now.

Returns: Result of committing the prepared block.

Implements iroha::ametsuchi::MutableFactory.

Here is the call graph for this function:

◆ create()

expected::Result< std::shared_ptr< StorageImpl >, std::string > iroha::ametsuchi::StorageImpl::create	(	const PostgresOptions &	postgres_options,
		std::shared_ptr< PoolWrapper >	pool_wrapper,
		std::shared_ptr< shared_model::interface::PermissionToString >	perm_converter,
		std::shared_ptr< PendingTransactionStorage >	pending_txs_storage,
		std::shared_ptr< shared_model::interface::QueryResponseFactory >	query_response_factory,
		std::unique_ptr< BlockStorageFactory >	temporary_block_storage_factory,
		std::shared_ptr< BlockStorage >	persistent_block_storage,
		std::optional< std::reference_wrapper< const VmCaller >>	vm_caller_ref,
		logger::LoggerManagerTreePtr	log_manager,
		size_t	pool_size = `10`
	)

static

Here is the call graph for this function:

◆ createBlockQuery()

boost::optional< std::shared_ptr< BlockQuery > > iroha::ametsuchi::StorageImpl::createBlockQuery ( ) const

overridevirtual

Creates a block query from the current state.

Returns: Created block query

Implements iroha::ametsuchi::BlockQueryFactory.

Here is the call graph for this function:

◆ createCommandExecutor()

expected::Result< std::unique_ptr< CommandExecutor >, std::string > iroha::ametsuchi::StorageImpl::createCommandExecutor ( )

overridevirtual

Create new command executor that holds a database session within.

Returns: The command executor or string error message.

Implements iroha::ametsuchi::Storage.

Here is the caller graph for this function:

◆ createMutableStorage() [1/2]

std::unique_ptr< MutableStorage > iroha::ametsuchi::StorageImpl::createMutableStorage ( std::shared_ptr< CommandExecutor > command_executor )

overridevirtual

Creates a mutable storage from the current state. Mutable storage is the only way to commit the block to the ledger.

Returns: Created mutable storage

Implements iroha::ametsuchi::MutableFactory.

Here is the caller graph for this function:

◆ createMutableStorage() [2/2]

std::unique_ptr< MutableStorage > iroha::ametsuchi::StorageImpl::createMutableStorage	(	std::shared_ptr< CommandExecutor >	command_executor,
		BlockStorageFactory &	storage_factory
	)

overridevirtual

Creates a mutable storage from the current state

Returns: Created mutable storage.

Implements iroha::ametsuchi::Storage.

Here is the call graph for this function:

◆ createPeerQuery()

boost::optional< std::shared_ptr< PeerQuery > > iroha::ametsuchi::StorageImpl::createPeerQuery ( ) const

overridevirtual

Creates a peer query from the current state.

Returns: Created peer query

Implements iroha::ametsuchi::PeerQueryFactory.

Here is the call graph for this function:

◆ createQueryExecutor()

iroha::expected::Result< std::unique_ptr< QueryExecutor >, std::string > iroha::ametsuchi::StorageImpl::createQueryExecutor	(	std::shared_ptr< PendingTransactionStorage >	pending_txs_storage,
		std::shared_ptr< shared_model::interface::QueryResponseFactory >	response_factory
	)		const

overridevirtual

Creates a query executor from the current state

Implements iroha::ametsuchi::QueryExecutorFactory.

◆ createSettingQuery()

boost::optional< std::unique_ptr< SettingQuery > > iroha::ametsuchi::StorageImpl::createSettingQuery ( ) const

overridevirtual

Creates a setting query

Returns: Created setting query

Implements iroha::ametsuchi::SettingQueryFactory.

◆ createTemporaryWsv()

std::unique_ptr< TemporaryWsv > iroha::ametsuchi::StorageImpl::createTemporaryWsv ( std::shared_ptr< CommandExecutor > command_executor )

overridevirtual

Creates a temporary world state view from the current state. Temporary state will be not committed and will be erased on destructor call. Temporary state might be used for transaction validation.