| plebble
    | 
#include <evidence_processor.h>


| Public Types | |
| typedef bgtask | t | 
| Public Member Functions | |
| evidence_processor () | |
| ~evidence_processor () | |
| void | process_evidences (uint64_t maxts) | 
| void | run () | 
| void | wait () | 
| void | wait_new_cycle () | 
| void | onwakeup () | 
| virtual void | on_block_closure (uint64_t)=0 | 
| virtual void | exec_evidence (const evidence &)=0 | 
| virtual bool | ready_for_block_opening (uint64_t) const =0 | 
|  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 | |
| calendar_t | calendar | 
| Private Attributes | |
| 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() | 
| us::gov::engine::evidence_processor::evidence_processor | ( | ) | 
| us::gov::engine::evidence_processor::~evidence_processor | ( | ) | 
| 
 | pure virtual | 
Implemented in us::gov::engine::daemon.
| 
 | pure virtual | 
Implemented in us::gov::engine::daemon.
| void us::gov::engine::evidence_processor::onwakeup | ( | ) | 
| void us::gov::engine::evidence_processor::process_evidences | ( | uint64_t | maxts | ) | 
| 
 | pure virtual | 
Implemented in us::gov::engine::daemon.
| void us::gov::engine::evidence_processor::run | ( | ) | 
Reimplemented from us::gov::bgtask.
| void us::gov::engine::evidence_processor::wait | ( | ) | 
| void us::gov::engine::evidence_processor::wait_new_cycle | ( | ) | 
| calendar_t us::gov::engine::evidence_processor::calendar | 
| 
 | mutableprivate |