#include <daemon.h>

Inheritance diagram for us::gov::peer::daemon:

[legend]

Collaboration diagram for us::gov::peer::daemon:

[legend]

Classes
struct	account_t

struct	grid_t

struct	nodes_t

Public Types
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 (uint16_t port, uint16_t pport, uint8_t edges, uint8_t devices, uint8_t workers)

	~daemon () override

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

void	on_destroy (client &) override

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

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
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

Private Attributes
nodes_t	nodes

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 auth::daemon us::gov::peer::daemon::b

◆ client

typedef socket::client us::gov::peer::daemon::client

◆ hash_t

typedef pub_t::hash_t us::gov::peer::daemon::hash_t

◆ keys

typedef crypto::ec::keys us::gov::peer::daemon::keys

◆ pub_t

typedef keys::pub_t us::gov::peer::daemon::pub_t

◆ t

typedef peer::mezzanine us::gov::peer::daemon::t

Constructor & Destructor Documentation

◆ daemon() [1/2]

us::gov::peer::daemon::daemon ( )

◆ daemon() [2/2]

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

◆ ~daemon()

us::gov::peer::daemon::~daemon ( )

overridevirtual

Reimplemented from us::gov::id::daemon.

Reimplemented in us::gov::relay::daemon.

Member Function Documentation

◆ add_node_()

ko us::gov::peer::daemon::add_node_ ( const pair< hash_t, pair< uint32_t, uint16_t >> & )

◆ add_seed_node()

ko us::gov::peer::daemon::add_seed_node ( const pair< uint32_t, uint16_t > & )

◆ add_seed_node_()

ko us::gov::peer::daemon::add_seed_node_ ( const pair< uint32_t, uint16_t > & )

◆ disconnect_one()

void us::gov::peer::daemon::disconnect_one ( )

◆ dump()

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

◆ dump_random_nodes()

void us::gov::peer::daemon::dump_random_nodes	(	size_t	num,
		ostream &	os
	)		const

◆ get_nodes() [1/2]

nodes_t& us::gov::peer::daemon::get_nodes ( )

inline

◆ get_nodes() [2/2]

const nodes_t& us::gov::peer::daemon::get_nodes ( ) const

inline

◆ grid_connect()

client* us::gov::peer::daemon::grid_connect	(	uint32_t	netaddr,
		uint16_t	port
	)

◆ grid_connect_test()

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

◆ grid_rotate()

void us::gov::peer::daemon::grid_rotate ( nodes_t & )

◆ grid_setcur()

void us::gov::peer::daemon::grid_setcur ( )

◆ is_active()

bool us::gov::peer::daemon::is_active ( ) const

inline

◆ isup()

bool us::gov::peer::daemon::isup ( ) const

inline

◆ join()

void us::gov::peer::daemon::join ( )

overridevirtual

Reimplemented from us::gov::bgtask.

◆ list_dev_neighbours()

vector<pair<uint32_t,uint16_t> > us::gov::peer::daemon::list_dev_neighbours ( ) const

◆ list_neighbours()

vector<pair<uint32_t,uint16_t> > us::gov::peer::daemon::list_neighbours ( ) const

◆ lookup_node()

bool us::gov::peer::daemon::lookup_node	(	const hash_t &	p,
		ostream &	os
	)		const

◆ on_destroy()

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

overridevirtual

Reimplemented from us::gov::socket::server.

Reimplemented in us::gov::relay::daemon.

◆ onwakeup()

void us::gov::peer::daemon::onwakeup ( )

◆ process_work()

bool us::gov::peer::daemon::process_work	(	socket::peer_t *	p,
		datagram *	d
	)

overridevirtual

Reimplemented from us::gov::id::daemon.

Reimplemented in us::gov::relay::daemon.

◆ purge_idle()

void us::gov::peer::daemon::purge_idle ( )

◆ remote_port()

virtual void us::gov::peer::daemon::remote_port	(	const crypto::ec::keys::pub_t &	,
		uint16_t	port
	)

inlinevirtual

◆ run()

void us::gov::peer::daemon::run ( )

Reimplemented from us::gov::bgtask.

◆ set_nodes()

void us::gov::peer::daemon::set_nodes ( const vector< pair< hash_t, pair< uint32_t, uint16_t >>> & )

◆ set_seed_nodes()

void us::gov::peer::daemon::set_seed_nodes ( const vector< pair< uint32_t, uint16_t >> & )

◆ start()

ko us::gov::peer::daemon::start ( )

overridevirtual

Reimplemented from us::gov::bgtask.

◆ stop()

void us::gov::peer::daemon::stop ( )

overridevirtual

Reimplemented from us::gov::bgtask.

◆ test_connectivity()

void us::gov::peer::daemon::test_connectivity ( )

◆ visit()

void us::gov::peer::daemon::visit ( const function< void(socket::client &)> & visitor )

◆ wait()

void us::gov::peer::daemon::wait ( )

◆ wait_ready()

ko us::gov::peer::daemon::wait_ready ( const chrono::system_clock::time_point & deadline ) const

overridevirtual

Reimplemented from us::gov::bgtask.

◆ wakeup()

void us::gov::peer::daemon::wakeup ( )

inline

Reimplemented from us::gov::bgtask.

Member Data Documentation

◆ cli

client* us::gov::peer::daemon::cli {nullptr}

◆ cv

condition_variable us::gov::peer::daemon::cv

◆ edges

uint8_t us::gov::peer::daemon::edges

◆ force_seeds

bool us::gov::peer::daemon::force_seeds {false}

◆ grid

grid_t us::gov::peer::daemon::grid

◆ grid_dev

grid_t us::gov::peer::daemon::grid_dev

◆ hall

nodes_t us::gov::peer::daemon::hall

◆ mx_hall

mutex us::gov::peer::daemon::mx_hall

◆ mx_nodes

mutex us::gov::peer::daemon::mx_nodes

mutable

◆ mx_seed_nodes

mutex us::gov::peer::daemon::mx_seed_nodes

◆ myself

hash_t us::gov::peer::daemon::myself

◆ nodes

nodes_t us::gov::peer::daemon::nodes

private

◆ seed_nodes

nodes_t us::gov::peer::daemon::seed_nodes

◆ tlo

chrono::system_clock::time_point us::gov::peer::daemon::tlo

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

gov/peer/daemon.h

Classes

Public Types

Public Member Functions

Public Attributes

Private Attributes

Additional Inherited Members

Member Typedef Documentation

◆ b

◆ client

◆ hash_t

◆ keys

◆ pub_t

◆ t

Constructor & Destructor Documentation

◆ daemon() [1/2]

◆ daemon() [2/2]

◆ ~daemon()

Member Function Documentation

◆ add_node_()

◆ add_seed_node()

◆ add_seed_node_()

◆ disconnect_one()

◆ dump()

◆ dump_random_nodes()

◆ get_nodes() [1/2]

◆ get_nodes() [2/2]

◆ grid_connect()

◆ grid_connect_test()

◆ grid_rotate()

◆ grid_setcur()

◆ is_active()

◆ isup()

◆ join()

◆ list_dev_neighbours()

◆ list_neighbours()

◆ lookup_node()

◆ on_destroy()

◆ onwakeup()

◆ process_work()

◆ purge_idle()

◆ remote_port()

◆ run()

◆ set_nodes()

◆ set_seed_nodes()

◆ start()

◆ stop()

◆ test_connectivity()

◆ visit()

◆ wait()

◆ wait_ready()

◆ wakeup()

Member Data Documentation

◆ cli

◆ cv

◆ edges

◆ force_seeds

◆ grid

◆ grid_dev

◆ hall

◆ mx_hall

◆ mx_nodes

◆ mx_seed_nodes

◆ myself

◆ nodes

◆ seed_nodes

◆ tlo