Zero  0.1.0
Public Member Functions | Private Attributes | List of all members
log_worker_thread_t Class Reference

#include <worker_thread.h>

Inheritance diagram for log_worker_thread_t:
worker_thread_t thread_wrapper_t ReaderThread

Public Member Functions

 log_worker_thread_t (int interval_ms=-1)
 
virtual ~log_worker_thread_t ()
 
void wakeup_until_lsn (lsn_t lsn, bool wait=false, int rounds_to_wait=-1)
 
lsn_t getEndLSN ()
 
- Public Member Functions inherited from worker_thread_t
 worker_thread_t (int inverval_ms=-1)
 
virtual ~worker_thread_t ()
 
void wakeup (bool wait=false, int rounds_to_wait=-1)
 
void stop ()
 
void wait_for_round (long round=0)
 
long get_rounds_completed () const
 
bool is_busy () const
 
- Public Member Functions inherited from thread_wrapper_t
 thread_wrapper_t ()
 
virtual ~thread_wrapper_t ()
 
virtual void before_run ()
 
virtual void after_run ()
 
void spawn ()
 
void fork ()
 
void join ()
 

Private Attributes

std::atomic< lsn_tendLSN
 

Additional Inherited Members

- Protected Member Functions inherited from worker_thread_t
virtual void do_work ()=0
 
bool should_exit () const
 
void notify_one ()
 
void notify_all ()
 
void quit ()
 

Detailed Description

Specialization of worker_thread_t for threads that work on LSN ranges

Constructor & Destructor Documentation

§ log_worker_thread_t()

log_worker_thread_t::log_worker_thread_t ( int  interval_ms = -1)
inline

§ ~log_worker_thread_t()

virtual log_worker_thread_t::~log_worker_thread_t ( )
inlinevirtual

Member Function Documentation

§ getEndLSN()

lsn_t log_worker_thread_t::getEndLSN ( )
inline

§ wakeup_until_lsn()

void log_worker_thread_t::wakeup_until_lsn ( lsn_t  lsn,
bool  wait = false,
int  rounds_to_wait = -1 
)

Member Data Documentation

§ endLSN

std::atomic<lsn_t> log_worker_thread_t::endLSN
private

The documentation for this class was generated from the following files: