RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-03 09:32:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/osd: use obc->get_oid() instead of passing hobject_t around.

Browse Source 
Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
This commit is contained in:
Radoslaw Zarzynski 2021-03-15 19:24:27 +00:00 committed by Kefu Chai
parent 2b8076a7d5
commit a8e05fc5a6
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/crimson/osd/pg.cc
View File

@ -861,16 +861,16 @@ PG::with_head_obc(hobject_t oid, with_obc_func_t&& func)
logger().debug("{} {}", __func__, oid);
boost::intrusive_ptr<PG> pgref{this};
assert(oid.is_head());
auto [obc, existed] = shard_services.obc_registry.get_cached_obc(oid);
auto [obc, existed] =
shard_services.obc_registry.get_cached_obc(std::move(oid));
obc->append_to(obc_set_accessing);
return obc->with_lock<State, IOInterruptCondition>(
[oid=std::move(oid), existed=existed, obc=obc,
func=std::move(func), this] {
[existed=existed, obc=obc, func=std::move(func), this] {
auto loaded = load_obc_iertr::make_ready_future<ObjectContextRef>(obc);
if (existed) {
logger().debug("with_head_obc: found {} in cache", oid);
logger().debug("with_head_obc: found {} in cache", obc->get_oid());
} else {
logger().debug("with_head_obc: cache miss on {}", oid);
logger().debug("with_head_obc: cache miss on {}", obc->get_oid());
loaded = obc->with_promoted_lock<State, IOInterruptCondition>([this, obc] {
return load_head_obc(obc);
});