CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
24 namespace cache {
class CatapultCache; }
25 namespace config {
class CatapultDirectory; }
26 namespace subscribers {
class StateChangeSubscriber; }
29 namespace catapult {
namespace local {
34 const config::CatapultDirectory& stateChangeDirectory,
35 const cache::CatapultCache& catapultCache,
36 subscribers::StateChangeSubscriber& registeredSubscriber,
37 subscribers::StateChangeSubscriber& repairSubscriber);
State change subscriber.
Definition: StateChangeSubscriber.h:31
void ReadAll(io::InputStream &inputStream, TSubscriber &subscriber, TMessageReader readNextMessage)
Reads all messages from inputStream into subscriber using readNextMessage.
Definition: BrokerMessageReaders.h:49
config::CatapultDirectory m_stateChangeDirectory
Definition: RepairState.cpp:67
Definition: IoThreadPool.h:25
bool m_isBrokerRecovery
Definition: RepairState.cpp:69
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 directory.
Definition: CatapultDataDirectory.h:30
void RepairState(const config::CatapultDirectory &stateChangeDirectory, const cache::CatapultCache &catapultCache, subscribers::StateChangeSubscriber ®isteredSubscriber, subscribers::StateChangeSubscriber &repairSubscriber)
Definition: RepairState.cpp:75
Central cache holding all sub caches.
Definition: CatapultCache.h:40
Definition: AddressExtractionExtension.cpp:28
const cache::CatapultCache & m_catapultCache
Definition: RepairState.cpp:68