CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
26 namespace extensions {
class ProcessBootstrapper; }
30 namespace catapult {
namespace local {
40 std::unique_ptr<RecoveryOrchestrator>
CreateRecoveryOrchestrator(std::unique_ptr<extensions::ProcessBootstrapper>&& pBootstrapper);
std::unique_ptr< subscribers::StateChangeSubscriber > m_pStateChangeSubscriber
Definition: RecoveryOrchestrator.cpp:250
#define CATAPULT_LOG(SEV)
Writes a log entry to the default logger with SEV severity.
Definition: Logging.h:340
plugins::PluginManager & m_pluginManager
Definition: RecoveryOrchestrator.cpp:252
#define CATAPULT_THROW_RUNTIME_ERROR_2(MESSAGE, PARAM1, PARAM2)
Macro used to throw a catapult runtime error with two parameters.
Definition: exceptions.h:175
def debug(*args)
Definition: Parser.py:46
State was written to disk.
std::unique_ptr< extensions::ProcessBootstrapper > m_pBootstrapper
Definition: RecoveryOrchestrator.cpp:237
config::CatapultDataDirectory m_dataDirectory
Definition: RecoveryOrchestrator.cpp:241
utils::BaseValue< uint64_t, Height_tag > Height
Definition: src/catapult/types.h:85
void ReadAll(io::InputStream &inputStream, TSubscriber &subscriber, TMessageReader readNextMessage)
Reads all messages from inputStream into subscriber using readNextMessage.
Definition: BrokerMessageReaders.h:49
std::unique_ptr< RecoveryOrchestrator > CreateRecoveryOrchestrator(std::unique_ptr< extensions::ProcessBootstrapper > &&pBootstrapper)
Creates and boots a recovery orchestrator around the specified bootstrapper (pBootstrapper).
Definition: RecoveryOrchestrator.cpp:256
constexpr std::underlying_type_t< TEnum > to_underlying_type(TEnum value)
Converts a strongly typed enumeration value to its underlying integral value.
Definition: Casting.h:37
void SaveStateToDirectoryWithCheckpointing(const config::CatapultDataDirectory &dataDirectory, const config::NodeConfiguration &nodeConfig, const cache::CatapultCache &cache, const state::CatapultState &state, const model::ChainScore &score)
Serializes state composed of cache, state and score with checkpointing to dataDirectory given nodeCon...
Definition: LocalNodeStateFileStorage.cpp:192
subscribers::StateChangeSubscriber & m_subscriber1
Definition: RecoveryOrchestrator.cpp:67
state::CatapultState m_catapultState
Definition: RecoveryOrchestrator.cpp:244
model::ChainScore LoadBlockChain(const BlockDependentNotificationObserverFactory &observerFactory, const plugins::PluginManager &pluginManager, const extensions::LocalNodeStateRef &stateRef, Height startHeight)
Definition: MultiBlockLoader.cpp:178
Definition: ChainScore.h:30
Height FindStartHeight(const io::BlockStorage &storage)
Returns starting height of storage.
Definition: StorageStart.cpp:26
const config::CatapultConfiguration & m_config
Definition: RecoveryOrchestrator.cpp:240
std::vector< plugins::PluginModule > m_pluginModules
Definition: RecoveryOrchestrator.cpp:236
subscribers::StateChangeSubscriber & m_subscriber2
Definition: RecoveryOrchestrator.cpp:68
Level for logging informational events.
model::ChainScore Score
Definition: BlockChainSyncConsumer.cpp:43
void MoveBlockFiles(PrunableBlockStorage &sourceStorage, BlockStorage &destinationStorage, Height startHeight)
Moves block files starting at startHeight from sourceStorage to destinationStorage.
Definition: MoveBlockFiles.cpp:28
void RepairState(const config::CatapultDirectory &stateChangeDirectory, const cache::CatapultCache &catapultCache, subscribers::StateChangeSubscriber ®isteredSubscriber, subscribers::StateChangeSubscriber &repairSubscriber)
Definition: RepairState.cpp:75
std::unique_ptr< io::BlockStorage > CreateReadOnlyStorageAdapter(const io::BlockStorage &storage)
Creates non-owning read-only storage around storage.
Definition: RecoveryStorageAdapter.cpp:66
void ReadNextTransactionStatus(io::InputStream &inputStream, TransactionStatusSubscriber &subscriber)
Reads next transaction status from inputStream and forwards it to subscriber.
Definition: TransactionStatusReader.cpp:29
StateHeights LoadStateFromDirectory(const config::CatapultDirectory &directory, const LocalNodeStateRef &stateRef, const plugins::PluginManager &pluginManager)
Loads catapult state into stateRef from directory given pluginManager.
Definition: LocalNodeStateFileStorage.cpp:96
std::unique_ptr< io::BlockStorage > m_pBlockStorage
Definition: RecoveryOrchestrator.cpp:245
Catapult process host.
Definition: ProcessHost.h:27
def info(*args)
Definition: forwardsValidation.py:12
void ReadNextBlockChange(io::InputStream &inputStream, io::BlockChangeSubscriber &subscriber)
Reads next block change from inputStream and forwards it to subscriber.
Definition: BlockChangeReader.cpp:50
void RepairSpooling(const config::CatapultDataDirectory &dataDirectory, consumers::CommitOperationStep commitStep)
Repairs catapult spooling folders inside dataDirectory given last server commit operation step that s...
Definition: RepairSpooling.cpp:68
void PurgeDirectory(const std::string &directory)
Deletes everything in directory but does not delete the directory itself.
Definition: FilesystemUtils.cpp:26
cache::CatapultCache m_catapultCache
Definition: RecoveryOrchestrator.cpp:243
io::BlockStorageCache m_storage
Definition: RecoveryOrchestrator.cpp:246
std::unique_ptr< subscribers::StateChangeSubscriber > CreateStateChangeRepairingSubscriber(cache::CatapultCache &cache, extensions::LocalNodeChainScore &localNodeScore)
Creates state change repairing subscriber around cache and localNodeScore.
Definition: StateChangeRepairingSubscriber.cpp:58
model::ChainScore ChainScore
Definition: tools/health/main.cpp:43
std::vector< plugins::PluginModule > LoadAllPlugins(extensions::ProcessBootstrapper &bootstrapper)
Loads all plugins using bootstrapper.
Definition: HostUtils.cpp:64
CommitOperationStep
Steps in a commit operation.
Definition: BlockChainSyncHandlers.h:62
Definition: AddressExtractionExtension.cpp:28
io::BlockChangeSubscriber * m_pBlockChangeSubscriber
Definition: RecoveryOrchestrator.cpp:239
virtual model::ChainScore score() const =0
Gets the current chain score.
Represents a recovery orchestrator.
Definition: RecoveryOrchestrator.h:33
extensions::LocalNodeChainScore m_score
Definition: RecoveryOrchestrator.cpp:247
std::unique_ptr< subscribers::TransactionStatusSubscriber > m_pTransactionStatusSubscriber
Definition: RecoveryOrchestrator.cpp:249