Tracks outstanding RangeServer update requests. More...
#include <TableMutatorAsyncCompletionCounter.h>
Public Member Functions | |
TableMutatorAsyncCompletionCounter () | |
void | set (size_t count) |
bool | decrement () |
void | set_retries () |
void | set_errors () |
bool | has_retries () |
bool | has_errors () |
void | clear_errors () |
Private Attributes | |
std::mutex | m_mutex |
size_t | m_outstanding {} |
bool | m_done {} |
bool | m_retries {} |
bool | m_errors {} |
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 39 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 41 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 67 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 50 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 65 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 63 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 43 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 61 of file TableMutatorAsyncCompletionCounter.h.
|
inline |
Definition at line 59 of file TableMutatorAsyncCompletionCounter.h.
|
private |
Definition at line 72 of file TableMutatorAsyncCompletionCounter.h.
|
private |
Definition at line 74 of file TableMutatorAsyncCompletionCounter.h.
|
private |
Definition at line 70 of file TableMutatorAsyncCompletionCounter.h.
|
private |
Definition at line 71 of file TableMutatorAsyncCompletionCounter.h.
|
private |
Definition at line 73 of file TableMutatorAsyncCompletionCounter.h.