Public Types
using	ServiceDiscoveredCallback = std::function<void(msgpack::object &&, SockAddr &&)>

Public Member Functions
	PeerDiscovery (in_port_t port=DEFAULT_PORT, std::shared_ptr< asio::io_context > ioContext={}, std::shared_ptr< Logger > logger={})
void	startDiscovery (const std::string &type, ServiceDiscoveredCallback callback)
template<typename T>
void	startDiscovery (const std::string &type, std::function< void(T &&, SockAddr &&)> cb)
void	startPublish (const std::string &type, const msgpack::sbuffer &pack_buf)
void	startPublish (sa_family_t domain, const std::string &type, const msgpack::sbuffer &pack_buf)
template<typename T>
void	startPublish (const std::string &type, const T &object)
void	stop ()
bool	stopDiscovery (const std::string &type)
bool	stopPublish (const std::string &type)
bool	stopPublish (sa_family_t domain, const std::string &type)
void	connectivityChanged ()
void	stopConnectivityChanged ()

Static Public Attributes
static constexpr in_port_t	DEFAULT_PORT = 8888

Detailed Description

Definition at line 37 of file peer_discovery.h.

Member Typedef Documentation

◆ ServiceDiscoveredCallback

using dht::PeerDiscovery::ServiceDiscoveredCallback = std::function<void(msgpack::object &&, SockAddr &&)>

Definition at line 41 of file peer_discovery.h.

Member Function Documentation

◆ startDiscovery() [1/2]

void dht::PeerDiscovery::startDiscovery	(	const std::string &	type,
		ServiceDiscoveredCallback	callback )

startDiscovery - Keep Listening data from the sender until node is joinned or stop is called

◆ startDiscovery() [2/2]

template<typename T>

void dht::PeerDiscovery::startDiscovery	(	const std::string &	type,
		std::function< void(T &&, SockAddr &&)>	cb )

inline

Definition at line 55 of file peer_discovery.h.

◆ startPublish() [1/2]

void dht::PeerDiscovery::startPublish	(	const std::string &	type,
		const msgpack::sbuffer &	pack_buf )

startPublish - Keeping sending data until node is joinned or stop is called

◆ startPublish() [2/2]

template<typename T>

void dht::PeerDiscovery::startPublish	(	const std::string &	type,
		const T &	object )

inline

Definition at line 68 of file peer_discovery.h.

◆ stop()

void dht::PeerDiscovery::stop ( )

Thread Stopper

◆ stopDiscovery()

bool dht::PeerDiscovery::stopDiscovery ( const std::string & type )

Remove possible callBack to discovery

◆ stopPublish()

bool dht::PeerDiscovery::stopPublish ( const std::string & type )

Remove different serivce message to send

Member Data Documentation

◆ DEFAULT_PORT

in_port_t dht::PeerDiscovery::DEFAULT_PORT = 8888

staticconstexpr

Definition at line 40 of file peer_discovery.h.

The documentation for this class was generated from the following file:

/home/abuild/rpmbuild/BUILD/opendht-3.4.0-build/opendht-3.4.0/include/opendht/peer_discovery.h

Public Types

Public Member Functions

Static Public Attributes