|
plebble
|
#include <gc.h>


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() |
| typedef wbgtask us::gov::socket::gc_t::t |
| us::gov::socket::gc_t::gc_t | ( | ) |
| us::gov::socket::gc_t::~gc_t | ( | ) |
| void us::gov::socket::gc_t::add_ | ( | client * | ) |
| void us::gov::socket::gc_t::clear | ( | ) |
|
overridevirtual |
Implements us::gov::wbgtask.
| void us::gov::socket::gc_t::dump | ( | ostream & | ) | const |
| void us::gov::socket::gc_t::onwakeup | ( | ) |
|
overridevirtual |
Implements us::gov::wbgtask.
|
overridevirtual |
Reimplemented from us::gov::wbgtask.
|
overridevirtual |
Reimplemented from us::gov::wbgtask.
| condition_variable us::gov::socket::gc_t::cv |
|
mutable |