diff options
| author | Samuel Just <sam.just@inktank.com> | 2013-09-09 13:20:29 -0700 |
|---|---|---|
| committer | Samuel Just <sam.just@inktank.com> | 2013-09-14 00:45:33 -0700 |
| commit | 9e08b522c3f06478b22a8ff0995370bb8206f009 (patch) | |
| tree | 560114f3f783e6d2e4d8654d1289a73953107e6d | |
| parent | 2a38af0c66569ebbfd5da6daf8f5271cb6072769 (diff) | |
| download | ceph-9e08b522c3f06478b22a8ff0995370bb8206f009.tar.gz | |
ReplicatedBackend: track object contexts in Push/PullInfo
Signed-off-by: Samuel Just <sam.just@inktank.com>
| -rw-r--r-- | src/osd/ReplicatedBackend.h | 3 | ||||
| -rw-r--r-- | src/osd/ReplicatedPG.cc | 19 |
2 files changed, 7 insertions, 15 deletions
diff --git a/src/osd/ReplicatedBackend.h b/src/osd/ReplicatedBackend.h index 196ef6912a4..413461f2221 100644 --- a/src/osd/ReplicatedBackend.h +++ b/src/osd/ReplicatedBackend.h @@ -149,6 +149,7 @@ private: struct PushInfo { ObjectRecoveryProgress recovery_progress; ObjectRecoveryInfo recovery_info; + ObjectContextRef obc; void dump(Formatter *f) const { { @@ -169,6 +170,8 @@ private: struct PullInfo { ObjectRecoveryProgress recovery_progress; ObjectRecoveryInfo recovery_info; + ObjectContextRef head_ctx; + ObjectContextRef obc; void dump(Formatter *f) const { { diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index e9ce3c883c1..301cb1e3382 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -5815,6 +5815,7 @@ void ReplicatedBackend::prepare_pull( assert(!pulling.count(soid)); pull_from_peer[fromosd].insert(soid); PullInfo &pi = pulling[soid]; + pi.head_ctx = headctx; pi.recovery_info = op.recovery_info; pi.recovery_progress = op.recovery_progress; } @@ -5995,6 +5996,7 @@ void ReplicatedBackend::prep_push( get_parent()->begin_peer_recover(peer, soid); // take note. PushInfo &pi = pushing[soid][peer]; + pi.obc = obc; pi.recovery_info.size = obc->obs.oi.size; pi.recovery_info.copy_subset = data_subset; pi.recovery_info.clone_subset = clone_subsets; @@ -6202,21 +6204,8 @@ bool ReplicatedBackend::handle_pull_response( << dendl; if (first) { - bufferlist oibl; - if (pop.attrset.count(OI_ATTR)) { - oibl.push_back(pop.attrset[OI_ATTR]); - ::decode(pi.recovery_info.oi, oibl); - } else { - assert(0); - } - bufferlist ssbl; - if (pop.attrset.count(SS_ATTR)) { - ssbl.push_back(pop.attrset[SS_ATTR]); - ::decode(pi.recovery_info.ss, ssbl); - } else { - assert(pi.recovery_info.soid.snap != CEPH_NOSNAP && - pi.recovery_info.soid.snap != CEPH_SNAPDIR); - } + pi.obc = get_parent()->get_obc(pi.recovery_info.soid, pop.attrset); + pi.recovery_info.oi = pi.obc->obs.oi; } bool complete = pi.is_complete(); |