#include <daemon.h>

Inheritance diagram for us::gov::relay::daemon:

[legend]

Collaboration diagram for us::gov::relay::daemon:

[legend]

Classes
struct	mem_t

Public Types
typedef peer::daemon	b

typedef crypto::ec::keys::pub_t::hash_t	hash_t

Public Types inherited from us::gov::peer::daemon
typedef auth::daemon	b

typedef peer::mezzanine	t

typedef socket::client	client

typedef crypto::ec::keys	keys

typedef keys::pub_t	pub_t

typedef pub_t::hash_t	hash_t

Public Types inherited from us::gov::id::daemon
typedef socket::daemon	b

typedef crypto::ec::keys	keys

using	datagram = socket::datagram

Public Types inherited from us::gov::socket::daemon
typedef server	b

typedef thpool	pool_t

Public Types inherited from us::gov::socket::server
typedef bgtask	b

typedef crypto::ec::keys::pub_t	pub_t

Public Types inherited from us::gov::peer::mezzanine
typedef bgtask	b

Public Member Functions
	daemon ()

	daemon (const daemon &)=delete

daemon &	operator= (const daemon &)=delete

	daemon (uint16_t port, uint16_t pport, uint8_t edges, uint8_t devices, int workers)

	~daemon () override

bool	process_work (socket::peer_t c, datagram d) override

bool	process_evidence (const datagram &)

void	process_harvester_payload (const string &payload, string &ans)

virtual bool	process_evidence (evidence *)=0

void	dump (const string &prefix, ostream &os) const

void	send_evidence (datagram *)

int	send (int num, const socket::client *exclude, const datagram &)

int	send (int num, const socket::client exclude, datagram )

int	grid_devices_send (const datagram &d)

int	grid_devices_send (const datagram &d, const function< bool(const client &)> &)

int	grid_devices_send (const vector< datagram * > &v, const function< bool(const client &)> &filter)

void	rollback (uint16_t timeout, string payload)

void	on_destroy (client &) override

virtual bool	check_relay_permission (const hash_t &addr) const

virtual evidence *	parse_custom_evidence (const string &payload) const

Public Member Functions inherited from us::gov::peer::daemon
	daemon ()

	daemon (uint16_t port, uint16_t pport, uint8_t edges, uint8_t devices, uint8_t workers)

void	dump (const string &prefix, ostream &) const

void	visit (const function< void(socket::client &)> &visitor)

vector< pair< uint32_t, uint16_t > >	list_neighbours () const

vector< pair< uint32_t, uint16_t > >	list_dev_neighbours () const

void	purge_idle ()

ko	start () override

ko	wait_ready (const chrono::system_clock::time_point &deadline) const override

void	stop () override

void	join () override

bool	is_active () const

void	wakeup ()

bool	isup () const

void	wait ()

void	dump_random_nodes (size_t num, ostream &os) const

bool	lookup_node (const hash_t &p, ostream &os) const

virtual void	remote_port (const crypto::ec::keys::pub_t &, uint16_t port)

void	test_connectivity ()

void	grid_rotate (nodes_t &)

void	run ()

void	onwakeup ()

void	set_seed_nodes (const vector< pair< uint32_t, uint16_t >> &)

ko	add_seed_node (const pair< uint32_t, uint16_t > &)

ko	add_seed_node_ (const pair< uint32_t, uint16_t > &)

void	set_nodes (const vector< pair< hash_t, pair< uint32_t, uint16_t >>> &)

ko	add_node_ (const pair< hash_t, pair< uint32_t, uint16_t >> &)

void	grid_setcur ()

void	disconnect_one ()

client *	grid_connect (uint32_t netaddr, uint16_t port)

bool	grid_connect_test (peer::peer_t *p, uint32_t netaddr, uint16_t port, ostream &os)

nodes_t &	get_nodes ()

const nodes_t &	get_nodes () const

Public Member Functions inherited from us::gov::id::daemon
	daemon ()

	daemon (uint16_t port, uint16_t pport, int workers)

virtual socket::client *	create_client (int sock) override

virtual const keys &	get_keys () const =0

bool	is_duplicate (const pub_t &) const

void	dump (const string &prefix, ostream &os) const

Public Member Functions inherited from us::gov::socket::daemon
	daemon ()

	daemon (const daemon &)=delete

daemon &	operator= (const daemon &)=delete

	daemon (uint16_t port, uint8_t workers)

	~daemon () override

client *	create_client (int sock) override

ko	start () override

ko	wait_ready (const chrono::system_clock::time_point &deadline) const override

void	stop () override

void	join () override

void	dump (const string &prefix, ostream &os) const

void	receive_and_process (client *) override

void	process_work (peer_t *c)

virtual string	homedir () const =0

Public Member Functions inherited from us::gov::socket::server
	server ()

	server (uint16_t port)

virtual	~server ()

virtual void	attach (client *)

virtual void	attach_noupdate (client *)

virtual void	detach (client *)

datagram *	read_from_client (int sock)

int	make_socket (uint16_t port)

bool	banned_throttle (const string &addr)

void	dump (const string &prefix, ostream &os) const

void	proc_evil (const vector< pair< uint32_t, string >> &)

void	run ()

void	onwakeup ()

ko	start () override

ko	wait_ready (const chrono::system_clock::time_point &deadline) const override

void	stop () override

void	join () override

Public Member Functions inherited from us::gov::bgtask
	bgtask ()

	bgtask (function< void()> run, function< void()> onwakeup)

virtual	~bgtask ()

void	set_run_function (function< void()> r)

void	wakeup ()

bool	isup () const

bool	isdown () const

bool	resumed () const

void	run_ ()

void	reset ()

bool	reset_wait ()

bool	reset_resume ()

bool	is_active () const

	bgtask ()

	bgtask (callback cb0)

void	set_callback (callback r)

ko	wait_ready (Date deadline)

boolean	reset_wait ()

boolean	reset_resume ()

boolean	isup ()

boolean	isdown ()

boolean	resumed ()

void	reset ()

boolean	is_active ()

Public Member Functions inherited from us::gov::peer::mezzanine
	mezzanine (daemon *)

Public Attributes
mem_t	_mem

Public Attributes inherited from us::gov::peer::daemon
client *	cli {nullptr}

mutex	mx_nodes

mutex	mx_hall

nodes_t	hall

nodes_t	seed_nodes

mutex	mx_seed_nodes

uint8_t	edges

grid_t	grid

condition_variable	cv

hash_t	myself

chrono::system_clock::time_point	tlo

bool	force_seeds {false}

grid_t	grid_dev

Public Attributes inherited from us::gov::id::daemon
uint16_t	pport

Public Attributes inherited from us::gov::socket::daemon
pool_t	pool

uint8_t	num_workers

Public Attributes inherited from us::gov::socket::server
clients_t	clients

uint16_t	port

int	sock {0}

blacklist	ban

client::queue_t	sendq

Public Attributes inherited from us::gov::peer::mezzanine
daemon *	d

Additional Inherited Members
Static Public Member Functions inherited from us::gov::socket::server
static int	set_not_blocking_mode (int sock)

Static Public Attributes inherited from us::gov::socket::daemon
static const char *	KO_4093

Static Public Attributes inherited from us::gov::bgtask
static const char *	KO_81021

static ko	KO_81021 =new ko("KO 81021 Ready status never reached.")

Protected Attributes inherited from us::gov::bgtask
atomic< short >	resume {0}

thread *	th {nullptr}

bool	active {false}

function< void()>	run

function< void()>	onwakeup

mutex	mx_ready

bool	ready {false}

condition_variable	cv_ready

AtomicInteger	resume =new AtomicInteger(0)

Thread	th =null

boolean	active =false

callback	cb =null

ReentrantLock	mx_ready = new ReentrantLock()

boolean	ready =false

Condition	cv_ready =mx_ready.newCondition()

Member Typedef Documentation

◆ b

typedef peer::daemon us::gov::relay::daemon::b

◆ hash_t

typedef crypto::ec::keys::pub_t::hash_t us::gov::relay::daemon::hash_t

Constructor & Destructor Documentation

◆ daemon() [1/3]

us::gov::relay::daemon::daemon ( )

◆ daemon() [2/3]

us::gov::relay::daemon::daemon ( const daemon & )

delete

◆ daemon() [3/3]

us::gov::relay::daemon::daemon	(	uint16_t	port,
		uint16_t	pport,
		uint8_t	edges,
		uint8_t	devices,
		int	workers
	)

◆ ~daemon()

us::gov::relay::daemon::~daemon ( )

overridevirtual

Reimplemented from us::gov::peer::daemon.

Member Function Documentation

◆ check_relay_permission()

virtual bool us::gov::relay::daemon::check_relay_permission ( const hash_t & addr ) const

virtual

Reimplemented in us::gov::engine::networking.

◆ dump()

void us::gov::relay::daemon::dump	(	const string &	prefix,
		ostream &	os
	)		const

◆ grid_devices_send() [1/3]

int us::gov::relay::daemon::grid_devices_send ( const datagram & d )

◆ grid_devices_send() [2/3]

int us::gov::relay::daemon::grid_devices_send	(	const datagram &	d,
		const function< bool(const client &)> &
	)

◆ grid_devices_send() [3/3]

int us::gov::relay::daemon::grid_devices_send	(	const vector< datagram * > &	v,
		const function< bool(const client &)> &	filter
	)

◆ on_destroy()

void us::gov::relay::daemon::on_destroy ( client & )

overridevirtual

Reimplemented from us::gov::peer::daemon.

◆ operator=()

daemon& us::gov::relay::daemon::operator= ( const daemon & )

delete

◆ parse_custom_evidence()

virtual evidence* us::gov::relay::daemon::parse_custom_evidence ( const string & payload ) const

virtual

◆ process_evidence() [1/2]

bool us::gov::relay::daemon::process_evidence ( const datagram & )

◆ process_evidence() [2/2]

virtual bool us::gov::relay::daemon::process_evidence ( evidence * )

pure virtual

Implemented in us::gov::engine::networking.

◆ process_harvester_payload()

void us::gov::relay::daemon::process_harvester_payload	(	const string &	payload,
		string &	ans
	)

◆ process_work()

bool us::gov::relay::daemon::process_work	(	socket::peer_t *	c,
		datagram *	d
	)

overridevirtual

Reimplemented from us::gov::peer::daemon.

◆ rollback()

void us::gov::relay::daemon::rollback	(	uint16_t	timeout,
		string	payload
	)

◆ send() [1/2]

int us::gov::relay::daemon::send	(	int	num,
		const socket::client *	exclude,
		const datagram &
	)

◆ send() [2/2]

int us::gov::relay::daemon::send	(	int	num,
		const socket::client *	exclude,
		datagram *
	)

◆ send_evidence()

void us::gov::relay::daemon::send_evidence ( datagram * )

Member Data Documentation

◆ _mem

mem_t us::gov::relay::daemon::_mem

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

gov/relay/daemon.h

Classes

Public Types

Public Member Functions

Public Attributes

Additional Inherited Members

Member Typedef Documentation

◆ b

◆ hash_t

Constructor & Destructor Documentation

◆ daemon() [1/3]

◆ daemon() [2/3]

◆ daemon() [3/3]

◆ ~daemon()

Member Function Documentation

◆ check_relay_permission()

◆ dump()

◆ grid_devices_send() [1/3]

◆ grid_devices_send() [2/3]

◆ grid_devices_send() [3/3]

◆ on_destroy()

◆ operator=()

◆ parse_custom_evidence()

◆ process_evidence() [1/2]

◆ process_evidence() [2/2]

◆ process_harvester_payload()

◆ process_work()

◆ rollback()

◆ send() [1/2]

◆ send() [2/2]

◆ send_evidence()

Member Data Documentation

◆ _mem