delayed_flush = nullptr;
}
+ if (int r = journaler.get_error()) {
+ derr << "Error " << r << " recovering write_pos" << dendl;
+ on_error->complete(r);
+ return could_consume;
+ }
+
if (!journaler.is_readable()) {
dout(10) << " not readable right now" << dendl;
// Because we are the writer and the reader of the journal
Mutex::Locker l(lock);
if (r == 0) {
_consume();
+ } else if (r != -EAGAIN) {
+ on_error->complete(r);
}
}));
}