rippled
Loading...
Searching...
No Matches
Public Member Functions | Private Attributes | List of all members
ripple::ManifestCache Class Reference

Remembers manifests with the highest sequence number. More...

#include <Manifest.h>

Collaboration diagram for ripple::ManifestCache:
Collaboration graph
[legend]

Public Member Functions

 ManifestCache (beast::Journal j=beast::Journal(beast::Journal::getNullSink()))
 
std::uint32_t sequence () const
 A monotonically increasing number used to detect new manifests.
 
std::optional< PublicKeygetSigningKey (PublicKey const &pk) const
 Returns master key's current signing key.
 
PublicKey getMasterKey (PublicKey const &pk) const
 Returns ephemeral signing key's master public key.
 
std::optional< std::uint32_tgetSequence (PublicKey const &pk) const
 Returns master key's current manifest sequence.
 
std::optional< std::stringgetDomain (PublicKey const &pk) const
 Returns domain claimed by a given public key.
 
std::optional< std::stringgetManifest (PublicKey const &pk) const
 Returns mainfest corresponding to a given public key.
 
bool revoked (PublicKey const &pk) const
 Returns true if master key has been revoked in a manifest.
 
ManifestDisposition applyManifest (Manifest m)
 Add manifest to cache.
 
bool load (DatabaseCon &dbCon, std::string const &dbTable, std::string const &configManifest, std::vector< std::string > const &configRevocation)
 Populate manifest cache with manifests in database and config.
 
void load (DatabaseCon &dbCon, std::string const &dbTable)
 Populate manifest cache with manifests in database.
 
void save (DatabaseCon &dbCon, std::string const &dbTable, std::function< bool(PublicKey const &)> const &isTrusted)
 Save cached manifests to database.
 
template<class Function >
void for_each_manifest (Function &&f) const
 Invokes the callback once for every populated manifest.
 
template<class PreFun , class EachFun >
void for_each_manifest (PreFun &&pf, EachFun &&f) const
 Invokes the callback once for every populated manifest.
 

Private Attributes

beast::Journal j_
 
std::shared_mutex mutex_
 
hash_map< PublicKey, Manifestmap_
 Active manifests stored by master public key.
 
hash_map< PublicKey, PublicKeysigningToMasterKeys_
 Master public keys stored by current ephemeral public key.
 
std::atomic< std::uint32_tseq_ {0}
 

Detailed Description

Remembers manifests with the highest sequence number.

Definition at line 255 of file Manifest.h.

Constructor & Destructor Documentation

◆ ManifestCache()

ripple::ManifestCache::ManifestCache ( beast::Journal  j = beast::Journal(beast::Journal::getNullSink()))
explicit

Definition at line 270 of file Manifest.h.

Member Function Documentation

◆ sequence()

std::uint32_t ripple::ManifestCache::sequence ( ) const

A monotonically increasing number used to detect new manifests.

Definition at line 278 of file Manifest.h.

◆ getSigningKey()

std::optional< PublicKey > ripple::ManifestCache::getSigningKey ( PublicKey const &  pk) const

Returns master key's current signing key.

Parameters
pkMaster public key
Returns
pk if no known signing key from a manifest
Thread Safety

May be called concurrently

Definition at line 311 of file Manifest.cpp.

◆ getMasterKey()

PublicKey ripple::ManifestCache::getMasterKey ( PublicKey const &  pk) const

Returns ephemeral signing key's master public key.

Parameters
pkEphemeral signing public key
Returns
pk if signing key is not in a valid manifest
Thread Safety

May be called concurrently

Definition at line 323 of file Manifest.cpp.

◆ getSequence()

std::optional< std::uint32_t > ripple::ManifestCache::getSequence ( PublicKey const &  pk) const

Returns master key's current manifest sequence.

Returns
sequence corresponding to Master public key if configured or std::nullopt otherwise

Definition at line 335 of file Manifest.cpp.

◆ getDomain()

std::optional< std::string > ripple::ManifestCache::getDomain ( PublicKey const &  pk) const

Returns domain claimed by a given public key.

Returns
domain corresponding to Master public key if present, otherwise std::nullopt

Definition at line 347 of file Manifest.cpp.

◆ getManifest()

std::optional< std::string > ripple::ManifestCache::getManifest ( PublicKey const &  pk) const

Returns mainfest corresponding to a given public key.

Returns
manifest corresponding to Master public key if present, otherwise std::nullopt

Definition at line 359 of file Manifest.cpp.

◆ revoked()

bool ripple::ManifestCache::revoked ( PublicKey const &  pk) const

Returns true if master key has been revoked in a manifest.

Parameters
pkMaster public key
Thread Safety

May be called concurrently

Definition at line 371 of file Manifest.cpp.

◆ applyManifest()

ManifestDisposition ripple::ManifestCache::applyManifest ( Manifest  m)

Add manifest to cache.

Parameters
mManifest to add
Returns
ManifestDisposition::accepted if successful, or stale or invalid otherwise
Thread Safety

May be called concurrently

Definition at line 383 of file Manifest.cpp.

◆ load() [1/2]

bool ripple::ManifestCache::load ( DatabaseCon dbCon,
std::string const &  dbTable,
std::string const &  configManifest,
std::vector< std::string > const &  configRevocation 
)

Populate manifest cache with manifests in database and config.

Parameters
dbConDatabase connection with dbTable
dbTableDatabase table
configManifestBase64 encoded manifest for local node's validator keys
configRevocationBase64 encoded validator key revocation from the config
Thread Safety

May be called concurrently

Definition at line 551 of file Manifest.cpp.

◆ load() [2/2]

void ripple::ManifestCache::load ( DatabaseCon dbCon,
std::string const &  dbTable 
)

Populate manifest cache with manifests in database.

Parameters
dbConDatabase connection with dbTable
dbTableDatabase table
Thread Safety

May be called concurrently

Definition at line 544 of file Manifest.cpp.

◆ save()

void ripple::ManifestCache::save ( DatabaseCon dbCon,
std::string const &  dbTable,
std::function< bool(PublicKey const &)> const &  isTrusted 
)

Save cached manifests to database.

Parameters
dbConDatabase connection with ValidatorManifests table
isTrustedFunction that returns true if manifest is trusted
Thread Safety

May be called concurrently

Definition at line 608 of file Manifest.cpp.

◆ for_each_manifest() [1/2]

template<class Function >
void ripple::ManifestCache::for_each_manifest ( Function &&  f) const

Invokes the callback once for every populated manifest.

Note
Do not call ManifestCache member functions from within the callback. This can re-lock the mutex from the same thread, which is UB.
Do not write ManifestCache member variables from within the callback. This can lead to data races.
Parameters
fFunction called for each manifest
Thread Safety

May be called concurrently

Definition at line 425 of file Manifest.h.

◆ for_each_manifest() [2/2]

template<class PreFun , class EachFun >
void ripple::ManifestCache::for_each_manifest ( PreFun &&  pf,
EachFun &&  f 
) const

Invokes the callback once for every populated manifest.

Note
Do not call ManifestCache member functions from within the callback. This can re-lock the mutex from the same thread, which is UB.
Do not write ManifestCache member variables from within the callback. This can lead to data races.
Parameters
pfPre-function called with the maximum number of times f will be called (useful for memory allocations)
fFunction called for each manifest
Thread Safety

May be called concurrently

Definition at line 453 of file Manifest.h.

Member Data Documentation

◆ j_

beast::Journal ripple::ManifestCache::j_
private

Definition at line 258 of file Manifest.h.

◆ mutex_

std::shared_mutex ripple::ManifestCache::mutex_
mutableprivate

Definition at line 259 of file Manifest.h.

◆ map_

hash_map<PublicKey, Manifest> ripple::ManifestCache::map_
private

Active manifests stored by master public key.

Definition at line 262 of file Manifest.h.

◆ signingToMasterKeys_

hash_map<PublicKey, PublicKey> ripple::ManifestCache::signingToMasterKeys_
private

Master public keys stored by current ephemeral public key.

Definition at line 265 of file Manifest.h.

◆ seq_

std::atomic<std::uint32_t> ripple::ManifestCache::seq_ {0}
private

Definition at line 267 of file Manifest.h.