diff options
author | Greg Farnum <greg@inktank.com> | 2013-10-21 17:24:35 -0700 |
---|---|---|
committer | Greg Farnum <greg@inktank.com> | 2013-10-21 17:55:00 -0700 |
commit | 4c611ad7bf9d29a0e682f13f636c0c051a38aa7c (patch) | |
tree | 6d403f608fd8e78f846bdcaf65ea7f53f0eca22c | |
parent | 2f84cedb02d2bb6dd11412604fef1163b88a8cdb (diff) | |
download | ceph-4c611ad7bf9d29a0e682f13f636c0c051a38aa7c.tar.gz |
ReplicatedPG: rename start_recovery_ops::started -> ops_begun
Get rid of the stupid aliasing we did for git diff convenience.
Signed-off-by: Greg Farnum <greg@inktank.com>
-rw-r--r-- | src/osd/ReplicatedPG.cc | 23 | ||||
-rw-r--r-- | src/osd/ReplicatedPG.h | 2 |
2 files changed, 12 insertions, 13 deletions
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index 85a6d472906..17adff0fe4c 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -7481,8 +7481,7 @@ bool ReplicatedPG::start_recovery_ops( ThreadPool::TPHandle &handle, int& ops_begun) { - int& started = ops_begun; - started = 0; + ops_begun = 0; bool work_in_progress = false; assert(is_primary()); @@ -7506,24 +7505,24 @@ bool ReplicatedPG::start_recovery_ops( if (num_missing == num_unfound) { // All of the missing objects we have are unfound. // Recover the replicas. - started = recover_replicas(max, handle); + ops_begun = recover_replicas(max, handle); } - if (!started) { + if (!ops_begun) { // We still have missing objects that we should grab from replicas. - started += recover_primary(max, handle); + ops_begun += recover_primary(max, handle); } - if (!started && num_unfound != get_num_unfound()) { + if (!ops_begun && num_unfound != get_num_unfound()) { // second chance to recovery replicas - started = recover_replicas(max, handle); + ops_begun = recover_replicas(max, handle); } - if (started) + if (ops_begun) work_in_progress = true; bool deferred_backfill = false; if (recovering.empty() && state_test(PG_STATE_BACKFILL) && - backfill_target >= 0 && started < max && + backfill_target >= 0 && ops_begun < max && missing.num_missing() == 0 && !waiting_on_backfill) { if (get_osdmap()->test_flag(CEPH_OSDMAP_NOBACKFILL)) { @@ -7543,12 +7542,12 @@ bool ReplicatedPG::start_recovery_ops( } deferred_backfill = true; } else { - started += recover_backfill(max - started, handle, work_in_progress); + ops_begun += recover_backfill(max - ops_begun, handle, work_in_progress); } } - dout(10) << " started " << started << dendl; - osd->logger->inc(l_osd_rop, started); + dout(10) << " started " << ops_begun << dendl; + osd->logger->inc(l_osd_rop, ops_begun); if (!recovering.empty() || work_in_progress || recovery_ops_active > 0 || deferred_backfill) diff --git a/src/osd/ReplicatedPG.h b/src/osd/ReplicatedPG.h index c7734efa3f8..c929666e3a1 100644 --- a/src/osd/ReplicatedPG.h +++ b/src/osd/ReplicatedPG.h @@ -883,7 +883,7 @@ protected: void queue_for_recovery(); bool start_recovery_ops( int max, RecoveryCtx *prctx, - ThreadPool::TPHandle &handle, int& started); + ThreadPool::TPHandle &handle, int& ops_begun); int recover_primary(int max, ThreadPool::TPHandle &handle); int recover_replicas(int max, ThreadPool::TPHandle &handle); |