plebble
us::gov::engine::evidence_processor Struct Referenceabstract

#include <evidence_processor.h>

Inheritance diagram for us::gov::engine::evidence_processor:
Collaboration diagram for us::gov::engine::evidence_processor:

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

Member Typedef Documentation

◆ t

Constructor & Destructor Documentation

◆ evidence_processor()

us::gov::engine::evidence_processor::evidence_processor ( )

◆ ~evidence_processor()

us::gov::engine::evidence_processor::~evidence_processor ( )

Member Function Documentation

◆ exec_evidence()

virtual void us::gov::engine::evidence_processor::exec_evidence ( const evidence )
pure virtual

Implemented in us::gov::engine::daemon.

◆ on_block_closure()

virtual void us::gov::engine::evidence_processor::on_block_closure ( uint64_t  )
pure virtual

Implemented in us::gov::engine::daemon.

◆ onwakeup()

void us::gov::engine::evidence_processor::onwakeup ( )

◆ process_evidences()

void us::gov::engine::evidence_processor::process_evidences ( uint64_t  maxts)

◆ ready_for_block_opening()

virtual bool us::gov::engine::evidence_processor::ready_for_block_opening ( uint64_t  ) const
pure virtual

Implemented in us::gov::engine::daemon.

◆ run()

void us::gov::engine::evidence_processor::run ( )

Reimplemented from us::gov::bgtask.

◆ wait()

void us::gov::engine::evidence_processor::wait ( )

◆ wait_new_cycle()

void us::gov::engine::evidence_processor::wait_new_cycle ( )

Member Data Documentation

◆ calendar

calendar_t us::gov::engine::evidence_processor::calendar

◆ cv

condition_variable us::gov::engine::evidence_processor::cv
mutableprivate

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