If the future is already in-flight, there is no purpose served
by requesting the future be flushed to disk.
Signed-off-by: Jason Dillaman <dillaman@redhat.com>
}
inline void set_flush_in_progress() {
Mutex::Locker locker(m_lock);
+ assert(m_flush_handler);
+ m_flush_handler.reset();
m_flush_state = FLUSH_STATE_IN_PROGRESS;
}
bool attach(const FlushHandlerPtr &flush_handler);
inline void detach() {
Mutex::Locker locker(m_lock);
- assert(m_flush_handler);
m_flush_handler.reset();
}
inline FlushHandlerPtr get_flush_handler() const {