plebble
us::gov::socket::gc_t Struct Referencefinal

#include <gc.h>

Inheritance diagram for us::gov::socket::gc_t:
Collaboration diagram for us::gov::socket::gc_t:

Public Types

typedef wbgtask t
 
- Public Types inherited from us::gov::wbgtask
typedef bgtask b
 

Public Member Functions

 gc_t ()
 
 ~gc_t ()
 
void add_ (client *)
 
void dump (ostream &) const
 
void clear ()
 
void task_init () override
 
void task () override
 
void task_cleanup () override
 
void collect () override
 
void onwakeup ()
 
- Public Member Functions inherited from us::gov::wbgtask
 wbgtask (function< void()> onwakeup)
 
virtual ~wbgtask ()
 
- 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)
 
virtual ko start ()
 
virtual ko wait_ready (const chrono::system_clock::time_point &deadline) const
 
virtual void stop ()
 
virtual void join ()
 
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 start ()
 
ko wait_ready (Date deadline)
 
void stop ()
 
void join ()
 
boolean reset_wait ()
 
void wakeup ()
 
boolean reset_resume ()
 
boolean isup ()
 
boolean isdown ()
 
boolean resumed ()
 
void reset ()
 
boolean is_active ()
 

Public Attributes

mutex mx
 
condition_variable cv
 

Additional Inherited Members

- 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

◆ t

Constructor & Destructor Documentation

◆ gc_t()

us::gov::socket::gc_t::gc_t ( )

◆ ~gc_t()

us::gov::socket::gc_t::~gc_t ( )

Member Function Documentation

◆ add_()

void us::gov::socket::gc_t::add_ ( client )

◆ clear()

void us::gov::socket::gc_t::clear ( )

◆ collect()

void us::gov::socket::gc_t::collect ( )
overridevirtual

Implements us::gov::wbgtask.

◆ dump()

void us::gov::socket::gc_t::dump ( ostream &  ) const

◆ onwakeup()

void us::gov::socket::gc_t::onwakeup ( )

◆ task()

void us::gov::socket::gc_t::task ( )
overridevirtual

Implements us::gov::wbgtask.

◆ task_cleanup()

void us::gov::socket::gc_t::task_cleanup ( )
overridevirtual

Reimplemented from us::gov::wbgtask.

◆ task_init()

void us::gov::socket::gc_t::task_init ( )
overridevirtual

Reimplemented from us::gov::wbgtask.

Member Data Documentation

◆ cv

condition_variable us::gov::socket::gc_t::cv

◆ mx

mutex us::gov::socket::gc_t::mx
mutable

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