1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:nil -*-
// vim: ts=8 sw=2 smarttab expandtab
#include "crimson/osd/osd_operations/client_request_common.h"
#include "crimson/osd/pg.h"
#include "crimson/osd/osd_operations/background_recovery.h"
namespace {
seastar::logger& logger() {
return crimson::get_logger(ceph_subsys_osd);
}
}
namespace crimson::osd {
typename InterruptibleOperation::template interruptible_future<>
CommonClientRequest::do_recover_missing(
Ref<PG> pg,
const hobject_t& soid,
const osd_reqid_t& reqid)
{
logger().debug("{} reqid {} check for recovery, {}",
__func__, reqid, soid);
assert(pg->is_primary());
eversion_t ver;
auto &peering_state = pg->get_peering_state();
auto &missing_loc = peering_state.get_missing_loc();
bool needs_recovery_or_backfill = false;
if (pg->is_unreadable_object(soid)) {
logger().debug("{} reqid {}, {} is unreadable",
__func__, reqid, soid);
ceph_assert(missing_loc.needs_recovery(soid, &ver));
needs_recovery_or_backfill = true;
}
if (pg->is_degraded_or_backfilling_object(soid)) {
logger().debug("{} reqid {}, {} is degraded or backfilling",
__func__, reqid, soid);
if (missing_loc.needs_recovery(soid, &ver)) {
needs_recovery_or_backfill = true;
}
}
if (!needs_recovery_or_backfill) {
logger().debug("{} reqid {} nothing to recover {}",
__func__, reqid, soid);
return seastar::now();
}
logger().debug("{} reqid {} need to wait for recovery, {} version {}",
__func__, reqid, soid, ver);
if (pg->get_recovery_backend()->is_recovering(soid)) {
logger().debug("{} reqid {} object {} version {}, already recovering",
__func__, reqid, soid, ver);
return pg->get_recovery_backend()->get_recovering(soid).wait_for_recovered();
} else {
logger().debug("{} reqid {} object {} version {}, starting recovery",
__func__, reqid, soid, ver);
auto [op, fut] =
pg->get_shard_services().start_operation<UrgentRecovery>(
soid, ver, pg, pg->get_shard_services(), pg->get_osdmap_epoch());
return std::move(fut);
}
}
bool CommonClientRequest::should_abort_request(
const Operation& op,
std::exception_ptr eptr)
{
if (*eptr.__cxa_exception_type() ==
typeid(::crimson::common::actingset_changed)) {
try {
std::rethrow_exception(eptr);
} catch(::crimson::common::actingset_changed& e) {
if (e.is_primary()) {
logger().debug("{} {} operation restart, acting set changed", __func__, op);
return false;
} else {
logger().debug("{} {} operation abort, up primary changed", __func__, op);
return true;
}
}
} else {
assert(*eptr.__cxa_exception_type() ==
typeid(crimson::common::system_shutdown_exception));
crimson::get_logger(ceph_subsys_osd).debug(
"{} {} operation skipped, system shutdown", __func__, op);
return true;
}
}
} // namespace crimson::osd
|
