RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-28 22:43:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

mgr/DaemonServer: add js-output for "ceph osd safe-to-destroy"

Browse Source 
E.g.:
 - case 1:
$ceph osd safe-to-destroy 0 1 2 -f json-pretty
Error EAGAIN: 12 pgs have unknown state; cannot draw any conclusions

 - case 2:
$ceph osd safe-to-destroy 0 1 2 -f json-pretty
{
    "safe_to_destroy": [
        0,
        1,
        2
    ],
    "active": [],
    "missing_stats": [],
    "stored_pgs": []
}

 - case 3:
$ceph osd safe-to-destroy 0 1 2 -f json-pretty
{
    "safe_to_destroy": [],
    "active": [
        0,
        1,
        2
    ],
    "missing_stats": [],
    "stored_pgs": []
}

Signed-off-by: xie xingguo <xie.xingguo@zte.com.cn>
This commit is contained in:
xie xingguo 2018-10-29 16:56:07 +08:00
parent 43840db329
commit 432f194355
1 changed files with 49 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
src/mgr/DaemonServer.cc
View File

@ -1327,6 +1327,10 @@ bool DaemonServer::_handle_command(
}
});
});
if (r && prefix == "osd safe-to-destroy") {
cmdctx->reply(r, ss); // regardless of formatter
return true;
}
if (!r && (!active_osds.empty() ||
!missing_stats.empty() || !stored_pgs.empty())) {
if (!safe_to_destroy.empty()) {
@ -1353,8 +1357,40 @@ bool DaemonServer::_handle_command(
}
}
if (r && (prefix == "osd destroy" ||
prefix == "osd purge")) {
if (prefix == "osd safe-to-destroy") {
if (!r) {
ss << "OSD(s) " << osds << " are safe to destroy without reducing data"
<< " durability.";
safe_to_destroy.swap(osds);
}
if (f) {
f->open_object_section("osd_status");
f->open_array_section("safe_to_destroy");
for (auto i : safe_to_destroy)
f->dump_int("osd", i);
f->close_section();
f->open_array_section("active");
for (auto i : active_osds)
f->dump_int("osd", i);
f->close_section();
f->open_array_section("missing_stats");
for (auto i : missing_stats)
f->dump_int("osd", i);
f->close_section();
f->open_array_section("stored_pgs");
for (auto i : stored_pgs)
f->dump_int("osd", i);
f->close_section();
f->close_section(); // osd_status
f->flush(cmdctx->odata);
r = 0;
std::stringstream().swap(ss);
}
cmdctx->reply(r, ss);
return true;
}
if (r) {
bool force = false;
cmd_getval(cct, cmdctx->cmdmap, "force", force);
if (!force) {
@ -1362,30 +1398,24 @@ bool DaemonServer::_handle_command(
cmd_getval(cct, cmdctx->cmdmap, "yes_i_really_mean_it", force);
}
if (!force) {
ss << "\nYou can proceed by passing --force, but be warned that this will likely mean real, permanent data loss.";
ss << "\nYou can proceed by passing --force, but be warned that"
" this will likely mean real, permanent data loss.";
} else {
r = 0;
r = 0;
}
}
if (r) {
cmdctx->reply(r, ss);
return true;
}
if (prefix == "osd destroy" ||
prefix == "osd purge") {
const string cmd =
"{"
"\"prefix\": \"" + prefix + "-actual\", "
"\"id\": " + stringify(osds) + ", "
"\"yes_i_really_mean_it\": true"
"}";
auto on_finish = new ReplyOnFinish(cmdctx);
monc->start_mon_command({cmd}, {}, nullptr, &on_finish->outs, on_finish);
} else {
ss << "OSD(s) " << osds << " are safe to destroy without reducing data"
<< " durability.";
cmdctx->reply(0, ss);
}
const string cmd =
"{"
"\"prefix\": \"" + prefix + "-actual\", "
"\"id\": " + stringify(osds) + ", "
"\"yes_i_really_mean_it\": true"
"}";
auto on_finish = new ReplyOnFinish(cmdctx);
monc->start_mon_command({cmd}, {}, nullptr, &on_finish->outs, on_finish);
return true;
} else if (prefix == "osd ok-to-stop") {
vector<string> ids;