#include <store.h>

Inherits ccf::kv::AbstractStore, ccf::kv::StoreState, ccf::kv::ExecutionWrapperStore, and ccf::kv::ReadOnlyStore.

Public Member Functions
	Store (bool strict_versions_=true, bool is_historical_=false)

	Store (const Store &that)=delete

std::shared_ptr< Consensus >	get_consensus () override

void	set_consensus (const std::shared_ptr< Consensus > &consensus_)

std::shared_ptr< TxHistory >	get_history () override

void	set_history (const std::shared_ptr< TxHistory > &history_)

std::shared_ptr< ILedgerChunker >	get_chunker () override

void	set_chunker (const std::shared_ptr< ILedgerChunker > &chunker_)

void	set_encryptor (const EncryptorPtr &encryptor_)

EncryptorPtr	get_encryptor () override

void	set_snapshotter (const SnapshotterPtr &snapshotter_)

std::shared_ptr< AbstractMap >	get_map (ccf::kv::Version v, const std::string &map_name) override

std::shared_ptr< AbstractMap >	get_map_unsafe (ccf::kv::Version v, const std::string &map_name) override

std::shared_ptr< ccf::kv::untyped::Map >	get_map_internal (ccf::kv::Version v, const std::string &map_name)

void	add_dynamic_map (ccf::kv::Version v, const std::shared_ptr< AbstractMap > &map_) override

std::unique_ptr< AbstractSnapshot >	snapshot_unsafe_maps (Version v) override

void	lock_maps () override

void	unlock_maps () override

std::vector< uint8_t >	serialise_snapshot (std::unique_ptr< AbstractSnapshot > snapshot) override

ApplyResult	deserialise_snapshot (const uint8_t data, size_t size, ccf::kv::ConsensusHookPtrs &hooks, std::vector< Version > view_history=nullptr, bool public_only=false) override

void	compact (Version v) override

void	rollback (const TxID &tx_id, Term term_of_next_version_) override

void	initialise_term (Term t) override

bool	fill_maps (const std::vector< uint8_t > &data, bool public_only, ccf::kv::Version &v, ccf::kv::Term &view, ccf::kv::EntryFlags &entry_flags, OrderedChanges &changes, MapCollection &new_maps, ccf::ClaimsDigest &claims_digest, std::optional< ccf::crypto::Sha256Hash > &commit_evidence_digest, bool ignore_strict_versions=false) override

std::unique_ptr< ccf::kv::AbstractExecutionWrapper >	deserialize (const std::vector< uint8_t > &data, bool public_only=false, const std::optional< TxID > &expected_txid=std::nullopt) override

bool	operator== (const Store &that) const

Version	current_version () override

ccf::TxID	current_txid () override

std::pair< TxID, Term >	current_txid_and_commit_term () override

Version	compacted_version () override

Term	commit_view () override

CommitResult	commit (const TxID &txid, std::unique_ptr< PendingTx > pending_tx, bool globally_committable) override

bool	should_create_ledger_chunk (Version version) override

bool	should_create_ledger_chunk_unsafe (Version version) override

void	lock_map_set () override

void	unlock_map_set () override

bool	check_rollback_count (Version count) override

std::tuple< Version, Version >	next_version (bool commit_new_map) override

Version	next_version () override

TxID	next_txid () override

size_t	committable_gap () override

void	swap_private_maps (Store &store)

void	set_map_hook (const std::string &map_name, const ccf::kv::untyped::Map::MapHook &hook)

void	unset_map_hook (const std::string &map_name)

void	set_global_hook (const std::string &map_name, const ccf::kv::untyped::Map::CommitHook &hook)

void	unset_global_hook (const std::string &map_name)

ReadOnlyTx	create_read_only_tx () override

std::unique_ptr< ReadOnlyTx >	create_read_only_tx_ptr () override

TxDiff	create_tx_diff () override

CommittableTx	create_tx ()

std::unique_ptr< CommittableTx >	create_tx_ptr ()

ReservedTx	create_reserved_tx (const TxID &tx_id)

void	set_flag (StoreFlag f) override

void	unset_flag (StoreFlag f) override

bool	flag_enabled (StoreFlag f) override

void	set_flag_unsafe (StoreFlag f) override

void	unset_flag_unsafe (StoreFlag f) override

bool	flag_enabled_unsafe (StoreFlag f) const override

Public Member Functions inherited from ccf::kv::AbstractStore
virtual	~AbstractStore ()=default

virtual std::unique_ptr< AbstractExecutionWrapper >	deserialize (const std::vector< uint8_t > &data, bool public_only=false, const std::optional< ccf::TxID > &expected_txid=std::nullopt)=0

Public Member Functions inherited from ccf::kv::StoreState
void	clear ()

Public Member Functions inherited from ccf::kv::ExecutionWrapperStore
virtual	~ExecutionWrapperStore ()=default

Public Member Functions inherited from ccf::kv::ReadOnlyStore
virtual	~ReadOnlyStore ()=default

Additional Inherited Members
Public Types inherited from ccf::kv::AbstractStore
enum class	StoreFlag : uint8_t { SNAPSHOT_AT_NEXT_SIGNATURE = 0x02 }

Protected Types inherited from ccf::kv::StoreState
using	Maps = std::map< std::string, std::pair< ccf::kv::Version, std::shared_ptr< untyped::Map > > >

Protected Attributes inherited from ccf::kv::StoreState
ccf::pal::Mutex	maps_lock

Maps	maps

ccf::pal::Mutex	version_lock

std::atomic< Version >	version = 0

Version	last_new_map = ccf::kv::NoVersion

std::atomic< Version >	compacted = 0

ccf::pal::Mutex	commit_lock

std::atomic< Term >	term_of_next_version = 0

Term	term_of_last_version = 0

Version	last_replicated = 0

Version	last_committable = 0

Version	rollback_count = 0

std::unordered_map< Version, std::tuple< std::unique_ptr< PendingTx >, bool > >	pending_txs

Constructor & Destructor Documentation

◆ Store() [1/2]

ccf::kv::Store::Store	(	bool	strict_versions_ = `true`,
		bool	is_historical_ = `false`
	)

inline

◆ Store() [2/2]

ccf::kv::Store::Store ( const Store & that )

delete

Member Function Documentation

◆ add_dynamic_map()

void ccf::kv::Store::add_dynamic_map	(	ccf::kv::Version	v,
		const std::shared_ptr< AbstractMap > &	map_
	)

inlineoverridevirtual

Transfer ownership of a dynamically created map to this Store.

Should be called as part of the commit process, once a transaction is known to be conflict-free and has been assigned a unique Version. This publishes dynamically created Maps so they can be retrieved via get_map in future transactions.

Parameters

v	Version at which map is being committed/created
map_	Map to add

Implements ccf::kv::AbstractStore.

◆ check_rollback_count()

bool ccf::kv::Store::check_rollback_count ( Version count )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ commit()

CommitResult ccf::kv::Store::commit	(	const TxID &	txid,
		std::unique_ptr< PendingTx >	pending_tx,
		bool	globally_committable
	)

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ commit_view()

Term ccf::kv::Store::commit_view ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ committable_gap()

size_t ccf::kv::Store::committable_gap ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ compact()

void ccf::kv::Store::compact ( Version v )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ compacted_version()

Version ccf::kv::Store::compacted_version ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ create_read_only_tx()

ReadOnlyTx ccf::kv::Store::create_read_only_tx ( )

inlineoverridevirtual

Implements ccf::kv::ReadOnlyStore.

◆ create_read_only_tx_ptr()

std::unique_ptr< ReadOnlyTx > ccf::kv::Store::create_read_only_tx_ptr ( )

inlineoverridevirtual

Implements ccf::kv::ReadOnlyStore.

◆ create_reserved_tx()

ReservedTx ccf::kv::Store::create_reserved_tx ( const TxID & tx_id )

inline

◆ create_tx()

CommittableTx ccf::kv::Store::create_tx ( )

inline

◆ create_tx_diff()

TxDiff ccf::kv::Store::create_tx_diff ( )

inlineoverridevirtual

Implements ccf::kv::ReadOnlyStore.

◆ create_tx_ptr()

std::unique_ptr< CommittableTx > ccf::kv::Store::create_tx_ptr ( )

inline

◆ current_txid()

ccf::TxID ccf::kv::Store::current_txid ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ current_txid_and_commit_term()

std::pair< TxID, Term > ccf::kv::Store::current_txid_and_commit_term ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ current_version()

Version ccf::kv::Store::current_version ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ deserialise_snapshot()

ApplyResult ccf::kv::Store::deserialise_snapshot	(	const uint8_t *	data,
		size_t	size,
		ccf::kv::ConsensusHookPtrs &	hooks,
		std::vector< Version > *	view_history = `nullptr`,
		bool	public_only = `false`
	)

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ deserialize()

std::unique_ptr< ccf::kv::AbstractExecutionWrapper > ccf::kv::Store::deserialize	(	const std::vector< uint8_t > &	data,
		bool	public_only = `false`,
		const std::optional< TxID > &	expected_txid = `std::nullopt`
	)

inlineoverride

◆ fill_maps()

bool ccf::kv::Store::fill_maps	(	const std::vector< uint8_t > &	data,
		bool	public_only,
		ccf::kv::Version &	v,
		ccf::kv::Term &	view,
		ccf::kv::EntryFlags &	entry_flags,
		OrderedChanges &	changes,
		MapCollection &	new_maps,
		ccf::ClaimsDigest &	claims_digest,
		std::optional< ccf::crypto::Sha256Hash > &	commit_evidence_digest,
		bool	ignore_strict_versions = `false`
	)

inlineoverridevirtual

Implements ccf::kv::ExecutionWrapperStore.

◆ flag_enabled()

bool ccf::kv::Store::flag_enabled ( StoreFlag f )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ flag_enabled_unsafe()

bool ccf::kv::Store::flag_enabled_unsafe ( StoreFlag f ) const

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ get_chunker()

std::shared_ptr< ILedgerChunker > ccf::kv::Store::get_chunker ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ get_consensus()

std::shared_ptr< Consensus > ccf::kv::Store::get_consensus ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ get_encryptor()

EncryptorPtr ccf::kv::Store::get_encryptor ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ get_history()

std::shared_ptr< TxHistory > ccf::kv::Store::get_history ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ get_map()

std::shared_ptr< AbstractMap > ccf::kv::Store::get_map	(	ccf::kv::Version	v,
		const std::string &	map_name
	)

inlineoverridevirtual

Get a map by name, iff it exists at the given version.

This means a prior transaction must have created the map, and successfully committed at a version <= v. If this has not happened (the map has never been created, or never been committed, or committed at a later version) this will return nullptr.

Parameters

v	Version at which the map must exist
map_name	Name of requested map

Returns: Abstract shared-owning pointer to requested map, or nullptr if no such map exists

Implements ccf::kv::AbstractStore.

◆ get_map_internal()

std::shared_ptr< ccf::kv::untyped::Map > ccf::kv::Store::get_map_internal	(	ccf::kv::Version	v,
		const std::string &	map_name
	)

inline

◆ get_map_unsafe()

std::shared_ptr< AbstractMap > ccf::kv::Store::get_map_unsafe	(	ccf::kv::Version	v,
		const std::string &	map_name
	)

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ initialise_term()

void ccf::kv::Store::initialise_term ( Term t )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ lock_map_set()

void ccf::kv::Store::lock_map_set ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ lock_maps()

void ccf::kv::Store::lock_maps ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ next_txid()

TxID ccf::kv::Store::next_txid ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ next_version() [1/2]

Version ccf::kv::Store::next_version ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ next_version() [2/2]

std::tuple< Version, Version > ccf::kv::Store::next_version ( bool commit_new_map )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ operator==()

bool ccf::kv::Store::operator== ( const Store & that ) const

inline

◆ rollback()

void ccf::kv::Store::rollback	(	const TxID &	tx_id,
		Term	term_of_next_version_
	)

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ serialise_snapshot()

std::vector< uint8_t > ccf::kv::Store::serialise_snapshot ( std::unique_ptr< AbstractSnapshot > snapshot )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ set_chunker()

void ccf::kv::Store::set_chunker ( const std::shared_ptr< ILedgerChunker > & chunker_ )

inline

◆ set_consensus()

void ccf::kv::Store::set_consensus ( const std::shared_ptr< Consensus > & consensus_ )

inline

◆ set_encryptor()

void ccf::kv::Store::set_encryptor ( const EncryptorPtr & encryptor_ )

inline

◆ set_flag()

void ccf::kv::Store::set_flag ( StoreFlag f )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ set_flag_unsafe()

void ccf::kv::Store::set_flag_unsafe ( StoreFlag f )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ set_global_hook()

void ccf::kv::Store::set_global_hook	(	const std::string &	map_name,
		const ccf::kv::untyped::Map::CommitHook &	hook
	)

inline

◆ set_history()

void ccf::kv::Store::set_history ( const std::shared_ptr< TxHistory > & history_ )

inline

◆ set_map_hook()

void ccf::kv::Store::set_map_hook	(	const std::string &	map_name,
		const ccf::kv::untyped::Map::MapHook &	hook
	)

inline

◆ set_snapshotter()

void ccf::kv::Store::set_snapshotter ( const SnapshotterPtr & snapshotter_ )

inline

◆ should_create_ledger_chunk()

bool ccf::kv::Store::should_create_ledger_chunk ( Version version )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ should_create_ledger_chunk_unsafe()

bool ccf::kv::Store::should_create_ledger_chunk_unsafe ( Version version )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ snapshot_unsafe_maps()

std::unique_ptr< AbstractSnapshot > ccf::kv::Store::snapshot_unsafe_maps ( Version v )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ swap_private_maps()

void ccf::kv::Store::swap_private_maps ( Store & store )

inline

This is only safe in very restricted circumstances, and is only meant to be used during catastrophic recovery, between a KV with public-state only and a KV with full state, to swap in the private state from the latter into the former.

It's also important to note that swapping in private state may result in previously uncompacted writes becoming effectively compacted, from a user's perspective (they would not be internally compacted until the next compact() however). So it is important to make sure that the private state being swapped in is fully compacted before the swap.

◆ unlock_map_set()

void ccf::kv::Store::unlock_map_set ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ unlock_maps()

void ccf::kv::Store::unlock_maps ( )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ unset_flag()

void ccf::kv::Store::unset_flag ( StoreFlag f )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ unset_flag_unsafe()

void ccf::kv::Store::unset_flag_unsafe ( StoreFlag f )

inlineoverridevirtual

Implements ccf::kv::AbstractStore.

◆ unset_global_hook()

void ccf::kv::Store::unset_global_hook ( const std::string & map_name )

inline

◆ unset_map_hook()

void ccf::kv::Store::unset_map_hook ( const std::string & map_name )

inline

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

src/kv/store.h

Public Member Functions

Additional Inherited Members

Constructor & Destructor Documentation

◆ Store() [1/2]

◆ Store() [2/2]

Member Function Documentation

◆ add_dynamic_map()

◆ check_rollback_count()

◆ commit()

◆ commit_view()

◆ committable_gap()

◆ compact()

◆ compacted_version()

◆ create_read_only_tx()

◆ create_read_only_tx_ptr()

◆ create_reserved_tx()

◆ create_tx()

◆ create_tx_diff()

◆ create_tx_ptr()

◆ current_txid()

◆ current_txid_and_commit_term()

◆ current_version()

◆ deserialise_snapshot()

◆ deserialize()

◆ fill_maps()

◆ flag_enabled()

◆ flag_enabled_unsafe()

◆ get_chunker()

◆ get_consensus()

◆ get_encryptor()

◆ get_history()

◆ get_map()

◆ get_map_internal()

◆ get_map_unsafe()

◆ initialise_term()

◆ lock_map_set()

◆ lock_maps()

◆ next_txid()

◆ next_version() [1/2]

◆ next_version() [2/2]

◆ operator==()

◆ rollback()

◆ serialise_snapshot()

◆ set_chunker()

◆ set_consensus()

◆ set_encryptor()

◆ set_flag()

◆ set_flag_unsafe()

◆ set_global_hook()

◆ set_history()

◆ set_map_hook()

◆ set_snapshotter()

◆ should_create_ledger_chunk()

◆ should_create_ledger_chunk_unsafe()

◆ snapshot_unsafe_maps()

◆ swap_private_maps()

◆ unlock_map_set()

◆ unlock_maps()

◆ unset_flag()

◆ unset_flag_unsafe()

◆ unset_global_hook()

◆ unset_map_hook()