Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
assert(maybe_write_base.has_value());
assert(!write_base.has_value());
write_base = maybe_write_base;
- } else {
- assert(io_promise.has_value());
}
state = state_t::PENDING;
assert(write_base.has_value());
+ assert(io_promise.has_value());
return io_promise->get_shared_future(
).then([dlength_offset, FNAME, &name
// Add to the batch, the future will be resolved after the batch is
// written.
//
- // Set write_result_t::write_length to 0 if the record is not the first one
- // in the batch.
- //
// write_base must be assigned when the state is empty
using add_pending_ertr = JournalAllocator::write_ertr;
using add_pending_ret = add_pending_ertr::future<record_locator_t>;