|
CatapultServer
v0.5.0.1 (Elephant)
|
Go to the documentation of this file.
24 namespace catapult {
namespace ionet {
struct NetworkNode; } }
26 namespace catapult {
namespace nodediscovery {
Requires all packet io pickers to be registered.
DECLARE_SERVICE_REGISTRAR() NodeDiscovery(const ConstNetworkNodePointer &pLocalNetworkNode)
Definition: NodeDiscoveryService.cpp:137
void RegisterNodeDiscoveryPullPeersHandler(ionet::ServerPacketHandlers &handlers, const NodesSupplier &nodesSupplier)
Registers a node discovery pull peers handler in handlers that responds with nodes from nodesSupplier...
Definition: NodeDiscoveryHandlers.cpp:100
NodeSet FindAllActiveNodes(const NodeContainerView &view)
Finds all active nodes in view.
Definition: NodeContainer.cpp:263
void RegisterNodeDiscoveryPullPingHandler(ionet::ServerPacketHandlers &handlers, const std::shared_ptr< const ionet::NetworkNode > &pLocalNode)
Definition: NodeDiscoveryHandlers.cpp:59
void IncrementNodeInteraction(ionet::NodeContainer &nodes, const ionet::NodeInteractionResult &result)
Increments the interaction counter indicated by result in the node container (nodes).
Definition: NodeInteractionUtils.cpp:27
ConstNetworkNodePointer m_pLocalNetworkNode
Definition: NodeDiscoveryService.cpp:133
void RegisterNodeDiscoveryPushPingHandler(ionet::ServerPacketHandlers &handlers, model::NetworkIdentifier networkIdentifier, const NodeConsumer &nodeConsumer)
Definition: NodeDiscoveryHandlers.cpp:31
Task CreateNamedTask(const std::string &name, const TaskCallback &callback)
Creates an unscheduled task with name and callback.
Definition: Task.cpp:52
consumer< const ionet::PacketPayload & > PacketPayloadSink
A packet payload sink.
Definition: ServerHooks.h:44
net::ConnectionSettings GetConnectionSettings(const config::CatapultConfiguration &config)
Extracts connection settings from config.
Definition: NetworkUtils.cpp:25
std::shared_ptr< NodePingRequestor > CreateNodePingRequestor(const std::shared_ptr< thread::IoThreadPool > &pPool, const crypto::KeyPair &keyPair, const net::ConnectionSettings &settings, model::NetworkIdentifier networkIdentifier)
Definition: NodePingRequestor.cpp:25
def info(*args)
Definition: forwardsValidation.py:12
void RegisterNodeDiscoveryPushPeersHandler(ionet::ServerPacketHandlers &handlers, const NodesConsumer &nodesConsumer)
Registers a node discovery push peers handler in handlers that forwards received nodes to nodesConsum...
Definition: NodeDiscoveryHandlers.cpp:70
net::BriefServerRequestor< NodePingRequestPolicy, NodePingResponseCompatibilityChecker > NodePingRequestor
A brief server requestor for requesting node ping information.
Definition: NodePingRequestor.h:62
consumer< const ionet::Node & > NodeConsumer
Consumes a node.
Definition: NodeDiscoveryHandlers.h:31
future< T > make_ready_future(T &&value)
Produces a future that is ready immediately and holds the given value.
Definition: Future.h:126
consumer< const ionet::NodeSet & > NodesConsumer
Consumes multiple nodes.
Definition: NodeDiscoveryHandlers.h:34
Definition: AddressExtractionExtension.cpp:28
#define DECLARE_SERVICE_REGISTRAR(NAME)
Declares a service registrar entry point with NAME.
Definition: ServiceRegistrar.h:61
static PacketPayload FromEntity(PacketType type, const std::shared_ptr< TEntity > &pEntity)
Creates a packet payload with the specified packet type around a single entity (pEntity).
Definition: PacketPayloadFactory.h:31
1.8.16