|
Zero
0.1.0
|
#include <worker_thread.h>
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_t > | endLSN |
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 () |
Specialization of worker_thread_t for threads that work on LSN ranges
|
inline |
|
inlinevirtual |
|
inline |
| void log_worker_thread_t::wakeup_until_lsn | ( | lsn_t | lsn, |
| bool | wait = false, |
||
| int | rounds_to_wait = -1 |
||
| ) |
|
private |
1.8.12