RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-03 01:22:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd: add dump_reservations asok command

Browse Source 
Allow an admin to inspect pending and in-progress reservations.

Backport: firefly
Signed-off-by: Sage Weil <sage@inktank.com>
This commit is contained in:
Sage Weil 2014-07-01 22:04:50 -07:00
parent 6483710613
commit 70c0723f80
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/osd/OSD.cc
View File

@ -1119,6 +1119,15 @@ bool OSD::asok_command(string command, cmdmap_t& cmdmap, string format,
}
f->close_section(); //watches
} else if (command == "dump_reservations") {
f->open_object_section("reservations");
f->open_object_section("local_reservations");
service.local_reserver.dump(f);
f->close_section();
f->open_object_section("remote_reservations");
service.remote_reserver.dump(f);
f->close_section();
f->close_section();
} else {
assert(0 == "broken asok registration");
}
@ -1375,6 +1384,10 @@ void OSD::final_init()
"show clients which have active watches,"
" and on which objects");
assert(r == 0);
r = admin_socket->register_command("dump_reservations", "dump_reservations",
asok_hook,
"show recovery reservations");
assert(r == 0);
test_ops_hook = new TestOpsSocketHook(&(this->service), this->store);
// Note: pools are CephString instead of CephPoolname because
@ -1656,6 +1669,7 @@ int OSD::shutdown()
cct->get_admin_socket()->unregister_command("dump_op_pq_state");
cct->get_admin_socket()->unregister_command("dump_blacklist");
cct->get_admin_socket()->unregister_command("dump_watchers");
cct->get_admin_socket()->unregister_command("dump_reservations");
delete asok_hook;
asok_hook = NULL;