[this] {
bool done = !pg->get_peering_state().needs_recovery();
if (done) {
- crimson::get_logger(ceph_subsys_osd).debug("start_recovery_ops: AllReplicasRecovered for pg: {}",
- pg->get_pgid());
+ logger().debug("start_recovery_ops: AllReplicasRecovered for pg: {}",
+ pg->get_pgid());
using LocalPeeringEvent = crimson::osd::LocalPeeringEvent;
if (!pg->get_peering_state().needs_backfill()) {
logger().debug("start_recovery_ops: AllReplicasRecovered for pg: {}",
const auto &missing = pg->get_peering_state().get_pg_log().get_missing();
- crimson::get_logger(ceph_subsys_osd).info(
- "{} recovering {} in pg {}, missing {}",
- __func__,
- pg->get_recovery_backend()->total_recovering(),
- *static_cast<crimson::osd::PG*>(pg),
- missing);
+ logger().info("{} recovering {} in pg {}, missing {}", __func__,
+ pg->get_recovery_backend()->total_recovering(),
+ *static_cast<crimson::osd::PG*>(pg),
+ missing);
unsigned started = 0;
int skipped = 0;
hobject_t head = soid.get_head();
- crimson::get_logger(ceph_subsys_osd).info(
+ logger().info(
"{} {} item.need {} {} {} {} {}",
__func__,
soid,
pg->get_peering_state().set_last_requested(v);
}
- crimson::get_logger(ceph_subsys_osd).info(
- "{} started {} skipped {}",
- __func__,
- started,
- skipped);
+ logger().info("{} started {} skipped {}", __func__, started, skipped);
return started;
}
assert(peer != pg->get_peering_state().get_primary());
const auto& pm = pg->get_peering_state().get_peer_missing(peer);
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: peer osd.{} missing {} objects", __func__,
- peer, pm.num_missing());
- crimson::get_logger(ceph_subsys_osd).trace(
- "{}: peer osd.{} missing {}", __func__,
- peer, pm.get_items());
+ logger().debug("{}: peer osd.{} missing {} objects", __func__,
+ peer, pm.num_missing());
+ logger().trace("{}: peer osd.{} missing {}", __func__,
+ peer, pm.get_items());
// recover oldest first
for (auto p = pm.get_rmissing().begin();
const auto &soid = p->second;
if (pg->get_peering_state().get_missing_loc().is_unfound(soid)) {
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: object {} still unfound", __func__, soid);
+ logger().debug("{}: object {} still unfound", __func__, soid);
continue;
}
const pg_info_t &pi = pg->get_peering_state().get_peer_info(peer);
if (soid > pi.last_backfill) {
if (!pg->get_recovery_backend()->is_recovering(soid)) {
- crimson::get_logger(ceph_subsys_osd).error(
+ logger().error(
"{}: object {} in missing set for backfill (last_backfill {})"
" but not in recovering",
__func__,
}
if (pg->get_recovery_backend()->is_recovering(soid)) {
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: already recovering object {}", __func__, soid);
+ logger().debug("{}: already recovering object {}", __func__, soid);
continue;
}
if (pg->get_peering_state().get_missing_loc().is_deleted(soid)) {
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: soid {} is a delete, removing", __func__, soid);
+ logger().debug("{}: soid {} is a delete, removing", __func__, soid);
map<hobject_t,pg_missing_item>::const_iterator r =
pm.get_items().find(soid);
started += prep_object_replica_deletes(
if (soid.is_snap() &&
pg->get_peering_state().get_pg_log().get_missing().is_missing(
soid.get_head())) {
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: head {} still missing on primary",
- __func__, soid.get_head());
+ logger().debug("{}: head {} still missing on primary", __func__,
+ soid.get_head());
continue;
}
if (pg->get_peering_state().get_pg_log().get_missing().is_missing(soid)) {
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: soid {} still missing on primary", __func__, soid);
+ logger().debug("{}: soid {} still missing on primary", __func__, soid);
continue;
}
- crimson::get_logger(ceph_subsys_osd).debug(
- "{}: recover_object_replicas({})",
- __func__,
- soid);
+ logger().debug("{}: recover_object_replicas({})", __func__,soid);
map<hobject_t,pg_missing_item>::const_iterator r = pm.get_items().find(
soid);
started += prep_object_replica_pushes(
const object_stat_sum_t& stat_diff,
const bool is_delete)
{
- crimson::get_logger(ceph_subsys_osd).info("{} {}", __func__, soid);
+ logger().info("{} {}", __func__, soid);
pg->get_peering_state().object_recovered(soid, stat_diff);
auto& recovery_waiter = pg->get_recovery_backend()->get_recovering(soid);
if (!is_delete)