Periodically flushes deferred writes to disk. More...
Public Member Functions | |
WriteScheduler (Writer *writer) | |
Constructor. More... | |
virtual | ~WriteScheduler () |
void | schedule () |
void | handle (EventPtr &event) override |
Callback method. More... | |
![]() | |
virtual | ~DispatchHandler () |
Destructor. More... | |
Private Attributes | |
std::mutex | m_mutex |
Mutex for serializing access to members More... | |
std::condition_variable | m_cond |
Condition variable to signal when timer has stopped. More... | |
Writer * | m_writer {} |
Pointer to MetaLogWriter. More... | |
Comm * | m_comm {} |
Pointer to Comm layer. More... | |
int32_t | m_interval {} |
Timer interval. More... | |
bool | m_scheduled {} |
Flag indicating that write has been scheduled. More... | |
Periodically flushes deferred writes to disk.
Definition at line 160 of file MetaLogWriter.h.
Writer::WriteScheduler::WriteScheduler | ( | Writer * | writer | ) |
Constructor.
Definition at line 250 of file MetaLogWriter.cc.
|
virtual |
Definition at line 256 of file MetaLogWriter.cc.
|
overridevirtual |
Callback method.
When the Comm layer needs to deliver an event to the application, this method is called to do so. The set of event types include, CONNECTION_ESTABLISHED, DISCONNECT, MESSAGE, ERROR, and TIMER.
event_ptr | smart pointer to Event object |
Implements Hypertable::DispatchHandler.
Definition at line 277 of file MetaLogWriter.cc.
void Writer::WriteScheduler::schedule | ( | ) |
Definition at line 263 of file MetaLogWriter.cc.
|
private |
Pointer to Comm layer.
Definition at line 180 of file MetaLogWriter.h.
|
private |
Condition variable to signal when timer has stopped.
Definition at line 176 of file MetaLogWriter.h.
|
private |
Timer interval.
Definition at line 182 of file MetaLogWriter.h.
|
private |
Mutex for serializing access to members
Definition at line 174 of file MetaLogWriter.h.
|
private |
Flag indicating that write has been scheduled.
Definition at line 184 of file MetaLogWriter.h.
|
private |
Pointer to MetaLogWriter.
Definition at line 178 of file MetaLogWriter.h.