|
CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
25 namespace catapult {
namespace extensions {
class ProcessBootstrapper; } }
27 namespace catapult {
namespace local {
33 std::unique_ptr<Broker>
CreateBroker(std::unique_ptr<extensions::ProcessBootstrapper>&& pBootstrapper);
#define CATAPULT_LOG(SEV)
Writes a log entry to the default logger with SEV severity.
Definition: Logging.h:340
def debug(*args)
Definition: Parser.py:46
std::unique_ptr< cache::PtChangeSubscriber > m_pPtChangeSubscriber
Definition: Broker.cpp:119
void ReadNextPtChange(io::InputStream &inputStream, cache::PtChangeSubscriber &subscriber)
Reads next partial transactions change from inputStream and forwards it to subscriber.
Definition: PtChangeReader.cpp:55
void ReadAll(io::InputStream &inputStream, TSubscriber &subscriber, TMessageReader readNextMessage)
Reads all messages from inputStream into subscriber using readNextMessage.
Definition: BrokerMessageReaders.h:49
static constexpr TimeSpan FromMilliseconds(uint64_t milliseconds)
Creates a time span from the given number of milliseconds.
Definition: TimeSpan.h:59
static CatapultDataDirectory Prepare(const boost::filesystem::path &directory)
Creates a data directory around directory.
Definition: CatapultDataDirectory.h:95
std::unique_ptr< Broker > CreateBroker(std::unique_ptr< extensions::ProcessBootstrapper > &&pBootstrapper)
Creates and boots a broker around the specified bootstrapper (pBootstrapper).
Definition: Broker.cpp:127
config::CatapultDataDirectory m_dataDirectory
Definition: Broker.cpp:113
std::unique_ptr< subscribers::StateChangeSubscriber > m_pStateChangeSubscriber
Definition: Broker.cpp:121
DelayGenerator CreateUniformDelayGenerator(const utils::TimeSpan &delay)
Creates a uniform delay generator that always returns delay.
Definition: Task.cpp:26
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
Level for logging informational events.
cache::CatapultCache m_catapultCache
Definition: Broker.cpp:115
void ReadNextTransactionStatus(io::InputStream &inputStream, TransactionStatusSubscriber &subscriber)
Reads next transaction status from inputStream and forwards it to subscriber.
Definition: TransactionStatusReader.cpp:29
std::unique_ptr< cache::UtChangeSubscriber > m_pUtChangeSubscriber
Definition: Broker.cpp:118
std::unique_ptr< extensions::ProcessBootstrapper > m_pBootstrapper
Definition: Broker.cpp:111
Catapult process host.
Definition: ProcessHost.h:27
std::string Name
Friendly name of the task (optional).
Definition: Task.h:56
def info(*args)
Definition: forwardsValidation.py:12
plugins::PluginManager & m_pluginManager
Definition: Broker.cpp:123
void ReadNextBlockChange(io::InputStream &inputStream, io::BlockChangeSubscriber &subscriber)
Reads next block change from inputStream and forwards it to subscriber.
Definition: BlockChangeReader.cpp:50
std::unique_ptr< subscribers::TransactionStatusSubscriber > m_pTransactionStatusSubscriber
Definition: Broker.cpp:120
Simple RAII class that logs scope messages.
Definition: StackLogger.h:29
DelayGenerator NextDelay
Generates the delay until the next execution of the task.
Definition: Task.h:50
TaskCallback Callback
Callback associated with the task.
Definition: Task.h:53
utils::TimeSpan StartDelay
Delay until the first execution of the task.
Definition: Task.h:47
future< T > make_ready_future(T &&value)
Produces a future that is ready immediately and holds the given value.
Definition: Future.h:126
std::vector< plugins::PluginModule > m_pluginModules
Definition: Broker.cpp:110
std::vector< plugins::PluginModule > LoadAllPlugins(extensions::ProcessBootstrapper &bootstrapper)
Loads all plugins using bootstrapper.
Definition: HostUtils.cpp:64
Definition: AddressExtractionExtension.cpp:28
Represents a broker.
Definition: Broker.h:30
Definition: DispatcherUtils.h:30
std::shared_ptr< Scheduler > CreateScheduler(const std::shared_ptr< IoThreadPool > &pPool)
Creates a scheduler around the specified thread pool (pPool).
Definition: Scheduler.cpp:213
void ReadNextUtChange(io::InputStream &inputStream, cache::UtChangeSubscriber &subscriber)
Reads next unconfirmed transactions change from inputStream and forwards it to subscriber.
Definition: UtChangeReader.cpp:30
A task that can be dispatched to the scheduler.
Definition: Task.h:45
std::unique_ptr< io::BlockChangeSubscriber > m_pBlockChangeSubscriber
Definition: Broker.cpp:117
1.8.16