|
CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
24 namespace catapult {
namespace partialtransaction {
static EntityRange FromEntity(std::unique_ptr< TEntity > &&pEntity)
Creates an entity range around a single entity (pEntity).
Definition: EntityRange.h:292
std::unique_ptr< PtValidator > CreatePtValidator(const cache::CatapultCache &cache, const TimeSupplier &timeSupplier, const plugins::PluginManager &pluginManager)
Creates a default partial transaction validator around cache, current time supplier (timeSupplier) an...
Definition: PtValidator.cpp:98
#define CATAPULT_LOG(SEV)
Writes a log entry to the default logger with SEV severity.
Definition: Logging.h:340
extensions::ServiceState & m_state
Definition: PtDispatcherService.cpp:126
void AddDispatcherCounters(ServiceLocator &locator, const std::string &dispatcherName, const std::string &counterPrefix)
Adds dispatcher counters with prefix counterPrefix to locator for a dispatcher named dispatcherName.
Definition: DispatcherUtils.cpp:43
utils::ByteArray< Hash256_Size, Hash256_tag > Hash256
Definition: src/catapult/types.h:47
const config::NodeConfiguration & m_nodeConfig
Definition: PtDispatcherService.cpp:127
def debug(*args)
Definition: Parser.py:46
thread::Task CreateBatchTransactionTask(TransactionBatchRangeDispatcher &dispatcher, const std::string &name)
Creates a task with name that dispatches all transactions batched in dispatcher.
Definition: DispatcherUtils.cpp:54
Definition: ConsumerUtils.h:25
ionet::Node Local
Definition: tools/network/main.cpp:42
auto & utCache() const
Gets the unconfirmed transactions cache.
Definition: ServiceState.h:119
PtCache & GetMemoryPtCache(const extensions::ServiceLocator &locator)
Gets the memory partial transactions cache stored in locator.
Definition: PtBootstrapperService.cpp:97
disruptor::DisruptorInspector CreateReclaimMemoryInspector()
Creates an inspector that reclaims memory.
Definition: ReclaimMemoryInspector.cpp:43
Definition: DispatcherSyncHandlers.h:26
A registrar for registering a service.
Definition: ServiceRegistrar.h:45
consumers::HashCheckOptions CreateHashCheckOptions(const utils::TimeSpan &cacheDuration, const config::NodeConfiguration &nodeConfig)
Creates hash check options based on cacheDuration and nodeConfig.
Definition: DispatcherUtils.cpp:30
std::unique_ptr< ServiceRegistrar > CreatePtDispatcherServiceRegistrar()
Definition: PtDispatcherService.cpp:265
future< std::vector< future< T > > > when_all(std::vector< future< T >> &&allFutures)
Returns a future that is signaled when all futures in allFutures complete.
Definition: FutureUtils.h:31
Consumer dispatcher options.
Definition: ConsumerDispatcherOptions.h:27
DECLARE_SERVICE_REGISTRAR() PtDispatcher()
Creates a registrar for a partial transaction dispatcher service.
chain::FailedTransactionSink SubscriberToSink(subscribers::TransactionStatusSubscriber &subscriber)
Converts subscriber to a sink.
Definition: DispatcherUtils.cpp:37
void SplitCosignedTransactionInfos(CosignedTransactionInfos &&transactionInfos, const consumer< model::TransactionRange && > &transactionRangeConsumer, const consumer< model::DetachedCosignature && > &cosignatureConsumer)
Definition: PtUtils.cpp:52
std::vector< DisruptorConsumer > DisruptorConsumersFromTransactionConsumers(const std::vector< TransactionConsumer > &transactionConsumers)
Maps transactionConsumers to disruptor consumers so that they can be used to create a ConsumerDispatc...
Definition: DisruptorConsumer.cpp:50
def info(*args)
Definition: forwardsValidation.py:12
Information about a service registrar.
Definition: ServiceRegistrar.h:36
State that is used as part of service registration.
Definition: ServiceState.h:51
disruptor::TransactionConsumer CreateTransactionHashCalculatorConsumer(const GenerationHash &generationHash, const model::TransactionRegistry &transactionRegistry)
Definition: HashCalculatorConsumer.cpp:103
Definition: AuditConsumer.cpp:28
disruptor::TransactionConsumer CreateTransactionHashCheckConsumer(const chain::TimeSupplier &timeSupplier, const HashCheckOptions &options, const chain::KnownHashPredicate &knownHashPredicate)
Definition: HashCheckConsumer.cpp:107
const auto & hooks() const
Gets the server hooks.
Definition: ServiceState.h:170
ionet::Node Node
Definition: PacketWriters.cpp:45
Definition: AddressExtractionExtension.cpp:28
disruptor::DisruptorConsumer CreateNewTransactionsConsumer(const NewTransactionsSink &newTransactionsSink)
Definition: NewTransactionsConsumer.cpp:79
constexpr size_t Hash256_Size
Definition: src/catapult/types.h:34
std::unique_ptr< chain::PtUpdater > m_pUpdater
Definition: PtDispatcherService.cpp:155
#define DECLARE_SERVICE_REGISTRAR(NAME)
Declares a service registrar entry point with NAME.
Definition: ServiceRegistrar.h:61
std::shared_ptr< ConsumerDispatcher > m_pDispatcher
Definition: PtDispatcherService.cpp:154
auto & pool()
Gets the multiservice pool.
Definition: ServiceState.h:155
std::function< void(TArgs...)> consumer
A consumer function.
Definition: functions.h:35
consumer< const consumers::TransactionInfos & > SharedNewTransactionsSink
A new transactions sink prototype that does not take ownership of new infos.
Definition: ServerHooks.h:41
std::lock_guard< SpinLock > SpinLockGuard
A spin lock guard.
Definition: SpinLock.h:60
std::vector< TransactionConsumer > m_consumers
Definition: PtDispatcherService.cpp:128
A service locator for local node services.
Definition: ServiceLocator.h:33
PtServerHooks & GetPtServerHooks(const extensions::ServiceLocator &locator)
Gets the partial transactions server hooks stored in locator.
Definition: PtBootstrapperService.cpp:101
1.8.16