| 
    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