CatapultServer  v0.5.0.1 (Elephant)
RepairState.h
Go to the documentation of this file.
1 
21 #pragma once
22 
23 namespace catapult {
24  namespace cache { class CatapultCache; }
25  namespace config { class CatapultDirectory; }
26  namespace subscribers { class StateChangeSubscriber; }
27 }
28 
29 namespace catapult { namespace local {
30 
33  void RepairState(
34  const config::CatapultDirectory& stateChangeDirectory,
35  const cache::CatapultCache& catapultCache,
36  subscribers::StateChangeSubscriber& registeredSubscriber,
37  subscribers::StateChangeSubscriber& repairSubscriber);
38 }}
StateChangeReader.h
catapult::subscribers::StateChangeSubscriber
State change subscriber.
Definition: StateChangeSubscriber.h:31
catapult::subscribers::ReadAll
void ReadAll(io::InputStream &inputStream, TSubscriber &subscriber, TMessageReader readNextMessage)
Reads all messages from inputStream into subscriber using readNextMessage.
Definition: BrokerMessageReaders.h:49
m_stateChangeDirectory
config::CatapultDirectory m_stateChangeDirectory
Definition: RepairState.cpp:67
boost
Definition: IoThreadPool.h:25
CacheChangesStorage.h
CatapultDataDirectory.h
m_isBrokerRecovery
bool m_isBrokerRecovery
Definition: RepairState.cpp:69
catapult::subscribers::ReadNextStateChange
void ReadNextStateChange(io::InputStream &inputStream, const CacheChangesStorages &cacheChangesStorages, StateChangeSubscriber &subscriber)
Reads next state change from inputStream and forwards it to subscriber using cacheChangesStorages for...
Definition: StateChangeReader.cpp:63
catapult::config::CatapultDirectory
Catapult directory.
Definition: CatapultDataDirectory.h:30
catapult::local::RepairState
void RepairState(const config::CatapultDirectory &stateChangeDirectory, const cache::CatapultCache &catapultCache, subscribers::StateChangeSubscriber &registeredSubscriber, subscribers::StateChangeSubscriber &repairSubscriber)
Definition: RepairState.cpp:75
RepairState.h
catapult::cache::CatapultCache
Central cache holding all sub caches.
Definition: CatapultCache.h:40
CatapultCache.h
catapult
Definition: AddressExtractionExtension.cpp:28
m_catapultCache
const cache::CatapultCache & m_catapultCache
Definition: RepairState.cpp:68
StateChangeSubscriber.h
BrokerMessageReaders.h