return ret;
}
-record_t Cache::try_construct_record(Transaction &t)
+record_t Cache::prepare_record(Transaction &t)
{
- LOG_PREFIX(Cache::try_construct_record);
+ LOG_PREFIX(Cache::prepare_record);
DEBUGT("enter", t);
// Should be valid due to interruptible future
);
/**
- * try_construct_record
+ * prepare_record
*
* Construct the record for Journal from transaction.
*/
- record_t try_construct_record(
+ record_t prepare_record(
Transaction &t ///< [in, out] current transaction
);
tref.get_handle().enter(write_pipeline.prepare)
).then_interruptible([this, FNAME, &tref]() mutable
-> submit_transaction_iertr::future<> {
- auto record = cache->try_construct_record(tref);
+ auto record = cache->prepare_record(tref);
tref.get_handle().maybe_release_collection_lock();
seastar::future<> submit_transaction(TransactionRef t)
{
- auto record = cache.try_construct_record(*t);
+ auto record = cache.prepare_record(*t);
return journal.submit_record(std::move(record), t->get_handle()).safe_then(
[this, t=std::move(t)](auto p) mutable {
auto [addr, seq] = p;
seastar::future<paddr_t> submit_transaction(
TransactionRef t) {
- auto record = cache.try_construct_record(*t);
+ auto record = cache.prepare_record(*t);
bufferlist bl;
for (auto &&block : record.extents) {