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>
(cherry picked from commit
1cb9b1a1b25d0f4c2d9a9e22661636e195fc70a0)
}
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 {