|
CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
25 namespace catapult {
namespace sync {
28 std::shared_ptr<net::PacketWriters>
GetPacketWriters(
const extensions::ServiceLocator& locator);
consumers::NewBlockSink NewBlockSink
A new block sink prototype.
Definition: ServerHooks.h:38
#define CATAPULT_LOG(SEV)
Writes a log entry to the default logger with SEV severity.
Definition: Logging.h:340
Manages a collection of connections that send data to external nodes.
Definition: PacketWriters.h:41
First phase (no dependencies).
std::shared_ptr< net::PacketWriters > GetPacketWriters(const extensions::ServiceLocator &locator)
Gets the packet writers service from locator.
Definition: NetworkPacketWritersService.cpp:94
std::function< thread::future< std::vector< Height > >(size_t)> RemoteChainHeightsRetriever
A retriever that returns the network chain heights for a number of peers.
Definition: ServerHooks.h:66
def warning(*args)
Definition: colorPrint.py:10
std::shared_ptr< TService > service(const std::string &serviceName) const
Gets the service with serviceName.
Definition: ServiceLocator.h:74
std::vector< T > get_all_ignore_exceptional(std::vector< future< T >> &&futures)
Definition: FutureUtils.h:125
static constexpr TimeSpan FromSeconds(uint64_t seconds)
Creates a time span from the given number of seconds.
Definition: TimeSpan.h:54
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
std::unique_ptr< ChainApi > CreateRemoteChainApiWithoutRegistry(ionet::PacketIo &io)
Creates a chain api for interacting with a remote node with the specified io.
Definition: RemoteChainApi.cpp:159
net::PacketWriters & PacketWriters
Definition: PeersConnectionTasks.cpp:105
std::vector< ionet::NodePacketIoPair > PickMultiple(PacketIoPicker &picker, size_t numRequested, const utils::TimeSpan &ioDuration)
Definition: PacketIoPicker.cpp:26
net::ConnectionSettings GetConnectionSettings(const config::CatapultConfiguration &config)
Extracts connection settings from config.
Definition: NetworkUtils.cpp:25
def info(*args)
Definition: forwardsValidation.py:12
future< T > make_ready_future(T &&value)
Produces a future that is ready immediately and holds the given value.
Definition: Future.h:126
std::shared_ptr< PacketWriters > CreatePacketWriters(const std::shared_ptr< thread::IoThreadPool > &pPool, const crypto::KeyPair &keyPair, const ConnectionSettings &settings)
Definition: PacketWriters.cpp:425
Definition: AddressExtractionExtension.cpp:28
DECLARE_SERVICE_REGISTRAR() NetworkPacketWriters()
Definition: NetworkPacketWritersService.cpp:98
#define DECLARE_SERVICE_REGISTRAR(NAME)
Declares a service registrar entry point with NAME.
Definition: ServiceRegistrar.h:61
consumer< const consumers::TransactionInfos & > SharedNewTransactionsSink
A new transactions sink prototype that does not take ownership of new infos.
Definition: ServerHooks.h:41
A service locator for local node services.
Definition: ServiceLocator.h:33
1.8.16