#include "storage_impl.hpp"

Inheritance diagram for iroha::ametsuchi::StorageImpl:

Collaboration diagram for iroha::ametsuchi::StorageImpl:

Public Member Functions
expected::Result< std::unique_ptr< TemporaryWsv >, std::string >	createTemporaryWsv () override

expected::Result< std::unique_ptr< MutableStorage >, std::string >	createMutableStorage () override

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

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

boost::optional< std::shared_ptr< QueryExecutor > >	createQueryExecutor (std::shared_ptr< PendingTransactionStorage > pending_txs_storage, std::shared_ptr< shared_model::interface::QueryResponseFactory > response_factory) const override

bool	insertBlock (const shared_model::interface::Block &block) override

bool	insertBlocks (const std::vector< std::shared_ptr< shared_model::interface::Block >> &blocks) override

void	reset () override

void	dropStorage () override

void	freeConnections () override

boost::optional< std::unique_ptr< LedgerState > >	commit (std::unique_ptr< MutableStorage > mutableStorage) override

boost::optional< std::unique_ptr< LedgerState > >	commitPrepared (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< 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

Static Public Member Functions
static expected::Result< std::shared_ptr< StorageImpl >, std::string >	create (std::string block_store_dir, std::string postgres_connection, std::shared_ptr< shared_model::interface::CommonObjectsFactory > factory, std::shared_ptr< shared_model::interface::BlockJsonConverter > converter, std::shared_ptr< shared_model::interface::PermissionToString > perm_converter, size_t pool_size=10)

Protected Member Functions
	StorageImpl (std::string block_store_dir, PostgresOptions postgres_options, std::unique_ptr< KeyValueStorage > block_store, std::shared_ptr< soci::connection_pool > connection, std::shared_ptr< shared_model::interface::CommonObjectsFactory > factory, std::shared_ptr< shared_model::interface::BlockJsonConverter > converter, std::shared_ptr< shared_model::interface::PermissionToString > perm_converter, size_t pool_size, bool enable_prepared_blocks, logger::Logger log=logger::log("StorageImpl"))

Static Protected Member Functions
static expected::Result< bool, std::string >	createDatabaseIfNotExist (const std::string &dbname, const std::string &options_str_without_dbname)

static expected::Result< ConnectionContext, std::string >	initConnections (std::string block_store_dir)

static expected::Result< std::shared_ptr< soci::connection_pool >, std::string >	initPostgresConnection (std::string &options_str, size_t pool_size)

Protected Attributes
const std::string	block_store_dir_

const PostgresOptions	postgres_options_

Static Protected Attributes
static const std::string &	drop_

static const std::string &	reset_

static const std::string &	init_

Constructor & Destructor Documentation

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

override

Here is the call graph for this function:

iroha::ametsuchi::StorageImpl::StorageImpl	(	std::string	block_store_dir,
		PostgresOptions	postgres_options,
		std::unique_ptr< KeyValueStorage >	block_store,
		std::shared_ptr< soci::connection_pool >	connection,
		std::shared_ptr< shared_model::interface::CommonObjectsFactory >	factory,
		std::shared_ptr< shared_model::interface::BlockJsonConverter >	converter,
		std::shared_ptr< shared_model::interface::PermissionToString >	perm_converter,
		size_t	pool_size,
		bool	enable_prepared_blocks,
		logger::Logger	log = `logger::log("StorageImpl")`
	)

protected

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

boost::optional< std::unique_ptr< LedgerState > > 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: new state of the ledger, boost::none if commit failed

Implements iroha::ametsuchi::MutableFactory.

Here is the call graph for this function:

Here is the caller graph for this function:

boost::optional< std::unique_ptr< LedgerState > > iroha::ametsuchi::StorageImpl::commitPrepared ( const shared_model::interface::Block & block )

overridevirtual

Try to apply prepared block to Ametsuchi.

Returns: state of the ledger if commit is succesful, boost::none if prepared block failed to apply. WSV is not changed in this case.

Implements iroha::ametsuchi::MutableFactory.

Here is the call graph for this function:

expected::Result< std::shared_ptr< StorageImpl >, std::string > iroha::ametsuchi::StorageImpl::create	(	std::string	block_store_dir,
		std::string	postgres_connection,
		std::shared_ptr< shared_model::interface::CommonObjectsFactory >	factory,
		std::shared_ptr< shared_model::interface::BlockJsonConverter >	converter,
		std::shared_ptr< shared_model::interface::PermissionToString >	perm_converter,
		size_t	pool_size = `10`
	)

static

Here is the call graph for this function:

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:

expected::Result< bool, std::string > iroha::ametsuchi::StorageImpl::createDatabaseIfNotExist	(	const std::string &	dbname,
		const std::string &	options_str_without_dbname
	)

staticprotected

Here is the call graph for this function:

Here is the caller graph for this function:

expected::Result< std::unique_ptr< MutableStorage >, std::string > iroha::ametsuchi::StorageImpl::createMutableStorage ( )

overridevirtual

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

Returns: Created Result with mutable storage or error string

Implements iroha::ametsuchi::MutableFactory.

Here is the call graph for this function:

Here is the caller graph for this function:

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:

boost::optional< std::shared_ptr< QueryExecutor > > 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.

expected::Result< std::unique_ptr< TemporaryWsv >, std::string > iroha::ametsuchi::StorageImpl::createTemporaryWsv ( )

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.

Returns: Created Result with temporary wsv or string error

Implements iroha::ametsuchi::TemporaryFactory.

Here is the call graph for this function:

void iroha::ametsuchi::StorageImpl::dropStorage ( )

overridevirtual

Remove all information from ledger Tables and the database will be removed too

Implements iroha::ametsuchi::Storage.

Here is the call graph for this function:

void iroha::ametsuchi::StorageImpl::freeConnections ( )

overridevirtual

Implements iroha::ametsuchi::Storage.

Here is the caller graph for this function:

std::shared_ptr< BlockQuery > iroha::ametsuchi::StorageImpl::getBlockQuery ( ) const

overridevirtual

Implements iroha::ametsuchi::Storage.

Here is the caller graph for this function:

std::shared_ptr< WsvQuery > iroha::ametsuchi::StorageImpl::getWsvQuery ( ) const

overridevirtual

Implements iroha::ametsuchi::Storage.

Here is the caller graph for this function:

expected::Result< ConnectionContext, std::string > iroha::ametsuchi::StorageImpl::initConnections ( std::string block_store_dir )

staticprotected

Here is the call graph for this function:

Here is the caller graph for this function:

expected::Result< std::shared_ptr< soci::connection_pool >, std::string > iroha::ametsuchi::StorageImpl::initPostgresConnection	(	std::string &	options_str,
		size_t	pool_size
	)

staticprotected

Here is the call graph for this function:

Here is the caller graph for this function:

bool iroha::ametsuchi::StorageImpl::insertBlock ( const shared_model::interface::Block & block )

overridevirtual

Insert block without validation

Parameters

blocks - block for insertion

Returns: true if all blocks are inserted

Implements iroha::ametsuchi::Storage.

Here is the call graph for this function:

bool iroha::ametsuchi::StorageImpl::insertBlocks ( const std::vector< std::shared_ptr< shared_model::interface::Block >> & blocks )

overridevirtual

Insert blocks without validation

Parameters

blocks - collection of blocks for insertion

Returns: true if inserted

Implements iroha::ametsuchi::Storage.

Here is the call graph for this function:

rxcpp::observable< std::shared_ptr< shared_model::interface::Block > > iroha::ametsuchi::StorageImpl::on_commit ( )

overridevirtual

method called when block is written to the storage

Returns: observable with the Block committed

Implements iroha::ametsuchi::Storage.

void iroha::ametsuchi::StorageImpl::prepareBlock ( std::unique_ptr< TemporaryWsv > wsv )

overridevirtual

Prepare state which was accumulated in temporary WSV. After preparation, this state is not visible until commited.

Parameters

wsv	- state which will be prepared.

Implements iroha::ametsuchi::TemporaryFactory.

Here is the call graph for this function:

void iroha::ametsuchi::StorageImpl::reset ( )

overridevirtual

Remove all records from the tables and remove all the blocks

Implements iroha::ametsuchi::Storage.

Here is the call graph for this function:

Member Data Documentation

const std::string iroha::ametsuchi::StorageImpl::block_store_dir_

protected

Folder with raw blocks

const std::string & iroha::ametsuchi::StorageImpl::drop_

staticprotected

Initial value:

= R"(
DROP TABLE IF EXISTS account_has_signatory;
DROP TABLE IF EXISTS account_has_asset;
DROP TABLE IF EXISTS role_has_permissions CASCADE;
DROP TABLE IF EXISTS account_has_roles;
DROP TABLE IF EXISTS account_has_grantable_permissions CASCADE;
DROP TABLE IF EXISTS account;
DROP TABLE IF EXISTS asset;
DROP TABLE IF EXISTS domain;
DROP TABLE IF EXISTS signatory;
DROP TABLE IF EXISTS peer;
DROP TABLE IF EXISTS role;
DROP TABLE IF EXISTS height_by_hash;
DROP TABLE IF EXISTS tx_status_by_hash;
DROP TABLE IF EXISTS height_by_account_set;
DROP TABLE IF EXISTS index_by_creator_height;
DROP TABLE IF EXISTS position_by_account_asset;
)"

const std::string & iroha::ametsuchi::StorageImpl::init_

staticprotected

const PostgresOptions iroha::ametsuchi::StorageImpl::postgres_options_

protected

const std::string & iroha::ametsuchi::StorageImpl::reset_

staticprotected

Initial value:

= R"(
DELETE FROM account_has_signatory;
DELETE FROM account_has_asset;
DELETE FROM role_has_permissions CASCADE;
DELETE FROM account_has_roles;
DELETE FROM account_has_grantable_permissions CASCADE;
DELETE FROM account;
DELETE FROM asset;
DELETE FROM domain;
DELETE FROM signatory;
DELETE FROM peer;
DELETE FROM role;
DELETE FROM position_by_hash;
DELETE FROM tx_status_by_hash;
DELETE FROM height_by_account_set;
DELETE FROM index_by_creator_height;
DELETE FROM position_by_account_asset;
)"

The documentation for this class was generated from the following files:

irohad/ametsuchi/impl/storage_impl.hpp
irohad/ametsuchi/impl/storage_impl.cpp

Public Member Functions

Static Public Member Functions

Protected Member Functions

Static Protected Member Functions

Protected Attributes

Static Protected Attributes

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation