Tracks outstanding RangeServer update requests. More...
#include <TableMutatorCompletionCounter.h>
Public Member Functions | |
TableMutatorCompletionCounter () | |
void | set (size_t count) |
void | decrement () |
bool | wait_for_completion (Timer &timer) |
bool | wait_for_completion () |
void | set_retries () |
void | set_errors () |
bool | has_retries () |
bool | has_errors () |
void | clear_errors () |
bool | is_complete () |
Private Attributes | |
std::mutex | m_mutex |
std::condition_variable | m_cond |
size_t | m_outstanding {} |
bool | m_retries {} |
bool | m_errors {} |
bool | m_done {} |
Tracks outstanding RangeServer update requests.
This class is used to track the state of outstanding RangeServer update requests for a scatter send. It is initialized with the number of updates issued. When each update returns or times out the counter is decremented and when all updates have completed or timed out, an object of this class will signal completion.
Definition at line 40 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 42 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 91 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 51 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 89 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 87 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 93 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 44 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 85 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 83 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 62 of file TableMutatorCompletionCounter.h.
|
inline |
Definition at line 77 of file TableMutatorCompletionCounter.h.
|
private |
Definition at line 97 of file TableMutatorCompletionCounter.h.
|
private |
Definition at line 101 of file TableMutatorCompletionCounter.h.
|
private |
Definition at line 100 of file TableMutatorCompletionCounter.h.
|
private |
Definition at line 96 of file TableMutatorCompletionCounter.h.
|
private |
Definition at line 98 of file TableMutatorCompletionCounter.h.
|
private |
Definition at line 99 of file TableMutatorCompletionCounter.h.