diff options
| -rw-r--r-- | src/osd/ReplicatedPG.cc | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index cf1b1f14683..675973e8f07 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -119,7 +119,7 @@ void ReplicatedPG::wait_for_missing_object(const hobject_t& soid, OpRequestRef o } else { dout(7) << "missing " << soid << " v " << v << ", pulling." << dendl; - pull(soid, v, op->request->get_priority()); + pull(soid, v, g_conf->osd_client_op_priority); } waiting_for_missing_object[soid].push_back(op); op->mark_delayed(); @@ -175,7 +175,7 @@ void ReplicatedPG::wait_for_degraded_object(const hobject_t& soid, OpRequestRef break; } } - recover_object_replicas(soid, v, op->request->get_priority()); + recover_object_replicas(soid, v, g_conf->osd_client_op_priority); } waiting_for_degraded_object[soid].push_back(op); op->mark_delayed(); @@ -6832,7 +6832,7 @@ int ReplicatedPG::recover_backfill(int max) MOSDPGBackfill *m = NULL; if (bound.is_max()) { m = new MOSDPGBackfill(MOSDPGBackfill::OP_BACKFILL_FINISH, e, e, info.pgid); - m->set_priority(g_conf->osd_recovery_op_priority); + // Use default priority here, must match sub_op priority /* pinfo.stats might be wrong if we did log-based recovery on the * backfilled portion in addition to continuing backfill. */ @@ -6840,7 +6840,7 @@ int ReplicatedPG::recover_backfill(int max) start_recovery_op(hobject_t::get_max()); } else { m = new MOSDPGBackfill(MOSDPGBackfill::OP_BACKFILL_PROGRESS, e, e, info.pgid); - m->set_priority(g_conf->osd_recovery_op_priority); + // Use default priority here, must match sub_op priority } m->last_backfill = bound; m->stats = pinfo.stats.stats; |