summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGreg Farnum <greg@inktank.com>2013-10-21 17:24:35 -0700
committerGreg Farnum <greg@inktank.com>2013-10-21 17:55:00 -0700
commit4c611ad7bf9d29a0e682f13f636c0c051a38aa7c (patch)
tree6d403f608fd8e78f846bdcaf65ea7f53f0eca22c
parent2f84cedb02d2bb6dd11412604fef1163b88a8cdb (diff)
downloadceph-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.cc23
-rw-r--r--src/osd/ReplicatedPG.h2
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);