us::gov::socket::daemon Struct Reference

#include <daemon.h>

Inheritance diagram for us::gov::socket::daemon:

Collaboration diagram for us::gov::socket::daemon:

Public Types
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 Member Functions
	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 bool	process_work (peer_t *c, datagram *d)
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 *)
virtual void	on_destroy (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 ()
void	wakeup ()
boolean	reset_resume ()
boolean	isup ()
boolean	isdown ()
boolean	resumed ()
void	reset ()
boolean	is_active ()

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

Static Public Attributes
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.")

Additional Inherited Members
Static Public Member Functions inherited from us::gov::socket::server
static int	set_not_blocking_mode (int sock)
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 server us::gov::socket::daemon::b

pool_t

typedef thpool us::gov::socket::daemon::pool_t

Constructor & Destructor Documentation

daemon() [1/3]

us::gov::socket::daemon::daemon

(

)

daemon() [2/3]

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

delete

daemon() [3/3]

us::gov::socket::daemon::daemon	(	uint16_t	port,
		uint8_t	workers
	)

~daemon()

us::gov::socket::daemon::~daemon ( )

override

Member Function Documentation

create_client()

client* us::gov::socket::daemon::create_client ( int  sock )

overridevirtual

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

dump()

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

homedir()

virtual string us::gov::socket::daemon::homedir ( ) const

pure virtual

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

join()

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

overridevirtual

Reimplemented from us::gov::bgtask.

operator=()

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

delete

process_work() [1/2]

void us::gov::socket::daemon::process_work

(

peer_t *

c

)

process_work() [2/2]

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

virtual

Reimplemented in us::gov::peer::daemon, us::gov::id::daemon, us::gov::relay::daemon, us::gov::engine::networking, and us::gov::dfs::daemon.

receive_and_process()

void us::gov::socket::daemon::receive_and_process ( client *  )

overridevirtual

Implements us::gov::socket::server.

start()

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

overridevirtual

Reimplemented from us::gov::bgtask.

stop()

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

overridevirtual

Reimplemented from us::gov::bgtask.

wait_ready()

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

overridevirtual

Reimplemented from us::gov::bgtask.

Member Data Documentation

KO_4093

const char* us::gov::socket::daemon::KO_4093

static

num_workers

uint8_t us::gov::socket::daemon::num_workers

pool

pool_t us::gov::socket::daemon::pool

---

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

• gov/socket/daemon.h