ghobject_t{coid, ghobject_t::NO_GEN, shard_id_t::NO_SHARD},
OI_ATTR,
bl);
- add_log_entry(
+ auto &loge = add_log_entry(
pg_log_entry_t::MODIFY,
coid,
obc->obs.oi.prior_version,
osd_reqid_t(),
obc->obs.oi.mtime,
0);
- return OpsExecuter::snap_map_modify(
- coid, new_snaps, pg->snap_mapper, pg->osdriver, txn);
+ bufferlist snapsbl;
+ encode(new_snaps, snapsbl);
+ loge.snaps.swap(snapsbl);
+ return interruptor::now();
}
void SnapTrimObjSubEvent::update_head(
remove_or_update_iertr::future<ceph::os::Transaction>
remove_or_update(ObjectContextRef obc, ObjectContextRef head_obc);
- void add_log_entry(
+ pg_log_entry_t& add_log_entry(
int _op,
const hobject_t& _soid,
const eversion_t& pv,
mt,
return_code);
osd_op_p.at_version.version++;
+ return log_entries.back();
}
Ref<PG> pg;